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

2023-08-11 21:54:28

昨天因为需要开始学习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去转发那些个你想要转发出去的信息 ，所以说套路是这样 更复杂的我也还没做过 ，但是复杂的 就是 很多简单的扣在一起换着玩法去写吧。

码农公寓

相关文章