chatofpomelo简析之二——聊天

上一篇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,monospace; overflow:auto; width:702px; border-style:none"> 11:                 target: target
 12:             },255)">function (data) {
 13:                 $("value",128)">""); // 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) {
var rid = session.get('rid');
var username = session.uid.split('*')[0];
var channelService = this.app.get('channelService');
var param = {
  6:         route: 'onChat',96)">  7:         msg: msg.content,96)">  8:         from: username,96)">  9:         target: msg.target
 10:     };
 11:     channel = channelService.getChannel(rid,255)">false);
 12:
 13://the target is all users
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,monospace; overflow:auto; width:702px; border-style:none"> 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打印出来,对比

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

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

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

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

1: app.configure('production|development',255); font-size:14px">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-server,是随机分配,还是自增分配?

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

希望各位能够指点一下。

参考资料:

Pomelo一周之旅

对于ChannelService的问题

本文出自http://www.jb51.cc/article/p-tvqxhpsj-dw.html

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


    本文实践自 RayWenderlich、Ali Hafizji 的文章《How To Create Dynamic Textures with CCRenderTexture in Cocos2D 2.X》,文中使用Cocos2D,我在这里使用Cocos2D-x 2.1.4进行学习和移植。在这篇文章,将会学习到如何创建实时纹理、如何用Gimp创建无缝拼接纹
Cocos-code-ide使用入门学习地点:杭州滨江邮箱:appdevzw@163.com微信公众号:HopToad 欢迎转载,转载标注出处:http://blog.csdn.netotbaron/article/details/424343991.  软件准备 下载地址:http://cn.cocos2d-x.org/download 2.  简介2.1         引用C
第一次開始用手游引擎挺激动!!!进入正题。下载资源1:从Cocos2D-x官网上下载,进入网页http://www.cocos2d-x.org/download,点击Cocos2d-x以下的Download  v3.0,保存到自定义的文件夹2:从python官网上下载。进入网页https://www.python.org/downloads/,我当前下载的是3.4.0(当前最新
    Cocos2d-x是一款强大的基于OpenGLES的跨平台游戏开发引擎,易学易用,支持多种智能移动平台。官网地址:http://cocos2d-x.org/当前版本:2.0    有很多的学习资料,在这里我只做为自己的笔记记录下来,错误之处还请指出。在VisualStudio2008平台的编译:1.下载当前稳
1.  来源 QuickV3sample项目中的2048样例游戏,以及最近《最强大脑》娱乐节目。将2048改造成一款挑战玩家对数字记忆的小游戏。邮箱:appdevzw@163.com微信公众号:HopToadAPK下载地址:http://download.csdn.net/detailotbaron/8446223源码下载地址:http://download.csdn.net/
   Cocos2d-x3.x已经支持使用CMake来进行构建了,这里尝试以QtCreatorIDE来进行CMake构建。Cocos2d-x3.X地址:https://github.com/cocos2d/cocos2d-x1.打开QtCreator,菜单栏→"打开文件或项目...",打开cocos2d-x目录下的CMakeLists.txt文件;2.弹出CMake向导,如下图所示:设置
 下载地址:链接:https://pan.baidu.com/s/1IkQsMU6NoERAAQLcCUMcXQ提取码:p1pb下载完成后,解压进入build目录使用vs2013打开工程设置平台工具集,打开设置界面设置: 点击开始编译等待编译结束编译成功在build文件下会出现一个新文件夹Debug.win32,里面就是编译
