Как реализовать связь TCP-соединения с интеграцией Spring?

Question

Я новичок в Spring Integration и в настоящее время пытается получить данные с некоторых устройств через TCP. Я придумал следующий контекст Spring:

<bean id="serializer" class="com.somepackage.CustomSerializer"/> 

<int-ip:tcp-connection-factory id="connectionFactory" 
           type="server" 
           port="${tcp.socket.connection.listener.port}" 
           deserializer="serializer" /> 

Проблемы с протоколом беспроводного устройства является то, что при первоначальном подключении он посылает последовательность квитирования и ожидает волшебный ответа, прежде чем он начинает посылать сообщения.

A сообщение шаблон отличается от последовательности установления связи, я не могу реализовать сериализатор, который различает эти два. Если бы я мог реализовать этот процесс рукопожатия в качестве перехватчика. Итак, я попытался реализовать полноразмерный сериализатор, но оказалось, что сериализаторы являются одноточечными, разделяемыми между различными соединениями.

Не могли бы вы посоветовать, как выполнить некоторые пользовательские переговоры (подтверждение связи) до того, как механизмы по умолчанию (разделение данных на сообщения) вступают в игру? Должен ли я настраивать фабрику соединений?

Спасибо!

Answer 1

Я думаю, что вам нужно обычай TCP Interceptor. Из документации:

16,4 TCP перехватчики подключения

фабрики подключений могут быть сконфигурированы с ссылкой на TcpConnectionInterceptorFactoryChain. Перехватчики могут использоваться для добавления поведения к соединениям, таким как согласование, безопасность и другие настройки. Никакие перехватчики в настоящее время не предусмотрены каркасом, но, например, см. InterceptedSharedConnectionTests в исходном репозитории.