rabbitmq 延时队列

    public void sendDelay(String exchange, String routingKey, Object object, Long noticeTime) {
        if (ObjectUtils.isEmpty(noticeTime)) {
            return;
        }
        if (noticeTime <= 0) {
            logger.info("send mq message to {} by key {}, time:{} -> return ", exchange, routingKey,
                    noticeTime);
            return;
        }
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        logger.info("send mq message to {} by key {} id {}  ttl:{}  content {}", exchange, routingKey,
                correlationData.getId(), noticeTime, JSON.toJSonString(object));
        rabbitTemplate.convertAndSend(exchange, routingKey, JSON.toJSonString(object), message -> {
            message.getMessageProperties().setHeader("x-delay", noticeTime);
            return message;
        }, correlationData);
    }

// 可在message中设置属性x-delay，值为要多久会过期即ttl，单位毫秒

message.getMessageProperties().setHeader("x-delay", noticeTime);