千家信息网

怎么理解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);        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死信队列,延迟队列,优先级队列"的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注网站,小编会继续努力为大家带来更多实用的文章!

0