//声明交换机
@Bean
public DirectExchange overdueRangeDirectExchange() {
DirectExchange directExchange = new DirectExchange(ExchangeEnum.OVERDUE_RANGE_EXCHANGE.getName());
directExchange.setDelayed(true);
return directExchange;
}
//声明队列
@Bean
public Queue overdueRangeQueue() {
Map<String, Object> arguments = new HashMap<>();
arguments.put("x-dead-letter-exchange", ExchangeEnum.COMMON_DLX.getName());
arguments.put("x-dead-letter-routing-key", QueueEnum.DEAD_LETTER.getName());
// 消息过期时间10分钟
arguments.put("x-message-ttl",600000);
return new Queue(QueueEnum.OVERDUE_RANGE_QUEUE.getName(),true,false,false,arguments);
}
/**
声明绑定:
1. 队列与交换机的绑定
2. routing key的绑定
**/
@Bean
public Binding overdueRangeBinding(DirectExchange overdueRangeDirectExchange, Queue overdueRangeQueue) {
return BindingBuilder.bind(overdueRangeQueue).to(overdueRangeDirectExchange)
.with(QueueEnum.OVERDUE_RANGE_QUEUE.getName());
}
Exchange路由策略
Direct:消息直接发送routing key绑定的queue
Fanout:不需要Routing key,发送到所有绑定到exchange的queue
Topic:消息通过正则表达式匹配,可以匹配多个queue。例如:bindingKey = *order,可以接受的Routing Key:firstOrder,ExtenelOrder等
Header:这种类型的交换机不依赖于路由键匹配规则来路由信息,而是根据发送消息携带的headers属性进行匹配,在绑定队列和交换器是指定一组键值对.当发送的消息到交换机时,RabbitMQ会获取到消息中的headers信息,对比叫交换机中的键值对信息是否匹配,如果匹配,消息就会保存到该队列中,headers类型的交换机性能很差,不建议使用.