到目前为止,对于 RabbitMQ 中的单个队列,我使用了单个通道,但是现在我动态创建了多个队列,因此我是否必须为每个队列创建一个新通道,或者一个通道可以从不同队列接收消息/向不同队列发送消息?
# consuming
for ch in items:
channel1 = rconn.channel()
channel1.queue_declare(queue=itm)
channel1.basic_consume(some_callback, queue=itm, no_ack=True)
channel1.start_consuming()
# publishing
for ch in items:
# ....
channel1.basic_publish(exchange="", routing_key=itm, body="fdsfds")
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
4534 次 |
| 最近记录: |