Comet
虽然实现比较简单,但是12bet,实际使用过程中并不是那么简单,12bet,还需要考虑很多实际的问题,例如连接断开如何重连。而且Comet
并不是HTML5
规范的一部分,并且在服务器端和浏览器端都需要第三方库的支持。幸运的是HTML5
规范中新增了SSE
(Server-Sent Event
),直接使用SSE API
就能实现和Comet
一样的功能,下面就一起来看看SSE
吧。
什么是Server-Sent Event
SSE
主要由两个部分组成:第一个部分是服务器端与浏览器端之间的通讯协议,12bet,第二部分则是在浏览器端可供 JavaScript 使用的 EventSource
对象。 SSE
用于创建到服务器的单向连接,服务器通过这个连接可以发送任意数量的数据。服务器响应的MIME类型必须为text/event-stream
。SSE
支持短轮询、长轮询和HTTP流,而且能在断开连接时自动重新连接。响应文本的内容可以看成是一个事件流,由不同的事件所组成。每个事件由类型和数据两部分组成,12博体育,同时每个事件可以有一个可选的标识符。不同事件的内容之间通过仅包含回车符和换行符的空行(“rn”)来分隔。每个事件的数据可能由多行组成。
data: first event
data: second event
id: 100
event: myevent
data: third event
id: 101
: this is a comment
data: fourth event
data: fourth event continue
上面的例子中每个事件用空行分隔,对于每一行,冒号前为该行的类型,冒号后为对应的值。可能的值有:
- 类型为空白,表示该行是注释,会在处理时被忽略。
- 类型为
data
,表示该行包含的是数据。以 data 开头的行可以出现多次。所有这些行都是该事件的数据。 - 类型为
event
,表示该行用来声明事件的类型。浏览器在收到数据时,会产生对应类型的事件。 - 类型为
id
,表示该行用来声明事件的标识符。 - 类型为
retry
,表示该行用来声明浏览器在连接断开之后进行再次连接之前的等待时间。
如果服务器端返回的数据中包含了事件的标识符,浏览器会记录最近一次接收到的事件的标识符。如果与服务器端的连接中断,当浏览器端再次进行连接时,12博体育,会通过 HTTP 头“Last-Event-ID”来声明最后一次接收到的事件的标识符。12bet,服务器端可以通过浏览器端发送的事件标识符来确定从哪个事件开始来继续连接。
对于服务器端返回的响应,浏览器端需要在 JavaScript 中使用 EventSource
对象来进行处理。EventSource
使用的是标准的事件监听器方式,只需要在对象上添加相应的事件处理方法即可。EventSource
提供了三个标准事件:
open
:当成功与服务器建立连接时产生message
:当收到服务器发送的事件时产生error
:当出现错误时产生
下面就来实现一下吧。
实现
先来看客户端,首先创建EventSource
对象,然后监听标准的open
,error
,message
事件,同时监听了自定义的connecttime
事件。当有message到来时,将数据显示到页面的output上。
var button = document.getElementById("connect");
var status1 = document.getElementById("status");
var output = document.getElementById("output");
var connectTime = document.getElementById("connecttime");
var source;
function connect() {
source = new EventSource("https://localhost:3000/event-stream");
source.addEventListener("message", function(event) {
output.textContent = event.data;
}, false);
source.addEventListener("connecttime", function(event) {
connectTime.textContent = "连接创建时间: " + event.data;
}, false);
source.addEventListener("open", function(event) {
button.value = "断开连接";
status1.textContent = "连接已开启!";
button.onclick = function(event) {
source.close();
button.value = "连接";
button.onclick = connect;
status1.textContent = "连接已关闭!";
};
}, false);
source.addEventListener("error", function(event) {
if (event.target.readyState === EventSource.CLOSED) {
source.close();
status1.textContent = "连接已关闭!";
} else if (event.target.readyState === EventSource.CONNECTING) {
status1.textContent = "连接已关闭. 正在尝试重连!";
} else {
status1.textContent = "连接已关闭. 位置错误!";
}
}, false);
}
if (!!window.EventSource) {
button.onclick = connect;
} else {
button.style.display = "none";
status1.textContent = "你的浏览器不支持server-sent events";
}
再来看服务端的实现,首先我们向客户端发送一个connecttime
事件的数据-连接时间,然后每隔1s返回一条系统时间的数据,同时监听连接的close事件。这里注意头部Content-Type
为text/event-stream
,并且由于是跨域的,还要加上Access-Control-Allow-Origin
头部。
router.get('/event-stream', function(req, res, next) {
res.writeHead(200, {
"Content-Type":"text/event-stream",
"Cache-Control":"no-cache",
"Connection":"keep-alive",
"Access-Control-Allow-Origin" : "*"
});
res.write("retry: 10000n");
res.write("event: connecttimen");
res.write("data: " + (new Date()) + "nn");
res.write("data: " + (new Date()) + "nn");
var interval = setInterval(function() {
res.write("data: " + (new Date()) + "nn");
}, 1000);
req.connection.addListener("close", function () {
clearInterval(interval);
}, false);
});
效果
下面来看看效果吧:
可以看到SSE
只建立了一个连接,然后就可以从服务器获取数据了。但是这种方式只能从服务器拉取数据,也就是从建立服务器到客户端的单工通信,如果要实现双工通信可以考虑使用Websocket
。
SSE
目前已经被主流的浏览器支持(IE不支持),包括:Firefox 6.0+、Chrome 6.0+、Safari 5.0+、Opera 11.0+、iOS Safari 4.0+、Opera Mobile 11.1+、Chrome for Android 25.0+、Firefox for Android 19.0+ 以及 Blackberry Browser 7.0+ 等。
对于IE的支持,一般用两种方法:第一种办法是在其他浏览器上使用原生 EventSource
对象,而在 IE 上则使用轮询或 Comet
技术来实现;另外一种做法是使用 polyfill
技术,即使用第三方提供的 JavaScript 库来屏蔽浏览器的不同。一般推荐使用第二种方法。
下一节就来试试全双工的Websocket
协议吧。
完整代码请看这里
参考
- Server-sent Events实战
- Server-Sent Events in Node.js
- Server-Sent Events