Pomelo实现最简单的通信-egret。

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

昨天因为需要开始学习Pomelo 做H5游戏的服务端。

因为个人学习习惯，我从来不适合去跟着文档看。一般我直接是看下大概的API，但是Pomelo的API全部都是英文的。

昨天我就告诉自己用一下午时间去做一个最基本的通信功能的DEMO。

安装NODE.JS Phython VS 一切就绪之后就开始了。

转到目录下面，输入命令就会创建一个Pomelo项目，之后会要求选择个人理解就是通信方法把。

选择好之后就会生成项目目录

目录结构就是这样的。

一开始我以为这样就可以了啊，但是后来发现不对总感觉少了点什么，应该是基础包吧?||环境包？个人理解就是支持程序跑起来的一些基础类库。

直接运行他，就可以了。

接下来我就瞅这个项目目录结构，当然我值看Game-server web-server没大看，不过感觉大致差不大多吧。

先看了下app.js --

app.configure('production|development', 'connector', function(){//其实我不大了解这个方法的具体实现方式，但是我觉得他的功能大概就是设置Connector的连接方式。
app.set('connectorConfig',
{
connector : pomelo.connectors.hybridconnector,
heartbeat : 3,
useDict : true,
useProtobuf : true
});
});

connector : pomelo.connectors.hybridconnector,【进去看他的代码】Pomelo.connectors.__defineGetter__('sioconnector', load.bind(null, './connectors/sioconnector'));Pomelo.connectors.__defineGetter__('hybridconnector', load.bind(null, './connectors/hybridconnector'));Pomelo.connectors.__defineGetter__('udpconnector', load.bind(null, './connectors/udpconnector'));

Pomelo.connectors.__defineGetter__('mqttconnector', load.bind(null, './connectors/mqttconnector'));他设置了几个几个常量咯根据这个方法选择通信方式。

设置完这些，然后我就开始琢磨怎么连上我的第一个WebSocket服务器，哪里都不用改直接跑起来看下把，先连接上了再说下一步。

其实应该去设置server.json的里面可以设置服务端口跟客户端端口的，但是我直接用项目创建时候默认的把，上面有个clientPort

那个是客户端连接的端口，连接上去之后

我用的是EGRET引擎，所以在论坛里直接找了Pomelo客户端用的包，用上了，这样就连接上去了。加下来才是终点

最简单的通信，先看下客户端我是这么些的

this.socket.request("connector.entryHandler.join", {//requst（@网友说这叫路由地址，在我看来这个参数就是写Connector（服务器路由？每个路由单独处理属于自己的工作分工明确提高效率？）.文件名（为毛不是类名）.方法名--。那个在，@参数，@回调//这个回调，不是可以说是通信完成的回调，但也不能说完全就是，因为这个回调干不干活触不触发还要看服务端）
"uid":UID,
"rid":RID ,
"target": TAG
}, function (result) {
console.log(result);
});})/**
上面那是客户端调用湖物端的方法，他那写好了就要在湖物端开始写要触发的方法了**/

Handler.prototype.join = function (msg, session, next) {
var self = this;
console.log(msg.uid);
var id = msg.uid + "*" + msg.rid;
console.log(id);msg就是前端发过来的msg var sessionService = self.app.get('sessionService');
next(null, {
code: 500,
error: true
});
return; var chanel = this.ChannelServers.getChannel("pomelo", true); //关键就是这个Chanl啊 chanl就是一个对象，我理解就是一个麻将桌，你给他创建编号就能王这个麻将桌里面放人进去，嘿嘿。所有用户触发JOIN的时候都会获取叫“pomelo”的麻将桌，然后把自己加进去，后面那个参数就是如果麻将桌还没创建就创建一个新的
chanel.add(msg.uid, this.app.get('serverId'));//加入Chanel，UID的话按正常的应该是绑定sesson的uid 只是我把session-uid放在后面去绑定所以就，这样就区分了第二个参数是绑定的是SESSION uid 还是每个玩家app里面那个id ，答案是后者
var rid = msg.rid;
var uid = msg.uid;
msg.sid = msg.rid;
session.bind(uid);
session.set('rid', rid);
session.push('rid', function (err) {
});发送聊天消息-服务端

Handler.prototype.Chatto = function (msg, session, next) {
var uid = session.uid;
var sid = session.get("rid");
var uid = session.uid; console.log("uid=" + uid + "--sid=" + sid);
var chanel = this.ChannelServers.getChannel("pomelo", true);
console.log(chanel.records);
next(null, {"msg": "uid=" + uid})
if (chanel.getMember(uid)) {
chanel.pushMessage("back", {"msg": "玩家:" + uid + "-->发布信息"});
}
}｝其实按功能上来说就是通过Chanel去转发那些个你想要转发出去的信息，所以说套路是这样更复杂的我也还没做过，但是复杂的就是很多简单的扣在一起换着玩法去写吧。