统一消息系统

import pika

import base64

from cryptography.fernet import Fernet

# 生成密钥

key = Fernet.generate_key()

cipher_suite = Fernet(key)

# 加密消息

encrypted_message = cipher_suite.encrypt(b"招标通知：项目编号001已发布")

# 发送消息

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

channel = connection.channel()

channel.basic_publish(

exchange='auction_exchange',

routing_key='notification',

body=base64.b64encode(encrypted_message)

)

print(" [x] Sent encrypted message")

connection.close()