消息队列linux

### 消息队列在 Linux 下的使用与配置 #### RabbitMQ 的安装 为了在 Linux 环境下使用消息队列，通常会选择 RabbitMQ 这样的工具。以下是 RabbitMQ 在 Linux 上的典型安装过程： 1. **更新包管理器缓存** 需要先确保系统的软件源是最新的： ```bash sudo apt update ``` 2. **安装 Erlang 和 RabbitMQ Server** 安装 RabbitMQ 前需安装其依赖项 Erlang： ```bash sudo apt install erlang -y ``` 接着下载并安装 RabbitMQ 软件包： ```bash wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.9.7/rabbitmq-server_3.9.7-1_all.deb sudo dpkg -i rabbitmq-server_3.9.7-1_all.deb ``` 3. **启动服务** 启动 RabbitMQ 并设置开机自启： ```bash sudo systemctl start rabbitmq-server sudo systemctl enable rabbitmq-server ``` #### RabbitMQ 的基本配置 完成安装后可以进行一些基础配置来优化性能。 1. **启用插件支持 Web 控制台** 通过命令启用 RabbitMQ Management 插件以便于监控和调试： ```bash sudo rabbitmq-plugins enable rabbitmq_management ``` 2. **创建用户并赋予权限** 创建一个新的用户 `myuser` 并赋予完全权限： ```bash sudo rabbitmqctl add_user myuser mypassword sudo rabbitmqctl set_user_tags myuser administrator sudo rabbitmqctl set_permissions -p / myuser ".*" ".*" ".*" ``` 3. **调整异步 IO 设置** RabbitMQ 利用了 Linux 的 AIO 功能以增强磁盘 I/O 性能[^2]。可以通过修改 `/etc/rabbitmq/rabbitmq.conf` 文件中的参数进一步调优： ```ini disk_free_limit.relative = 1.0 vm_memory_high_watermark.relative = 0.4 ``` #### 示例代码：Python 中连接 RabbitMQ 发送/接收消息 下面是一个简单的 Python 实现示例，展示如何发送和接收消息到 RabbitMQ。 ##### 发送端 (Producer) ```python import pika connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue='hello') message = 'Hello, RabbitMQ!' channel.basic_publish(exchange='', routing_key='hello', body=message) print(f"[x] Sent {message}") connection.close() ``` ##### 接收端 (Consumer) ```python import pika def callback(ch, method, properties, body): print(f"[x] Received {body.decode()}") connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue='hello') channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True) print("[*] Waiting for messages.") channel.start_consuming() ``` 以上脚本展示了如何利用 RabbitMQ 构建一个简单的消息传递模型。 ---