DB1中的表数据同步到DB2对应的表中
--DB1下
1: 建立指向DB2的 database link
2: 对表创建触发器. 表中数据有变化时候enqueue到对应的advanced queue 中
3: 对 advanced queue 添加一个 subscriber 通过dblink 指向DB2对应的queue中
4: 对 advanced queue 添加propagation 机制
5: 完成上面步骤后, 当DB1下某表数据变化后,就会吧消息加入到advanced queue中, 然后这个queue中的消息会广播到dblink指向的另一个库的queue中,就是那个订阅者.
-- DB2下
6: 对DB2下对应的queue 添加 消息注册通知. 即: 当这个queue收到消息后,就会通知一个注册的程序. 这个程序就去处理一些自定义的事情. 这个程序可以是 procedure. email地址....等.
7: 这里消息注册一个procedure. 目的是: 当这个queue收到消息后,就触发这个储存过程. prcoedure 拿到queue中的消息, 然后通过指向DB1的一个dblink 去DB1的相关表下拿到数据,然后在插入到本地的相关表中. 这样就实现了DB1到DB2的数据同步.
-- 总结:
1: propagation机制:
DB1.queue 传播到 DB2.queue. 这个过程是比较快的. 我认为是由于它是两个queue消息之间的传播. 这个过程不会对消息进行解析,只是传播RAW格式的信息.所以比较快
2: message register information 机制
1): 这时DB2下的ini参数job_queue_processes不能为0,应该配置合适的大小,才能触发消息通知.
2): 消息通知机制是异步的,并发的. 也就是说每条消息可能会同时触发那个procedure去做事情.,若queue中当前传播到了100条消息,也许这时系统正有100个procedure同时处理.每个procedure只处理一条消息. 这个机制不同于job. job是串行的.即:当job调用的一个procedure执行完后,下一个调用才能开始. 而消息通知的每个调用不会影响下个调用.实现了并发和异步.
3): procedure中的处理: 是通过dblink 拿db1的数据到db2.这个过程比较慢
来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/523774/viewspace-366183/ ，如需转载，请注明出处，否则将追究法律责任。
