时间戳

首页 > 解决方案 > RabbitMQ 的延迟功能不起作用

spring-boot - RabbitMQ 的延迟功能不起作用

问题描述

我在 Spring Boot 中使用 RabbitMQ 通过微服务发送消息。我需要为每条消息设置延迟选项。这种情况下，我使用 MessageProperties 文件和 Message，它喜欢这个。

 MessageProperties properties = new MessageProperties();
    properties.setDelay(15000);
    properties.setContentType(ContentType.APPLICATION_JSON.getMimeType());
    properties.setType("direct");
    properties.setHeader("x-delay",15000);
    properties.setHeader("x-delayed-type","direct");
    properties.setHeader("x-delayed-message",true);
    Message forSms = MessageBuilder.withBody(SerializationUtils.serialize(updatedAppointment.getId())).andProperties(properties).setCorrelationId(correlationIdForSms.getBytes()).setHeader("x-delay", 20000).setHeaderIfAbsent("x-delay", 20000).build();
rabbitTemplate.send("auto.exch", "orderRoutingKey", forSms);
and I handle it in this function:

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(value = "myQueue", durable = "true"),arguments = @Argument(name = "x-delay",value = "15000",type = "java.lang.Integer"),
        exchange = @Exchange(value = "auto.exch", delayed ="true",ignoreDeclarationExceptions = "true",arguments = @Argument(name = "x-delayed-type",value = "direct"), type = ExchangeTypes.HEADERS),
         key = "orderRoutingKey")
)

public void sendMessagePatientPhone(final Message message) throws EntityNotFoundException {
    Long appointmentId = (Long) SerializationUtils.deserialize(message.getBody());
    String correlationId = new String(message.getMessageProperties().getCorrelationId());


    Appointment appointment = appointmentService.findById(appointmentId);
    User user = appointment.getPatient().getUser();
    String msg = "Teleconference is started after " + formattedTime(user.getNotificationPeriodForSms());
    sendSms(user, msg);

}

但我只得到空标题，消息没有延迟。也许我使用了错误的方式，但我需要正确的解决方案。我的基本目标是用特定时间延迟每条消息

标签： spring-bootrabbitmqmicroservicesspring-rabbitrabbitmq-exchange

解决方案

你似乎有些困惑：

properties.setHeader("x-delayed-type","direct");
properties.setHeader("x-delayed-message",true);

这些属性是交换属性，而不是消息属性。

要设置x-delay属性，只需使用properties.setDelay(15000).

推荐阅读