Apache NiFi 2.x处理器:ListenWebSocket 2.2.0
包
org.apache.nifi | nifi-websocket-processors-nar
描述
作为WebSocket服务器端点，用于接受客户端连接。当配置此处理器的WebSocket服务器接收到客户端请求时，FlowFile会根据接收到的消息类型传输到下游关系。
标签
WebSocket, consume, listen, subscribe
输入要求
禁止
支持敏感动态属性
否
属性
- Server URL Path（服务器URL路径）：此处理器监听的WebSocket URL路径。必须以“/”开头，例如“/example”。
- 显示名称：Server URL Path（服务器URL路径）
- 描述：此处理器监听的WebSocket URL路径。必须以“/”开头，例如“/example”。
- API名称：server-url-path
- 表达式语言作用域：不支持
- 是否敏感：否
- 是否必需：是
- WebSocket Server ControllerService（WebSocket服务器控制器服务）：一种可以接受WebSocket请求的WebSocket服务器控制器服务。
- 显示名称：WebSocket Server ControllerService（WebSocket服务器控制器服务）
- 描述：一种可以接受WebSocket请求的WebSocket服务器控制器服务。
- API名称：websocket-server-controller-service
- 服务接口：org.apache.nifi.websocket.WebSocketServerService
- 服务实现：org.apache.nifi.websocket.jetty.JettyWebSocketServer
- 表达式语言作用域：不支持
- 是否敏感：否
- 是否必需：是
关系
名称 | 描述 |
binary message | WebSocket二进制消息输出 |
text message | WebSocket文本消息输出 |
disconnected | WebSocket会话断开连接 |
connected | 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。 |
