cannal源码赏析 - client模块
1. CanalConnector重点介绍RocketMQCanalConnector。 1.1 RocketMQCanalConnector-属性12345678910111213141516private String nameServer;private String ...
cannal源码赏析 - common模块
1. MigrateMap1.1 源码1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939...
cannal安装 - 使用
1. 介绍canal [kə’næl]，基于数据库增量日志解析，提供增量数据订阅&消费。 1.1 MYSQL主备复制实现 master将改变记录到二进制日志(binary log)中（这些记录叫做二进制日志事件，binary log events，可以通过show binlog events进行查看）； slave将master的binary log events拷贝到它的中继日志(...
xxl-job源码
1. 调度器 1.1 借助InitializingBean接口启动1234567891011121314151617181920212223242526272829@Componentpublic class XxlJobAdminConfig implements InitializingBean, DisposableBean { private static XxlJo...
SPI机制
1. SPI机制SPI 全称为 Service Provider Interface，是一种服务发现机制。 SPI 的本质是将接口实现类的全限定名配置在文件中，并由服务加载器读取配置文件，加载实现类。这样可以在运行时，动态为接口替换实现类。正因此特性，我们可以很容易的通过 SPI 机制为我们的程序提供拓展功能。 2. Java SPI2.1 demo首先，定义接口； 1234public i...
ServiceThread
这是rocketmq中封装的线程类org.apache.rocketmq.common.ServiceThread，rocketmq通过继承该线程类实现两个方法getServiceName()、run()，来实现对线程功能的增强。 123456789101112131415161718192021222324252627282930313233343536373839404142434445...
关于网络通信
首先，我想要为接下来的博客起一个标题“网络通信”。那什么是网络通信呢？ 网络通信最主要的工作就是在发送端把信息通过规定好的协议进行组装包，在接收端按照规定好的协议把包进行解析，从而提取出对应的信息，达到通信的目的。中间最主要的就是数据包的组装，数据包的过滤，数据包的捕获，数据包的分析，当然最后再做一些处理。 – 百度百科 好像还有点抽象，再举一个例子。 12345678910## 1. ...
面试题
1. 三种缓存模式1.1 旁路缓存模式Cache Aside Pattern1.2 读写穿透Read/Write Through Pattern1.3 异步缓存写入Write Behind Pattern2. 分布式系统服务注册与发现原理3. Spring Boot自动装配原理4. 讲讲读写分离和分库分表的理解4.1 读写分离的好处4.2 读写分离会带来什么问题？如何解决？4.3 ...
TTL应用
1. TransmittableThreadLocal 怎么用?1.1 ThreadLocal使用子线程获取不到 父线程set到ThreadLocal所修饰变量的值； 123456789101112public class TtlTest { @Test public void Test001() { ThreadLocal<String&...
LockSupport
1. 简介为构建锁和同步器提供基本的线程阻塞唤醒原语，LockSupport中的park()和unpark()的作用分别是阻塞线程和解除阻塞线程。类似于wait和notify，类似于await和signal。 2. 使用示例1234567891011121314151617181920212223242526272829303132333435363738394041424344454647...