0

我正在尝试解决与 Nest API 和不支持流式传输的服务 (ST) 之间的流式传输有关的问题。

为了解决这个问题，我在 Sails 上构建了一个服务，该服务从 ST 接收包含 Nest 令牌的发布请求，然后触发 EventSource 事件侦听器，将数据发送回 ST。

它在很大程度上基于此处的 Nest rest-streaming 示例： https ://github.com/nestlabs/rest-streaming ，我的代码如下：

    startStream: function(req, res) {
        var nestToken = req.body.nestToken,
                stToken = req.body.stToken,
                endpointURL = req.body.endpointURL,
                source = new EventSource(sails.config.nest.nest_api_url + '?auth=' + nestToken);


        source.addEventListener('put', function(e) {
            var d = JSON.parse(e.data);
            var data = { devices: d.data.devices, structures: d.data.structures},
                    config = { headers : {'Authorization': 'Bearer ' + stToken}};

            sendData(endpointURL, data, config);
        });

        source.addEventListener('open', function(e) {
            console.log("Connection opened");
        });

        source.addEventListener('auth_revoked', function(e){
            console.log("Auth token revoed");
        });

        source.addEventListener('error', function(e) {
        if (e.readyState == EventSource.CLOSED) {
          console.error('Connection was closed! ', e);
        } else {
          console.error('An unknown error occurred: ', e);
        }
      }, false);
    }
};

我预见的问题是，一旦节点服务器收到请求，它就会启动事件侦听器，但是我无法终生弄清楚如何杀死事件侦听器。

如果我无法找到阻止这种情况的方法，那么每个 EventListener 都会无限期地运行，这显然是不合适的。

有没有人对如何克服这个问题有任何建议？

4

1 回答 1

2

每个 SSH 客户端连接都是一个专用套接字。

如果特定客户端不想要事件流，请不要建立连接。如果他们开始事件流，但想将其关闭，请致电source.close();source=NULL;

如果您想从服务器端停止发送消息，请关闭套接字。您没有显示服务器端代码，但如果它为每个 SSE 客户端运行一个专用进程，那么您只需退出该进程。如果您要维护一个套接字列表，每个连接的客户端一个，请关闭套接字。在 node.js 上，您可能正在 setInterval 上运行一个函数。要关闭连接，您执行 和clearInterval()和response.end();。

于 2017-01-18T09:52:37.453 回答