聊聊puma的Sender
序本文主要研究一下puma的SenderSenderpuma/puma/src/main/java/com/dianping/puma/sender/Sender.javapublic interface Sender extends LifeCycle { String getName(); void send(ChangedEvent event, PumaContext context) throws SenderException;}Sender定义了getName、send方法Abst...
2024-01-10
聊聊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
聊聊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
聊聊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
聊聊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
聊聊dubbogo的DubboPackage
序本文只要研究一下dubbo-go的DubboPackageDubboPackagedubbo-go-v1.4.2/protocol/dubbo/codec.go//CallType call typetype CallType int32const ( // CT_UNKNOWN unknown call type CT_UNKNOWN CallType = 0 // CT_OneWay call one way CT_OneWay CallType = 1 // CT_TwoWay call in re...
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
聊聊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
聊聊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
聊聊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的RPCInvocation
序本文主要研究一下dubbo-go的RPCInvocationInvocationdubbo-go-v1.4.2/protocol/invocation.go// Invocation ...type Invocation interface { MethodName() string ParameterTypes() []reflect.Type ParameterValues() []reflect.Value Arguments() []interface{} Reply() interface{} ...
2024-01-10
聊聊dubbogo的metricsFilter
序本文主要研究一下dubbo-go的metricsFiltermetricsFilterdubbo-go-v1.4.2/filter/filter_impl/metrics_filter.goconst ( metricFilterName = "metrics")var ( metricFilterInstance filter.Filter)// must initialized before using the filter and after loading configurationfunc in...
2024-01-10
聊聊skywalking的JVMService
BootServiceskywalking-6.6.0/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/boot/BootService.javapublic interface BootService { void prepare() throws Throwable; void boot() throws Throwable; void onComplete() throws T...
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
聊聊nacossdkgo的ConfigProxy
ConfigProxynacos-sdk-go-v0.3.2/clients/config_client/config_proxy.gotype ConfigProxy struct { nacosServer nacos_server.NacosServer clientConfig constant.ClientConfig}ConfigProxy定义了nacosServer、clientConfig属性NewConfigProxynacos-sdk-go-v0.3.2/clients/config_...
2024-01-10
聊聊debezium的eventHandlers
handleInsertdebezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.javapublic class BinlogReader extends AbstractReader { //...... protected void handleInsert(Event event) throws InterruptedException { ...
2024-01-10
聊聊skywalking的mysqlplugin
skywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/mysql-8.x-plugin/src/main/resources/skywalking-plugin.defmysql-8.x=org.apache.skywalking.apm.plugin.jdbc.mysql.v8.define.ConnectionImplCreateInstrumentationmysql-8.x=org.apache.skywalking.apm...
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
聊聊dubbogo的forkingCluster
序本文主要研究一下dubbo-go的forkingClusterforkingClusterdubbo-go-v1.4.2/cluster/cluster_impl/forking_cluster.gotype forkingCluster struct{}const forking = "forking"func init() { extension.SetCluster(forking, NewForkingCluster)}// NewForkingCluster ...func NewForking...
2024-01-10
聊聊debezium的BlockingReader
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
聊聊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
聊聊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
聊聊rocketmq的SlaveSynchronize
序本文主要研究一下rocketmq的SlaveSynchronizeBrokerControllerrocketmq-all-4.6.0-source-release/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.javapublic class BrokerController { //...... private void handleSlaveSynchronize(BrokerRole role) { ...
2024-01-10
聊聊artemis的NetworkHealthCheck
NetworkHealthCheckactivemq-artemis-2.11.0/artemis-commons/src/main/java/org/apache/activemq/artemis/core/server/NetworkHealthCheck.javapublic class NetworkHealthCheck extends ActiveMQScheduledComponent { private static final Logger logger = Logger.getLog...
2024-01-10
