服务端:

1.监听客户端连接:

io.on("connection",socket=>{ });

不分组数据传输:传输对象为当前socket

2.1给该socket所有客户端广播消息

socket.emit("名称",内容);

2.2给该socket除了自己外的所有客户端广播消息

socket.broadcast.emit("名称",内容);

2.3给该socket所有客户端广播消息

socket.emit("名称",内容);

2.4给在game房间内除了自己的其他所有客户端广播消息

socket.broadcast.to(‘game’).emit("名称",内容);

2.5给在game房间内包括自己的所有客户端广播消息

io.sockets.in(‘game’).emit("名称",内容);

3.监听该socket的客户端发送给服务端的消息

socket.on("名称",msg=>{ });

分组数据传输:生成命名空间来管理用户

服务端:

io.sockets.on('connection', function (socket) {

socket.on('firefox', function (data) {

socket.join('firefox');

});

socket.on('chrome',function(data){

socket.join('chrome');

});

});

//emit to 'room' except this socket client

socket.broadcast.to('chrome').emit('event_name', data);

//emit to all socket client in the room

io.sockets.in('chrome').emit('event_name', data)

客户端:

socket.emit('firefox'); //就可以加入 firefox 聊天室

socket.emit('chrome');  //就可以加入 chrome 聊天室

socket连接需要添加权限验证,让已登录用户socket直接连接到服务器上,未登陆的用户无条件拒绝连接

callback 函数有两个参数,第一个为 error ,第二个参数为是否授权bool值,通过授权回调函数应为 callback(null,true) ,其它情况下都为拒绝建立连接。

io.sockets.authorization(function (handshakeData, callback) {

callback(null, true);

}).

websocket是持久化的协议,http是非持久化的协议。

http的1.0协议中一个http连接只有一次request和response;

http的1.1协议中允许一个http连接,存在多次请求和接收数据。

websocket连线过程中,浏览器和服务器只需要做一个握手的动作就形成了一条快速通道,实现两者相互推送数据。

Socket.IO是一个WebSocket库,包括了客户端的js和服务器端的nodejs,它的目标是构建可以在不同浏览器和移动设备上使用的实时应用。

在客户端的话,可以通过<script src="/socket.io/socket.io.js"></script>

或引用socket.io的CDN服务。                      <scriptsrc="http://cdn.socket.io/stable/socket.io.js"></script>

socket.io实现监听:

1.引用socket.io模块,调用listen方法传入端口号即可;

var app = require('express')();

var http = require('http').Server(app);

var io = require('socket.io')(http);

socket.io实现事件注册:

服务端:connection、disconnect、emit

客户端:connect、connecting、disconnect、connect_failed、reconnect、emit

io.on(connection,function(socket){

//连接成功

console.log("socket连接成功")

//断开连接

socket.on('disconnect',function(){

console.log("socket连接断开")

})

})

socket.io提供两种服务端广播方式。参数一:名称;参数二:内容

1.全局广播:socket.broadcast.emit('DATA',data);

2.命名空间广播:socket.broadcast.to('chat').emit('DATA',data)

1.创建对象:var ws = new WebSocket(url,name);

2.发送文本消息:ws.send(msg);

3.接受消息:ws.onmessage = (function(){...})();

4.错误处理:ws.onerror = (function(){...})();

5.关闭连接:ws.close();

var socket;

if(typeof(WebSocket) == "undefined") {

alert("您的浏览器不支持WebSocket");

return;

}

//连接

$("#btnConnection").click(function() {

//实例化WebSocket对象,指定要连接的服务器地址与端口

socket = new WebSocket("ws://192.168.1.2:8888");

//打开事件

socket.onopen = function() {

alert("Socket 已打开");

socket.send("这是来自客户端的消息" + location.href + new Date());

};

//获得消息事件

socket.onmessage = function(msg) {

alert(msg.data);

};

//关闭事件

socket.onclose = function() {

alert("Socket已关闭");

};

//发生了错误事件

socket.onerror = function() {

alert("发生了错误");

}

});

服务端:

1.监听客户端连接 io.on('connection',socket=>{ })

05-26 04:20