文档章节

pomelo sync在lordofpomleo的使用分析

piggybear
 piggybear
发布于 2015/02/16 10:31
字数 1165
阅读 28
收藏 0
点赞 0
评论 0

关于pomelo sync的使用其实官方是有一篇文档介绍的,使劲搓这里,后来看了lordofpomelo游戏分析 这个文档,发现里面的数据持久化模块也有讲到pomelo sync,但本人对nodejs属于菜鸟级别,居然没看懂,今天抽时间结合lordofpomleo源码好好看了一下,终于弄懂了,特此分享。

话说Lord采用Pomelo-sync从内存同步数据到数据库,是为了减轻数据库压力,它的工作原理是创建一个sql行为处理队列,每隔一段时间轮询一次,执行队列里的sql 操作。那么它在Lord中是如何发挥作用呢?

简单来讲特就是使用了nodjs的EventEmitter,在Lord中很多实体对象都是继承自EventEmitter的,然后都定义了一个save方法用来触发“save”事件,在这些对象加入场景时注册save监听器,监听到"save"事件时就执行sync的exec来添加异步定时执行的数据库更新操作。在场景中,如果需要更新数据,如:增加玩家经验,就直接调用对应实体对象的save方法即可。具体分析如下:

如果你看了 lordofpomelo游戏分析 这个文档的话,你很容易发现,当用户登录验证完毕之后,客户端web-server/public/js/ui/clientManager.js,就会向场景服务器发请求进入场景:

[javascript]  view plain copy
  1. function enterScene(){  
  2.   pomelo.request("area.playerHandler.enterScene"nullfunction(data){  
  3.     app.init(data);  
  4.   });  
  5. }  

场景服务器game-server/app/servers/\area/handler/playerHandler.js,会获取玩家及场景,然后将玩家加入到场景对象中:

[javascript]  view plain copy
  1. handler.enterScene = function(msg, session, next) {  
  2. ...  
  3.         if (!area.addEntity(player)) {  
  4.       logger.error("Add player to area faild! areaId : " + player.areaId);  
  5.     }  
  6. ...  
  7. };  

这里先看看这个player,在game-server/app/domain/entity/player.js中,其实是继承自character

[javascript]  view plain copy
  1. util.inherits(Player, Character);  

game-server/app/domain/entity/character.js,继承自entity

[javascript]  view plain copy
  1. util.inherits(Character, Entity);  

game-server/app/domain/entity/entity.js,继承自EventEmitter

[javascript]  view plain copy
  1. var Entity = function(opts) {  
  2.     EventEmitter.call(this);  
  3. ...  
  4.   
  5. };  
  6.   
  7. util.inherits(Entity, EventEmitter);  

而在game-server/app/domain/entity/player.js中,定义了save方法用来触发“save”事件

[javascript]  view plain copy
  1. // Emit the event 'save'.  
  2. Player.prototype.save = function() {  
  3.     this.emit('save');  
  4. };  

有了触发事件,再来看看如何监听事件,看这个area.addEntity,在game-server/app/domain/area.js中,作用是将那个player通过eventManager加进来:

[javascript]  view plain copy
  1. exp.addEntity = function(e) {  
  2. ...  
  3.     eventManager.addEvent(e);  
  4. ...  
  5. };  

然后game-server/app/domain/event/eventManager.js,

[javascript]  view plain copy
  1. exp.addEvent = function(entity){  
  2.     ...  
  3.     addSaveEvent(entity);  
  4.     ...  
  5. };  

调用了这个addSaveEvent函数,来注册监听器,监听"save"事件

[html]  view plain copy
  1. /**  
  2.  * Add save event for player  
  3.  * @param {Object} player The player to add save event for.  
  4.  */  
  5. function addSaveEvent(player) {  //通过同步工具,回写相关信息到数据库  
  6.     var app = pomelo.app;  
  7.     player.on('save', function() {  
  8.         app.get('sync').exec('playerSync.updatePlayer', player.id, player.strip());  
  9.     });  
  10.   
  11.     player.bag.on('save', function() {  
  12.         app.get('sync').exec('bagSync.updateBag', player.bag.id, player.bag);  
  13.     });  
  14.   
  15.     player.equipments.on('save', function() {  
  16.         app.get('sync').exec('equipmentsSync.updateEquipments', player.equipments.id, player.equipments);  
  17.     });  
  18. }  

当player、bag、equipments这三个对象见监听到"save"事件就会执行sync的exec来添加异步定时执行的数据库更新操作。

接下来看如何触发“save”事件,以玩家郑家经验为例,player对象直接调用this.save方法即可。

[javascript]  view plain copy
  1. //Add experience  
  2. Player.prototype.addExperience = function(exp) {  
  3.     this.experience += exp;  
  4.     if (this.experience >= this.nextLevelExp) {  
  5.         this.upgrade();  
  6.     }  
  7.     this.save();  
  8. };  

