2017年免费建网站,整合营销的特点,wordpress左栏主题,房屋设计图纸平面图文章内容是学习过程中的知识总结#xff0c;如有纰漏#xff0c;欢迎指正 文章目录 一、什么是死信队列#xff1f; 二、死信队列使用场景 三、死信队列如何使用 四、打车超时处理 1.打车超时实现 以下是本篇文章正文内容
一、什么是死信队列#xff1f; 先从概念解释上搞… 文章内容是学习过程中的知识总结如有纰漏欢迎指正 文章目录 一、什么是死信队列 二、死信队列使用场景 三、死信队列如何使用 四、打车超时处理 1.打车超时实现 以下是本篇文章正文内容
一、什么是死信队列 先从概念解释上搞清楚这个定义死信顾名思义就是无法被消费的消息字面意思可以这样理解 一般来说producer将消息投递到broker或者直接到queue里了consumer从queue取出消息进行消费但某些时候由于特定的原因导致queue中的某些消息无法被消费这样的消息如果没有后续的处理就变成了死信有死信自然就有了死信队列
二、死信队列使用场景 RabbitMQ中的死信交换器(dead letter exchange)可以接收下面三种场景中的消息: 消费者对消息使用了basicReject或者basicNack回复并且requeue参数设置为false,即不再将该消息重新在消费者间进行投递消息在队列中超时RabbitMQ可以在单个消息或者队列中设置TTL(最大存活时间)属性队列中的消息已经超过其设置的最大消息个数
三、死信队列如何使用 死信交换器不是默认的设置这里是被投递消息被拒绝后的一个可选行为是在创建队列的时进行声明的往往用在对问题消息的诊断上。 死信交换器仍然只是一个普通的交换器创建时并没有特别要求和操作在创建队列的时候声明该交换器将用作保存被拒绝的消息即可相关的参数是x-dead-letter-exchange。 相关代码
Bean
public Queue taxiOverQueue() {MapString, Object args new HashMap(2);// x-dead-letter-exchange 这里声明当前队列绑定的死信交换机args.put(x-dead-letter-exchange, TAXI_DEAD_QUEUE_EXCHANGE);// x-dead-letter-routing-key 这里声明当前队列的死信路由keyargs.put(x-dead-letter-routing-key, TAXI_DEAD_KEY);return QueueBuilder.durable(TAXI_OVER_QUEUE).withArguments(args).build();
}
四、打车超时处理 用户通过调用打车服务将数据放进RabbitMQ的死信队列进行延时操作等待一段时间后正常的业务处理还没有处理到我们发起的数据将会进行超时处理通过通知服务将我们的处理结构通过websocket方式推送到我们的客户端。 1.打车超时实现 在创建队列的时候配置死信交换器并设置队列的“x-message-ttl”属性。此时该属性为整个队列消息的生存时间这里有一篇专门讲延时任务的文章。RabbitMQ高阶使用延时任务-CSDN博客 Bean
public Queue taxiDeadQueue() {return new Queue(TAXI_DEAD_QUEUE,true);
}Bean
public Queue taxiOverQueue() {MapString, Object args new HashMap(2);// x-dead-letter-exchange 这里声明当前队列绑定的死信交换机args.put(x-dead-letter-exchange, TAXI_DEAD_QUEUE_EXCHANGE);// x-dead-letter-routing-key 这里声明当前队列的死信路由keyargs.put(x-dead-letter-routing-key, TAXI_DEAD_KEY);// x-message-ttl 声明队列的TTLargs.put(x-message-ttl, 30000);return QueueBuilder.durable(TAXI_OVER_QUEUE).withArguments(args).build();
}
这样所有被投递到该队列的消息都最多不会存活超过30s超时后的消息会被投递到死信交换器
