如何关闭服务器上的“服务器发送事件”连接？

Question

关于本规范：http : //www.w3.org/TR/eventsource/

如何关闭服务器上打开的连接？客户端明智很容易，只需调用close()，但是我应该在服务器上做什么？就杀了？

Answer 1

因此，我四处寻找协议中内置的解决方案，但似乎没有。如果您的服务器调用response.emit('close')或response.end()，客户端会将其视为错误并尝试重新连接到服务器。（至少在 Chrome 的情况下，它会无限期地尝试重新连接，除非它认为网络错误是致命的）。

因此，无论怎样，您的客户端都必须关闭连接。这就留下了两个选择。第一种是简单地假设来自服务器的任何错误都应该关闭 EventSource。

const sse = new EventSource('/events')
sse.onmessage = m => console.log(m.data)
sse.onerror = () => sse.close()

不过，上述内容还有一些不足之处。我们假设网络错误是正常关闭，但情况可能并非如此。在某些情况下，我们可能确实需要重新连接行为。

因此，我们为什么不直接要求客户端优雅地自行关闭呢！我们有一种方法可以从服务器向客户端发送消息，所以我们需要做的就是从服务器发送一条消息说“关闭我”。

// client.js
const maxReconnectTries = 3

let reconnectAttempts = 0
const sse = new EventSource('/events')
sse.onmessage = m => {
  const { type, data } = JSON.parse(m.data)
  if (type === 'close') sse.close()
  else console.log(data)
}
sse.onerror = () => {
  if (reconnectAttempts > maxReconnectTries) {
    sse.close()
    alert("We have a baaad network error!")
  } else {
    reconnectAttempts++
  }
}

// server.js
const express = require('express')


function sendEvent(res, type, data) {
  res.write(`data: ${JSON.stringify({ type, data })}\n\n`)
}

function sseHandler(req, res) {
  response.writeHead(200, {
    'Connection': 'keep-alive',
    'Content-Type': 'text/event-stream',
    'Cache-Control': 'no-cache'
  }

  let manualShutdown
  request.on('close', () => {
    console.log('disconnected.')
    clearTimeout(manualShutdown)  // prevent shutting down the connection twice
  })
  
  sendEvent(res, 'message', `Ping sent at ${new Date()}`)

  // when it comes time to shutdown the event stream (for one reason or another)
  setTimeout(() => {
    sendEvent(res, 'close', null)
    // give it a safe buffer of time before we shut it down manually
    manualShutdown = setTimeout(() => res.end(), clientShutdownTimeout)
  }, 10000)
}

const clientShutdownTimeout = 2000
const app = express()
app.get('/events', sseHandler)
app.listen(4000, () => console.log('server started on 4000'))

这涵盖了安全的客户端/服务器实现所需的所有领域。如果服务器出现问题，我们会尝试重新连接，但如果出现故障，我们仍然可以通知客户端。当服务器想要关闭连接时，它会要求客户端关闭连接。两秒钟后，如果客户端没有关闭连接，我们可以假设出现问题并关闭服务器端的连接。

我们在这里所做的是在服务器发送的事件之上构建一个协议。它有一个非常简单的API：{ "type": "close" }告诉客户端关闭服务器，并{ "type": "message", "data": {"some": "data" }告诉客户端这是一条常规消息。

Answer 2

节点.js：

http.createServer(function (req, res) {

    //...

    // client closes connection
    res.socket.on('close', function () {
      res.end();
      //...
    });

});

请参阅在 Node.js 中实现 SSE 服务器的示例：

https://github.com/Yaffle/EventSource/blob/master/nodechat/server.js