如何删除rabbitmq（pika）中的消息

Posted 2021-04-16

如何删除发布和接收的消息，在rabbitmq我用python测试rabitmq，同样的消息继续发布和接收，如何避免这种情况。如何删除已发布和已接收的消息

答案

请关注此：

https://www.rabbitmq.com/tutorials/tutorial-two-python.html

最幸运的是你没有发送确认：

def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)
    time.sleep( body.count('.') )
    print " [x] Done"
    ch.basic_ack(delivery_tag = method.delivery_tag) ### <--- this one

channel.basic_consume(callback,
                      queue='hello')