最后再来看看pomelo sync是如何配置使用的。

很简单,在game-server/app.js配置

[javascript]  view plain copy
  1. // Configure database  
  2. app.configure('production|development''area|auth|connector|master'function() {  
  3.     var dbclient = require('./app/dao/mysql/mysql').init(app);  
  4.     app.set('dbclient', dbclient);  
  5.     app.load(pomelo.sync, {path:__dirname + '/app/dao/mapping', dbclient: dbclient});  
  6. });  

app.load(pomelo.sync, {path:__dirname + '/app/dao/mapping', dbclient: dbclient});给sync提供了持久化时同步方法的映射及数据库连接dbclient,其中在game-server/app/dao/mapping下定义了同步方法,以bagSync.js为例,直接就是一个update语句:

[javascript]  view plain copy
  1. module.exports = {  
  2.   updateBag: function (dbclient, val, cb) {  
  3.     var sql = 'update Bag set items = ? where id = ?';  
  4.     var items = val.items;  
  5.     if (typeof items !== 'string') {  
  6.       items = JSON.stringify(items);  
  7.     }  
  8.     var args = [items, val.id];  
  9.   
  10.     dbclient.query(sql, args, function (err, res) {  
  11.       if (err) {  
  12.         console.error('write mysql failed! ' + sql + ' ' + JSON.stringify(val));  
  13.       }  
  14.       cb(!!err);  
  15.     });  
  16.   }  
  17. };  

好了最后总结一下,使用流程就是:先在app.js设置app.load(pomelo.sync, {path:__dirname + '/app/dao/mapping', dbclient: dbclient});,然后在game-server/app/dao/mapping下定义了同步方法的js脚本,最后使用exec执行即可,如:app.get('sync').exec('bagSync.updateBag', player.bag.id, player.bag);为方便使用exec,Lord引入了EventEmitter来处理。如果你对EventEmitter不熟的话,可以看看下面这个例子:

[javascript]  view plain copy
  1. var util = require("util");  
  2. var events = require("events");//EventEmitter通过events模块来访问  
  3.   
  4. function MyStream() {//新建一个类  
  5.     events.EventEmitter.call(this);  
  6. }  
  7.   
  8. util.inherits(MyStream, events.EventEmitter);//使这个类继承EventEmitter  
  9.   
  10. MyStream.prototype.write = function(data) {//定义一个新方法  
  11.     this.emit("data", data);//在此触发名为"data"事件  
  12. }  
  13.   
  14. var stream = new MyStream();  
  15.   
  16. stream.on("data"function(data) {//注册监听器,监听名为"data"事件  
  17.     console.log('Received data: "' + data + '"');  
  18. })  
  19. stream.write("It works!"); // Received data: "It works!"  

本人对nodejs仍属于菜鸟级别,pomelo也刚上手不久,有错在所难免请多多指教!


本文转载自:http://blog.csdn.net/aa294194253/article/details/41329109

共有 人打赏支持
piggybear
粉丝 3
博文 237
码字总数 37552
作品 0
西安
技术主管
网易开源游戏服务器框架 pomelo 发布 0.6 版

pomelo 0.6是一次很大的升级, 是自0.3版以来最重要的一次升级 在Pomelo 0.6版本中,对pomelo部分结构进行了调整,将原有的globalChannel组件和master高可用组件从框架中移出,以一种插件的形...

谢骋超
2013/08/26
6.2K
7
网易开源游戏服务器框架 pomelo 0.9 版发布

pomelo 0.9版于2月26日发布,以下是该版本的新特性。 pomelo websocket支持自动重连 在pomelo 0.9版本中,pomelo-jsclient-websocket 支持自动重连。重连发生在连接断开后的5s后,在重连失败...

谢骋超
2014/02/27
7.8K
5
网易正式发布 Pomelo 开源游戏服务端框架

10月20日的开源中国 杭州源创会 上,来自网易的 @谢骋超为大家介绍了网易即将开源的基于 Node.js 的游戏服务器框架 Pomelo (柚子),并称该框架将于11月正式开源。 今天这个框架终于正式跟我们...

oschina
2012/11/21
27.2K
97
用Pomelo 搭建一个简易的推送平台

