ConnectWebSocket 2025.5.31.15¶

捆绑包¶

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

描述¶

充当 WebSocket 客户端终端，用于与远程 WebSocket 服务器交互。当配置了该处理器的 WebSocket 客户端从远程 WebSocket 服务器接收消息时，会根据接收到的消息类型将 FlowFiles 传送到不同的下游关系中。如果处理器接收到一个新的 FlowFile，则之前的会话将被关闭，任何正在传输的数据也将中止。

标签¶

WebSocket、consume、listen、subscribe

输入要求¶

ALLOWED

支持敏感的动态属性¶

false

属性¶

属性	描述
websocket-client-controller-service	一个可以连接到 WebSocket 服务器的 WebSocket CLIENT 控制器服务。
websocket-client-id	用于识别 WebSocket 会话的客户端 ID。它在 WebSocket 客户端控制器服务中应该是唯一的。否则，它会在启动时抛出 WebSocketConfigurationException。

关系¶

名称	描述
binary message	WebSocket 二进制消息输出
connected	WebSocket 会话已建立
disconnected	WebSocket 会话已断开连接
failure	如果连接失败，将输出包含连接配置属性（如 URL 或 HTTP 头信息）的 FlowFile
success	如果连接成功，将输出包含连接配置属性（如 URL 或 HTTP 头信息）的 FlowFile
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。