深入浅出分布式RabbitMQ中间件,一份精心整理的RabbitMQ实战
RabbitMQ是一个开源的消息代理和队列服务器,用于通过整个企业和应用程序之间发送消息。以下是一些RabbitMQ的基本概念和操作:
- 安装和配置RabbitMQ
# 在Ubuntu系统上安装RabbitMQ
sudo apt-get update
sudo apt-get install rabbitmq-server
# 启动RabbitMQ管理插件
sudo rabbitmq-plugins enable rabbitmq_management
# 添加用户
sudo rabbitmqctl add_user admin StrongPassword
# 设置用户角色
sudo rabbitmqctl set_user_tags admin administrator
# 设置用户权限
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
# 查看所有的队列
sudo rabbitmqctl list_queues
- 创建和管理RabbitMQ队列
import pika
# 连接到RabbitMQ服务器
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()
- 接收RabbitMQ队列的消息
import pika
# 连接到RabbitMQ服务器
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的基本安装、连接、创建队列、发送消息、接收消息的操作,是RabbitMQ实战的基础。在实际应用中,你可能需要根据具体需求进行高级配置,如虚拟主机、消息确认、消息持久化等。
评论已关闭