pomelo程序如何使用pomelo-sync

原文链接：http://www.cnblogs.com/pampam/p/4015273.html

    新版本的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语句来实现的。

 

引用自：http://www.cppblog.com/yangsf5/archive/2013/12/04/204582.html

转载于:https://www.cnblogs.com/pampam/p/4015273.html

标签：use,函数,plugin,程序,sync,js,pomelo
来源： https://blog.csdn.net/weixin_30776863/article/details/98459268