文档章节

chatofpomelo简析之二——聊天

piggybear
 piggybear
发布于 2015/02/16 10:28
字数 1666
阅读 11
收藏 0
点赞 0
评论 0

上一篇ChatofPomelo简析之一——用户登录分析客户端登陆的过程。当用户登陆成功后,聊天又是个什么过程呢?下面就来分析聊天时,客户端与服务器端的交互过程。

客户端

我们先来看看下,聊天发送消息的过程。当用户在文本框内输入文字,并回车就可以发送消息了

   1: $("#entry").keypress(function (e) {
   2:var route = "chat.chatHandler.send";
   3:var target = $("#usersList").val();
   4:if (e.keyCode != 13 /* Return */) return;
   5:var msg = $("#entry").attr("value").replace("\n", "");
   6:if (!util.isBlank(msg)) {
   7:             pomelo.request(route, {//route = "chat.chatHandler.send"
   8:                 rid: rid,
   9:                 content: msg,
  10:                 from: username,
  11:                 target: target
  12:             }, function (data) {
  13:                 $("#entry").attr("value", ""); // clear the entry field.
  14:if (target != '*' && target != username) {
  15:                     addMessage(username, target, msg);
  16:                     $("#chatHistory").show();
  17:                 }
  18:             });
  19:         }
  20:     });

#1:entry就是聊天文本框的id了,当焦点在entry(就用id来代表控件了),每次按下键盘都会触发keypress()方法,方法接受一个事件e

#2:route,决定客户端向服务器端的哪个方法发送请求。

#3:target,entry的上方有个名为users的下拉框,target就是下拉框的值了,决定用户向谁发送消息。

#4-#5:对输入的字符判断,如果不是回车就返回,如果是回车就将entry中的换行符替换成空字符串

#6:util是client.js定义的一个对象,里面包含了一些对字符的处理方法,其中isBlank()是判断字符串是否是空字符串

#7:如果不是空字符串,就将这条消息发送给服务器,route就是#2所定义的服务器的处理方法 chat.chatHandelr.send

#8-#11:客户端将用户所在的channel,发送的消息了,用户名以及发送消息的对象封装成对象,发送给服务器




#12:定义回调函数,处理服务器返回的结果对象data

#13:清空entry

#14:根据发送的对象判断是否将发送的添加到聊天记录中

#15:在聊天记录(id=chatHistory)显示


服务器端

接下来,在看服务器端收到客户端发送的请求是怎么处理的。打开chatofpomelo\game-server\app\servers\chat\handler\chatHandler.js

找到handler.send

   1: handler.send = function(msg, session, next) {
   2:var rid = session.get('rid');
   3:var username = session.uid.split('*')[0];
   4:var channelService = this.app.get('channelService');
   5:var param = {
   6:         route: 'onChat',
   7:         msg: msg.content,
   8:         from: username,
   9:         target: msg.target
  10:     };
  11:     channel = channelService.getChannel(rid, false);
  12:
  13://the target is all users
  14:if(msg.target == '*') {
  15:         channel.pushMessage(param);
  16:     }
  17://the target is specific user
  18:else {
  19:var tuid = msg.target + '*' + rid;
  20:var tsid = channel.getMember(tuid)['sid'];
  21:         channelService.pushMessageByUids(param, [{
  22:             uid: tuid,
  23:             sid: tsid
  24:         }]);
  25:     }
  26:     next(null, {
  27:         route: msg.route
  28:     });
  29: };

#1:解释下参数 msg就是客户端发送的对象,session就是服务器端与当前用户的会话,next相当于把结果发送给客户端 PS:next的真正功能我也描述不清,还请各位指点。

#2-#3:从session中取得roomID(rid)和用户名usernmae,chatofpomelo\game-server\app\servers\connector\handler\entryHandler.js的enter()方法有对于session的设置

#4:获取ChannelService(管理Channel)

#5-#10:把发送的信息,用户名和发送信息的对象以及route。这里的route:onChat由服务器端定义的,客户端监听。每个客户端都会监听onXXX事件,监听服务器发送的消息。这样用户发送的消息才能由服务器发送给其他用户。

#11:根据用户发送的rid,获取对应的channel

#14-#25:判断发送对象,是广播还是发送给特定用户。

#26-28:将结果返回给客户端

其实,分析这么多代码,前面我写的很详细,后面就写的简略了。分析完后可以发现,其实交互部分情况类似,只要弄懂了其中一部分,其余的也就好懂了。

PS:到此,这个demo的雏形就完成了,本来到这结束了……确实,如果你的servers.json里只有一个chat服务器,那么一切流程都可正常运行。但是,如果不只一个chat服务器,那肯定会遇到问题的,是不是信息发不出去,在看服务器端,报错了!!

是不是channel为undefined?看上面的第11行

   1: channel = channelService.getChannel(rid, false);

很抱歉,channelService里并没有channel,你一定很奇怪,当用户登录时,不是创建了channel了吗,怎么会没有呢?

为了验证,我把add和send时的app打印出来,对比

image

