消息推送系统

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

channel = connection.channel()

channel.queue_declare(queue='bid_files')

def callback(ch, method, properties, body):

print(" [x] Received %r" % body)

# 这里处理收到的投标文件消息

handle_bid_file(body)

channel.basic_consume(queue='bid_files', on_message_callback=callback, auto_ack=True)

channel.start_consuming()

def handle_bid_file(message):

root = etree.fromstring(message)

file_name = root.find('file_name').text

教材征订信息管理系统

file_content = root.find('file_content').text

# 将文件名和内容保存到数据库

save_to_database(file_name, file_content)