发送带有Spring云流和RabbitMq更改ID的消息

Question

我正在使用Spring Cloud Stream和RabbitMq在不同的微服务之间交换消息。

这是我发布消息的设置。

public interface OutputChannels {
  static final String OUTPUT_CHANNEL = "outputChannel";

  @Output
  MessageChannel outputChannel();
}

.

@EnableBinding(OutputChannels.class)
@Log4j
public class OutputProducer {

  @Autowired
  private OutputChannels outputChannels;

  public void createMessage(MyContent myContent) {
    Message<MyContent> message = MessageBuilder
      .withPayload(myContent)
      .build();
    outputChannels.outputChannel().send(message);
    log.info("Sent message: " + message.getHeaders().getId() + myContent);
  }
}

以及接收消息的设置

public interface InputChannels {
  String INPUT_CHANNEL = "inputChannel";

  @Input
  SubscribableChannel inputChannel();
}

.

@EnableBinding(InputChannels.class)
@Log
public class InputConsumer {

  @StreamListener(InputChannels.INPUT_CHANNEL)
  public void receive(Message<MyContent> message) {

    MyContent myContent = message.getPayload();
    log.info("Received message: " + message.getHeaders().getId() + ", " + myContent);
  }
}

我能够成功地使用此设置交换消息。我希望，发送消息和接收消息的ID是相等的。但它们总是不同的UUID。

有没有一种方法可以让消息从生产者通过RabbitMq一直保持相同的ID到消费者？

Answer 1

Spring Messaging消息是不可变的；每次突变时，它们都会获得一个新ID。

您可以使用自定义标头或IntegrationMessageHeaderAccessor。CORRELATION\u ID传递常量值；在大多数用例中，相关id标头由应用程序在消息旅程开始时设置为id标头。