怎么理解rabbitmq死信队列,延迟队列,优先级队列
发表于:2024-11-21 作者:千家信息网编辑
千家信息网最后更新 2024年11月21日,这篇文章主要介绍"怎么理解rabbitmq死信队列,延迟队列,优先级队列",在日常操作中,相信很多人在怎么理解rabbitmq死信队列,延迟队列,优先级队列问题上存在疑惑,小编查阅了各式资料,整理出简
千家信息网最后更新 2024年11月21日怎么理解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安全错误
数据库的锁怎样保障安全
球球大作战游戏服务器坏了吗
波兰的网络安全中心
数据库stxt
香港服务器的好处
县域网络安全论坛
软件开发竞赛
扶余县天气预报软件开发
怎么查看谷歌服务器ip
赛天服务器
神途霸业服务器
为什么使用代理服务器
网络安全人员职业规划
嘻嘻网络技术服务有限公司
一元嗨购软件开发
批量修改数据库字段
海康硬盘录像机远程服务器超时
海洋管理系统软件开发
量化软件开发用什么
数据库管理岗位日常工作
手机架服务器
web服务器缓存技术
数据库tcp动态端口
数据库怎么创建学生管理xsgl
dw中如何添加数据库
网络安全管理平台soc全称
群晖打印服务器管理
科技跟互联网
网络安全三大预测
软件开发红石船长
计算机网络技术及就业方向