如何解决如何使用NiFi的WebSocket将特定的流文件从流路由到特定的客户端
我必须过滤传入的流文件流(下图中的Input to API*
),并根据它们的要求(通过某些属性)通过Websockets
将它们发送到连接的客户端。但是我不知道如何路由消息。详细方案是:
- 传入的流文件是消息的恒定流,当前从多个
Input to API*
输入路由到PutWebSocket
- 客户端可以连接(
ListenWebSocket
),然后发送诸如“ 我想要具有XX属性的流文件”之类的消息,因此我必须开始将传入流重定向到它们。在下面的示例中,过滤由RouteOnAttribute
处理器完成,该处理器执行h01,h02,h03
连接,该连接已被该属性拆分。 - 只要客户端不发送“停止”(“ 我不再有兴趣”)消息,客户端就会开始从传入队列中接收消息
现在,我知道{connected
连接了哪些客户端)以及它们通过{的JSON负载请求了什么请求(“ 我想要具有XX属性的流文件”)。 {1}}连接)。这些连接具有text message
,websocket.controller.service.id
和websocket.endpoint.id
属性。
我仍然想念的是“自从您提出要求以来,我将为所有提出要求的人打开过滤后的闸门,直到您告诉我停止为止”
任何帮助将不胜感激!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。