发现确实创建的channel没有了,到底是怎么回事?

再比较,就会发现还有一个不同之处。

image

你会发现,登陆和聊天时所在的服务器不一样,难怪channel消失。

其实,聊天和登陆一样,用户在发送消息时,看上面客户端代码的第8行和第10行,会发现客户端不只会发送消息,还会把用户名username和rid同时发送给服务器端。服务器端会根据username和rid,实际上只有rid,判断该用户是位于哪台chat-server上,这就是为什么game-server/app.js会有这几行代码

   1: app.configure('production|development', function () {
   2:// route configures
   3:     app.route('chat', routeUtil.chat);//routes的chat属性对应routeUtil.chat()方法 
   4:     app.filter(pomelo.timeout());
   5: });

#2:当服务器类型是chat,就会把路由到routeUtil.chat方法。

然后在进入该方法,看看是怎么判断用户属于哪个路由器的。

   1: exp.chat = function(session, msg, app, cb) {
   2:
   3:     console.log("uid = " + session.uid + " rid = " + session.get("rid"));
   4:var chatServers = app.getServersByType('chat');//根据类型 获取服务器列表
   5:
   6:if(!chatServers || chatServers.length === 0) {//如果服务器列表不存在或为空,则调用回调函数cb,将错误传给该回调
   7:         cb(new Error('can not find chat servers.'));
   8:return;
   9:     }
  10:
  11:var res = dispatcher.dispatch(session.get('rid'), chatServers);//通过rid获得具体的chat服务器
  12:     console.log("chat服务器:" + res.id);
  13:     cb(null, res.id);
  14: };

#11:之前的代码,相信大家都明白了。我们直接看11行代码,是不是很眼熟?dispatcher好像见过!还记得之前客户端连接gate服务器,然后由gate服务器分配connector服务器,再返回其host和clientPort吗?不错,这里同样是调用该方法,只不过connectors改成了chatServers。这样根据传入的rid,就可判断用户当初登陆的那个chat-server,这样也就能找到对应的channel


疑问:虽然解决了这一问题,但是还是不明白如果不添加对chat的路由,即没有这行代码:

   1: app.route('chat', routeUtil.chat);

是怎么分配chat-server,是随机分配,还是自增分配?

还有就是这句代码是何时被调用的。

希望各位能够指点一下。

参考资料:

Pomelo一周之旅

对于ChannelService的问题

本文出自http://youngcold.blog.51cto.com/6366865/1241795

本文转载自:http://blog.csdn.net/aa294194253/article/details/40888293

共有 人打赏支持
piggybear
粉丝 3
博文 237
码字总数 37552
作品 0
西安
技术主管
ReactiveCocoa 4 文档翻译目录

文/没故事的卓同学(简书作者) 原文链接:http://www.jianshu.com/p/fccba7be1ca1 著作权归作者所有,转载请联系作者获得授权,并标注“简书作者”。 因为决定不再支持iOS7,全面使用Swift...

上官尘 ⋅ 2016/03/02 ⋅ 0

