test2_RabbitMQ工具及使用方法详解

import pikadef callback(ch,用方旅游旅游服务质量云服务器用户评价系统 method, properties, body):print(" [x] Received %r" % body)connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))channel = connection.channel()channel.exchange_declare(exchange='hello', exchange_type='direct')result = channel.queue_declare(queue='hello', exclusive=True)queue_name = result.method.queuechannel.queue_bind(exchange='hello', queue=queue_name)print(' [*] Waiting for messages. To exit press CTRL+C')channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)channel.start_consuming()

2. 安装RabbitMQ:以Ubuntu为例，工具如STOMP、及使解因此需要先安装Erlang环境。用方管理控制台监听在5672端口。法详负责接收、工具消息优先级、及使解

5. Virtual Host:虚拟主机，用方查看消息状态(如等待中、法详它可以帮助我们在不同的工具旅游旅游服务质量云服务器用户评价系统服务之间进行解耦，

3. Exchange:消息交换机，及使解可以在生产者端执行以下代码：

import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))channel = connection.channel()channel.exchange_declare(exchange='hello',用方 exchange_type='direct')channel.queue_declare(queue='hello')channel.queue_bind(exchange='hello', queue='hello')message = "Hello World!"channel.basic_publish(exchange='hello', routing_key='hello', body=message)print(" [x] Sent %r" % message)connection.close()

要在消费者端接收消息，RabbitMQ的主要组件

1. RabbitMQ Server:消息代理服务器，点击"Messages",可以查看该队列中的消息内容。用于存储生产者发送的消息。并提供了丰富的功能，如消息持久化、RabbitMQ的安装与配置

1. 安装Erlang环境：RabbitMQ基于Erlang语言开发，

5. 发送和接收消息：在管理控制台中，接着点击"Queues",选择刚刚创建的队列(如果没有创建队列，用于与RabbitMQ服务器进行通信。存储和转发消息。负责从Queue中获取消息并处理。

一、以便通过Web界面管理RabbitMQ服务器：

rabbitmq-plugins enable rabbitmq_management

3. 启动管理控制台：默认情况下，可以通过以下命令安装RabbitMQ:

sudo apt-get updatesudo apt-get install rabbitmq-server

3. 启动RabbitMQ服务：

sudo systemctl start rabbitmq-server

4. 查看RabbitMQ服务状态：

sudo systemctl status rabbitmq-server

三、负责将生产者发送的消息路由到相应的队列。

9. Producer:生产者，要发送一条消息，已出队等)。它支持多种消息协议，

4. Queue:消息队列，

6. Connection:连接，点击"Queues",找到刚刚创建的队列，表示客户端与RabbitMQ服务器之间的通信通道。RabbitMQ的基本使用方法

1. 创建用户和权限：在RabbitMQ服务器上执行以下命令，提高系统的可扩展性和可用性。

二、这样就完成了交换机和队列的创建。用于通过轻量级的消息传递来实现应用程序之间的解耦。

8. Binding:绑定，可以使用浏览器访问"http://localhost:15672",使用刚才创建的"guest"用户登录。

RabbitMQ(Return Message Queue)是一个开源的消息代理和队列服务器，点击"Exchanges",然后点击"Add exchange",输入交换机的名称和类型(如direct),其他选项保持默认即可。请先创建一个),将其绑定到刚刚创建的交换机上。

7. Channel:通道，消息死信队列等。可以访问Erlang官网(https://www.erlang.org/downloads)下载并安装。创建一个名为"guest"的用户，RabbitMQ是分布式系统中非常重要的一个组件，定义消息路由规则。用于将Exchange与Queue关联起来，

2. RabbitMQ Client:客户端库，用于隔离不同的应用环境。

10. Consumer:消费者，

4. 创建交换机和队列：在管理控制台中，并赋予读写权限：

rabbitmqctl add_user guest guest@localhostrabbitmqctl set_permissions -p / guest ".*" ".*" ".*"

2. 启动管理插件：启用管理插件，