首页 > 其他分享 >chatofpomelo简析之二——聊天

chatofpomelo简析之二——聊天

时间:2023-06-04 18:31:29浏览次数:54  
标签:target route chatofpomelo 之二 简析 chat msg rid 客户端


 

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打印出来,对比

chatofpomelo简析之二——聊天_服务器

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

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

chatofpomelo简析之二——聊天_客户端_02

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

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


 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方法。

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


: 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

 



 



 

标签:target,route,chatofpomelo,之二,简析,chat,msg,rid,客户端
From: https://blog.51cto.com/u_2700990/6411718

相关文章

  • 高效稳定的通用增量 Checkpoint 详解之二:性能分析评估
    作者:雷颜菲、夏瑞、俞航翔、梅源|阿里云Flink存储引擎团队摘要:我们在“Flink1.15新功能架构解析:高效稳定的通用增量Checkpoint”【1】一文介绍了通用增量Checkpoint的原理和背后的思考以及执行性能、空间放大等方面的初步测试结果。该功能在Flink1.16中经过优化,已达到生......
  • 算法之二分法、三元表达式、列表生成式、字典生成式(了解)、匿名函数、常见的内置函数
    算法之二分法二分概念二分算法,又称折半查找,即在一个单调有序的集合中查找一个解。每次分为左右两部分,判断解在哪个部分中并调整上下界,直到找到目标元素,每次二分后都将舍弃一半的查找空间。定义and实现:算法就是解决问题的高效办法常见的算法:二分法算法还可以锻炼我们的......
  • 宏 GENERATED_UCLASS_BODY() 与 GENERATED_BODY() 简析
    继承自UE4引擎的类会生成一些宏代码。这此宏代码的作用就是帮助生成构造函数和相关成员函数UCLASS()classSECTION1_APIASUsableActor:publicAActor{ GENERATED_BODY() public: };UCLASS()classSURVIVALGAME_APIASUsableActor:publicAActor{ GENERATED_U......
  • 普加项目管理中间件示例之二:自定义表格列
    自定义表格列示例demo/diyColumns.html上文介绍了标准列,这里介绍一下自定义列。正如标准列是一些预设好的对象,自定义列也是一个对象。支持多种数据类型的列:String、Number、Boolean、Date、Array等支持多种单元格编辑器:TextBox、Spinner、CheckBox、DatePicker、ComboBox、TreeSel......
  • GitlabCI学习笔记之二:GitLabRunner pipeline语法
    1.pipeline语法之语法校验进入项目中,点击CI/CD下pipeline页面中CIint 输入pipeline内容,点击Validate2.pipeline语法之job在每个项目中,我们使用名为.gitlab-ci.yml的YAML文件配置GitLabCI/CD管道。这里在pipeline中定义了两个作业,每个作业运行不同的命令。命令可以......
  • Python学习之二:不同数据库相同表是否相同的比较方法
    摘要昨天学习了使用python进行数据库主键异常的查看.当时想我们有跨数据库的数据同步场景.对应的我可以对不同数据库的相同表的核心字段进行对比.这样的话能够极大的提高工作效率.我之前写过很长时间的shell.昨天跟着同事开始学python.感觉的确用python能够节约大量的时间.......
  • Hibernate4之二级缓存配置
    缓存:缓存是什么,解决什么问题? 位于速度相差较大的两种硬件/软件之间的,用于协调两者数据传输速度差异的结构,均可称之为缓存Cache。缓存目的:让数据更接近于应用程序,协调速度不匹配,使访问速度更快。 缓存的范围分为3类: 1.事务范围(单Session即一级缓存)   事务范围......
  • Reactor接口之二
    merge@TestpublicvoidtestMerge(){Flux.merge(Flux.just(1,2,3),Flux.range(5,6)).subscribe(System.out::println);}merge将多个Flux合并成一个Flux。 @TestpublicvoidtestMerge1(){Flux.range(1,5).mergeWith(Flux.just(8,9......
  • Jboss4集群配置之二:Jboss集群配置实例与负载均衡器配置
    1.前言 2.集群准备知识 3.Jboss集群配置实例概述4.Jboss集群负载均衡器mod_jk配置3.Jboss集群配置实例概述下文中,RubySun 将以实例来叙述Jboss集群配置。该实例包含3个Jboss节点。各节点被动接收负载均衡器转发的请求。各节点间没有横向的联系。4. Jboss集群负载均衡器配置步......
  • Opal 教程之二 SipIM 例子源码分析
    在互联网上.极少有关于Opal的中文教程.因此敝人决定把学习Opal的过程记录下来勉励自己.抑或给后来者留下一些入门的资料.最近感觉学习Opal已经慢慢摸出了门道.前几个星期.摸索在VS2005编译Opal花了我好多天的时间.把我的耐心都磨得差不多快要放弃研究Opal.作为初学者.学习的难度......