rabbitmq队列和交换机的实现

package com.zking.provider.config; import org.springframework.amqp.core.Binding; import org.springframework.amqp.core.BindingBuilder; import org.springframework.amqp.core.DirectExchange; import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.util.HashMap; import java.util.Map; //绑定死信交换机绑定死信队列 @Configuration public class DeadConfig { /* 创建死信队列 创建正常队列 创建死信交换机 将死信队列绑定给死信交换机 */ //正常队列 private final static String MORMAL_QUEUE="normalQueue"; //死信队列 private final static String DEAD_QUEUE="deadQueue"; //正常交换机 private final static String NORMAL_EXCHANGE="normalExchange"; //死信交换机 private final static String DEAD_EXCHANGE="deadExchange"; //正常路由键 private final static String NORMAL_ROUTING="normalRouting"; //死信路由键 private final static String DEAD_ROUTING="deadRouting"; //创建正常的队列 @Bean public Queue normalQueue(){ Map<String,Object> map=new HashMap<>(); map.put("x-message-ttl", 10000);//message在该队列queue的存活时间最大为10秒 map.put("x-dead-letter-exchange", DEAD_EXCHANGE); //x-dead-letter-exchange参数是设置该队列的死信交换器（DLX） map.put("x-dead-letter-routing-key", DEAD_ROUTING);//x-dead-letter-routing-key参数是给这个DLX指定路由键 // 是否持久化 是否排他 是否自动删除 放入到正常队列 return new Queue(MORMAL_QUEUE,true,false,false,map); } //创建死信队列 @Bean public Queue deadQueue(){ return new Queue(DEAD_QUEUE,true); } //直连交换机 @Bean public DirectExchange normalExchange(){ return new DirectExchange(NORMAL_EXCHANGE,true,false); } //死信交换机 只是叫这个名字 @Bean public DirectExchange deadExchang(){ return new DirectExchange(DEAD_EXCHANGE,true,false); } //绑定普通 @Bean public Binding normalBinding(){ return BindingBuilder.bind(normalQueue()).to(normalExchange()).with(NORMAL_ROUTING); } //绑定死信 @Bean public Binding deadBinding(){ return BindingBuilder.bind(deadQueue()).to(deadExchang()).with(DEAD_ROUTING); } }