使用 Spring Cloud Stream 和 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_ID 来传达常量值；在大多数用例中，相关 id 标头由应用程序设置为消息旅程开始时的 ID 标头。