如何定义非阻塞的RabbitMQ Python消费者以持续监听队列？

针对你遇到的start_consuming()阻塞主程序、basic_get()循环不够优雅的问题，这里提供两种实用的解决方案：

方案一：使用线程隔离消费者逻辑 #

把RabbitMQ的消费逻辑放到单独线程中执行，主程序可以继续处理其他任务，互不干扰。

示例代码：

import threading
import pika

# 假设已提前建立RabbitMQ连接connection和通道channel
def consume_orders():
    def callback(ch, method, properties, body):
        print(f" [x] 收到订单: {body.decode()}")
        # 在此添加处理订单并返回给客户端的业务逻辑

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

# 启动消费者线程
consumer_thread = threading.Thread(target=consume_orders)
consumer_thread.daemon = True  # 设置为守护线程，主程序退出时自动终止
consumer_thread.start()

# 主程序正常执行自身逻辑
print("主程序正在运行，不会被消费者阻塞")
while True:
    # 此处编写你的主程序业务代码
    pass

优点：实现简单，无需大幅修改原有消费逻辑，适配大多数常规场景。
注意：如果需要在线程间传递订单数据，需确保线程安全，可使用queue.Queue作为数据传递容器。

方案二：使用异步非阻塞连接（pika SelectConnection） #

pika提供的SelectConnection基于IO多路复用实现非阻塞消息消费，无需额外线程，适合高并发场景。

示例代码：

import pika
from pika.adapters.select_connection import SelectConnection
import threading

# RabbitMQ连接参数
credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters('localhost', 5672, '/', credentials)

def on_message(ch, method, properties, body):
    print(f" [x] 收到订单: {body.decode()}")
    # 处理订单并返回给客户端的业务逻辑

def on_open(connection):
    connection.channel(on_open_callback=on_channel_open)

def on_channel_open(channel):
    channel.basic_consume(queue='verified_orders',
                          auto_ack=True,
                          on_message_callback=on_message)

# 创建异步连接
connection = SelectConnection(parameters, on_open_callback=on_open)

def start_io_loop():
    connection.ioloop.start()

# 启动异步IO循环线程
threading.Thread(target=start_io_loop, daemon=True).start()

# 主程序正常运行
print("主程序运行中...")
while True:
    # 此处编写你的主程序业务代码
    pass

优点：纯异步非阻塞，避免线程切换开销，适合对性能要求较高的场景。
注意：逻辑相对复杂，需要熟悉pika的异步API使用方式。

为什么不推荐basic_get()循环？ #

basic_get()是轮询式拉取消息，会频繁建立/关闭请求，效率低下；空循环时还会占用不必要的CPU资源，可靠性和性能都远不如上述两种方案。

内容的提问来源于stack exchange，提问作者Obaida Ammar