pomelo使用采坑记(学习使用部署相关)

本文主要是介绍pomelo使用采坑记(学习使用部署相关)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

pomelo推送方式

pomelo和客户端保持长链接，推送可以根据频道推送或者根据用户连接的服务器推送

频道推送

1. 创建频道

let channel = this.app.get('channelService').getChannel(channelName, true);
参数1为频道的名字，参数2为是否在没有该频道的时候创建一个
channel.add(uid, sid);
将用户放到频道里面，其中uid为用户唯一标识，sid为connector的服务器Id

假设服务器配置是

"connector":[{"id":"c1", "host":"172.16.46.14","port":4050, "clientPort": 3050, "frontend": true,"cpu": 1},{"id":"c2", "host":"172.16.46.14", "port":4051, "clientPort": 3051, "frontend": true,"cpu": 2},{"id":"c3", "host":"172.16.46.14",  "port":4052, "clientPort": 3052, "frontend": true,"cpu": 3},{"id":"c4", "host":"172.16.46.14",  "port":4053, "clientPort": 3053, "frontend": true,"cpu": 4}]

并且用户123和connector2连接，用户234连接connector3

channel.add(123, c2);
channel.add(234, c3);

2. 根据频道推送
   调用

let channel = this.app.get('channelService').getChannel(channelName);
channel.pushMessage(event, msg, cb);
其中event为客户端监听的push方法，例如onAdd
msg为推送参数，随意传
cb为推送后的回调函数

以上方法可以给用户123和用户234推送同一条消息

直接推送

1. 保存用户Id和用户connector服务器的对应关系

let uids = [];
uids.push({uid:123,sid:"c2"});
uids.push({uid:234,sid:"c3"});

2. 根据uids推送

this.app.get('channelService').pushMessageByUids(method, params, uids);
其中method为客户端监听的push方法，例如onAdd
params为推送参数，随意传

bearcat集成

remote和handler集成

1. 安装bearcat

npm install --save bearcat

2. app.js中的配置

var bearcat = require('bearcat');
let contextPath = require.resolve('./context.json');
bearcat.createApp([contextPath]);bearcat.start(function() {Configure();app.set('bearcat', bearcat);// start appapp.start();
});其中context.json为{"name": "myApp","scan": "app",   //需要扫描app文件夹下的所有js文件"beans": []
}

3. 集成到handler

var bearcat = require('bearcat');
var Handler = function (app) {this.app = app;this.redis = null;  //假设要用到redis
};
var handler = Handler.prototype;
handler.queryEntry = function (msg, session, next) {//自己的业务逻辑
}module.exports = function (app) {return bearcat.getBean({id: "gateHandler",func: Handler,args: [{name: "app",value: app}],props: [{name: "redis", ref: "redis"}]});
};

其他地方需要使用gateHandler的时候，只需要

var other= function () {this.gateHandler=null;
}
other.prototype.funA= function(){this.gateHandler.queryEntry();...
}
module.exports = {id: "other",func: other,props: [{name: "gateHandler", ref: "gateHandler"}]
}

非pomelo框架的service、util等的集成

1. 安装bearcat

npm install --save bearcat

2. app.js中的配置

