Завершить прослушиватель событий EventSource?

Question

Я пытаюсь решить проблему, связанную с потоком отдыха между API-интерфейсом Nest и службой (ST), которая не поддерживает потоковую передачу.

Чтобы обойти это, я создал службу на Sails, которая отправляет запрос от ST, содержащий токен Nest, а затем запускает прослушиватель событий EventSource, который отправляет данные обратно в ST.

Это в значительной степени основано от Nest покоя потокового примера здесь: 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 будет работать бесконечно, что явно не подходит.

Есть ли у кого-нибудь какие-либо предложения о том, как преодолеть эту проблему?

Answer 1

Каждое подключение к SSH-клиенту является специальным сокетом.

Если конкретный клиент не хочет потокового потока событий, не делайте соединение. Если они запускают потоки событий, но хотят отключить их, позвоните по телефону source.close();source=NULL;

Если с серверной стороны вы хотите прекратить отправку сообщений, закройте сокет. Вы не указали код на стороне сервера, но если он запускает выделенный процесс на SSE-клиент, вы просто выходите из процесса. Если вы поддерживаете список сокетов, по одному на подключенный клиент, закройте сокет. На node.js вы можете запускать функцию на setInterval. Чтобы закрыть соединение, которое вы делаете, и clearInterval() и response.end();.