服务器推送技术

首先让我们来看WebSockets。WebSockets是一种允许浏览器和服务器之间进行双向通信的技术。它通过一个建立在TCP协议上的连接，在浏览器和服务器之间建立了一条持久的通信管道。这样，服务器就可以在需要时随时向客户端推送更新，而不需要客户端发起请求。

例如，在一个在线聊天应用中，WebSockets可以用来实现实时通信。客户端可以通过WebSockets与服务器建立连接，服务器收到新消息后，可以通过WebSockets将消息推送到客户端，以实现实时通信。

接下来是Server-Sent Events（SSE）。SSE是一种基于事件流的协议，允许服务器推送事件消息到客户端。它是通过HTTP协议进行通信的，因此它不需要建立一个新的连接来推送消息。

例如，在一个新闻网站中，SSE可以用来实现推送新闻更新。客户端可以通过SSE与服务器建立连接，当服务器有新闻更新时，可以通过SSE将消息推送到客户端，以实现实时更新。

最后是Long Polling。Long Polling是一种技术，允许客户端发起一个请求，然后在服务器有新数据更新时才返回响应。在这种方式下，客户端会不断发送请求，服务器会持续保持连接，直到有新的数据更新，才会向客户端返回响应。这样，客户端就可以在收到响应后立刻更新数据。

例如，在一个股票交易平台中，Long Polling可以用来实现实时更新股票数据。客户端可以通过Long Polling与服务器建立连接，当服务器有新的股票数据更新时，可以通过Long Polling将更新推送到客户端，以实现实时更新。

// 服务器端
const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
  });

  ws.send('something');
});

// 客户端
const WebSocket = require('ws');
const ws = new WebSocket('ws://localhost:8080/');

ws.on('open', function open() {
  ws.send('hello');
});

ws.on('message', function incoming(data) {
  console.log(data);
});

// 服务器端
const http = require('http');
const fs = require('fs');

const server = http.createServer((req, res) => {
  res.writeHead(200, {
    'Content-Type': 'text/event-stream',
    'Cache-Control': 'no-cache',
    Connection: 'keep-alive'
  });

  setInterval(() => {
    res.write(`data: ${new Date()}\n\n`);
  }, 1000);
});

server.listen(8080);

// 客户端
const EventSource = require('eventsource');
const es = new EventSource('http://localhost:8080/');

es.onmessage = function(event) {
  console.log(event.data);
};

// 服务器端
const http = require('http');
const fs = require('fs');

const server = http.createServer((req, res) => {
  res.writeHead(200, {
    'Content-Type': 'application/json',
    'Cache-Control': 'no-cache'
  });

  fs.readFile('data.json', (err, data) => {
    if (err) throw err;

    res.end(data);
  });
});

server.listen(8080);

// 客户端
const http = require('http');

setInterval(() => {
  http.get('http://localhost:8080/', res => {
    res.on('data', data => {
      console.log(data.toString());
    });
  });
}, 1000);