var bearcat = require('bearcat');
let contextPath = require.resolve('./context.json');
bearcat.createApp([contextPath]);bearcat.start(function() {Configure();app.set('bearcat', bearcat);// start appapp.start();
});app.configure('development', 'chat', function() {  //chat类型的服务器在development环境下的配置let chat_OnLineService = bearcat.getBean('chat_OnLineService');chat_OnLineService.init(app);});其中context.json为{"name": "myApp","scan": "app",   //需要扫描app文件夹下的所有js文件"beans": []
}

3. 集成到chat_OnLineService
   文件onlineService.js中

var OnLineService = function() ｛｝;
OnLineService.prototype.init=function (app) {this.app = app;
}module.exports = {id: "chat_OnLineService",func: OnLineService,props: []
}注意onlineService.js必须在app文件夹下，不然扫描不到
其余使用方式handler、remote和普通js文件一模一样

bearcat优势

1. 不需要每次都require，只需要引入bean的id即可，即知道id名字就可以全局使用
2. 类似于spring的javabean的方式，适合习惯了使用java框架开发的开发人员快速上手

默认路由规则采坑

未进行用户Id绑定的多服务器远程调用

pomelo进行远程调用时（1、系统远程调用，一般调用Handler，例如客户端调用pomelo的online.onLineHandler.showOnlinePlayers方法；2、用户远程调用，一般调用Remote，例如app.rpc.chat.onLineRemote.kick，是由用户在服务端代码中直接调用），有个默认路由规则

  var uid = session ? (session.uid || '') : '';var index = Math.abs(crc.crc32(uid.toString())) % list.length;utils.invokeCallback(cb, null, list[index].id);

即先判断有无session参数传入，若有则使用session中绑定好的uid否则用空串，然后进行路由。

当用户未进行session.bind(uid)之前进行远程调用的时候，如果用户没有手动配置路由规则，即使有若干同类型的服务器，也只会调用其中的一台，负载均衡的效果就没有了。

所以，如果要在未绑定uid的时候进行多端口或者多服务器的负载均衡，必须要自定义路由规则而不使用默认规则（在进行auth鉴权服务器调用的时候，往往还不知道用户的Id）

路由配置

exp.auth = function(session, msg, app, cb) {let chatServers = app.getServersByType('auth');if(!chatServers || chatServers.length === 0) {cb(new Error('can not find cron servers.'));return;}cb(null, chatServers[session.id%chatServers.length].id);  //推荐使用session的id或者用户的设备信息等进行路由到不同的服务器或者端口
};app.route('auth', routeUtil.auth);

log按照时间日期服务器分割

按服务器和天分割

{"type": "dateFile","filename": "${opts:base}/logs/cron-${opts:serverId}.log","compress": true,"pattern": ".yyyy-MM-dd","layout": {"type": "basic"},"backups": 0,"category":"cron"}let logger = require('pomelo-logger').getLogger('cron', __filename);
logger.error("***")

按服务端和小时分割

{"type": "dateFile","filename": "${opts:base}/logs/service-${opts:serverId}.log","layout": {"type": "basic"},"pattern": ".yyyy-MM-dd-hh","compress": true,"backups": 0,"category":"service"}
let logger = require('pomelo-logger').getLogger('service', __filename);
logger.error("***")

按天分割

{"type": "dateFile","filename": "${opts:base}/logs/error.log","compress": true,"pattern": ".yyyy-MM-dd","layout": {"type": "basic"},"backups": 0,"category":"error"}
let logger = require('pomelo-logger').getLogger('error', __filename);
logger.error("***")

IDEA调式

服务器配置

IDEA配置

步骤

1. 

2. node app.js 或者 pomelo start

3. idea里面直接断点，搞定

分布式部署

ssh方式

1. 假设有2台机器,A和B
2. 在A机器上ssh B的ip(内网和外网ip都可以，如果是内网ip则servers.json里面就要配置内网ip，否则配置外网ip) ，如果不需要设置密码则进入步骤4，否则进入步骤3
3. 配置机器A和机器B的ssh互信免密登录，网上一搜一大把…
4. 在master机器上（假设是A）敲命令 pomelo start -D
5. 查看进程是否全部启动,A机器敲命令 pomelo list
6. 如果没有全部启动，则返回步骤3!

非ssh方式

1. 假设A机器需要启动对外7003端口对内4050端口的connector服务器一台，B机器需要启动6053端口的chat服务器一台
2. 则先在A机器上，使用命令

/usr/local/bin/node /data/node/root/app.js env=dev type=all
/usr/local/bin/node /data/node/root/app.js env=dev id=c1 host=172.*.*.* port=4050 clientPort=7003 frontend=true serverType=connector

3. 在B机器上，使用命令

/usr/local/bin/node /data/node/root/app.js env=dev id=ch4 host=172.*.*.* port=6053 serverType=chat

先写到这吧··有问题联系 滕庆亚

这篇关于pomelo使用采坑记(学习使用部署相关)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---