**RabbitMQ安装使用——直接交换（direct exchange）**
RabbitMQ是一款开源的消息队列系统，基于AMQP（Advanced Message Queuing Protocol）协议，广泛应用于分布式系统中的异步任务处理、解耦通信以及高并发场景。本文将详细介绍如何在本地环境中安装RabbitMQ，并演示如何使用直接交换（direct exchange）这一基本的路由模式。
### 1. 安装RabbitMQ
确保你的系统是基于Unix/Linux或Windows。在Unix/Linux环境下，你可以通过包管理器（如apt-get, yum或brew）进行安装。在Windows上，可以从官方网站下载安装包。
对于Ubuntu/Debian用户：
```bash
sudo apt-get update
sudo apt-get install rabbitmq-server
```
对于CentOS/RHEL用户：
```bash
sudo yum install epel-release
sudo yum install rabbitmq-server
```
对于Windows用户，请访问[官方下载页面](https://www.rabbitmq.com/download.html)获取适合的版本。
### 2. 启动与停止RabbitMQ服务
在Unix/Linux上，可以使用以下命令启动和停止服务：
```bash
sudo systemctl start rabbitmq-server
sudo systemctl status rabbitmq-server
sudo systemctl stop rabbitmq-server
```
在Windows上，可以在服务管理器中找到RabbitMQ服务进行操作。
### 3. 配置管理界面
RabbitMQ默认开启管理界面，可以通过http://localhost:15672 访问。首次访问需要创建一个用户和设置权限，例如创建名为`guest`的用户：
```bash
rabbitmqctl add_user guest guest
rabbitmqctl set_user_tags guest administrator
rabbitmqctl set_permissions -p / guest ".*" ".*" ".*"
```
然后用新创建的用户登录，记得替换URL中的`guest`和`guest`。
### 4. 创建直接交换
直接交换是最基础的交换类型，它根据路由键（routing key）将消息发送到特定的队列。在RabbitMQ管理界面中，可以创建新的交换和队列，并关联它们。也可以通过API或客户端库（如Python的pika库）来完成。
```python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
routing_key = 'info'
message = 'This is an info message'
channel.basic_publish(exchange='direct_logs',
routing_key=routing_key,
body=message)
print(" [x] Sent %r:%r" % (routing_key, message))
connection.close()
```
### 5. 绑定队列和路由键
在RabbitMQ中，队列需要绑定到交换上，并指定一个路由键。当消息通过交换并匹配该路由键时，消息会被投递到对应的队列。例如，创建一个队列`q_direct_info`并绑定到`direct_logs`交换，路由键为`info`。
```python
channel.queue_declare(queue='q_direct_info')
channel.queue_bind(exchange='direct_logs', queue='q_direct_info', routing_key='info')
```
### 6. 消费消息
消费者订阅队列，接收由直接交换分发的消息。以下代码展示了如何在Python中消费消息：
```python
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(callback,
queue='q_direct_info',
no_ack=True)
print(' [*] Waiting for logs. To exit press CTRL+C')
channel.start_consuming()
```
### 7. 总结
RabbitMQ通过直接交换提供了一种简单而有效的方式来路由消息。路由键作为匹配条件，决定了消息应该被发送到哪个队列。这种方式非常适合需要按类型或者标签分发消息的场景。在实际应用中，可以根据业务需求选择不同的交换类型和路由策略，以实现更复杂的消息处理逻辑。
以上内容介绍了RabbitMQ的安装、直接交换的使用以及基本的生产者和消费者示例。在实践中，还可以探索其他交换类型（如fanout, topic, headers）以及更高级的特性，如死信队列、持久化等，以适应不同应用场景的需求。
rabbitmq安装和部署.zip （1个子文件） 
rabbitmq安装和部署.docx 283KB
