PutWebSocket

文档中心 › 组件索引 › PutWebSocket

PutWebSocket Processor

类型全限定名:cn.org.acal.lynxus.processors.websocket.PutWebSocket

所属 Bundle:cn.org.acal.lynxus:lynxus-websocket-processors-nar:2.11.8

描述

使用 ListenWebSocket 或 ConnectWebSocket 建立的 WebSocket 会话将消息发送到 WebSocket 远程端点。

标签

WebSocketpublishsend

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
WebSocket Session Id${websocket.session.id}用于获取会话 ID 的 Lynxus 表达式。如果未指定,消息将发送到 WebSocket 控制器服务端点的所有已连接 WebSocket 对等方。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
WebSocket Controller Service Id${websocket.controller.service.id}用于检索 WebSocket Controller Service id 的 Lynxus 表达式。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
WebSocket Endpoint Id${websocket.endpoint.id}用于检索 WebSocket Controller Service的端点 ID 的 Lynxus 表达式。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
WebSocket Message TypeTEXT消息内容类型:TEXT 或 BINARY
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)

关系 (Relationships)

名称描述自动终止
failure未能发送到目的地的 FlowFile 将传输到此关系。否
success成功发送到目的地的FlowFile将传输到此关系。否

写入的 FlowFile 属性

名称描述
websocket.controller.service.idWebSocket Controller Service ID。
websocket.session.id已建立的 WebSocket 会话 ID。
websocket.endpoint.idWebSocket 端点 ID。
websocket.message.type文本或二进制。
websocket.local.addressWebSocket 服务器地址。
websocket.remote.addressWebSocket 客户端地址。
websocket.failure.detail失败的详细信息。

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。

系统资源考量

资源描述
MEMORYAn instance of this component can cause high usage of this system resource. Multiple instances or high concurrency settings may result a degradation of performance.