统一消息系统

import pika

def send_message():

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

channel = connection.channel()

channel.queue_declare(queue='company_queue')

channel.basic_publish(exchange='',

routing_key='company_queue',

body='Hello from company system!')

print(" [x] Sent 'Hello from company system!'")

connection.close()

def receive_message():

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

channel = connection.channel()

channel.queue_declare(queue='company_queue')

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

print(f" [x] Received {body}")

channel.basic_consume(callback,

queue='company_queue',

no_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')

channel.start_consuming()