是否可以在 Spring Integration TCP 中使用自定义标头？

如何解决是否可以在 Spring Integration TCP 中使用自定义标头？

我一直在尝试创建一个简单的 Spring Integration TCP 示例，它在 Message 中使用自定义 UUID 标头，并通过 TCP 通道发送此消息。之后，我在其他服务中恢复了相同的消息，但标头不会发送到服务器。

这是我创建消息的方式：

           Message<byte[]> message1 = MessageBuilder
          .withPayload(payload)
          .setHeader("traceId",traceId)
          .build();

这是我的网关类：

@MessagingGateway
public interface IntegrationGateway {


  @Gateway(requestChannel = "toTcp")
  String toOut(Message<byte[]> message);
}

这是我在其他服务中的“侦听器”：

  @ServiceActivator(inputChannel = "fromTcp")
  public void convert(Message<byte[]> message) {

    byte[] payload = message.getPayload();

    UUID traceId = message.getHeaders().get("traceId",UUID.class);

}

但是当我在另一个服务中恢复消息时，这个头是null。

是否可以在服务器中恢复我的自定义标头？

解决方法

TCP 是流协议；它没有标头和有效载荷的概念。

该框架确实提供了一种将标头映射到流中的机制，例如使用 JSON。

Docs here。

TCP 是一种流媒体协议。序列化器和反序列化器在流中划分消息。在 3.0 之前，只能通过 TCP 传输消息有效负载（String 或 byte[]）。从 3.0 开始，您可以传输选定的标头以及有效负载。但是，“活动”对象，例如replyChannel 标头，无法序列化。

通过 TCP 发送标头信息需要一些额外的配置。

第一步是为 ConnectionFactory 提供使用 mapper 属性的 MessageConvertingTcpMessageMapper。此映射器委托给任何 MessageConverter 实现，以将消息与某些可以由配置的序列化器和反序列化器进行序列化和反序列化的对象相互转换。

Spring Integration 提供了一个 MapMessageConverter，它允许指定添加到 Map 对象的标头列表以及有效负载。生成的 Map 有两个条目：payload 和 headers。 headers 条目本身是一个 Map 并包含选定的标题。

...