怎么理解rabbitmq死信队列，延迟队列，优先级队列

发布时间：2021-11-16 11:12:13 阅读：118 作者：iii 栏目：大数据

开发者测试专用服务器限时活动，0元免费领，库存有限，领完即止！点击查看>>

这篇文章主要介绍“怎么理解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<String , Object> map = new HashMap<String, Object>( );
        //消息在正常队列过期时间
        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()) ;
    }
}