聊聊DebeziumEngine
DebeziumEnginedebezium-v1.1.1.Final/debezium-api/src/main/java/io/debezium/engine/DebeziumEngine.java@Incubatingpublic interface DebeziumEngine<R> extends Runnable, Closeable { //...... public static <T> Builder<T> create(Class<? extends ChangeEventFor...
2024-01-10
聊聊SkyWalkingAgent
SkyWalkingAgentskywalking-6.6.0/apm-sniffer/apm-agent/src/main/java/org/apache/skywalking/apm/agent/SkyWalkingAgent.javapublic class SkyWalkingAgent { private static final ILog logger = LogManager.getLogger(SkyWalkingAgent.class); /** * Main entr...
2024-01-10
聊聊canal的LogFetcher
序本文主要研究一下canal的LogFetcherLogFetchercanal-1.1.4/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogFetcher.javapublic abstract class LogFetcher extends LogBuffer implements Closeable { /** Default initial capacity. */ public static final int DEFA...
2024-01-10
聊聊puma的ChangedEvent
序本文主要研究一下puma的ChangedEventEventpuma/core/src/main/java/com/dianping/puma/core/event/Event.javapublic abstract class Event implements Serializable { private static final long serialVersionUID = 7986284681273254505L; private long seq; public void setSeq(long...
2024-01-10
聊聊canal的ClientIdentity
序本文主要研究一下canal的ClientIdentityClientIdentitycanal-1.1.4/protocol/src/main/java/com/alibaba/otter/canal/protocol/ClientIdentity.javapublic class ClientIdentity implements Serializable { private static final long serialVersionUID = -8262100681930834834L; ...
2024-01-10
聊聊debezium的BinlogReader
Readerdebezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/Reader.javapublic interface Reader { public static enum State { /** * The reader is stopped and static. */ STOPPED, /** ...
2024-01-10
聊聊dubbogo的HystrixFilter
序本文主要研究一下dubbo-go的HystrixFilterHystrixFilterdubbo-go-v1.4.2/filter/filter_impl/hystrix_filter.go// HystrixFilter ...type HystrixFilter struct { COrP bool //true for consumer res map[string][]*regexp.Regexp ifNewMap sync.Map}HystrixFilter定义了COrP、re...
2024-01-10
聊聊SpinalTap的BinlogEvent
序本文主要研究一下SpinalTap的BinlogEventBinlogEventSpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/BinlogEvent.java@Getter@ToStringpublic abstract class BinlogEvent extends SourceEvent { private final long tableId; private final long serve...
2024-01-10
聊聊artemis的groupRebalance
groupRebalanceactivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.javapublic class QueueImpl extends CriticalComponentImpl implements Queue { //...... private volatile boolean groupRebalance; pr...
2024-01-10
聊聊rocketmq的AccessChannel
序本文主要研究一下rocketmq的AccessChannelAccessChannelrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/AccessChannel.javapublic enum AccessChannel { /** * Means connect to private IDC cluster. */ LOCAL, /** * Means connect to Cloud ...
2024-01-10
聊聊nacossdkgo的BeatReactor
序本文主要研究一下nacos-sdk-go的BeatReactorBeatReactornacos-sdk-go-v0.3.2/clients/naming_client/beat_reactor.gotype BeatReactor struct { beatMap cache.ConcurrentMap serviceProxy NamingProxy clientBeatInterval int64 beatThreadCount int beatThr...
2024-01-10
聊聊dubbogo的TpsLimitFilter
序本文主要研究一下dubbo-go的TpsLimitFilterTpsLimitFilterdubbo-go-v1.4.2/filter/filter_impl/tps_limit_filter.goconst ( // TpsLimitFilterKey key TpsLimitFilterKey = "tps")func init() { extension.SetFilter(TpsLimitFilterKey, GetTpsLimitFilter)}type TpsLimitFilter struc...
2024-01-10
聊聊nacossdkgo的PushReceiver
序本文主要研究一下nacos-sdk-go的PushReceiverPushReceivernacos-sdk-go-v0.3.2/clients/naming_client/push_receiver.gotype PushReceiver struct { port int host string hostReactor *HostReactor}PushReceiver定义了port、host、hostReactor属性NewPushReceviernacos-sdk-go...
2024-01-10
聊聊dubbogo的failsafeCluster
序本文主要研究一下dubbo-go的failsafeClusterfailsafeClusterdubbo-go-v1.4.2/cluster/cluster_impl/failsafe_cluster.gotype failsafeCluster struct{}const failsafe = "failsafe"func init() { extension.SetCluster(failsafe, NewFailsafeCluster)}// NewFailsafeCluster ...func N...
2024-01-10
聊聊canal的CanalAdapterWorker
CanalAdapterWorkercanal-1.1.4/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterWorker.javapublic class CanalAdapterWorker extends AbstractCanalAdapterWorker { private static final int BATCH_SIZE = 50; ...
2024-01-10
聊聊rocketmq的AccessValidator
序本文主要研究一下rocketmq的AccessValidatorAccessValidatorrocketmq/acl/src/main/java/org/apache/rocketmq/acl/AccessValidator.javapublic interface AccessValidator { /** * Parse to get the AccessResource(user, resource, needed permission) * * @param req...
2024-01-10
聊聊skywalking的rocketmqplugin
skywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/rocketMQ-4.x-plugin/src/main/resources/skywalking-plugin.defrocketMQ-4.x=org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageConcurrentlyInstrumentationrocketMQ-4.x=org.apache.s...
2024-01-10
聊聊rocketmq的AclClientRPCHook
序本文主要研究一下rocketmq的AclClientRPCHookRPCHookrocketmq-remoting-4.5.2-sources.jar!/org/apache/rocketmq/remoting/RPCHook.javapublic interface RPCHook { void doBeforeRequest(final String remoteAddr, final RemotingCommand request); void doAfterResponse(final...
2024-01-10
聊聊dubbogo的ConsumerSignFilter
序本文主要研究一下dubbo-go的ConsumerSignFilterConsumerSignFilterdubbo-go-v1.4.2/filter/filter_impl/auth/consumer_sign.gotype ConsumerSignFilter struct {}func init() { extension.SetFilter(constant.CONSUMER_SIGN_FILTER, getConsumerSignFilter)}ConsumerSignFilter的init方法...
2024-01-10
聊聊carrera的GroovyScriptAction
序本文主要研究一下carrera的GroovyScriptActionActionDDMQ/carrera-consumer/src/main/java/com/xiaojukeji/carrera/cproxy/actions/Action.javapublic interface Action { enum Status { FAIL, CONTINUE, FINISH, ASYNCHRONIZED } class UnsupportedDataType extends ...
2024-01-10
聊聊artemis的callFailoverTimeout
establishNewConnectionactivemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.javapublic class ClientSessionFactoryImpl implements ClientSessionFactoryInternal, ClientConnectionLifeCyc...
2024-01-10
聊聊canal的EventTransactionBuffer
序本文主要研究一下canal的EventTransactionBufferEventTransactionBuffercanal-1.1.4/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/EventTransactionBuffer.javapublic class EventTransactionBuffer extends AbstractCanalLifeCycle { private static final long ...
2024-01-10
聊聊dubbogo的registryAwareCluster
序本文主要研究一下dubbo-go的registryAwareClusterregistryAwareClusterdubbo-go-v1.4.2/cluster/cluster_impl/registry_aware_cluster.gotype registryAwareCluster struct{}func init() { extension.SetCluster("registryAware", NewRegistryAwareCluster)}// NewRegistryAwareCluste...
2024-01-10
聊聊artemis的scheduledDeliveryTime
HDR_SCHEDULED_DELIVERY_TIMEactivemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.javapublic class CoreMessage extends RefCountMessage implements ICoreMessage { //...... @Override public Lo...
2024-01-10
聊聊rocketmqclientgo的QueueSelector
序本文主要研究一下rocketmq-client-go的QueueSelectorQueueSelectorrocketmq-client-go-v2.0.0/producer/selector.gotype QueueSelector interface { Select(*primitive.Message, []*primitive.MessageQueue) *primitive.MessageQueue}QueueSelector接口，定义了Select方法manualQueueSelectorr...
2024-01-10
