实时通讯Socket.io:Socket.io 进阶篇

前言

在入门篇中,我们学习了如何创建一个简单的socket服务器,并实现客户端和服务端的通讯。但是在生产环境中,显然这样简单的功能是不够的,所幸socket.io提供很多有趣的功能,来帮助我们将想法变成实际。

进阶篇主要主要关注两个方面。

第一,讲解socket.io提供的进阶功能。 第二,结合使用场景,通过进阶功能来实现需求。

发送信息

socket.io既然是用来实现通讯的,那么如何发送、接收信息才是根本。

在socket.io中,emit函数用于发送数据,还记得在入门篇中,我们使用send的方式实现了信息的互发,其实send函数只是emit的封装,实际上还是使用了emit,且看send函数是如何实现的:

function send(){
  var args = toArray(arguments);
  args.unshift('message');
  this.emit.apply(this, args);
  return this;
}

在send函数中,获取到原来的参数,并在原来的基础上插入了一个参数message,然后调用了emit函数。通过send函数的实现,我们也学会了emit函数的用法,它有连个参数,第一个参数是事件名称,在接收端注册该事件就可以接收到发送过去的信息,事件名称可以自由定义,在不同的场景下,我们可以定义不同的事件来接收消息。第二个参数才是发送的数据。了解清楚了工作原理,下面来将send替换成emit函数发送信息:

//app.js
io.on('connection',function(socket){
     socket.emit('message','连接成功!');
     socket.on('message',function(data){
    });
});

服务端事件

事件监听是实现通讯的基础,因此充分了解socket.io的事件,学习如何在正确的时候使用它们至关重要。在一些关键的的状态下,socket.io可以注册相应的事件,通过事件监听,我们可以在这些事件中作出反应,常用的事件如下:

客户端

较服务端而言,客户端提供更多的监听事件,在实时应用中,我们可以为这些事件注册监听并作出反应,例如:connect提示用户连接成功,disconnect时提示用户停止服务等等。

那么客户端socket发起连接时的顺序是怎么样的呢?当第一次连接时,事件触发顺序为: connecting → connect;

当失去连接时,事件触发顺序为:disconnect → reconnecting → connecting → reconnect → connect。

命名空间

命名空间着实是一个非常实用好用的功能。我们可以通过命名空间,划分出不同的房间,在房间里的广播和通信都不会影响到房间以外的客户端。

那么如何创建房间呢?在服务端,通过of("")的方式来划分新的命名空间:

io.of('chat').on('connection',function(socket){

});

示例中,我们创建一个名为chat的房间,客户端可以通过如下方式连接到指定的房间:

var socket = io.connect('/chat');

虽然连接到指定的房间,但是我们也可以在服务端操作,自由的进出房间:

socket.join('chat');//进入chat房间
socket.leave('chat');//离开chat房间

广播消息

在实时应用中,广播是一个不可或缺的功能,socket.io提供两种服务端广播方式。

第一种广播方式可以称之为'全局广播',顾名思义,全局广播就是所有连接到服务器的客户端都会受到广播的信息:

socket.broadcast.emit('DATA',data);

但是,在实际应用场景中,我们很多时候并不需要所有用户都收到广播信息,有的广播信息只发送给一部分客户端,比如某个房间里面的用户,那么可以使用如下方式:

socket.broadcast.to('chat').emit('DATA',data);

当使用to()的方式广播信息时,只有该命名空间下的客户端才会收到广播信息,是不是很方便呢。

中间件

socket.io提供中间件功能,我们可以通过中间件来对请求进行预处理,比如身份验证:

io.use(function(socket, next){
  if (socket.request.headers.cookie) return next();
  next(new Error('Authentication error'));
});

示例中展示了通过中间件进行身份验证,当没有cookie的时候抛出异常。

传递参数

在很多应用场景中,客户端发起连接请求时都需要传递参数,这些参数可能是身份验证、初始化设置等等,那么socket.io发起连接时如何传递参数呢?

var socket = io.connect('/');

由于connect函数发起连接的参数是一个url,你可能会想到把参数拼接到url上,如http://xxxx?xx=xxxx,但是很遗憾这样是行不通的,我们可以通过这样的方式来传递参数:

var socket = io.connect('/',{ _query:'sid=123456' });

在服务端可以这样获取到传递的参数:

io.use(function(socket){
     var query = socket.request._query;
     var sid = query.sid; 
});

客户端传递的参数已经被解析成了一个json对象,这个对象就是_query。

课程小结

本节课程为大家讲解了socket.io的一些进阶功能,这些功能基本上已经能够满足我们的开发需求了。

当然socket.io的功能不仅仅只有这些,本课程只是抛砖引玉,更多细节、深入的问题欢迎大家一起参与讨论,如果有什么问题或建议欢迎使用'问题留言'发送给我们,我们会在第一时间处理。

谢谢支持!

全部评论(0)