pomelo广播包过大导致卡住怎么解决
发布网友
发布时间：2022-04-12 22:20
共2个回答
懂视网
时间：2022-04-13 02:41
一、pomelo在GitHub上各个项目间的关系 1、pomelo项目 pomelo项目是一个 游戏服务器框架 ，用它可以创建 服务器端项目 。 2、chatofpomelo-websocket项目 chatofpomelo-websocket项目是由pomelo服务器框架创建的一个服务器端项目。这个项目与pomelo-cocos2dc
一、pomelo在GitHub上各个项目间的关系
1、pomelo项目
pomelo项目是一个游戏服务器框架，用它可以创建服务器端项目。
2、chatofpomelo-websocket项目
chatofpomelo-websocket项目是由pomelo服务器框架创建的一个服务器端项目。这个项目与pomelo-cocos2dchat项目一同实现了一个简单的聊天室功能。
3、pomelo-cocos2dchat项目
这个项目是一个由Cocos2d-x游戏引擎创建的客户端项目。这个项目与chatofpomelo-websocket项目是相匹配的客户端与服务端。
4、libpomelo项目
这个项目其实是一个第三方库，Cocos2d-x的项目要与基于pomelo的服务器通信，就需要这个第三方库的支持。
二、移动网络游戏的实现流程
移动网络游戏实现流程图
一个移动网络游戏由客户端与服务器端两个部分组成，客户端与服务器端可以通过例如websocket接口进行通信。
Cocos2d-x引擎提供创建Cocos2d-x项目的模板，为新建项目添加必要的库文件后，对项目进行代码实现即可得到游戏的客户端程序。
服务器端程序亦是如此，pomelo框架提供pomelo项目的模板，新建pomelo项目后进行代码实现就可以完成服务器端。启动服务器端之后再启动客户端即可实现游戏的运行。
pomelo 与 Cocos2d-JS 开发环境搭建
Mac下将libpomelo连接到Cocos2d-x的解决方案
Cocos2d-js v3.0-rc0 下 pomelo-cocos2d-jsb native web 配置
手把手教你把pomelo客户端组件libpomelo加入Cocos2d-x 3.0项目（Windows、Android、iOS平台）
来源网址：http://www.cnblogs.com/tangyikejun/p/3981042.html
热心网友
时间：2022-04-12 23:49
一开始会觉得这种广播在分布式的环境下实现会比较的复杂。。但是当搞明白了pomelo的实现之后，发现它是采用了一种折中的方法实现广播。。虽然没有刚开始自己想的那么牛*，不过觉得也算是一种比较好的解决方案吧。。
那么接下来就用pomelo给的chat这个例子来分析吧，来看登录吧，首先会向gate服务器发起连接：
function queryEntry(uid, callback) {
var route = 'gate.gateHandler.queryEntry';
pomelo.init({
host: window.location.hostname,
port: 3014,
log: true
}, function() {
pomelo.request(route, { //发起请求，用于获取用于连接的connector服务器的地址
uid: uid
}, function(data) {
pomelo.disconnect();
if(data.code === 500) {
showError(LOGIN_ERROR);
return;
}
callback(data.host, data.port);
});
});
};
这部分代码主要要完成的目的就是与gate进行通信，gate会返回该客户用于连接的connector服务器的地址，我们来看看gate服务器是怎么生成这个地址的吧：
//next是一个函数，用于执行一些操作，将返回的数据发送回去
handler.queryEntry = function(msg, session, next) {
var uid = msg.uid;
if(!uid) {
next(null, {
code: 500
});
return;
}
// get all connectors
var connectors = this.app.getServersByType('connector'); //获取素有connector服务器的配置信息
if(!connectors || connectors.length === 0) {
next(null, { //第一个参error，第二个参数wie返回给客户端的信息
code: 500
});
return;
}
// select connector
var res = dispatcher.dispatch(uid, connectors); //选取一个connector服务器
next(null, {
code: 200,
host: res.host,
port: res.clientPort
});
};
var crc = require('crc');
mole.exports.dispatch = function(uid, connectors) {
var index = Math.abs(crc.crc32(uid)) % connectors.length;
return connectors[index];
};
到这里就应该知道gate服务器是怎么挑选connector服务器的了吧。。。那么在获取了用于连接的connector之后，就应该建立与connector服务器的连接，进行登录了。。。代码如下：
//query entry of connection
queryEntry(username, function(host, port) {
pomelo.init({
host: host, //这里是返回的用于连接的connector服务器的host与port
port: port,
log: true
}, function() {
var route = "connector.entryHandler.enter"; //这里可以当做是进行登录吧
pomelo.request(route, {
username: username,
rid: rid
}, function(data) {
if(data.error) {
showError(DUPLICATE_ERROR);
return;
}
setName();
setRoom();
showChat();
initUserList(data);
});
});
});
可以看到这里调用的是connector服务器的handler的enter方法，然后传过去的参数是username和rid（房间的id），那么我们来看看这个connector服务器的enter方法干了些什么事情吧：
handler.enter = function(msg, session, next) {
var self = this;
var rid = msg.rid;
var uid = msg.username + '*' + rid //用户名字还要加上组名字
var sessionService = self.app.get('sessionService');
//plicate log in
if( !! sessionService.getByUid(uid)) { //表示有相同的用户了
next(null, {
code: 500,
error: true
});
return;
}
session.bind(uid); //将这个session与uid绑定起来
session.set('rid', rid);
session.push('rid', function(err) {
if(err) {
console.error('set rid for session service failed! error is : %j', err.stack);
}
});
session.on('closed', onUserLeave.bind(null, self.app)); //设置closed事件的处理函数
//put user into channel
//这里session适用于挑选后台的chat服务器的，这里还要讲当前frontend服务器的serverID传送过去，因为后台要知道当前channel的用户都在哪些frontend服务器上面连接着
//这里挑选后台的chat服务器的时候，用的是rid，所以可以保证同一个房间的人分到同一个chatserver
self.app.rpc.chat.chatRemote.add(session, uid, self.app.get('serverId'), rid, true, function(users){
next(null, {
users:users //远程服务器返回的当前channel里面的所有的用户
});
});
};
