1.消息分发 当RabbitMQ队列拥有多个消费者时,队列收到的消息将以轮询的方式分发给消费者。每条消息只会发给订阅列表的一个消费者。这个方式非...
在上一节中,即使对交换器、队列以及消息进行了持久化,但是不将消息进行配置,当消费者从队列中获得消息以后,消费者出现异常,并没有消费消息,那么消息...
持久化可以提高RabbitMQ的可靠性,以防在RabbitMQ重启、关闭、宕机下的数据丢失。 1.交换器的持久化 交换器的持久化是在声明交换器的...
RPC,即远程过程调用,其流程如下: RPC实现RPC,则需要客户端(生产者)发送请求消息,服务端(消费者)回复响应的消息,为了接受响应的消息,...
1.死信队列 全称Dead-Letter-Exchange,DLX。当一个消息在队列中变成死信以后,它能被重新发送到另外一个交换器中,也就是死信...
TTL,Time to live即过期时间。RabbitMQ可以对消息和队列设置过期时间。 1.设置消息的TTL 目前有两种方式可以设置消息的T...
备份交换器,Alternate Exchange,简称AE,也叫做“备胎交换器”。生产者在发送消息的时候,如果不设置mantatory参数,那么...
1.相同点 1.mandatory和immediate都是basicPublish方法中的两个参数。2.都是boolean类型。3.它们都有当消...
1.消费者的确认与拒绝 为了确保消息从队列可靠地到达消费者,RabbitMQ提供了消息确认机制。消费者在使用basicConsume方法订阅队列...
文集作者