怎么理解rabbitmq死信队列,延迟队列,优先级队列
发表于:2024-10-09 作者:千家信息网编辑
千家信息网最后更新 2024年10月09日,这篇文章主要介绍"怎么理解rabbitmq死信队列,延迟队列,优先级队列",在日常操作中,相信很多人在怎么理解rabbitmq死信队列,延迟队列,优先级队列问题上存在疑惑,小编查阅了各式资料,整理出简
千家信息网最后更新 2024年10月09日怎么理解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); Mapmap = 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安全错误
数据库的锁怎样保障安全
常州网络安全答题入口
支付宝网络技术扣费啥意思
乐心互联网科技有限公司
数据库中的stint
数据库文件丢失读卡
同望公路预算软件开发公司
绝地反击服务器繁忙
window文件服务器小工具
剑灵电六服务器
怎样查找两表格不同的数据库
软件开发的流程是什么
简述数据库的安全控制方法
数据库转换测试点
c 链接数据库字符串
微信运动关了移动数据库
静安区数据软件开发厂家价格
梦幻西游服务器合并成功
svn服务器端管理
移动家客网络技术支撑待遇
俯首称臣小说软件开发
图像检测训练数据库
国务院国资委网络安全通知
java数据库底层
fda辅料安全数据库
最全的论文写作数据库汇总
服务器2012系统网卡驱动更新
嵌入式软件开发从下至上
8025网络技术标准
网络安全法知识测试题库
北京牛建新软件开发