Spring XD - UDP inside Jobs

Question

我使用Spring XD连续获取传感器数据已经有一段时间了，它工作得很好。

我的新需求是能够“重放”部分数据。在我的特定情况下，它将从MongoDB读取(使用某个查询)，生成一个包含该条目的某个字段的UDP数据包，并在固定的时间间隔内将其发送到SocketAddress。

我正在实现的第一个尝试是通过spring-batch作业。阅读器很简单，因为它只是查询MongoDB中的数据，但我关心的是UDP部分。使用spring-batch发送UDP数据包感觉很不自然，所以我想知道是否有人能给我一个实现它的建议。

谢谢

Answer 1

您可以使用自定义XD源和使用UDP Outbound Channel Adapter通过管道连接到自定义接收器的MongoDB Inbound Channel Adapter。