2014-09-10 4 views
2

나는 센서 데이터를 지속적으로 섭취하기 위해 Spring XD를 사용하고 있으며 완벽하게 작동합니다.Spring XD - UDP 내부 작업

내가 가진 새로운 요구 사항은 해당 데이터의 일부를 "재생"하는 것입니다. 특정 경우에 MongoDB에서 (특정 쿼리와 함께) 읽는 것입니다, 항목의 특정 분야와 UDP 패킷을 생성하고 시간의 고정 된 간격으로 SocketAddress로 보냅니다.

내가 구현할 첫 번째 시도는 스프링 배치 작업입니다. 독자는 데이터에 대해 MongoDB를 쿼리하기 때문에 간단하지만 UDP 부분에 대한 우려가 있습니다. UDP 패킷 전송을 위해 스프링 배치를 사용하는 것이 자연스럽지 않으므로 누구나 나에게이 구현 아이디어를 제안 할 수 있는지 알고 싶습니다.

감사

답변

1

당신은 UDP Outbound Channel Adapter를 사용하여 사용자 지정 싱크 파이프 MongoDB Inbound Channel Adapter와 사용자 정의 XD 소스를 사용할 수 있습니다.

+0

나는 그것들을 가지고있다. 나의 문제는 재생 개념이다. 데이터의 일부 재생 및 항목의 항목 화를 시작/중지 할 수 있기를 원합니다. – dmendezg