实时推送
最后更新于
这有帮助吗？
除了实时查询外，飞布还支持实时推送功能，常见用例：接入消息队列。相对于实时查询的准实时更新，实时推送是实时更新。
实时推送基于graphql的订阅 operation实现。订阅类似查询，但不是在一次读取中返回数据，而是持续获取服务器推送的数据。这适用于实时应用场景，如IM或物联网应用。
一般情况下，GraphQL 订阅是发送到 WebSocket 端点的订阅查询字符串。 每当后端出现数据变化，新数据都会通过 WebSocket 从服务器向客户端推送。
例如，下面是一个基于，正在执行订阅请求，数据通过WebSocket不断推送到客户端。
与通常graphql 服务不同，飞布基于SSE实现了实时推送，将上游的WebSocke订阅事件，转换为HTTP长连接。
当客户端访问时，飞布先与具有订阅接口的gql数据源建立连接，然后等待WebSocke推送数据，并将数据在通过SSE推送给客户端。
其流程图如下所示：
首先，当客户端订阅服务时①，飞布服务同步订阅事件源②。
然后，等待事件源推送消息给飞布服务③，飞布将其转发给客户端④。
最后，当客户端取消订阅时⑤，飞布也取消订阅⑥。
其中，③和④在取消订阅前，循环执行。
构建如下SUBSCRIPTION OPERATION：
点击顶部工具栏的 ”复制“ICON，获取访问地址：http://localhost:9991/operations/Sub?wg_see=true 。
前往访问，可以看到数据实时推送到界面。响应是一个JSON对象流，由两个换行符分割。
此外，若只想获取一次数据，则需要用 wg_subscribe_once 代替 wg_see。
订阅1次：wg_subscribe_once=true
持续订阅：wg_see=true
同理，订阅OPERATION编译的REST API也可复用HTTP的身份鉴权。在该OPERTION中设置的登录校验或者权限控制，无需任何额外操作，都可以应用到实时推送接口中。
SSE TypeScript示例：
