如何封装一个同步器？
1. CountDownLatch2为什么已经有了CountDownLatch，还要自定义一个CountDownLatch2呢？ 下面先介绍下CountDownLatch 定义：CountDownLatch是Java并发编程中的同步工具类，主要用于协调多个线程的执行顺序，允许一个或多个线程等待其他线程完成操作后再继续执行。其核心机制：通过计数器实现阻塞与唤醒，计数器初始值为任务线程数，每当一...
cannal源码赏析 - connector模块
private CanalMQProducer canalMQProducer = null;public synchronized void start() throws Throwable { String serverMode = CanalController.getProperty(properties, CanalConstants.CANAL_SERVER_MO...
cannal源码赏析 - meta模块
1. CanalMetaManager/** * meta信息管理器 * * @author jianghang 2012-6-14 下午09:28:48 * @author zebin.xuzb * @version 1.0.0 */public interface CanalMetaManager extends CanalLifeCycle { /** * ...
cannal源码赏析 - filter模块
1. CanalEventFilter/** * 数据过滤机制 * * @author jianghang 2012-7-20 下午03:51:27 */public interface CanalEventFilter<T> { boolean filter(T event) throws CanalFilterException;} 2. Av...
cannal源码赏析 - store模块
1. 简介这是canal的存储模块com.alibaba.otter.canal.store，能够将binlog解析后的event存储到内存中，由于内存有限，优先使用ITEMSIZE模式进行限制，其次使用MEMSIZE进行限制，MemoryEventStoreWithBuffer作为该模块的核心实现类，基于ReentrantLock提供阻塞的get、put方法。 数据存储在哪里？内存中 ...
cannal源码赏析 - sink模块
1. CanalEventSink/** * event事件消费者 * * <pre> * 1. 剥离filter/sink为独立的两个动作，方便在快速判断数据是否有效 * </pre> * * @author jianghang 2012-6-21 下午05:03:40 * @version 1.0.0 */public interface CanalEven...
cannal源码赏析 - parser模块
cannal源码赏析 - instance模块
1. 核心类图 2. Generator2.1 ManagerCanalInstanceGeneratorpublic class ManagerCanalInstanceGenerator implements CanalInstanceGenerator { private CanalConfigClient canalConfigClient; public C...
cannal源码赏析 - server模块
依赖模块 1. CanalServerWithNetty1.1 源码public class CanalServerWithNetty extends AbstractCanalLifeCycle implements CanalServer { private CanalServerWithEmbedded embeddedServer; // 嵌入式serve...
cannal源码赏析 - deployer模块
1. CanalLauncher// 1. 读取配置文件properties// 2. 创建CanalStarterfinal CanalStarter canalStater = new CanalStarter(properties);// 3. 启动canalStater.start(); 2. CanalStarter重点看CanalStarter的start方法： public ...