cannal源码赏析 - instance模块
1. 核心类图 2. Generator2.1 ManagerCanalInstanceGenerator1234567891011121314151617public class ManagerCanalInstanceGenerator implements CanalInstanceGenerator { private CanalConfigClient canal...
1. 核心类图 2. Generator2.1 ManagerCanalInstanceGenerator1234567891011121314151617public class ManagerCanalInstanceGenerator implements CanalInstanceGenerator { private CanalConfigClient canal...
依赖模块 1. CanalServerWithNetty1.1 源码123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858...
1. CanalLauncher1234567// 1. 读取配置文件properties// 2. 创建CanalStarterfinal CanalStarter canalStater = new CanalStarter(properties);// 3. 启动canalStater.start(); 2. CanalStarter重点看CanalStarter的start方法: ...
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011...
1. CanalConnector重点介绍RocketMQCanalConnector。 1.1 RocketMQCanalConnector-属性12345678910111213141516private String nameServer;private String ...
1. MigrateMap1.1 源码1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939...
1. 介绍canal [kə’næl],基于数据库增量日志解析,提供增量数据订阅&消费。 1.1 MYSQL主备复制实现 master将改变记录到二进制日志(binary log)中(这些记录叫做二进制日志事件,binary log events,可以通过show binlog events进行查看); slave将master的binary log events拷贝到它的中继日志(...
1. 调度器 1.1 借助InitializingBean接口启动1234567891011121314151617181920212223242526272829@Componentpublic class XxlJobAdminConfig implements InitializingBean, DisposableBean { private static XxlJo...
1. SPI机制SPI 全称为 Service Provider Interface,是一种服务发现机制。 SPI 的本质是将接口实现类的全限定名配置在文件中,并由服务加载器读取配置文件,加载实现类。这样可以在运行时,动态为接口替换实现类。正因此特性,我们可以很容易的通过 SPI 机制为我们的程序提供拓展功能。 2. Java SPI2.1 demo首先,定义接口; 1234public i...
这是rocketmq中封装的线程类org.apache.rocketmq.common.ServiceThread,rocketmq通过继承该线程类实现两个方法getServiceName()、run(),来实现对线程功能的增强。 123456789101112131415161718192021222324252627282930313233343536373839404142434445...