13518219792
这篇文章主要介绍“怎么理解rabbitmq死信队列，延迟队列，优先级队列”，在日常操作中，相信很多人在怎么理解rabbitmq死信队列，延迟队列，优先级队列问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”怎么理解rabbitmq死信队列，延迟队列，优先级队列”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
我们提供的服务有：成都网站建设、做网站、微信公众号开发、网站优化、网站认证、太谷ssl等。为上千余家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务，是有科学管理、有技术的太谷网站制作公司
延迟队列：死信队列通过过期时间实现就是延迟队列，消息发送到正常队列，等待过期，等待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死信队列，延迟队列，优先级队列”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！
