現(xiàn)在分析的版本為0.7版。pomelo-sync,pomelo里用于解決游戲進(jìn)程中需要持久化的數(shù)據(jù)在內(nèi)存與存儲系統(tǒng)之間的同步問題。
一、pomelo程序如何使用pomelo-sync
新版本的pomelo里增強(qiáng)了支持用戶自行擴(kuò)展的能力。用戶只用在app.use(plugin, opts)就可以了,具體請看pomelo的application.js里的use函數(shù)。需要這個plugin里有components成員。use函數(shù)里,pomelo將plugin的componets所指的組件load起來,并將opts傳給這個plugin的components。
pomelo-sync自身只負(fù)責(zé)實(shí)現(xiàn)db數(shù)據(jù)與內(nèi)存數(shù)據(jù)間的定時同步,所以另一個項(xiàng)目pomelo-sync-plugin就將pomelo-sync封裝成了一個componet。app.use(require('pomelo-sync-plugin', opts)就完成了數(shù)據(jù)同步插件的裝載。
二、pomelo-sync
pomelo-sync在構(gòu)造的時候,將參數(shù)里的client(與持久化層的鏈接)、mapping(如各種操作的sql語句的映射表)等賦值給自己的相應(yīng)成員。最后開啟定時刷內(nèi)存數(shù)據(jù)到持久化層的計(jì)時器SyncTimer。
對外接口不只在dbsync.js里,還分布在lib/commands下的幾個文件里。其中exec/flush/sync等在commands/server.js里。
(一)pomelo-sync.exec
pomelo-sync.exec函數(shù),被用戶程序調(diào)用。將用戶的數(shù)據(jù)放入pomelo-sync.flushQueue或者pomelo-sync.mergerMap。
(二)pomelo-sync.flush
pomelo-sync.flush函數(shù),將單挑數(shù)據(jù)立即持久化。
(二)pomelo-sync.sync
pomelo-sync.sync函數(shù),被SyncTimer調(diào)用,也可以被用戶程序調(diào)用,立即將全部內(nèi)存數(shù)據(jù)持久化。sync函數(shù)里調(diào)用的是rewriter.js里的sync。rewriter.sync里將pomelo-sync.flushQueue和pomelo-sync.mergerMap里的數(shù)據(jù)通過rewrite.tick刷進(jìn)持久層。rewriter.tick里是通過pomelo-sync.mapping里的映射調(diào)對應(yīng)的sql語句來實(shí)現(xiàn)的。