用的php语言,扩展包是php-amqplib。
问题1:未响应ack的消息如何重新发给其他的消费者呢?
问题2:消费者队列全部死了,如何让发送到exchange的消息不丢失呢?重新启动消费者进程可以获取到之前发送的消息。
谢谢
用的php语言,扩展包是php-amqplib。
问题1:未响应ack的消息如何重新发给其他的消费者呢?
问题2:消费者队列全部死了,如何让发送到exchange的消息不丢失呢?重新启动消费者进程可以获取到之前发送的消息。
谢谢
1.rmq将消息发送给consumer后,如果未收到ack,并不会删除队列中的消息,当收到ack后,才会删除
2.rmq,同时满足 exchange持久化&queue持久化&message持久化,才能真正保证消息不丢失,但对性能有影响
4 回答4.4k 阅读✓ 已解决
4 回答3.8k 阅读✓ 已解决
1 回答3k 阅读✓ 已解决
3 回答2.1k 阅读✓ 已解决
1 回答4k 阅读✓ 已解决
3 回答1.8k 阅读✓ 已解决
1 回答4.5k 阅读✓ 已解决
1 basic.nack
2 rabbitmq支持消息持久化