记录–服务端推送到Web前端有哪几种方式？

这个问题？

这个问题一般会出现在面试题里面，然后回答一些诸如轮询、WebSocket之类的答案。当然，实际开发中，也会遇到类似别人给你赞了，要通知给你的情况。这时服务端推送给Web前端（先局限在Web前端，毕竟其他端还有一些特殊方法）到底有多少种方法？它们到底是怎么实现的？

写个Demo看看吧，这样正好把主要（不清楚是否还有漏的）的方案都实现一遍。先看效果：

其中的代码也上传到GitHub了，在server-push（ github.com/waiter/serv… ）这里。

各种方案

从上面的截图也已经可以看出，本文主要写了5种方案，那么接下来也就一个一个简单介绍一下吧。

另外，本文涉及的Demo，后端直接使用原生的Node.js开发，没有使用Koa、Express之类的，也没有使用额外的库，类似socket.io，主要是想保持最精简的状态来呈现。前端也只是在最基础的HTML上，引入了jQuery来方便做DOM操作，也引入了Bootstrap来快速实现统一的样式，而未再引入类似Vue、React之类的框架。

还有，为了触发服务端推送，这边在前端页面上加了个输入框和按钮，来将消息发送给后端，后端会缓存消息，并触发推送，后端大体代码类似：

// 缓存需要推送的信息
const datas = [];
// 各种方案触发推送时的回调
const callbacks = {};
// 注册接口回调
server.on('request', (req, res) => {
const { pathname, query } = parse(req.url, true);
// 如果发现是前端触发推送接口
if (pathname === '/api/push') {
if (query.info) {
// 缓存推送信息
datas.push(query.info);
const d = JSON.stringify([query.info]);
// 触发所有推送回调
Object.keys(callbacks).forEach(k => callbacks[k](d));
}
res.end('ok');
}
});

这个看起来其实时性与请求频率成正相关，但是当请求频率上来了，性能浪费也就越高，毕竟可能大部分请求都是无意义的。

2. 长轮询

在翻找资料的时候，发现有些资料会直接把这个当作短轮询，有点匪夷所思。这里的长轮询相对前面的轮询来说，算是一种优化。具体就是前端发起请求到后端，后端不直接返回，而是等待有新信息时再返回。所以这样发起的一个请求，可能需要很长的时间才能等到返回，故而叫做长轮询。

其前端代码基本和短轮询一致，只不过把请求的超时时间设置较长（比如1分钟），然后无论请求成功或失败，马上再次发起请求即可。

相对来说，后端的写法就要稍微改动一下

const id = parseInt(query.id || '0', 10) || 0;
const cbk = 'long-polling';
delete callbacks[cbk];
const data = datas.slice(id);
res.writeHead(200, { 'Content-Type': 'application/json' });
// 发起请求时，正好有新消息就返回
if (data.length) {
return res.end(JSON.stringify(data));
}
req.on('close', () => {
delete callbacks[cbk];
});
// 注册新消息回调
callbacks[cbk] = (d) => {
res.end(d);
};

这样，**相对于短轮询，少了很多无意义的请求，而且消息的实时性也非常好。**不过，当服务端有异常时，会导致长轮询短时间内不断发起请求，可能让服务端承受更大的压力，所以两次长轮询之间最好有一定间隔，或者异常检测机制。

3. SSE（Server-sent events）

Traditionally, a web page has to send a request to the server to receive new data; that is, the page requests data from the server. With server-sent events, it's possible for a server to send new data to a web page at any time, by pushing messages to the web page. These incoming messages can be treated as Events + data inside the web page.

前面提到的轮询、长轮询都是一问一答式的，一次请求，无法推送多次消息到前端。而SSE就厉害了，一次请求，N次推送。

其原理，或者说类比，个人认为可以理解为下载一个巨大的文件，文件的内容分块传给前端，每块就是一次消息推送。

听起来很厉害，先看看后端代码要怎么写

const cbk = 'sse';
delete callbacks[cbk];
res.writeHead(200, {
// 这个是核心
'Content-Type': 'text/event-stream',
'Connection': 'keep-alive',
});
// 把缓存的信息推送给前端
res.write(`data: ${JSON.stringify(datas)}\n\n`);
// 注册新消息回调
callbacks[cbk] = (d) => {
res.write(`data: ${d}\n\n`);
};
req.on('close', () => {
delete callbacks[cbk];
});

后端代码很简单，核心在于Content-Type: text/event-stream，这要让前端知道这是SSE，还有就是传输信息的格式比较特别一点，详细的可以看 MDN（ developer.mozilla.org/en-US/docs/… ）

而前端有专门的EventSource来接收，使用起来很方便

const es = new EventSource('/api/sse');
es.onmessage = (e) => {
try {
const c = JSON.parse(e.data);
} catch (err) {
console.log(err);
}
}

另外，**SSE还支持自动重连！**服务器短时间异常，恢复之后，无需额外代码，SSE就自动重连上了。不过，本人在实际工作中却没有碰到过SSE，也就在面试题中见过。

4. WebSocket

既然有了SSE，那还要WebSocket干啥啊？因为WebSocket可以一次连接，双向推送，而SSE只能从服务端推送到前端。从这个角度来看，用WebSocket来单做服务端推送，有点大材小用了。

另外，初见WebSocket，可能会对其与Socket的联系有点疑惑。Socket协议是与HTTP协议平级的，而WebSocket协议是基于HTTP协议的，不过两者在使用层面上是十分相近的。

其前端使用写法与SSE类似，十分简单，只不过请求链接为ws://或者wss://开头（相当于http://和https://）

const ws = new WebSocket('ws://localhost:3000/ws');
ws.onmessage = e => {
try {
const c = JSON.parse(e.data);
} catch (err) {
console.log(err);
}
};

不过，它没有像SSE一样有自动重连，这块需要自行实现。

一般网页实时聊天之类需要双向推送的，都会使用WebSocket来实现。

5. iFrame

这算是找资料的时候意外发现的，之前并不知道还有这样的玩法。原理类似使用iFrame加载一个巨大的网页，利用浏览器会一边加载一边解析执行返回的HTML，通过分次返回Script标签来实现消息推送。其实现类似SSE，不过看起来就比较==hack==。

前端代码很简单，只不过要注册一个回调给iframe使用

// 注册给iframe使用的方法
window.change = function(data) {
};
$('body').append('<iframe src="https://www.cnblogs.com/api/iframe"></iframe>');