websocket
websocket 必须要先安装package.json HTTP和WebSocket两者的差距不大 浏览网页时，经过三个过程 1、浏览器经过三次握手与web服务器建立链接， 2、web服务器返回响应 3、浏览器通过四次握手主动断开链接 因为第三步导致不能持久链接，那我们去掉第三步不就可以了实现持久链接了吗？这就是WebSocket与HTTP最大的不同（Web服务器是不会主动断开连接的），当然还有更多的数据封装格式的不同。 可以看到WebSocket是在HTTP上做的改动，有人曾经用单片机的TCP/IP协议栈封装符合HTTP协议格式的字符串，去连接Web服务器。WebSocket和HTML5没有多大关系。 如果要搭建一个Web服务器，我们会有很多选择，市场上也有很多成熟的产品供我们应用，比如开源的Apache，安装后只需简单的配置（或者默认配置）就可以工作了。但是如果想搭建一个WebSocket服务器就没有那么轻松了，因为WebSocket是一种新的通信协议，目前还是草案，没有成为标准，市场上也没有成熟的WebSocket服务器或者Library实现WebSocket协议，我们就必须自己动手写代码去解析和组装WebSocket的数据包。要这样完成一个WebSocket服务器，估计所有的人都想放弃，幸好的是市场上有几款比较好的开源库供我们使用，我们可以调用这些接口，这在很大程度上减少了我们的工作量。 百万websocket常连接的服务器 Netty服务器 Spray服务器 Undertow服务器 node.js //----------------------------------------------- Websocket协议之握手连接 一、协议包含两个部分，第一个是“握手”，第二个是数据传输。 ws://127.0.0.1:8080 wss://127.0.0.1:8080 二、握手（Opening > Closing Handshake）打开连接 1、发送握手请求 GET /chat HTTP/1.1 Host: server.example.com Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ== Origin: http://example.com Sec-WebSocket-Protocol: chat, superchat Sec-WebSocket-Version: 13 2、返回握手应答 HTTP/1.1 101 Switching Protocols Upgrade: websocket Connection: Upgrade Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo= Sec-WebSocket-Protocol: chat 3、错误处理 所有数据传输都是UTF-8编码的数据，当一端接收到的字节流数据不是一个有效的UTF-8数据流，那个么接收到的这一方必须要马上关闭连接。这个规则在开始握手一直到所有的数据交换过程都要进行验证。
//--------------------------socket.io------------------------------------ Socket.io
node.js提供了高效的服务端运行环境，但是由于浏览器端对HTML5的支持不一，为了兼容所有浏览器，提供卓越的实时的用户体验，并且为程序员提供客户端与服务端一致的编程体验，于是socket.io诞生。Socket.io将Websocket和轮询 （Polling）机制以及其它的实时通信方式封装成了通用的接口，并且在服务端实现了这些实时机制的相应代码。也就是说，Websocket仅仅是 Socket.io实现实时通信的一个子集。那么，Socket.io都实现了Polling中的那些通信机制呢？
Adobe® Flash® Socket AJAX long polling AJAX multipart streaming Forever Iframe JSONP Polling
创建项目，文件夹下创建package.json文件
{ "name": "socket", "version": "0.0.1", "description": "myproject", "dependencies": {} }
安装net
G:\www\nodejs\socket>npm install net --save-dev
SocketServer.js
var net = require('net');
var chatServer = net.createServer(),
clientList = [];
clientMap=new Object();
var ii=0;
chatServer.on('connection', function(client) {
// JS 可以为对象自由添加属性。这里我们添加一个 name 的自定义属性，用于表示哪个客户端（客户端的地址+端口为依据）
client.name = client.remoteAddress + ':' + client.remotePort;
client.write('Hi ' + client.name + '!\n');
clientList.push(client);
client.name=++ii;
clientMap[client.name]=client;
client.setEncoding('utf-8');
//超时事件
client.setTimeout(timeout, function(){
console.log('连接超时');
client.end();
});
client.on('data', function(data) {
console.log('客户端传来:'+data);
//client.write('你发来:'+data);
broadcast(data, client); // 接受来自客户端的信息
});
//数据错误事件
client.on('error', function(exception){
console.log('client error:' + exception);
client.end();
});
//客户端关闭事件
client.on('close', function(data){
delete clientMap[client.name];
console.log(client.name+'下线了');
broadcast(client.name+'下线了', client);
});
});
function broadcast(message, client) {
for(var key in clientMap){
clientMap[key].write(client.name+'say:'+message+'\n');
}
}
chatServer.listen(9000);
4. SocketClient.js
var net = require('net');
var port = 9000;
var host = '127.0.0.1';
var client= new net. Socket();
client.setEncoding('UTF-8');
//client.setEncoding('binary');
//连接到服务端
client.connect(port, host, function(){
client.write('你好');
});
client.on('data', function(data){
console.log('服务端传来:'+ data);
say();
});
client.on('error', function(error){
console.log('error:'+error);
//client.destory();
});
client.on('close', function(){
console.log('Connection closed');
});
//----------------------------------------------------------
const readline = require('readline');
const rl = readline.createInterface({
input: process.stdin,
output: process.stdout
});
function say(){
rl.question('请输入： ', (inputStr) => {
if(inputStr!='bye'){
client.write(inputStr+'\n');
say();
}else{
client.destroy(); //关闭连接
rl.close();
}
});
}基本上用在手机，电脑端用的比较少 WS模块
要支持websocket的浏览器才能用
socket.io
socket.io包含websocket 安装socket.io G:\www\nodejs\socket>npm install "socket.io" --save-dev
安装Express
G:\www\nodejs\socket>npm install express --save-dev
创建服务端SocketIoServer.js
最后更新于
这有帮助吗？