聊聊OtterLauncher
序本文主要研究一下OtterLauncherOtterLauncherotter/node/deployer/src/main/java/com/alibaba/otter/node/deployer/OtterLauncher.javapublic class OtterLauncher { private static final Logger logger = LoggerFactory.getLogger(OtterLauncher.class); public static void ...
2024-01-10
聊聊CanalEventSink
序本文主要研究一下CanalEventSinkCanalEventSinkcanal-1.1.4/sink/src/main/java/com/alibaba/otter/canal/sink/CanalEventSink.javapublic interface CanalEventSink<T> extends CanalLifeCycle { /** * 提交数据 * * @param event * @param remoteAddress * @pa...
2024-01-10
聊聊RocketMQTemplate
序本文主要研究一下RocketMQTemplateRocketMQTemplaterocketmq-spring-boot-2.0.3-sources.jar!/org/apache/rocketmq/spring/core/RocketMQTemplate.javapublic class RocketMQTemplate extends AbstractMessageSendingTemplate<String> implements InitializingBean, DisposableBean {...
2024-01-10
聊聊kingbus的starRaft
序本文主要研究一下kingbus的starRaftstarRaftkingbus/server/server.gofunc (s *KingbusServer) starRaft(cfg config.RaftNodeConfig) error { var ( etcdRaftNode etcdraft.Node id types.ID cl *membership.RaftCluster remotes []*membership.Member ...
2024-01-10
聊聊chronos的cancelMessage
序本文主要研究一下chronos的cancelMessageMqPullServiceDDMQ/carrera-chronos/src/main/java/com/xiaojukeji/chronos/services/MqPullService.javapublic class MqPullService implements Runnable { private static final Logger LOGGER = LoggerFactory.getLogger(MqPullService.c...
2024-01-10
聊聊rocketmq的pullInterval
序本文主要研究一下rocketmq的pullIntervalpullIntervalrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.javapublic class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { private final InternalLogger l...
2024-01-10
聊聊artemis的ExpiryScanner
startExpiryScanneractivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/PostOfficeImpl.javapublic class PostOfficeImpl implements PostOffice, NotificationListener, BindingsFactory { //...... private Expir...
2024-01-10
聊聊skywalking的GCProvider
GCProviderskywalking-6.6.0/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/jvm/gc/GCProvider.javapublic enum GCProvider { INSTANCE; private GCMetricAccessor metricAccessor; private List<GarbageCollectorMXBean> beans; ...
2024-01-10
聊聊dubbogo的nacosRegistry
序本文主要研究一下dubbo-go的nacosRegistrynacosRegistrydubbo-go-v1.4.2/registry/nacos/registry.govar ( localIP = "")const ( //RegistryConnDelay registry connection delay RegistryConnDelay = 3)func init() { localIP, _ = gxnet.GetLocalIP() extension.SetRegistry(constan...
2024-01-10
聊聊rocketmq的pullBatchSize
序本文只要研究一下rocketmq的pullBatchSizepullBatchSizerocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.javapublic class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { private final InternalLogger...
2024-01-10
聊聊skywalking的kafkaplugin
序本文主要研究一下skywalking的kafka-pluginskywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/kafka-plugin/src/main/resources/skywalking-plugin.defkafka-0.11.x/1.x/2.x=org.apache.skywalking.apm.plugin.kafka.define.CallbackInstrumentationkafka-0.11.x/1.x...
2024-01-10
聊聊kingbus的startAdminServer
序本文主要研究一下kingbus的startAdminServerstartAdminServerkingbus/server/server.gofunc (s *KingbusServer) startAdminServer(urls types.URLs) error { if len(urls) != 1 { return ErrArgs } addr := urls[0].Host s.adminSvr = api.NewAdminServer(addr, s, s.cluster) return...
2024-01-10
聊聊artemis的lastValueProperty
CoreMessageactivemq-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 { //...... public SimpleString getLastValuePrope...
2024-01-10
聊聊rocketmqmysql的ColumnParser
序本文主要研究一下rocketmq-mysql的ColumnParserColumnParserrocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/ColumnParser.javapublic abstract class ColumnParser { public static ColumnParser getColumnParser(String dataType, Str...
2024-01-10
聊聊canal的PollingConfigService
PollingConfigServicecanal-1.1.4/canal-admin/canal-admin-server/src/main/java/com/alibaba/otter/canal/admin/service/PollingConfigService.javapublic interface PollingConfigService { public boolean autoRegister(String ip, Integer adminPort, String cluster)...
2024-01-10
聊聊skywalking的SamplingService
SamplingServiceskywalking-6.6.0/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/sampling/SamplingService.java@DefaultImplementorpublic class SamplingService implements BootService { private static final ILog logger = LogMan...
2024-01-10
聊聊dubbogo的PrometheusReporter
PrometheusReporterdubbo-go-v1.4.2/metrics/prometheus/reporter.goconst ( reporterName = "prometheus" serviceKey = constant.SERVICE_KEY groupKey = constant.GROUP_KEY versionKey = constant.VERSION_KEY methodKey = constant.METHOD_KEY timeoutKey = ...
2024-01-10
聊聊maxwell的BootstrapController
BootstrapControllermaxwell-1.25.1/src/main/java/com/zendesk/maxwell/bootstrap/BootstrapController.javapublic class BootstrapController extends RunLoopProcess { static final Logger LOGGER = LoggerFactory.getLogger(BootstrapController.class); private final ...
2024-01-10
聊聊maxwell的PositionStoreThread
PositionStoreThreadmaxwell-1.25.1/src/main/java/com/zendesk/maxwell/schema/PositionStoreThread.javapublic class PositionStoreThread extends RunLoopProcess implements Runnable { static final Logger LOGGER = LoggerFactory.getLogger(PositionStoreThread.class)...
2024-01-10
聊聊dubbogo的DefaultHealthChecker
DefaultHealthCheckerdubbo-go-v1.4.2/cluster/router/healthcheck/default_health_check.gofunc init() { extension.SethealthChecker(constant.DEFAULT_HEALTH_CHECKER, NewDefaultHealthChecker)}// DefaultHealthChecker is the default implementation of HealthChecker,...
2024-01-10
聊聊rocketmqmysql的EventProcessor
EventProcessorrocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/EventProcessor.javapublic class EventProcessor { private static final Logger LOGGER = LoggerFactory.getLogger(EventProcessor.class); private Replicator rep...
2024-01-10
聊聊skywalking的jvmreceiverplugin
序本文主要研究一下skywalking的jvm-receiver-pluginJVMModuleProviderskywalking-6.6.0/oap-server/server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/JVMModuleProvider.javapublic class JVMModuleProvi...
2024-01-10
聊聊debezium的ElapsedTimeStrategy
ElapsedTimeStrategydebezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/util/ElapsedTimeStrategy.java@FunctionalInterfacepublic interface ElapsedTimeStrategy { /** * Determine if the time period has elapsed since this method was last called...
2024-01-10
聊聊skywalking的clusternacosplugin
序本文主要研究一下skywalking的cluster-nacos-pluginClusterModuleNacosConfigskywalking-6.6.0/oap-server/server-cluster-plugin/cluster-nacos-plugin/src/main/java/org/apache/skywalking/oap/server/cluster/plugin/nacos/ClusterModuleNacosConfig.javapublic class ClusterModu...
2024-01-10
聊聊rocketmqclientgo的pushConsumer
序本文主要研究一下rocketmq-client-go的pushConsumerpushConsumerrocketmq-client-go-v2.0.0/consumer/push_consumer.gotype pushConsumer struct { *defaultConsumer queueFlowControlTimes int queueMaxSpanFlowControlTimes int consumeFunc utils.Set subm...
2024-01-10
