首页 / JAVASCRIPT / 基于node实现websocket协议

基于node实现websocket协议

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了基于node实现websocket协议，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6747字，纯文字阅读大概需要10分钟。

内容图文

一、协议
WebSocket是一种基于TCP之上的客户端与服务器全双工通讯的协议，它在HTML5中被定义，也是新一代webapp的基础规范之一。

它突破了早先的AJAX的限制，关键在于实时性，服务器可以主动推送内容到客户端！可能的应用有：多人在线游戏，即时聊天，实时监控，远程桌面，新闻服务器等等。

对于我自己，当前最想尝试的是canvas+websocket组合起来能做什么。

二、实现
由于握手的过程是一个标准的HTTP请求，因此 websocket 的实现有两种选择：1）TCP上实现； 2) 现有HTTP软件上实现。后者的优势在于可以共用现有的HTTP服务器端口，并且不用重新实现认证功能和解析HTTP请求的功能。

这个示例中使用的 node 的HTTP模块。（TCP版及所有文件见附件）

1、node服务器端代码：

var http = require('http');
var url = require('url');
// var mime = require('mime');
var crypto = require('crypto');

var port = 4400;
var server = http.createServer();
  server.listen(port,function() {
    console.log('server is running on localhost:',port);
    server
    .on('connection',function(s) {
      console.log('on connection ',s);
    })
    .on('request',onrequest)
    .on('upgrade',onupgrade);
  });

var onrequest = function(req,res) {
  console.log( Object.keys(req) ,req.url,req['upgrade']);
  if( !req.upgrade ){
    // 非upgrade请求选择：中断或提供普通网页
    res.writeHead(200, { 'content-type': 'text/plain' });
    res.write( 'WebSocket server works!' );
    
  }
  res.end();
  return;
};

var onupgrade = function (req,sock,head) {
  // console.log('方法:',Object.keys(sock));
  if(req.headers.upgrade !== 'WebSocket'){
    console.warn('非法连接');
    sock.end();
    return;
  }
  
  bind_sock_event(sock);

  try{
    handshake(req,sock,head);
  }catch(e){
    console.error(e);
    sock.end();
  }
};

// 包装将要发送的帧
var wrap = function(data) {
  var fa = 0x00, fe = 0xff, data = data.toString()
    len = 2+Buffer.byteLength(data),
    buff = new Buffer(len);

  buff[0] = fa;
  buff.write(data,1);
  buff[len-1] = fe;
  return buff;
}
// 解开接收到的帧
var unwrap = function(data) {
  return data.slice(1,data.length-1);
}

var bind_sock_event = function(sock) {
  sock
  .on('data',function(buffer) {
    var data = unwrap(buffer);
    console.log('socket receive data : ',buffer,data,'\n>>> '+data);
    // send('hello html5,'+Date.now())
    sock.emit('send',data);
  })
  .on('close',function() {
    console.log('socket close');
  })
  .on('end',function() {
    console.log('socket end');
  })
  .on('send',function(data) { //自定义事件
    sock.write(wrap(data),'binary');
  })
};

var get_part = function(key) {
  var empty  = '',
    spaces = key.replace(/\S/g,empty).length,
    part  = key.replace(/\D/g,empty);
  if(!spaces) throw {message:'Wrong key: '+key,name:'HandshakeError'}
  return get_big_endian(part / spaces);
}

var get_big_endian = function(n) { 
  return String.fromCharCode.apply(null,[3,2,1,0].map(function(i) { return n >> 8*i & 0xff }))
}

var challenge = function(key1,key2,head) {
  var sum = get_part(key1) + get_part(key2) + head.toString('binary');
  return crypto.createHash('md5').update(sum).digest('binary');
}

var handshake = function(req,sock,head) {
  var output = [],h = req.headers, br = '\r\n';

  // header
  output.push(
    'HTTP/1.1 101 WebSocket Protocol Handshake','Upgrade: WebSocket','Connection: Upgrade',
    'Sec-WebSocket-Origin: ' + h.origin,
    'Sec-WebSocket-Location: ws://' + h.host + req.url,
    'Sec-WebSocket-Protocol: my-custom-chat-protocol'+br
  );
  // body
  var c = challenge(h['sec-websocket-key1'],h['sec-websocket-key2'],head);
  output.push(c);

  sock.write(output.join(br),'binary');
}

2、浏览器客户端代码：

<html>
<head>
  <title>WebSocket Demo</title>
</head>
<style type="text/css">
 textarea{width:400px;height:150px;display:block;overflow-y:scroll;}
 #output{width:600px;height:400px;background:whiteSmoke;padding:1em .5em;color:#000;border:none;}
 button{padding:.2em 1em;}
