Я работаю над приложением, которое получит сообщения из очереди, а затем откроет клиентские соединения tcp на основе сообщения. Серверы, к которым будут подключаться клиенты, могут быть медленными или не отвечать на запросы, поэтому моя цель - использовать Spring Webflux и Netty для создания неблокирующих TCP-соединений, чтобы мои потоки не были связаны в ожидании ответа. К сожалению, я не смог найти ни одного рабочего примера этого, интегрированного с пружиной. Также все примеры демонстрируют какое-то поведение блокировки в какой-то момент. Может кто-нибудь указать мне на простой рабочий пример создания действительно неблокирующего клиента TCP с Netty?
Пример: в ответе на следующее: Как открыть TCP-соединение (клиент) в Netty?
в ответе конкретно сказано:
future.channel().closeFuture().sync(); //it will block until
// you invoke
// channel.close();
Так что, если я что-то упускаю, это не кажется мне неблокирующим.