怎么理解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<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()) ;
    }
}

管理端展示效果：

等待時間過期后:

到此，關于“怎么理解rabbitmq死信隊列，延遲隊列，優先級隊列”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！