聊聊CanalInstance
序本文主要研究一下CanalInstanceCanalLifeCyclecanal-1.1.4/common/src/main/java/com/alibaba/otter/canal/common/CanalLifeCycle.javapublic interface CanalLifeCycle { void start(); void stop(); boolean isStart();}CanalLifeCycle接口定义了start、stop、isStart方法AbstractC...
2024-01-10
聊聊OtterController
序本文主要研究一下OtterControllerOtterControllerotter/node/etl/src/main/java/com/alibaba/otter/node/etl/OtterController.javapublic class OtterController implements NodeTaskListener, OtterControllerMBean { private static final Logger logger ...
2024-01-10
聊聊artemis的QuorumVote
QuorumVoteactivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumVote.javapublic abstract class QuorumVote<V extends Vote, T> { private SimpleString name; public QuorumVote(SimpleString name) {...
2024-01-10
聊聊chronos的addMessage
序本文主要研究一下chronos的addMessageaddMessageDDMQ/carrera-chronos/src/main/java/com/xiaojukeji/chronos/services/MqPullService.javapublic class MqPullService implements Runnable { private static final Logger LOGGER = LoggerFactory.getLogger(MqPullService.class);...
2024-01-10
聊聊MaxwellKafkaProducer
MaxwellKafkaProducermaxwell-1.25.1/src/main/java/com/zendesk/maxwell/producer/MaxwellKafkaProducer.javapublic class MaxwellKafkaProducer extends AbstractProducer { private final ArrayBlockingQueue<RowMap> queue; private final MaxwellKafkaProducerWorker wor...
2024-01-10
聊聊kingbus的startRaftPeer
序本文主要研究一下kingbus的startRaftPeerstartRaftPeerkingbus/server/server.gofunc (s *KingbusServer) startRaftPeer(peerURLs types.URLs) error { err := s.raftNode.NewPeerListener(peerURLs) if err != nil { return err } s.raftNode.SetPeerHandler() s.raftNode.PeerHandl...
2024-01-10
聊聊artemis的QuorumManager
ClusterTopologyListeneractivemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/ClusterTopologyListener.javapublic interface ClusterTopologyListener { /** * Triggered when a node joins the cluster. * ...
2024-01-10
聊聊chronos的DeleteBgWorker
序本文主要研究一下chronos的DeleteBgWorkerDeleteBgWorkerDDMQ/carrera-chronos/src/main/java/com/xiaojukeji/chronos/workers/DeleteBgWorker.javapublic class DeleteBgWorker { private static final Logger LOGGER = LoggerFactory.getLogger(DeleteBgWorker.class); privat...
2024-01-10
聊聊canal的CanalEventFilter
CanalEventFiltercanal-1.1.4/filter/src/main/java/com/alibaba/otter/canal/filter/CanalEventFilter.javapublic interface CanalEventFilter<T> { boolean filter(T event) throws CanalFilterException;}CanalEventFilter接口定义了filter方法AviaterELFiltercanal-1.1.4/filt...
2024-01-10
聊聊MaxwellKafkaPartitioner
序本文主要研究一下MaxwellKafkaPartitionerMaxwellKafkaPartitionermaxwell-1.25.1/src/main/java/com/zendesk/maxwell/producer/partitioners/MaxwellKafkaPartitioner.javapublic class MaxwellKafkaPartitioner extends AbstractMaxwellPartitioner { HashFunction hashFunc; publi...
2024-01-10
聊聊dubbogo的availableCluster
序本文主要研究一下dubbo-go的availableClusterNewAvailableClusterdubbo-go-v1.4.2/cluster/cluster_impl/available_cluster.gotype availableCluster struct{}const available = "available"func init() { extension.SetCluster(available, NewAvailableCluster)}// NewAvailableClust...
2024-01-10
聊聊rocketmqmysql的Replicator
序本文主要研究一下rocketmq-mysql的ReplicatorReplicatorrocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/Replicator.javapublic class Replicator { private static final Logger LOGGER = LoggerFactory.getLogger(Replicator.class); private sta...
2024-01-10
聊聊skywaking的CommandService
CommandServiceskywalking-6.6.0/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/commands/CommandService.java@DefaultImplementorpublic class CommandService implements BootService, Runnable { private static final ILog LOGGER =...
2024-01-10
聊聊kingbus的startMasterServer
序本文主要研究一下kingbus的startMasterServerstartMasterServerkingbus/server/server.gofunc (s *KingbusServer) startMasterServer(args *config.BinlogServerConfig) error { master, err := NewBinlogServer(args, s, s.store, s.applyBroadcast) if err != nil { log.Log.Errorf...
2024-01-10
聊聊CarreraProducer的sendDelay
序本文主要研究一下CarreraProducer的sendDelayProducerInterfaceDDMQ/carrera-sdk/producer/java/carrera-producer-sdk/src/main/java/com/xiaojukeji/carrera/producer/ProducerInterface.javapublic interface ProducerInterface { void start() throws Exception; void shutdo...
2024-01-10
聊聊skywalking的MemoryProvider
MemoryProviderskywalking-6.6.0/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/jvm/memory/MemoryProvider.javapublic enum MemoryProvider { INSTANCE; private final MemoryMXBean memoryMXBean; MemoryProvider() { th...
2024-01-10
聊聊dubbogo的kubernetesRegistry
序本文主要研究一下dubbo-go的kubernetesRegistrykubernetesRegistrydubbo-go-v1.4.2/registry/kubernetes/registry.govar ( processID = "" localIP = "")const ( Name = "kubernetes" ConnDelay = 3 MaxFailTimes = 15)func init() { processID = fmt.Sprintf("%d", os.G...
2024-01-10
聊聊rocketmq的maxReconsumeTimes
序本文主要研究一下rocketmq的maxReconsumeTimesmaxReconsumeTimesrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.javapublic class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { private final Intern...
2024-01-10
聊聊dubbogo的apolloConfiguration
apolloConfigurationdubbo-go-v1.4.2/config_center/apollo/impl.goconst ( apolloProtocolPrefix = "http://" apolloConfigFormat = "%s.%s")type apolloConfiguration struct { url *common.URL listeners sync.Map appConf *agollo.AppConfig parser parser.Configu...
2024-01-10
聊聊debezium的OffsetCommitPolicy
OffsetCommitPolicydebezium-v1.1.1.Final/debezium-api/src/main/java/io/debezium/engine/spi/OffsetCommitPolicy.java@Incubating@FunctionalInterfacepublic interface OffsetCommitPolicy { boolean performCommit(long numberOfMessagesSinceLastCommit, Duration ti...
2024-01-10
聊聊rocketmq的MessageQueueSelector
序本文主要研究一下rocketmq的MessageQueueSelectorMessageQueueSelectorrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/producer/MessageQueueSelector.javapublic interface MessageQueueSelector { MessageQueue select(final List<MessageQueue> mqs, final Mes...
2024-01-10
聊聊rocketmqclientgo的PullConsumer
序本文主要研究一下rocketmq-client-go的PullConsumerPullConsumerrocketmq-client-go-v2.0.0/consumer/pull_consumer.gotype PullConsumer interface { // Start Start() // Shutdown refuse all new pull operation, finish all submitted. Shutdown() // Pull pull message of topic,...
2024-01-10
聊聊skywalking的jdkthreadingplugin
序本文主要研究一下skywalking的jdk-threading-pluginskywalking-plugin.defskywalking-6.6.0/apm-sniffer/bootstrap-plugins/jdk-threading-plugin/src/main/resources/skywalking-plugin.defjdk-threading-plugin=org.apache.skywalking.apm.plugin.jdk.threading.define.RunnableInst...
2024-01-10
聊聊skywalking的storagezipkinplugin
序本文主要研究一下skywalking的storage-zipkin-pluginZipkinStorageModuleElasticsearchProviderskywalking-6.6.0/oap-server/server-storage-plugin/storage-zipkin-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/zipkin/elasticsearch/ZipkinStorageModuleE...
2024-01-10
聊聊rocketmq的pullThresholdForTopic
序本文主要研究一下rocketmq的pullThresholdForTopicpullThresholdForTopicrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.javapublic class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { //...... /**...
2024-01-10
