RabbitMQ深度探索：死信队列

@Component
public class DeadExchangeConfig {
    //普通交换机
    @Value("${boyatop.order.exchange}")
    private  String order_exchange;

    //普通队列
    @Value("${boyatop.order.queue}")
    private String order_queue;

    //普通队列的 key
    @Value("${boyatop.order.routingKey}")
    private String order_rotingKey;

    //死信交换机
    @Value("${boyatop.dlx.exchange}")
    private String dlx_exchange;

    //死信队列
    @Value("${boyatop.dlx.queue}")
    private String dlx_queue;

    //死信队列的 key
    @Value("${boyatop.dlx.routingKey}")
    private String dlx_routingKey;

    //定义死信交换机
    @Bean
    public DirectExchange dlxExchange(){
        return new DirectExchange(dlx_exchange);
    }

    //定义死信队列
    @Bean
    public Queue dlxQueue(){
        return new Queue(dlx_queue);
    }

    //定义普通交换机
    @Bean
    public DirectExchange orderExchange(){
        return new DirectExchange(order_exchange);
    }

    //定义普通队列
    @Bean
    public Queue orderQueue(){
        //订单队列绑定死信交换机
        Map<String,Object> arguments = new HashMap<>(2);
        arguments.put("x-dead-letter-exchange",dlx_exchange);
        arguments.put("x-dead-letter-routing-key",dlx_routingKey);
        return new Queue(order_queue,true,false,false,arguments);
//        return QueueBuilder.durable(order_queue).withArguments(arguments).build();
    }


    //订单队列绑定交换机
    @Bean
    public Binding bindingOrderExchange(DirectExchange orderExchange, Queue orderQueue){
        return BindingBuilder.bind(orderQueue)
                .to(orderExchange)
                .with(order_rotingKey);
    }

    //死信队列绑定交换机
    @Bean
    public Binding bindingDlxExchange(DirectExchange dlxExchange, Queue dlxQueue){
        return BindingBuilder.bind(dlxQueue).to(dlxExchange).with(dlx_routingKey);
    }

}

@RestController
public class producerService {

    @Value("${boyatop.order.exchange}")
    private String orderExchange;

    @Value("${boyatop.order.routingKey}")
    private String orderRouTingKey;

    @Autowired
    RabbitTemplate rabbitTemplate;

    @RequestMapping("/sendMsg")
    public String send(){
        String msg = "11111";
        rabbitTemplate.convertAndSend(orderExchange,orderRouTingKey,msg,message -> {
            //设置超时时间
            message.getMessageProperties().setExpiration("5000");
            return message;
        });
        return "success";
    }

}

spring:
  rabbitmq:
    ####连接地址
    host: 127.0.0.1
    ####端口号
    port: 5672
    ####账号
    username: guest
    ####密码
    password: guest
    ### 地址
    virtual-host: boyatopVirtualHost

#演示死信队列
boyatop:
  #备胎交换机
  dlx:
    exchange: boyatop_dlx_exchange
    queue: boyatop_dlx_queue
    routingKey: dlx
  #普通交换机
  order:
    exchange: boyatop_order_exchange
    queue: boyatop_order_queue
    routingKey: order

1. 生产者投递消息先投递到普通交换机中，普通交换机再将该消息投到普通队列中缓存起来，普通队列对应有自己独立的消费者
2. 如果生产者投递消息到普通队列中，普通队列发现该消息一直没有被消费者消费的情况下，这时候会将该消息转移到死信(备胎)交换机中
3. 死信(备胎)交换机对应有自己独立的死信(备胎)队列，对应独立的死信(备胎)消费者

1. redis 过期 key
2. 死信延迟队列实现