EventSource-Ereignislistener beenden?

Question

Ich versuche, ein Problem mit Rest-Streaming zwischen der Nest-API und einem Dienst (ST), der kein Streaming unterstützt, zu umgehen.

Um dies zu umgehen, habe ich einen Dienst auf Sails erstellt, der eine Postanforderung von ST mit dem Nest Token annimmt und dann einen EventSource-Ereignis-Listener auslöst, der die Daten zurück an ST sendet.

Es wird hier aus dem Nest Rest-Streaming-Beispiel basiert stark: https://github.com/nestlabs/rest-streaming und mein Code wie folgt:

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); 
    } 
}; 

Das Problem, das ich allerdings vorauszusehen ist, dass, sobald eine Anforderung durch den Knoten-Server empfangen wird, Es startet den Event-Listener, aber ich kann nicht für das Leben von mir herausfinden, wie ich den Event-Listener töten kann.

Wenn ich nicht einen Weg finden kann, dies zu stoppen, dann wird jeder EventListener unbegrenzt laufen, was offensichtlich nicht geeignet ist.

Hat jemand irgendwelche Vorschläge, wie man das Problem überwinden kann?

Answer 1

Jede SSH-Clientverbindung ist ein dedizierter Socket.

Wenn ein bestimmter Client kein Ereignisstreaming benötigt, stellen Sie die Verbindung nicht her. Wenn sie das Ereignisstreaming starten, es jedoch deaktivieren möchten, rufen Sie source.close();source=NULL;

an. Wenn Sie von der Serverseite aus keine weiteren Nachrichten senden möchten, schließen Sie den Socket. Sie haben den serverseitigen Code nicht angezeigt, aber wenn er einen dedizierten Prozess pro SSE-Client ausführt, beenden Sie den Prozess einfach. Wenn Sie eine Liste von Sockets verwalten, eine pro verbundenem Client, schließen Sie den Socket. Auf node.js können Sie eine Funktion auf setInterval ausführen. Um die Verbindung zu schließen, tun Sie und clearInterval() und response.end();.