В настоящее время я работаю на сервере сокетов TCP, используя интеграцию Spring. пока у меня есть ниже упомянутый код. Но есть возможности балансировки нагрузки нескольких узлов этого сокет-сервера. Для этого мне нужно иметь стики сеансов контекста соединений сокетов, которые могут быть разделены между узлами. Кто-нибудь может предложить возможное решение?
@Bean
public IntegrationFlow listnerServerFlow(
TcpNetServerConnectionFactory serverConnectionFactory,
DeviceListenerService deviceListenerService) {
return IntegrationFlows
.from(Tcp.inboundGateway(serverConnectionFactory))
.handle(deviceListenerService::processRequest)
.get();
}
@Bean
public TcpNetServerConnectionFactory serverConnectionFactory() {
TcpNetServerConnectionFactory connectionFactory = new TcpNetServerConnectionFactory(2424);
connectionFactory.setSerializer(new ByteArrayCrLfSerializer());
connectionFactory.setDeserializer(new ByteArrayCrLfSerializer());
connectionFactory.setSingleUse(false);
connectionFactory.setSoKeepAlive(true);
return connectionFactory;
}