如何在 spring xd 中使用自定义 tcp encoder/decoder

Question

文档展示了如何使用一小组 tcp 解码器/编码器（CR、LF、其他一些） 我有由 2 个字节 0x1C 0x0D 分隔的有效载荷。 在流定义中指定它的最简单方法是什么？ 还是我必须创建自定义 source/sink，如此处所示？ http://docs.spring.io/spring-xd/docs/0.1.x-SNAPSHOT/reference/html/creating-a-sink-module.html

Answer 1

解码器在 source 秒内使用，而不是 sink 秒；接收器使用编码器。

是的，您需要自定义 source/sink。

请使用比 0 更新的 XD 版本。1.x;当前版本是 1.2.0.

请参阅 Spring Integration documentation 关于创建自定义 encoders/decoders（通常基于 AbstractByteArraySerializer）。