ListenWebSocket 2025.5.31.15

捆绑包

org.apache.nifi | nifi-websocket-processors-nar

描述

充当 WebSocket 服务器端点,用于接收客户端连接。当使用此处理器配置的 WebSocket 服务器接收客户端请求时,会根据收到的消息类型将 FlowFiles 传输到下游关系

标签

WebSocket、consume、listen、subscribe

输入要求

FORBIDDEN

支持敏感的动态属性

false

属性

属性

描述

server-url-path

该处理器监听的 WetSocket URL 路径。必须以“/”开头,例如“/example”。

websocket-server-controller-service

一个可以接受 WebSocket 请求的 WebSocket SERVER 控制器服务。

关系

名称

描述

binary message

WebSocket 二进制消息输出

connected

WebSocket 会话已建立

disconnected

WebSocket 会话已断开连接

text message

WebSocket 的文本消息输出

写入属性

名称

描述

websocket.controller.service.id

WebSocket 控制器服务 ID。

websocket.session.id

已建立的 WebSocket 会话 ID。

websocket.endpoint.id

WebSocket 端点 ID。

websocket.local.address

WebSocket 服务器地址。

websocket.remote.address

WebSocket 客户端地址。

websocket.message.type

TEXT 或 BINARY。

语言: 中文