python - RabbitMQ basic_publish 是异步的吗？

Question

我有以下生产者代码。

message是经过一些计算得到的dict数据。我想向队列发布消息。然后我将 message 重置为一个空字典以进行其他一些计算。但是消费者总是从队列中得到一个空的字典。我觉得 message 在发布之前被重置了(它是异步的吗？)。如何使其同步？

message = {a big dict ...}
channel.basic_publish(exchange='',
                            routing_key='my_queue',
                            body=json.dumps(message))
message = {}

Answer 1

是的，channel.basic_publish是async的，这种方式是正确的。

channel.basic_publish 不等待插入时间，否则会很慢。

你应该改变你处理信息的方式，但是如果你想同步你可以使用事务。

应该是这样的:

channel.tx_select
channel.basic_publish(exchange='',
                            routing_key='my_queue',
                            body=json.dumps(message))
channel.tx_commit

注意交易会降低性能。

Read here更多详情