PutWebSocket Processor
描述
使用 ListenWebSocket 或 ConnectWebSocket 建立的 WebSocket 会话将消息发送到 WebSocket 远程端点。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| 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 Type | TEXT | 消息内容类型:TEXT 或 BINARY 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 未能发送到目的地的 FlowFile 将传输到此关系。 | 否 |
success | 成功发送到目的地的FlowFile将传输到此关系。 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
websocket.controller.service.id | WebSocket Controller Service ID。 |
websocket.session.id | 已建立的 WebSocket 会话 ID。 |
websocket.endpoint.id | WebSocket 端点 ID。 |
websocket.message.type | 文本或二进制。 |
websocket.local.address | WebSocket 服务器地址。 |
websocket.remote.address | WebSocket 客户端地址。 |
websocket.failure.detail | 失败的详细信息。 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。
系统资源考量
| 资源 | 描述 |
|---|---|
| MEMORY | An instance of this component can cause high usage of this system resource. Multiple instances or high concurrency settings may result a degradation of performance. |