怎么理解rabbitmq死信队列,延迟队列,优先级队列
发表于:2025-12-04 作者:千家信息网编辑
千家信息网最后更新 2025年12月04日,这篇文章主要介绍"怎么理解rabbitmq死信队列,延迟队列,优先级队列",在日常操作中,相信很多人在怎么理解rabbitmq死信队列,延迟队列,优先级队列问题上存在疑惑,小编查阅了各式资料,整理出简
千家信息网最后更新 2025年12月04日怎么理解rabbitmq死信队列,延迟队列,优先级队列
这篇文章主要介绍"怎么理解rabbitmq死信队列,延迟队列,优先级队列",在日常操作中,相信很多人在怎么理解rabbitmq死信队列,延迟队列,优先级队列问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答"怎么理解rabbitmq死信队列,延迟队列,优先级队列"的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
延迟队列:死信队列通过过期时间实现就是延迟队列,消息发送到正常队列,等待过期,等待rabbitmq将正常队列中的消息投递到死信队列中,消费自己消费死信队列
优先级队列:x-max-priority指定优先级
package com.rabbitmq.demo;import com.rabbitmq.client.*;import java.util.HashMap;import java.util.Map;public class TtlProduce { public static void main(String args[]) throws Exception{ ConnectionFactory connectionFactory=new ConnectionFactory(); connectionFactory.setPassword("guest"); connectionFactory.setPassword("guest"); connectionFactory.setHost("192.168.1.141"); connectionFactory.setPort(5672); Connection connection=connectionFactory.newConnection(); Channel channel= connection.createChannel(); /** * 死信队列出现原因 * 消息被拒绝 (Basic.Reject/Basic .Na ck) ,井且设置 requeue 参数为 alse; * 消息过期; * 队列达到最大长度。 */ //死信队列 channel.exchangeDeclare("exchange.dlx" , "direct" , true); //正常队列,先发送消息到正常队列, channel.exchangeDeclare( "exchange.normal" , "fanout" , true); Map map = new HashMap( ); //消息在正常队列过期时间 map.put("x-message-ttl" , 10000); //通过x-max-priority指定优先级队列 map.put("x-max-priority" ,10) ;//关联的死信队列 map.put("x-dead-letter-exchange" , "exchange.dlx"); // 死信队列路由key map.put("x-dead-letter-routing-key" , "routingkey"); //正常队列绑定exchange channel.queueDeclare("queue.norma1" ,true ,false,false, map); channel.queueBind("queue.norma1" , "exchange.normal" , ""); // 死信队列绑定exchang channel.queueDeclare("queue.d1x" , true , false , false , null) ; channel.queueBind("queue.d1x" ,"exchange.dlx" ,"routingkey"); channel.basicPublish( "exchange.normal" , "rk" , MessageProperties.PERSISTENT_TEXT_PLAIN, "dlx" .getBytes()) ; }}管理端展示效果:
等待时间过期后:
到此,关于"怎么理解rabbitmq死信队列,延迟队列,优先级队列"的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注网站,小编会继续努力为大家带来更多实用的文章!
队列
死信
优先级
延迟
消息
学习
时间
更多
帮助
消费
实用
最大
接下来
原因
参数
就是
效果
文章
方法
理论
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
服务器加密安全手段
河南新一代软件开发
服务器软件开发框架
服务器配件入固定资产吗
网页和中间件数据库
奇虎360 国家网络安全
大疆无人机更新数据库
打开服务器出现连接数据库失败
数据库char的最大长度
静安区品质金融网络技术服务选择
浙江售后备件管理软件开发
北京定制化软件开发
黑龙江安防时间同步服务器
数据库框架图片大全
lol国际服服务器匹配
学软件开发需要准备什么
昆明公司软件开发
怀旧服宠物转移到服务器
2008 服务器无法远程
连续数据库的用途有哪些
网络安全法利法的手抄报
南京软件开发招聘技术经理
阿克苏服务器机柜
超漂亮网络安全手抄报
打开服务器出现连接数据库失败
如何恢复电脑微信旧数据库
北京定制化软件开发
网信委网络安全报告
excel做的软件开发
网络安全知识竞题