Python连接RabbitMQ教程详解

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《Python连接RabbitMQ消息队列教程》，这篇文章主要讲到等等知识，如果你对文章相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

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

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

安装 pika 和启动 RabbitMQ

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

• 安装 pika：

  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 会轮询分配任务，这很适合做分布式任务处理。

基本上就这些操作了。Python 结合 RabbitMQ 并不复杂，但有很多细节需要注意，尤其是在生产环境下。像连接管理、异常处理、消息确认这些环节都要考虑进去，才能让系统更稳定可靠。

今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~