延时队列优化 （2）

在这里新增了一个队列QC,绑定关系如下,该队列不设置TTL时间

 配置类文件：

@Bean("queueC")
    public Queue queueC()
    {
        HashMap<String, Object> args = new HashMap<String, Object>();
        args.put("x-dead-letter-exchange",Y_DEAD_LETTER_EXCHANGE);
        args.put("x-dead-letter-routing-key","YD");
        //在这里没有声明TTL属性
        return  QueueBuilder.durable(QUEUE_C).withArguments(args).build();
    }
    @Bean
    public Binding queueBindingX(@Qualifier("queueC") Queue queueC,@Qualifier("xExchange") DirectExchange exchange)
    {
        return BindingBuilder.bind(queueC).to(exchange).with("XC");
    }

生产者：

@Slf4j
@RequestMapping("ttl")
@RestController
public class Produce01 {
    @Autowired
    private RabbitTemplate rabbitTemplate;
//    @GetMapping("sendMsg/{message}")
//    public void sendMsg(@PathVariable String message)
//    {
//
//        log.info("当前时间：{},发送一条消息给俩个TTL队列：{}", new Date(),message);
//        rabbitTemplate.convertAndSend("X","XA","消息来于10s"+message);
//        rabbitTemplate.convertAndSend("X","XB","消息来于40s"+message);
//    }

    @GetMapping("sendExpirationMsg/{message}/{ttlTime}")
    public void senMsg(@PathVariable String message,@PathVariable  String ttlTime)
    {
        log.info("当前时间：{},发送一条时长{}毫秒TTL信息给队列C:{}", new Date(),ttlTime, message);
        rabbitTemplate.convertAndSend("X","XC",message, correlationData ->{
            correlationData.getMessageProperties().setExpiration(ttlTime);
            return correlationData;
        });
    }
}

消费者：

@Slf4j
@Component
public class Consumer {
    @RabbitListener(queues = "QD")
    public void receiveD(Message message, Channel channel)
    {
        String s = new String(message.getBody());
        log.info("当前时间{}，死信队列D接收到消息---->{}",new Date(),s);
    }
}

 

看起来似乎没什么问题，但是在最开始的时候，就介绍过如果使用在消息属性上设置TTL的方式，消息可能并不会按时“死亡“，因为RabbitMQ只会检查第一个消息是否过期，如果过期则丢到死信队列，

如果第一个消息的延时时长很长，而第二个消息的延时时长很短，第二个消息并不会优先得到执行。