现在分析的版本为0.7版。pomelo-sync,pomelo里用于解决游戏进程中需要持久化的数据在内存与存储系统之间的同步问题。
一、pomelo程序如何使用pomelo-sync
新版本的pomelo里增强了支持用户自行扩展的能力。用户只用在app.use(plugin, opts)就可以了,具体请看pomelo的application.js里的use函数。需要这个plugin里有components成员。use函数里,pomelo将plugin的componets所指的组件load起来,并将opts传给这个plugin的components。
pomelo-sync自身只负责实现db数据与内存数据间的定时同步,所以另一个项目pomelo-sync-plugin就将pomelo-sync封装成了一个componet。app.use(require('pomelo-sync-plugin', opts)就完成了数据同步插件的装载。
二、pomelo-sync
pomelo-sync在构造的时候,将参数里的client(与持久化层的链接)、mapping(如各种操作的sql语句的映射表)等赋值给自己的相应成员。最后开启定时刷内存数据到持久化层的计时器SyncTimer。
对外接口不只在dbsync.js里,还分布在lib/commands下的几个文件里。其中exec/flush/sync等在commands/server.js里。
(一)pomelo-sync.exec
pomelo-sync.exec函数,被用户程序调用。将用户的数据放入pomelo-sync.flushQueue或者pomelo-sync.mergerMap。
(二)pomelo-sync.flush
pomelo-sync.flush函数,将单挑数据立即持久化。
(二)pomelo-sync.sync
pomelo-sync.sync函数,被SyncTimer调用,也可以被用户程序调用,立即将全部内存数据持久化。sync函数里调用的是rewriter.js里的sync。rewriter.sync里将pomelo-sync.flushQueue和pomelo-sync.mergerMap里的数据通过rewrite.tick刷进持久层。rewriter.tick里是通过pomelo-sync.mapping里的映射调对应的sql语句来实现的。