我使用pika使用这个简单的代码:
conn = pika.BlockingConnection(pika.ConnectionParameters(host =‘localhost’))channel = conn.channel()
def on_message(ch,方法,属性,消息): 打印(”…
rabbitmq怎么能确保不向其他人发出同样的信息 工人,直到我打电话给basic_ack?
仅向一个消费者传递消息是一个 的 核心功能 强> RabbitMQ。该消息将保持不确定状态,直到它所交付的消费者对其进行处理,或者交付消息的通道关闭。
在我的测试中,如果我不打电话给basic_ack,则会再次发送消息 如果我多次运行代码。
当您多次运行代码时,会发生以下情况:
basic_ack
所有这些以及更多内容都包括在内 RabbitMQ文档 。
<子> 注意: RabbitMQ团队监控 rabbitmq-users 邮件列表 并且有时只回答StackOverflow上的问题。 子>
rabbitmq-users