Можно ли избирательно записывать flowfile в соединения tcp в nifi?

Question

Я пишу tcp сервер, который сидит между клиентами и работниками.И клиент, и работник будут подключаться к серверу по tcp-соединению, и соединение должно оставаться открытым.

Когда работник подключится к моему серверу, я сохраню их в пуле доступных работников.когда клиент подключается и отправляет запрос на мой сервер, сервер выполнит некоторую обработку и передаст запрос одному из работников в пуле.

Может ли nifi достичь вышеуказанного?Из процессоров listentcp и puttcp кажется невозможным выбрать из соединений tcp.

Answer 1

ListenTCP - сервер, а PutTCP - клиент.

Невозможно создать два разных типа подключений к одному ListenTCP, а затем соединить эти соединения друг с другом.

Вы можете получить ListenTCP, получающий подключения от клиентов, и затем отправитьданные для работ с использованием PutTCP, при условии, что рабочие имели свой собственный TCP-сервер.Я не знаю, что делают ваши работники, но вы также можете исключить работников и реализовать их логику в NiFi, чтобы у вас просто были клиенты -> ListenTCP -> остальная часть логики в потоке.