--- title: 使用服务器发送事件 slug: Web/API/Server-sent_events/Using_server-sent_events tags: - Advanced - DOM - Guide - SSE - Server Sent Events - messaging - 服务器发送事件 - 通信 translation_of: Web/API/Server-sent_events/Using_server-sent_events original_slug: Server-sent_events/Using_server-sent_events ---
{{DefaultAPISidebar("Server Sent Events")}}
开发一个使用服务器发送的事件的Web应用程序是很容易的。你需要在服务器上的一些代码将事件流传输到Web应用程序,但Web应用程序端的事情几乎完全相同,处理任何其他类型的事件。
在Web应用程序中使用服务器发送事件很简单.在服务器端,只需要按照一定的格式返回事件流,在客户端中,只需要为一些事件类型绑定监听函数,和处理其他普通的事件没多大区别.
服务器发送事件API也就是EventSource
接口,在你创建一个新的EventSource
对象的同时,你可以指定一个接受事件的URI.例如:
const evtSource = new EventSource("ssedemo.php");
EventSource
开始支持CORS.虽然该特性目前并不是标准,但很快会成为标准.如果发送事件的脚本不同源,应该创建一个新的包含URL和options参数的EventSource
对象。例如,假设客户端脚本在example.com上:
const evtSource = new EventSource("//api.example.com/ssedemo.php", { withCredentials: true } );
一旦你成功初始化了一个事件源,就可以对 {{event("message")}} 事件添加一个处理函数开始监听从服务器发出的消息了:
evtSource.onmessage = function(event) { const newElement = document.createElement("li"); const eventList = document.getElementById("list"); newElement.innerHTML = "message: " + event.data; eventList.appendChild(newElement); }
上面的代码监听了那些从服务器发送来的所有没有指定事件类型的消息(没有event
字段的消息),然后把消息内容显示在页面文档中.
你也可以使用addEventListener()
方法来监听其他类型的事件:
evtSource.addEventListener("ping", function(event) { const newElement = document.createElement("li"); const time = JSON.parse(event.data).time; newElement.innerHTML = "ping at " + time; eventList.appendChild(newElement); });
这段代码也类似,只是只有在服务器发送的消息中包含一个值为"ping"的event
字段的时候才会触发对应的处理函数,也就是将data
字段的字段值解析为JSON数据,然后在页面上显示出所需要的内容.
当不通过HTTP / 2使用时,SSE(server-sent events)会受到最大连接数的限制,这在打开各种选项卡时特别麻烦,因为该限制是针对每个浏览器的,并且被设置为一个非常低的数字(6)。该问题在 Chrome 和 Firefox中被标记为“无法解决”。此限制是针对每个浏览器+域的,因此这意味着您可以跨所有选项卡打开6个SSE连接到www.example1.com,并打开6个SSE连接到www.example2.com。 (来自 Stackoverflow)。使用HTTP / 2时,HTTP同一时间内的最大连接数由服务器和客户端之间协商(默认为100)。
服务器端发送的响应内容应该使用值为text/event-stream
的MIME类型.每个通知以文本块形式发送,并以一对换行符结尾。有关事件流的格式的详细信息,请参见事件流格式。
演示的{{Glossary("PHP")}}代码如下:
date_default_timezone_set("America/New_York"); header("Cache-Control: no-cache"); header("Content-Type: text/event-stream"); $counter = rand(1, 10); while (true) { // Every second, send a "ping" event. echo "event: ping\n"; $curDate = date(DATE_ISO8601); echo 'data: {"time": "' . $curDate . '"}'; echo "\n\n"; // Send a simple message at random intervals. $counter--; if (!$counter) { echo 'data: This is a message at time ' . $curDate . "\n\n"; $counter = rand(1, 10); } ob_end_flush(); flush(); sleep(1); }
上面的代码会让服务器每隔一秒生成一个事件流并返回,其中每条消息的事件类型为"ping",数据字段都使用了JSON格式,数组字段中包含了每个事件流生成时的 ISO 8601 时间戳.而且会随机返回一些无事件类型的消息.
注: 您可以在github上找到以上代码的完整示例—参见Simple SSE demo using PHP.
当发生错误(例如请求超时或与HTTP访问控制(CORS)有关的问题), 会生成一个错误事件. 您可以通过在EventSource
对象上使用onerror
回调来对此采取措施:
evtSource.onerror = function(err) { console.error("EventSource failed:", err); };
默认情况下,如果客户端和服务器之间的连接关闭,则连接将重新启动。可以使用.close()
方法终止连接。
evtSource.close();
事件流仅仅是一个简单的文本数据流,文本应该使用 UTF-8 格式的编码.每条消息后面都由一个空行作为分隔符.以冒号开头的行为注释行,会被忽略.
每条消息是由多个字段组成的,每个字段由字段名,一个冒号,以及字段值组成.
规范中规定了下面这些字段:
event
EventSource
对象上触发一个事件,事件类型就是该字段的字段值,你可以使用addEventListener()方法在当前EventSource
对象上监听任意类型的命名事件,如果该条消息没有event
字段,则会触发onmessage属性上的事件处理函数
.data
data
字段,则客户端会用换行符把它们连接成一个字符串来作为字段值.id
EventSource
对象的内部属性"最后一个事件ID"的属性值.retry
除了上面规定的字段名,其他所有的字段名都会被忽略.
下面的例子中发送了三条消息,第一条仅仅是个注释,因为它以冒号开头.第二条消息只包含了一个data
字段,值为"some text".第三条消息包含的两个data
字段会被解析成为一个字段,值为"another message\nwith two lines".其中每两条消息之间是以一个空行为分割符的.
: this is a test stream data: some text data: another message data: with two lines
下面的事件流中包含了一些命名事件.每个事件的类型都是由event
字段指定的,另外每个data
字段的值可以使用JSON格式,当然也可以不是.
event: userconnect data: {"username": "bobby", "time": "02:33:48"} event: usermessage data: {"username": "bobby", "time": "02:34:11", "text": "Hi everyone."} event: userdisconnect data: {"username": "bobby", "time": "02:34:23"} event: usermessage data: {"username": "sean", "time": "02:34:36", "text": "Bye, bobby."}
你可以在一个事件流中同时使用命名事件和未命名事件.
event: userconnect data: {"username": "bobby", "time": "02:33:48"} data: Here's a system message of some kind that will get used data: to accomplish some task. event: usermessage data: {"username": "bobby", "time": "02:34:11", "text": "Hi everyone."}
{{Compat("api.EventSource")}}