怎么理解rabbitmq死信队列,延迟队列,优先级队列
发表于:2025-02-05 作者:千家信息网编辑
千家信息网最后更新 2025年02月05日,这篇文章主要介绍"怎么理解rabbitmq死信队列,延迟队列,优先级队列",在日常操作中,相信很多人在怎么理解rabbitmq死信队列,延迟队列,优先级队列问题上存在疑惑,小编查阅了各式资料,整理出简
千家信息网最后更新 2025年02月05日怎么理解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安全错误
数据库的锁怎样保障安全
成都快购科技软件开发
软件开发定律原则
苹果11验证服务器失败
数据清洗软件开发
腾迅青年人网络安全
软件开发部报销核算类别
深圳服务器散热器哪家便宜
qq安全中心弄人工服务器
共享账号不能在这台服务器玩
网络技术维护工作述职
六部委 网络安全学科
怎么进行服务器安全评估
三大一级数据库
任子行网络技术股
经纬恒润软件开发行吗
网络安全奖牌
saas软件开发什么类型的好
上海智能软件开发有限公司
五项举措推动网络安全体系建设
造价数据库建设管理制度
软件开发需要什么特征
服务器类型英语
南京顺天网络技术
退出id显示无法连接服务器
哔哩哔哩漫游可用服务器
扶贫部门贫困户建档立卡数据库
网络安全常见的类型
mysql索引数据库原理
zabbix 数据库
cc3200接收服务器音频数据