現在分析的版本為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語句來實現的。