rabbitMQ安装与简单demo

RabbitMQ是一个消息代理和队列服务器，用于通过可靠消息传递进行异步通信。以下是在Linux系统上安装RabbitMQ并使用Python创建简单的生产者和消费者的步骤和代码示例。

1. 安装RabbitMQ:

对于基于Debian的系统（如Ubuntu）:

sudo apt-get update
sudo apt-get install rabbitmq-server

对于基于RPM的系统（如CentOS）:

sudo yum install rabbitmq-server
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

2. 启动RabbitMQ管理界面（可选）:

sudo rabbitmq-plugins enable rabbitmq_management

3. 通过浏览器访问RabbitMQ管理界面，默认情况下可以在 http://localhost:15672 访问，使用用户名和密码登录。
4. 使用Python创建简单的生产者和消费者:

生产者（发送消息）:

import pika
 
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 
channel.queue_declare(queue='hello')
 
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()

消费者（接收消息）:

import pika
 
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 
channel.queue_declare(queue='hello')
 
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
 
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
 
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

确保RabbitMQ服务正在运行，然后先运行生产者脚本发送消息，随后运行消费者脚本接收并打印出消息内容。