Spring Integration: скопируйте одно входящее сообщение в несколько исходящих

Question

Я хочу использовать Spring Integration для обработки сообщений MQTT.

Это мои требования к обработке: исходя из полезной нагрузки входящего сообщения, оно должно быть скопировано в несколько сообщений с одинаковой полезной нагрузкой, но разными заголовками.Более конкретно, другой заголовок темы MQTT, поскольку я хочу отправить их в разные темы.

Кроме того, исходящие сообщения следует отправлять по порядку: сначала все преобразованные сообщения из 1-го входящего сообщения, затем все сообщения из 2-х входящих сообщений.и т. д.

Какие конечные точки сообщения следует использовать для реализации этого?

Answer 1

Итак, то, что вы описываете, на самом деле не является специфичным для MQTT, а представляет собой шаблон интеграции предприятия под названием splitter , и Spring Integration обеспечивает его поддержку, которую вы можете настроить с помощью XML, Annotation и / или Java DSL.Вы можете найти более подробную информацию здесь .

В скорлупе ореха Splitter - это обработчик сообщений со специальным контрактом, позволяющим ему возвращать "много" из "одного" (вид, обратныйагрегатор).В основном вы получаете сообщение (от MQTT в вашем случае) и разделяете его на несколько сообщений в вашей реализации сплиттера.