转载自: http://youngcold.blog.51cto.com/6366865/1241795
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,
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打印出来,对比
发现确实创建的channel没有了,到底是怎么回事?
再比较,就会发现还有一个不同之处。
你会发现,登陆和聊天时所在的服务器不一样,难怪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
相关推荐
美国商业的崛起始于第二次工业革命,福特公司1908年批量生产Model T汽车,开启了大规模生产的新纪元。美国在短短几十年内迅速成为世界最强的工业国家,这得益于其创新精神、开放市场以及对新技术的接纳。 进入21...
#资源达人分享计划#
简析管理会计在中小企业的经营管理优化作用——以新能源企业为例.pdf
【标题解析】:“制胜之策——应对高值医用耗材带量采购政策(税务篇)”这个标题表明,文档主要关注的是医疗行业中高值医用耗材的带量采购政策,特别是从税务角度进行的分析。高值医用耗材通常指的是在医疗服务中...
【企业分配20策——简析立体薪酬体系】 在当今社会,改革收入分配制度和规范收入分配秩序成为了高层关注的重点。随着经济的高速发展,我国现有的薪酬体系已经无法满足企业和员工的需求,亟需改革以适应社会主义初级...
【PHP+新浪微博开放平台+新浪云平台(SAE)开发微博应用——PHP SDK中Demo程序简析】 在本文中,我们将探讨如何使用PHP与新浪微博开放平台以及新浪云平台(SAE)来构建微博应用,主要关注PHP SDK中的Demo程序。这个...
宏观经济修复持续向好——2020年8月宏观经济运行简析-2020.8-7页精品报告2020.pdf
第三代半导体材料主要以氮化镓(GaN)和碳化硅(SiC)为主,其性能上的优越性——包括较宽的禁带宽度、较高的击穿电场、更快的电子迁移速率、更高的热导率以及良好的化学稳定性和抗辐射能力——使得它们在满足5G通信...
新世纪评级-我国经济运行恢复明显——2020年4月宏观经济运行简析-2020.5-5页精品报告2020.pdf
《石油化工企业在役装置的又一种安全评价方法——美国达信风险评价简析》这篇文档主要探讨了美国达信(Dowson)公司的风险评价方法在石油化工企业中的应用,旨在为国内企业提供一种有效的安全评估工具,以提升在役...
总的来说,苹果公司之所以成功,是因为其不断在产品创新、用户体验和技术支持方面进行投入和改进。其产品特点包括极简而优雅的设计,强大的硬件性能,稳定的操作系统和丰富的软件生态,以及对多媒体处理的高度重视。...
传统的T&L(Transform and Lighting,变换与光照)数据处理任务现在完全由顶点处理器承担,T&L Unit被整合到顶点处理器中,这是第三代GPU的重要特性之一。 在像素着色方面,第二代GPU的Pixel Shader仅支持INT数据...
第二代GPU,如NV2X系列(GeForce3/4 Ti)、R2X系列(Radeon 8500)等,具备了硬件级别的可编程Shader运算能力。可编程Shader分为Vertex Shader(顶点着色器)和Pixel Shader(像素着色器)两部分。 Vertex Shader...
Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战Java中的泛型简析实战...
本文将探讨数字化制造的核心支撑技术——工艺数据结构化技术,并对其进行简要分析。 首先,我们需要了解工艺数据的定义及其在制造执行中的重要性。工艺数据是指在产品制造过程中产生的数据,这些数据包括但不限于...
GPU,全称为Graphic Processing Unit,即图形处理器,自1999年8月31日诞生以来,已经成为计算机图形处理领域的重要角色。它的主要任务是对计算机图形进行各种运算,包括顶点设置、光影处理、像素操作等。...
首先,关于“高速”,4G网络的高速特性是其区别于之前3G网络的最大亮点之一。它能够提供比3G更高的数据传输速率,从而支持更高质量的视频通话、流媒体服务、快速网页加载等。4G网络的实现依赖于高级的无线通信技术...