</style>
<link href="layout.css" rel="stylesheet" type="text/css" /> 
<body>

<textarea id="output" readonly="readonly"></textarea>
<br>
<textarea id="input"></textarea>
<button id="send">send</button>

<script type="text/javascript">
// localhost
var socket = new WebSocket('ws://192.168.144.131:4400/')
socket.onopen = function(e) {
  log(e.type);
  socket.send('hello node');
}
socket.onclose = function(e) {
  log(e.type);
}
socket.onmessage = function(e) {
  log('receive @ '+ new Date().toLocaleTimeString() +'\n'+e.data);
 output.scrollTop = output.scrollHeight
}
socket.onclose = function(e) {
  log(e.type);
}
socket.addEventListener('close',function() {
  log('a another close event handler..');
},false);

// dom
var id = function(id) {
  return document.getElementById(id);
}
var output = id('output'), input = id('input'), send = id('send');
var log = function(msg) {
  output.textContent += '> '+msg + '\n'
}
send.addEventListener('click',function() {
  socket.send(input.value);
},false);

</script>
</body>
</html>

三、细节
在 http 协议之上的 websocket 协议实现只有两步：握手，发送数据。

1、握手
握手的过程被称为 challenge-response。首先客户端发起一个名为Upgrade的HTTP GET请求，服务器验证此请求，给出101响应以表示接受此次协议升级，握手即完成了。

chrome inspector美化过的握手信息：

Request URL:ws://192.168.144.131:4400/pub/chat?q=me
Request Method:GET
Status Code:101 WebSocket Protocol Handshake

Request Headers
Connection:Upgrade
Host:192.168.144.131:4400
Origin:http://localhost:800
Sec-WebSocket-Key1:p2 G 947T 80 661 jAf2
Sec-WebSocket-Key2:z Z Q ^326 5 9= 7s1 1 7H4
Sec-WebSocket-Protocol::my-custom-chat-protocol
Upgrade:WebSocket
(Key3):7C:44:56:CA:1F:19:D2:0A

Response Headers
Connection:Upgrade
Sec-WebSocket-Location:ws://192.168.144.131:4400/pub/chat?q=me
Sec-WebSocket-Origin:http://localhost:800
Sec-WebSocket-Protocol:my-custom-chat-protocol
Upgrade:WebSocket
(Challenge Response):52:DF:2C:F4:50:C2:8E:98:14:B7:7D:09:CF:C8:33:40

请求头部分

Host: websocket服务器主机
Connection: 连接类型
Upgrade: 协议升级类型
Origin: 访问来源
Sec-WebSocket-Protocol: 可选，子协议名称，由应用自己定义，多个协议用空格分割。(*另外一个仅剩的可选项是cookie)
Sec-WebSocket-Key1: 安全认证key，xhr请求不能伪造'sec-'开头的请求头。
Sec-WebSocket-Key2: 同上
Key3: 响应体内容,8字节随机。
响应头部分

Sec-WebSocket-Protocol: 必须包含请求的子协议名
Sec-WebSocket-Origin: 必须等于请求的来源
Sec-WebSocket-Location: 必须等于请求的地址
Challenge Response: 响应体内容，根据请求中三个key计算得来，16字节。
应答字符串计算过程伪代码:

part_1 = key1中所有数字 / key1中空格数量
part_2 同上
sum = big_endian(part_1)+big_endian(part_2)+key3
challenge_response = md5_digest(sum);

32位整数的big_endian计算策略：

# 很类似于rgba颜色计算,从下面的函数可以看出计算过程
var big_endian = function(n) {
  return [3,2,1,0].map(function(i) { return n >> 8*i & 0xff });
}
big_endian(0xcc77aaff);
// -> [204, 119, 170, 255]

2、发送数据
WebSocket API的被设计成用事件处理数据，客户端只要得到事件通知就可以获取到完整的数据，而不需要手动处理缓冲器。

这种情况下，每一笔数据被称为一帧。在规范的定义中，它的头部必须以0x00开始，尾部属性以0xff结束，这样每一次数据发送至少有两个字节。

服务器实现中，收到数据时要截掉头尾；而发送数据是要包装头尾。格式如下：

# '你好'的原始二进制表示，请求头和这里都是utf8编码
<Buffer e4 bd a0 e5 a5 bd>
# 包装后的二进制表示。
<Buffer 00 e4 bd a0 e5 a5 bd ff>

以上就是本文的全部内容，希望对大家的学习有所帮助。

内容总结

以上是互联网集市为您收集整理的基于node实现websocket协议全部内容，希望文章能够帮你解决基于node实现websocket协议所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/353013.html

