debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/Reader.java

debezium-v1.1.1.Final/debezium-embedded/src/main/java/io/debezium/connector/simple/SimpleSourceConnector.java

maxwell-1.25.1/src/main/java/com/zendesk/maxwell/recovery/Recovery.java

maxwell-1.25.1/src/main/java/com/zendesk/maxwell/scripting/Scripting.java

puma/puma/src/main/java/com/dianping/puma/biz/service/ClientPositionService.java

序 本文主要研究一下puma的Sender Sender puma/puma/src/main/java/com/dianping/puma/sender/Sender.java {代码...} Sender定义了getName、send方法 AbstractSender puma/puma/src/main/java/com/dianping/puma/sender/AbstractSender.java {代码...} AbstractSender声明实现了Sender接口，其send方法通过while循环执行...

puma/puma/src/main/java/com/dianping/puma/sender/dispatcher/Dispatcher.java

canal-1.1.4/server/src/main/java/com/alibaba/otter/canal/spi/CanalMetricsService.java

canal-1.1.4/canal-admin/canal-admin-server/src/main/java/com/alibaba/otter/canal/admin/service/PollingConfigService.java

canal-1.1.4/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/EventTransactionBuffer.java

canal-1.1.4/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/ErosaConnection.java

rocketmq/acl/src/main/java/org/apache/rocketmq/acl/AccessValidator.java

rocketmq-spring-boot-2.0.3-sources.jar!/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java

canal-1.1.4/protocol/src/main/java/com/alibaba/otter/canal/protocol/ClientIdentity.java

dubbo-2.7.3/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/context/annotation/DubboComponentScanRegistrar.java

序 本文主要研究一下feign的Contract Contract feign-core-10.2.3-sources.jar!/feign/Contract.java {代码...} Contract定义了parseAndValidatateMetadata方法，该方法返回List形式的MethodMetadata Contract.BaseContract feign-core-10.2.3-sources.jar!/feign/Contract.java {代码...} Contract.BaseContract是个抽...

Retryer继承了Cloneable接口，它定义了continueOrPropagate、clone方法；它内置了一个名为Default以及名为NEVER_RETRY的实现