导航：首页 > 互联网科技 >

html5的服务器如何推送Server-sent Events和 websocket

发表于：2025-02-03 作者：千家信息网编辑

千家信息网最后更新 2025年02月03日，这期内容当中小编将会给大家带来有关html5的服务器如何推送Server-sent Events和 websocket，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。

千家信息网最后更新 2025年02月03日html5的服务器如何推送Server-sent Events和 websocket

这期内容当中小编将会给大家带来有关html5的服务器如何推送Server-sent Events和 websocket，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。

html5 的服务器推送 Server-sent Events和 websocket

Server-Sent Events

运行原理

浏览器通过HTTP向服务器发送请求，服务器端拿出数据库中的最新的信息，立即返回给客户端，客户端等待三秒后再次发出下一个请求。

实现方式

JavaScript模块打开EventSource，把接受者的id传给服务端。客户端收到相应后，onMessage事件的处理器将被调用。浏览器将每3秒发送一个请求，除非将连接关闭（Close方法）。

客户端示例：

      JS Bin

EventSource 对象

在上面的例子中，我们使用 onmessage 事件来获取消息。不过还可以使用其他事件：

事件	描述
onopen	当通往服务器的连接被打开
onmessage	当接收到消息
onerror	当发生错误

nodejs 服务端示例：

服务器端事件流的语法是非常简单的。把 "Content-Type" 报头设置为"text/event-stream"。

Content-Type: text/event-stream
Cache-Control: no-cache
Connection: keep-alive

服务器返回字段：

data ：数据内容
event ：自定义事件
id ：数据编号
retry ：指定浏览器重新发起连接的时间间隔。retry: 10000\n
：：冒号开头的行，表示注释

两种情况会导致浏览器重新发起连接：
一种是时间间隔到期，二是由于网络错误等原因，导致连接出错。

var http = require("http");http.createServer(function (req, res) {  var fileName = "." + req.url;  if (fileName === "./stream") {    res.writeHead(200, {      "Content-Type":"text/event-stream",      "Cache-Control":"no-cache",      "Connection":"keep-alive",      "Access-Control-Allow-Origin": '*',    });    res.write("retry: 10000\n");    res.write("event: connecttime\n");    res.write("data: " + (new Date()) + "\n\n");    res.write("data: " + (new Date()) + "\n\n");    interval = setInterval(function () {      res.write("data: " + (new Date()) + "\n\n");    }, 1000);    req.connection.addListener("close", function () {      clearInterval(interval);    }, false);  }}).listen(8844, "127.0.0.1");

WebSockets

返回目录

运行原理

客户端通知WebSockets服务器一个事件，告诉他接收者id，服务器将立即通知消息，当任何新的未读消息来的时候，服务器都将立即返回数据给客户端。

客户端示例：

socket服务端 nodejs

var net = require("net");server1 = net.createServer(function(client){    client.write('Hello World!\r\n');});server1.listen(9000);//--------------------------------------------------var WebSocketServer = require('ws').Server,wss = new WebSocketServer({ port: 8181 });wss.on('connection', function (ws) {    console.log('client connected');    ws.on('message', function (message) {        console.log(message);    });});