来源：【匿名】

【上一篇】下雪了 javascript实现雪花飞舞【下一篇】javascript 怎么调用php方法

更多 ►

【基于node实现websocket协议】教程文章相关的互联网学习教程文章

javascript中WebSocket用法【代码】【图】

一.概念websocket定义WebSocket是html5提供的一种在单个TCP连接上进行双向通信的协议，解决了客户端和服务端之间的实时通信问题。浏览器和服务器只需完成一次握手，两者之间就可以创建一个持久性的TCP连接，此后服务器和客户端通过此TCP连接进行双向实时通信。websocket优点很多网站为了实现数据推送，所用的技术都是ajax轮询。轮询是在特定的时间间隔，由浏览器主动发起请求，将服务器的数据拉回来。轮询需要不断的向服务器发送请...

实现 WebSocket 断开自动重连的 JavaScript 库【代码】

ReconnectingWebSocket 是一个小型的 JavaScript 库，封装了 WebSocket API 提供了在连接断开时自动重连的机制。只需要简单的将：ws = new WebSocket(‘ws://....‘);替换成：ws = new ReconnectingWebSocket(‘ws://....‘); 详见：https://github.com/fc653074701/reconnecting-websocket 或者： //间隔发送心跳包数据给服务器，服务器在一定时间内发回心跳包响应，对比超时限定，如果超过设定的超时时间，则认为当前与服务器的...

javascript-通过js用websocket连接打印机进行打印问题

通过js 用websocket 连接打印机进行打印，已知打印机的端口是默认开的，通过PHP代码 $s = fsockopen("192.168.1.122", 8081,$errno, $errstr, 30);fwrite($s,"abcjiuejseeeeeeeee2222222222ss"); 这样打印是可以的，但通过JS的websocket连接就只打印头信息，是什么情况？ js 代码是： ws = new WebSocket("ws://192.168.1.122:8081/"); console.log(ws); ws.onopen = function (e) {console.log(e);console.log("连接成功");ws.se...

javascript-Websocket服务器端用PHP怎么配置？

在网上搜了很多，有些不能用，有些看不懂。 websocket客户端代码没什么问题，问题就在服务器端php该怎么写？是像ajax那样就行还是需要php socket? 求解！回复内容：在网上搜了很多，有些不能用，有些看不懂。 websocket客户端代码没什么问题，问题就在服务器端php该怎么写？是像ajax那样就行还是需要php socket? 求解！不一定非要用php，php不擅长做这个,可以试一下 socket.io一个Redis的Web代理服务器Webdis? http://www.qixing...

javascript-浏览器中使用websocket有什么好的库？

要支持IE8以上的。网上一搜都是socket.io但是这个也好配合node.js使用。我的服务端使用的是php。回复内容：要支持IE8以上的。网上一搜都是socket.io但是这个也好配合node.js使用。我的服务端使用的是php。PHP写WebSocket需要自己处理原始数据，前端库本质上只是一种常用方法的封装，socket.io就可以。WebSocket是HTML5 API，是内置在浏览器内部的高级特性，IE8绝对不支持，而且客户端javascript也没有牛逼到可以自定义协议的地步...

javascript-websocket如何部署？

碰到的问题如下：静态页面地址192.168.8.79websocket server地址192.168.8.78:9876 于是静态页面想与websocket连接，却碰到浏览器chrome不能跨域访问websocket.回复内容：碰到的问题如下：静态页面地址192.168.8.79websocket server地址192.168.8.78:9876 于是静态页面想与websocket连接，却碰到浏览器chrome不能跨域访问websocket.可以让你的前端(比如nginx)做代理访问你的192.168.8.78:9876。nginx反代是实现跨域最简单的方法

javascript-websocket与EventSource的区别在哪里？作为wordpress主题使用，哪个更利好？

wordpress主题中需要一个消息通知服务，我就半吊子水平，各路大神来指点一二。websocket与EventSource的区别在哪里，在WP主题的场景中哪个更利用，比如PHP服务器的部署，比如json之类的数据格式？或者是jquery写个短轮询。回复内容：wordpress主题中需要一个消息通知服务，我就半吊子水平，各路大神来指点一二。websocket与EventSource的区别在哪里，在WP主题的场景中哪个更利用，比如PHP服务器的部署，比如json之类的数据格式？或...

javascript-怎么配置WebSocket服务器，用的SegmentFault

rt想用websocket代替轮询请问怎么配置websocket服务器回复内容：rt想用websocket代替轮询请问怎么配置websocket服务器PHP自身并没有提供WebSocket相关函数,这个你得用第三方扩展,比如峰哥的用C开发的PECL扩展Swoole,里面直接就封装有WebSocket Server,比如官网的示例:http://www.swoole.com/ on('Open', function($server, $req) {echo "connection open: ".$req->fd; }); $serv->on('Message', function($server, $frame) {echo "...

javascript-WebSocket如何向指定页面推送

已经把PHP的WebSocket框架Demo跑起来了(workerman -> web-msg-sender) 现在遇到个问题，就是如何像指定页面推送信息。比如每个用户的首页，和每个用户的收藏列表页，和一些公共的商品列表页，这些页面价格都是实时更新的。目前我想到的方法是： 1、当商品价格被执行更新后，从表中取出对应的商品信息 2、公共页：如首页，商品列表页；后台指定推送URL为这些页面，推送刚刚更新的商品ID和价格。JS获取后判断当前页面是否存在推送的...

javascript-php和websocket怎么建立连接

H5的WebSocket 怎么和服务端建立连接，网上找了几个例子都不好使，具体应该怎么做回复内容：H5的WebSocket 怎么和服务端建立连接，网上找了几个例子都不好使，具体应该怎么做个人理解的是1、了解websocket的协议和请求规范；2、使用PHP的socket函数库来处理websocket的请求；3、处理websocket的数据帧。下面是我写的一个小例子，里面的注释我觉得也挺详细的了，对帧的处理我没有完善，处理41字节以上的内容，要了解各种字处理。。。...

关于WebSocket的那些事儿

众所周知传统的http协议是客户端（浏览器）发送请求，浏览器响应请求的方式，一条请求对应一条响应。若浏览器不主动请求则服务端无法想客户端主动推数据。传统的方式是使用AJAX轮询（这个方式有它的问题）来解决这一问题后面展开讲。应用场景列举几个应用场景：网络聊天室多人在线游戏网站向页面实时推送广告、消息在线实现对控制设备的控制前面三个应用场景已经有很多大佬讲过了，我就不讲了，这里主要简单分析一下第四个应用场景...

WebSocket如何使用【图】

WebSocket是一种允许通过保持服务器端和用户端始终连接来进行双向通信的技术，这使得可以实时通信，例如聊天应用程序和多人可以同时玩的游戏。但是，由于还需要服务器端的程序，本篇文章我们将重点介绍前端的JavaScript中的WebSocket。我们先来看一下WebSocket的基本用法。为了能够使用带有JavaScript的WebSocket，首先要创建实例。var connection = new WebSocket(【进行通信的URL】);通过new一个WebSocket来创建实例。指定为参数...

如何使用WebSocket发送和接收数据【图】

WebSocket是一种允许通过保持服务器端和用户端始终连接来进行双向通信的技术，所以WebSocket既可以发送数据也可以接收数据，本篇文章我们就来看看如何使用WebSocket发送和接收数据。我们先来看一下如何发送文本数据？使用免费提供的echo.websocket.org作为样本具体示例如下var connection = new WebSocket(wss://echo.websocket.org);connection.send(样本数据);在此示例中，以看到正在创建WebSocket实例并使用send()方法发送数据。...

在nodejs中如何实现websocket通信功能

这篇文章主要介绍了nodejs结合socket.io实现websocket通信功能的方法,结合实例形式分析了nodejs结合socket.io实现websocket通信的具体步骤与相关操作技巧,需要的朋友可以参考下本文实例讲述了nodejs结合socket.io实现websocket通信功能的方法。分享给大家供大家参考，具体如下：因为项目中有需要实时获取后台数据的场景，之前一直是使用http心跳请求的方法。因为websocket与此模式相比有很大的性能提升，而且可以提高实时性，所以对...

nodejs+websocket案例分析（附代码）

这次给大家带来nodejs+websocket案例分析（附代码），nodejs+websocket案例分析的注意事项有哪些，下面就是实战案例，一起来看一下。服务端（nodejs）：var WebSocketServer = require(ws).Server, wss = new WebSocketServer({ port: 8080 }); wss.on(connection, function (ws) { console.log(client connected); ws.on(message, function (message) {console.log(message); }); });客户端：<script> var ws = new WebSocket("ws...

首页 / JAVASCRIPT / 基于node实现websocket协议

基于node实现websocket协议

内容导读

内容图文

内容总结

内容备注

内容手机端

【基于node实现websocket协议】教程文章相关的互联网学习教程文章

WEBSOCKET - 相关标签

NODE - 相关标签

协议 - 相关标签

JAVASCRIPT - 技术教程分类

JAVASCRIPT - 最新教程

JAVASCRIPT - 最热教程