ListenTCP
Описание
Прослушивает входящие TCP-подключения и считывает данные с каждого подключения, используя разделитель строк в качестве разделителя сообщений. Поведение по умолчанию — каждое сообщение порождает один FlowFile, однако это можно контролировать, увеличивая размер пакета для более высокой пропускной способности. Размер буфера приема должен быть установлен так, чтобы соответствовать самым большим ожидаемым сообщениям. Процессор можно настроить для использования SSL Context Service, чтобы разрешить только безопасные подключения. Когда подключенные клиенты представляют сертификаты для взаимной аутентификации TLS, различительные имена издателя и субъекта сертификата клиента добавляются в исходящие FlowFiles в виде атрибутов. Процессор не выполняет авторизацию на основе этих значений, но поскольку они прикреплены к исходящим FlowFiles, авторизацию можно реализовать на их основе.
Теги
listen, tcp, tls, ssl
Свойства
| Название | Описание |
|---|---|
| Local Network Interface | Имя локального сетевого интерфейса, используемого для ограничения прослушивания конкретной локальной сети. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Port | The port to listen on for communication. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Receive Buffer Size | Размер каждого буфера, используемого для получения сообщений. Отрегулируйте это значение в соответствии с ожидаемым размером входящих сообщений. |
| Max Size of Message Queue | Максимальный размер внутренней очереди, используемой для буферизации сообщений, передаваемых из базового канала в процессор. Если установить это значение выше, в памяти будет буферизироваться больше сообщений во время всплесков входящих сообщений, но увеличится общий объем памяти, используемой процессором во время таких всплесков. |
| Max Size of Socket Buffer | Максимальный размер буфера сокета, который следует использовать. Это рекомендация для операционной системы, указывающая, каким должен быть размер буфера сокета. Если это значение установлено слишком низким, буфер может заполниться до того, как данные будут считаны, и входящие данные будут отброшены. |
| Character Set | Указывает набор символов для полученных данных. |
| Max Number of Worker Threads | Максимальное количество рабочих потоков, доступных для обслуживания TCP-соединений. |
| Max Batch Size | The maximum number of messages to add to a single FlowFile. If multiple messages are available, they will be concatenated along with the <Message Delimiter> up to this configured maximum number of messages |
| Batching Message Delimiter | Указывает разделитель, который следует устанавливать между сообщениями при объединении нескольких сообщений (см. свойство <Максимальный размер пакета>). |
| Idle Connection Timeout | Время, в течение которого соединение клиента будет ос таваться открытым, если не будут получены данные. Значение по умолчанию 0 секунд оставляет соединения открытыми до тех пор, пока они не будут закрыты клиентом. |
| Max Number of Receiving Message Handler Threads | This property is deprecated and no longer used. |
| Pool Receive Buffers | Включить или отключить объединение буферов, которые процессор использует для обработки байтов, полученных по сокетным соединениям. Фреймворк выделяет буферы по мере необходимости во время обработки. |
| SSL Context Service | Служба контроллера, используемая для получения контекста SSL. Если это свойство задано, сообщения будут приниматься по защищенному соединению. |
| Client Auth | Политика аутентификации клиента, используемая для контекста SSL. Используется только в том случае, если предоставляется служба контекста SSL. |
Взаимосвязи
- success: Сообщения, успешно полученные, будут отправляться по этому каналу.