Python怎样操作消息队列？RabbitMQ连接指南-Python教程-PHP中文网

Python怎样操作消息队列？RabbitMQ连接指南

蓮花仙者

发布： 2025-07-08 14:58:02

原创

490人浏览过

python操作rabbitmq最常见方式是使用pika库，具体步骤如下：1. 安装pika并启动rabbitmq服务；2. 建立连接和通道，本地连接用localhost，远程需配置ip和认证信息；3. 发送消息前声明队列，通过basic_publish发送消息到指定队列；4. 接收消息使用basic_consume注册回调函数，并控制消息确认机制；5. 注意连接超时、防火墙设置、队列和消息持久化以及多消费者协调问题。

Python怎样操作消息队列？RabbitMQ连接指南

Python 操作消息队列，最常见的方式是通过 RabbitMQ 来实现。它是一个功能强大的开源消息中间件，适合做任务分发、异步处理等场景。使用 Python 连接 RabbitMQ 主要依赖 pika 这个库，下面从基础到实际操作一步步说明。

安装 pika 和启动 RabbitMQ

在开始前，需要确保你的环境中已经安装了 pika 库和 RabbitMQ 服务：

安装 pika：

立即学习“Python免费学习笔记（深入）”；
```
pip install pika
```
登录后复制
启动 RabbitMQ（以 Ubuntu 为例）：
```
sudo systemctl start rabbitmq-server
```
登录后复制

如果你是在本地开发，可以先用默认配置连接本地的 RabbitMQ，默认端口是 5672。

建立基本连接和通道

Python 使用 pika 与 RabbitMQ 通信的第一步是建立连接，然后打开一个“通道”来发送或接收消息：

import pika

# 连接到本地RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

登录后复制

这段代码创建了一个连接，并打开了一个通道。注意： 如果你是远程连接，需要把 'localhost' 替换成对应 IP 或域名，还可能需要配置用户名和密码。

例如带认证信息的连接方式：

壁纸样机神器

免费壁纸样机生成

查看详情

credentials = pika.PlainCredentials('username', 'password')
connection = pika.BlockingConnection(pika.ConnectionParameters('your.rabbitmq.host', credentials=credentials))

登录后复制

发送消息到队列

发送消息之前，最好先声明一个队列，这样即使队列不存在也不会报错：

channel.queue_declare(queue='task_queue')

登录后复制

然后就可以发送消息了：

channel.basic_publish(
    exchange='',
    routing_key='task_queue',
    body='Hello RabbitMQ!'
)

登录后复制

这里的 exchange 是空字符串，表示使用默认交换器；routing_key 就是目标队列名；body 是要发送的消息内容，必须是字节流。

所以如果你传字符串以外的数据类型，比如 JSON，记得用 json.dumps() 转换一下。

接收消息的基本方法

接收消息通常用的是“消费者回调”的方式。你可以写一个函数，每次有新消息到达时就会被自动调用：

def callback(ch, method, properties, body):
    print(f"收到消息: {body}")

channel.basic_consume(
    queue='task_queue',
    on_message_callback=callback,
    auto_ack=True
)

print('等待消息...')
channel.start_consuming()

登录后复制

这里的关键点在于 basic_consume 的参数：

on_message_callback：指定回调函数
auto_ack=True 表示自动确认消息已处理完，否则 RabbitMQ 会重复投递

如果你希望手动控制确认机制，可以在处理完后再手动调用 ch.basic_ack(delivery_tag=method.delivery_tag)，并把 auto_ack=False。

注意事项和常见问题

使用过程中有些细节容易出错或者忽略：

连接超时问题：如果远程连接不上，检查防火墙是否开放 5672 端口，以及 RabbitMQ 是否允许远程登录。
队列持久化：默认队列是非持久化的，如果 RabbitMQ 重启后消息会丢失。可以通过设置 durable=True 让队列持久化。
消息持久化：除了队列持久化，还要在 basic_publish 中加上 properties=pika.BasicProperties(delivery_mode=2) 才能保证消息也持久化。
多个消费者竞争消费：如果你启动多个消费者监听同一个队列，RabbitMQ 会轮询分配任务，这很适合做分布式任务处理。