分享一下我老师大神的人工智能教程吧。零基础!通俗易懂!风趣幽默!还带黄段子!希望你也加入到我们人工智能的队伍中来!http://www.captainbed.net前言上次用象棋演示了cocos2dx的基本用法,但是对cocos2dx并没有作深入的讨论,这次以超级马里奥的源代码为线索,我们一起来学习超级马里奥的实
1. 圆形音量button事实上作者的本意应该是叫做“电位计button”。可是我觉得它和我们的圆形音量button非常像,所以就这么叫它吧~先看效果:好了,不多解释,本篇到此为止。(旁白: 噗。就这样结束了?)啊才怪~我们来看看代码:[cpp] viewplaincopyprint?CCContro
原文链接:http://www.cnblogs.com/physwf/archive/2013/04/26/3043912.html为了进一步深入学习贯彻Cocos2d,我们将自己写一个场景类,但我们不会走的太远,凡是都要循序渐进,哪怕只前进一点点,那也至少是前进了,总比贪多嚼不烂一头雾水的好。在上一节中我们建
2019独角兽企业重金招聘Python工程师标准>>>cocos2d2.0之后加入了一种九宫格的实现,主要作用是用来拉伸图片,这样的好处在于保留图片四个角不变形的同时,对图片中间部分进行拉伸,来满足一些控件的自适应(PS: 比如包括按钮,对话框,最直观的形象就是ios里的短信气泡了),这就要求图
原文链接:http://www.cnblogs.com/linji/p/3599478.html1.环境和工具准备Win7VS2010/2012,至于2008v2版本之后似乎就不支持了。 2.安装pythonv.2.0版本之前是用vs模板创建工程的,到vs2.2之后就改用python创建了。到python官网下载版本2.7.5的,然后
环境:ubuntu14.04adt-bundle-linux-x86_64android-ndk-r9d-linux-x86_64cocos2d-x-3.0正式版apache-ant1.9.3python2.7(ubuntu自带)加入环境变量exportANDROID_SDK_ROOT=/home/yangming/adt-bundle-linux/sdkexportPATH=${PATH}:/$ANDROID_SDK_ROOTools/export
1开发背景游戏程序设计涉及了学科中的各个方面,鉴于目的在于学习与进步,本游戏《FlappyBird》采用了两个不同的开发方式来开发本款游戏,一类直接采用win32底层API来实现,另一类采用当前火热的cocos2d-x游戏引擎来开发本游戏。2需求分析2.1数据分析本项目要开发的是一款游
原文链接:http://www.cnblogs.com/linji/p/3599912.html//纯色色块控件(锚点默认左下角)CCLayerColor*ccc=CCLayerColor::create(ccc4(255,0,0,128),200,100);//渐变色块控件CCLayerGradient*ccc=CCLayerGradient::create(ccc4(255,0,0,
原文链接:http://www.cnblogs.com/linji/p/3599488.html//载入一张图片CCSprite*leftDoor=CCSprite::create("loading/door.png");leftDoor->setAnchorPoint(ccp(1,0.5));//设置锚点为右边中心点leftDoor->setPosition(ccp(240,160));/
为了答谢广大学员对智捷课堂以及关老师的支持,现购买51CTO学院关老师的Cocos2d-x课程之一可以送智捷课堂编写图书一本(专题可以送3本)。一、Cocos2d-x课程列表:1、Cocos2d-x入门与提高视频教程__Part22、Cocos2d-x数据持久化与网络通信__Part33、Cocos2d-x架构设计与性能优化内存优
Spawn让多个action同时执行。Spawn有多种不同的create方法,最终都调用了createWithTwoActions(FiniteTimeAction*action1,FiniteTimeAction*action2)方法。createWithTwoActions调用initWithTwoActions方法:对两个action变量初始化:_one=action1;_two=action2;如果两个a
需要环境:php,luajit.昨天在cygwin上安装php和luajit环境,这真特么是一个坑。建议不要用虚拟环境安装打包环境,否则可能会出现各种莫名问题。折腾了一下午,最终将环境转向linux。其中,luajit的安装脚本已经在quick-cocos2d-x-develop/bin/中,直接luajit_install.sh即可。我的lin
v3.0相对v2.2来说,最引人注意的。应该是对触摸层级的优化。和lambda回调函数的引入(嗯嗯,不枉我改了那么多类名。话说,每次cocos2dx大更新。总要改掉一堆类名函数名)。这些特性应该有不少人研究了,所以今天说点跟图片有关的东西。v3.0在载入图片方面也有了非常大改变,仅仅只是