前言 实际上,个人感觉,pomelo 目前提供的两个默认和 使用的协议并不适合用于做手机推送平台,在pomelo的一份公开ppt里面,有提到过, 网易的消息推送平台是基于pomelo开发的 (一个frontend 支持...

打杂程序猿
2013/06/18
0
9
pomelo 分布式聊天入门客户端demo(c#)

## c/s 聊天例子 目的:实现了一个简单的c/s分布式聊天例子,演示了c#客户端和pomelo服务器的交互,使用原生socket通信方式。本来是想用unity3d和pomelo通信,但是unity3d里面处理异步比较麻...

于小懒
2014/03/22
1K
0
网易游戏服务器开发框架--Pomelo

pomelo 是由网易开发的基于node.js开发的高性能、分布式游戏服务器框架, 也可作为高实时web应用框架。 Pomelo的应用范围 pomelo最适合的应用领域是网页游戏、社交游戏、移动游戏的服务端,开...

谢骋超
2012/10/23
84.2K
10
开源游戏服务器框架--pomelo-citrus

pomelo-citrus是一个使用Ruby编程语言开发的开源游戏服务器框架,其软件架构和设计均来源于pomelo并已实现了pomelo的大部分功能。

MinixLi
2014/09/27
1K
0
pomelo 0.8 发布,网易游戏服务器框架

0.8 版本新特性 pomelo-cocos2d-jsb 对 cocos2d-x javaScript binding 环境有了支持,开发者可以很方便的使用 javaScript 来完成前后端的开发,并发布到 ios,android,web平台上 详细请看 po...

oschina
2013/12/25
4.8K
0
用VSCode远程调试Pomelo服务器子进程

pomelo是网易开源的轻量级游戏服务器框架。是基于node.js的多进程异步服务器框架。非重度游戏,完全可以用它来实现游戏服务器。 pomelo的地址是:https://github.com/NetEase/pomelo,大家可以...

zdhsoft
05/04
0
0
当前的几种开源游戏服务端介绍

当前的几种开源游戏服务端介绍 pomelo Pomelo 是基于 Node.js 的高性能、分布式游戏服务器框架。它包括基础的开发框架和相关的扩展组件(库和工具包),可以帮助你省去游戏开发枯燥中的重复劳...

bot911
2015/02/02
2.3K
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Android LogUtil 日志优化 调试的时候打印 点击跳转

打印日志的时候,可以点击跳转 LogUtil.java public class LogUtil { private static boolean IS_DEBUG = BuildConfig.DEBUG; public static void i(String tag, String message) {......

Jay_kyzg
9分钟前
0
0
人工智能你必须掌握的32个算法(二)归并排序算法

归并排序(MERGE-SORT)是建立在归并操作上的一种有效的排序算法,该算法是采用分治法(Divide and Conquer)的一个非常典型的应用。将已有序的子序列合并,得到完全有序的序列;即先使每个子...

木头释然
11分钟前
0
0
第十四章NFS服务搭建与配置

14.1 NFS介绍 NFS介绍 NFS是Network File System的缩写;这个文件系统是基于网路层面,通过网络层面实现数据同步 NFS最早由Sun公司开发,分2,3,4三个版本,2和3由Sun起草开发,4.0开始Netap...

Linux学习笔记
34分钟前
1
0
流利阅读笔记27-20180716待学习

生了娃照样能打,两位母亲温网会师 Lala 2018-07-16 1.今日导读 现今在生儿育女后回归事业的母亲们已经非常多见,但是很少有人想到,以高强度运动与竞争激烈为特色的竞技体育项目也会有 work...

aibinxiao
35分钟前
4
0
Guava 源码分析(Cache 原理【二阶段】)

前言 在上文「Guava 源码分析(Cache 原理)」中分析了 Guava Cache 的相关原理。 文末提到了回收机制、移除时间通知等内容,许多朋友也挺感兴趣,这次就这两个内容再来分析分析。 在开始之前...

crossoverJie
47分钟前
0
0
OSChina 周一乱弹 —— 如果是你喜欢的女同学找你借钱

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @guanglun :分享Michael Learns To Rock的单曲《Fairy Tale》 《Fairy Tale》- Michael Learns To Rock 手机党少年们想听歌,请使劲儿戳(这...

小小编辑
今天
574
18
NNS域名系统之域名竞拍

0x00 前言 其实在官方文档中已经对域名竞拍的过程有详细的描述,感兴趣的可以移步http://doc.neons.name/zh_CN/latest/nns_protocol.html#id30 此处查阅。 我这里主要对轻钱包开发中会用到的...

暖冰
今天
0
0
32.filter表案例 nat表应用 (iptables)

10.15 iptables filter表案例 10.16/10.17/10.18 iptables nat表应用 10.15 iptables filter表案例: ~1. 写一个具体的iptables小案例,需求是把80端口、22端口、21 端口放行。但是,22端口我...

王鑫linux
今天
0
0
shell中的函数&shell中的数组&告警系统需求分析

20.16/20.17 shell中的函数 20.18 shell中的数组 20.19 告警系统需求分析

影夜Linux
今天
0
0
Linux网络基础、Linux防火墙

Linux网络基础 ip addr 命令 :查看网口信息 ifconfig命令:查看网口信息,要比ip addr更明了一些 centos 7默认没安装ifconfig命令,可以使用yum install -y net-tools命令来安装。 ifconfig...

李超小牛子
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部