2

我一直在使用 Spring XD 来持续摄取传感器数据,它运行良好。

我的新要求是能够“重放”部分数据。在我的特殊情况下,它将从 MongoDB 读取(带有特定查询),生成具有特定条目字段的 UDP 数据包,并在固定的时间间隔内将其发送到 SocketAddress。

我正在实施的第一次尝试是通过 spring-batch 作业。读者很简单,因为它只是查询 MongoDB 的数据,但我担心 UDP 部分。使用 spring-batch 发送 UDP 数据包感觉不自然,所以我想知道是否有人可以建议我实现这个的想法。

谢谢

4

1 回答 1

1

您可以使用带有MongoDB Inbound Channel Adapter的自定义 XD 源,使用UDP Outbound Channel Adapter通过管道传输到自定义接收器。

于 2014-09-10T15:40:35.767 回答