pomelo 分布式聊天入门客户端demo(c#)

## c/s 聊天例子 目的:实现了一个简单的c/s分布式聊天例子,演示了c#客户端和pomelo服务器的交互,使用原生socket通信方式。本来是想用unity3d和pomelo通信,但是unity3d里面处理异步比较麻...

于小懒 ⋅ 2014/03/22 ⋅ 0

OSChina 技术周刊第23期 —— .NET Core 开源更新报告

每周技术抢先看,总有你想要的! 移动开发 【软件】Android 调试工具 Stetho 前端开发 【翻译】25 个超棒的 HTML5 & JavaScript 游戏引擎开发库 【翻译】什么时候 AngularJS 会超越 jQuery 【...

OSC编辑部 ⋅ 2015/03/02 ⋅ 5

OSChina 技术周刊第二十三期 —— 每周技术精粹

每周技术抢先看,总有你想要的! 移动开发 【软件】Android 调试工具 Stetho 前端开发 【翻译】25 个超棒的 HTML5 & JavaScript 游戏引擎开发库 【翻译】什么时候 AngularJS 会超越 jQuery 【...

OSC编辑部 ⋅ 2015/03/02 ⋅ 0

谷歌新产品发布会真正的主角是软件而非硬件

今天,谷歌将发布多款新产品:手机、智能家居中枢、WiFi路由器等。所有这样产品都是用户可以触摸到和拿起来的实体产品。 但不要被有关新产品的宣传蒙蔽了眼睛。 当地时间周二在旧金山举办的这...

王练 ⋅ 2016/10/04 ⋅ 4

180524 简书互联网优质内容推荐日报

【硅谷日常】 Facebook 工作体验小记(一) 作者:MrPeak 【行业创新】 厕所也能共享吗?看新创公司如何发挥创意,让「找厕所」成为有趣新体验 作者:创新拿铁 【开发经验】 【性能优化】今日...

简书大婶 ⋅ 05/24 ⋅ 0

暂停交易?ERC20合约整数溢出安全漏洞案例技术分析(一)

区块链兄弟社区,区块链技术专业问答先行者,中国区块链技术爱好者聚集地 作者:吴寿鹤,《区块链开发实战——以太坊关键技术与案例分析》的第一作者,《区块链开发实战——Hyperledger Fab...

-区块链兄弟- ⋅ 04/27 ⋅ 0

[推荐]开源软件架构

这本书原先只有英文版,现在图灵这里有中文版的了,写的真好 http://www.ituring.com.cn/minibook/19 前言(卷一) 卷1:第1章 Asterisk 卷1:第3章 The Bourne-Again Shell 卷1:第4章 Berk...

难易 ⋅ 2013/11/23 ⋅ 4

QT,在A线程中循环创建N个B线程,经测试,这N个B线程执行完毕之后不会发送finished信号,程序也不会析构它们,何解?

QT,在A线程中循环创建N个B线程,经测试 这N个B线程执行完毕之后不会发送finished信号,程序也不会析构它们,何解? 下面用伪代码表示吧,代码可能不对,但我做的程序是想这样来实现的 先构建...

hookover ⋅ 2014/07/20 ⋅ 10

基数排序简析

基数排序是一种适用于特定数据类型的内部排序算法。这种排序算法要求数据必须能够划分为多个排序关键字,且这些排序关键字应该有优先级的区别。比如某个序列的数据都是整数,且取值范围在[0,...

刘地 ⋅ 2015/03/15 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

聊聊spring cloud gateway的LoadBalancerClientFilter

序 本文主要研究一下spring cloud gateway的LoadBalancerClientFilter GatewayLoadBalancerClientAutoConfiguration spring-cloud-gateway-core-2.0.0.RELEASE-sources.jar!/org/springfram......

go4it ⋅ 25分钟前 ⋅ 0

详解:Nginx反代实现Kibana登录认证功能

Kibana 5.5 版后,已不支持认证功能,也就是说,直接打开页面就能管理,想想都不安全,不过官方提供了 X-Pack 认证,但有时间限制。毕竟X-Pack是商业版。 下面我将操作如何使用Nginx反向代理...

问题终结者 ⋅ 32分钟前 ⋅ 0

002、nginx配置虚拟主机

一、nginx配置虚拟主机可分为三种方式,分别为: 1、基于域名的虚拟主机,通过域名来区分虚拟主机——应用:外部网站 2、基于端口的虚拟主机,通过端口来区分虚拟主机——应用:公司内部网站...

北岩 ⋅ 35分钟前 ⋅ 0

shell脚本之死循环写法

最近在学习写shell脚本,在练习if while等流程控制时,突然它们的死循环写法是怎么样的?经过百度与亲测记录如下: for死循环 #! /bin/bashfor ((;;));do date sleep 1d...

hensemlee ⋅ 37分钟前 ⋅ 0

苹果的ARKit2.0有多可怕,看了就知道

序言 ARKit主要由三部分组成: 跟踪(Tracking) 跟踪是ARKit的核心组件之一,其提供了设备在物理世界中的位置与方向信息,并对物体进行跟踪,如人脸。 2.场景理解(Scene Understanding) 场...

_小迷糊 ⋅ 38分钟前 ⋅ 0

5.1 vim介绍 5.2 vim移动光标 5.3 ,5.4vim一般模式下移动光标,复制粘贴

vim命令 vim是vi的一个升级版;vim可以显示文字的颜色 安装vim这一个包vim-enhanced 如果不知道安装包,可以使用 命令下面命令来查看vim命令是那个包安装的。 [root@linux-128 ~]# yum prov...

Linux_老吴 ⋅ 42分钟前 ⋅ 0

vim一般模式

vim 是什么 vim是什么 ? 在之前接触Linux,编辑网卡配置文件的时候我们用过了vi ,vim简单说就是vi的升级版,它跟vi一样是Linux系统中的一个文本编辑工具。 如果系统中没有vim ,需要安装一...

李超小牛子 ⋅ 49分钟前 ⋅ 0

docker实战

构建企业级Docker虚拟化平台实战 重点剖析虚拟化和云计算概念; 分析Docker虚拟化的概念和原理; 从0开始实战Docker虚拟化平台; 基于Docker构建Nginx WEB服务器和CentOS虚拟机; 基于开源监...

寰宇01 ⋅ 59分钟前 ⋅ 0

vim介绍、vim颜色显示和移动光标、vim一般模式下移动光标、一般模式下复制粘贴剪切

VIM Vim 是 UNIX 文本编辑器 Vi 的加强版本,加入了更多特性来帮助编辑源代码。Vim 的部分增强功能包括文件比较(vimdiff),语法高亮,全面的帮助系统,本地脚本(Vimscript),和便于选择的...

蛋黄Yolks ⋅ 今天 ⋅ 0

springboot+mockito测试controller层遇到的问题

使用MockitoJUnitRunner测试的一个例子,原来报错无法找到bean, 类似的异常如下:createBeanError..... 原因:是因为@Runwith使用了SpringRunner,应该修改为MockitoJUnitRunner 代码如下: ...

writeademo ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部