智能机器人Socket.IO应用小结

近期在繁忙的业务开发中挤了挤时间&＃xff0c;思考是否可以通过“前端”的能力来提升B端产品的效率.

我打算以对话&＃xff08;消息&＃xff09;系统作为切入点&＃xff0c;提升B端体系用户的内部沟通效率&＃xff0c;提高重要公告或软件升级通知的触达率&＃xff0c;让软件使用问题及用户体验反馈形成闭环&＃xff0c;让产品和开发者听到B端用户的声音。

如今的现状是各种沟通群分散&＃xff0c;一会儿拉个微信群一会儿拉个钉钉群&＃xff0c;而B端的APP则是触及B端所有用户的APP&＃xff0c;我们为什么不直接通过它来提升效率呢&＃xff1f;另一方面&＃xff0c;公司的数据信息也更为可控。

嗯&＃xff0c;说做就做&＃xff0c;我自己对聊天系统也是比较感兴趣的&＃xff0c;大半年前在原来的部门时因业务需要自己搞了个小Demo&＃xff0c;现在被繁重的业务开发埋没了?&＃xff0c;争取早日能转成一名Node开发者&＃xff0c;Leader看到我这篇文章是否考虑让我转个行?。

目前项目在开发中&＃xff0c;在后续的文章分享中会给大家一篇详尽的设计思路&＃xff0c;先给大家留个悬念&＃xff1a;

服务端技术栈&＃xff1a;Nest.js &＃43; TypeScript &＃43; TypeOrm&＃xff1b;
B端&＃xff1a;React Native&＃xff1b;
通知公告管理当然少不了Web端&＃xff0c;暂定了不起的React。

本篇文章还是来简单介绍下Socket.IO的基本API吧。

原来的文章笔记?记录于&＃xff1a;es8.es/post/Socket…

~~实战作品智能机器人~~ 小Demo&＃xff1a;es7.es

网友们搞笑的提问记录可以从这里查看&＃xff1a;es7.es/websocket/l…。

Demo很粗糙&＃xff0c;大家轻喷。

服务端

监听客户端连接&＃xff0c;回调函数会传递本次连接的socket对象

io.on(&＃39;connection&＃39;, function(socket){});

给所有客户端广播消息

io.sockets.emit(&＃39;key&＃39;, data);

给指定的客户端发送消息

io.sockets.socket(socketid).emit(&＃39;key&＃39;, data);

监听客户端发送的消息

socket.on(&＃39;key&＃39;, function(data) {});

给该socket的客户端发送消息

socket.emit(&＃39;key&＃39;, data);

广播消息

给除了自己以外的客户端广播消息

socket.broadcast.emit(&＃39;key&＃39;, {data: &＃39;everyone&＃39;});

给所有客户端广播消息 io.sockets.emit(&＃39;key&＃39;, {data: &＃39;all&＃39;});

分组

socket.on(&＃39;group1&＃39;, function (data) {socket.join(&＃39;group1&＃39;); }); socket.on(&＃39;group2&＃39;, function (data) {socket.join(&＃39;group2&＃39;); });

客户端发送

加入group1分组

socket.emit(&＃39;group1&＃39;);

加入group2分组

socket.emit(&＃39;group2&＃39;);

一个客户端可以存在多个分组&＃xff08;订阅模式&＃xff09;

踢出分组

socket.leave(data.room);

对分组中的用户发送消息

不包括自己

socket.broadcast.to(&＃39;group1&＃39;).emit(&＃39;key&＃39;, data);

包括自己

io.sockets.in(&＃39;group1&＃39;).emit(&＃39;key&＃39;, data);

获取连接的客户端socket

io.sockets.clients().forEach(function (socket) {console.log(socket); });

获取分组信息

获取所有房间&＃xff08;分组&＃xff09;信息

io.sockets.manager.rooms

获取此socketid进入的房间信息

io.sockets.manager.roomClients[socket.id]

获取particular room中的客户端&＃xff0c;返回所有在此房间的socket实例

io.sockets.clients(&＃39;particular room&＃39;);

另一种分组方式

服务端

io.of(&＃39;/some&＃39;).on(&＃39;connection&＃39;, function (socket) {socket.on(&＃39;test&＃39;, function (data) {socket.broadcasst.emit(&＃39;event_name&＃39;, {});}); });

客户端

var socket &＃61; io.connect(&＃39;ws://localhost:1234/some&＃39;); socket.on(&＃39;event_name&＃39;, function (data) {console.log(data); });

客户端都链接到ws:///localhost:1234 但是服务端可以通过io.of(&＃39;/some&＃39;)将其过滤出来。

另外&＃xff0c;Socket.IO提供了4个配置的API&＃xff1a;io.configure, io.set, io.enable, io.disable。其中io.set对单项进行设置&＃xff0c;io.enable和io.disable用于单项设置布尔型的配置。io.configure可以让你对不同的生产环境&＃xff08;如devlopment&＃xff0c;test等等&＃xff09;配置不同的参数。

客户端

建立一个socket连接

var socket &＃61; io("ws://localhost:1234");

监听服务消息

socket.on(&＃39;msg&＃39;, function (data) {// 向服务器发送消息socket.emit(&＃39;msg&＃39;, {}); });

监听socket断开与重连

socket.on(&＃39;disconnect&＃39;, function() {console.log("与服务其断开"); });socket.on(&＃39;reconnect&＃39;, function() {console.log("重新连接到服务器"); });

客户端socket.on()监听的事件&＃xff1a;

connect&＃xff1a;连接成功 connecting&＃xff1a;正在连接 disconnect&＃xff1a;断开连接 connect_failed&＃xff1a;连接失败 error&＃xff1a;错误发生&＃xff0c;并且无法被其他事件类型所处理 message&＃xff1a;同服务器端message事件 anything&＃xff1a;同服务器端anything事件 reconnect_failed&＃xff1a;重连失败 reconnect&＃xff1a;成功重连 reconnecting&＃xff1a;正在重连

当第一次连接时&＃xff0c;事件触发顺序为&＃xff1a;connecting->connect&＃xff1b;
当失去连接时&＃xff0c;事件触发顺序为&＃xff1a;disconnect->reconnecting&＃xff08;可能进行多次&＃xff09;->connecting->reconnect->connect。