聊聊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
聊聊maxwell的FileProducer
FileProducermaxwell-1.25.1/src/main/java/com/zendesk/maxwell/producer/FileProducer.javapublic class FileProducer extends AbstractProducer { private final File file; private final FileWriter fileWriter; public FileProducer(MaxwellContext context, String fil...
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
聊聊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
聊聊CanalInstanceGenerator
序本文主要研究一下CanalInstanceGeneratorCanalInstanceGeneratorcanal-1.1.4/instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalInstanceGenerator.javapublic interface CanalInstanceGenerator { /** * 通过 destination 产生特定的 {@link CanalInstance} ...
2024-01-10
聊聊dubbogo的failbackCluster
序本文主要研究一下dubbo-go的failbackClusterfailbackClusterdubbo-go-v1.4.2/cluster/cluster_impl/failback_cluster.gotype failbackCluster struct{}const failback = "failback"func init() { extension.SetCluster(failback, NewFailbackCluster)}// NewFailbackCluster ...func N...
2024-01-10
聊聊nacossdkgo的NamingClient
序本文主要研究一下nacos-sdk-go的NamingClientNamingClientnacos-sdk-go-v0.3.2/clients/naming_client/naming_client.gotype NamingClient struct { nacos_client.INacosClient hostReactor HostReactor serviceProxy NamingProxy subCallback SubscribeCallback beatReactor BeatR...
2024-01-10
聊聊dubbogo的AccessLogFilter
序本文主要研究一下dubbo-go的AccessLogFilterAccessLogFilterdubbo-go-v1.4.2/filter/filter_impl/access_log_filter.gotype AccessLogFilter struct { logChan chan AccessLogData}AccessLogFilter定义了AccessLogData类型的chanInvokedubbo-go-v1.4.2/filter/filter_impl/access_log_filter...
2024-01-10
聊聊rocketmq的enableMsgTrace
序本文主要研究一下rocketmq的enableMsgTraceenableMsgTracerocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/producer/DefaultMQProducer.javapublic class DefaultMQProducer extends ClientConfig implements MQProducer { private final InternalLogger log = Cli...
2024-01-10
聊聊rocketmq的sendMsgTimeout
序本文主要研究一下rocketmq的sendMsgTimeoutDefaultMQProducerrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/producer/DefaultMQProducer.javapublic class DefaultMQProducer extends ClientConfig implements MQProducer { private final InternalLogger log = ...
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
聊聊skywalking的HTTPAccessLog
HTTPAccessLogskywalking-6.6.0/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/HTTPAccessLog.java@ScopeDeclaration(id = HTTP_ACCESS_LOG, name = "HTTPAccessLog")public class HTTPAccessLog extends AbstractLog { @Override p...
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
聊聊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
聊聊artemis的reconnectAttempts
reconnectAttemptsactivemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.javapublic final class ServerLocatorImpl implements ServerLocatorInternal, DiscoveryListener { //...... public Cli...
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的persistenceEnabled
persistenceEnabledactivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImpl.javapublic class ConfigurationImpl implements Configuration, Serializable { //...... private boolean persistenceEnable...
2024-01-10
聊聊skywalking的httpclientplugin
skywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/httpClient-4.x-plugin/src/main/resources/skywalking-plugin.defhttpclient-4.x=org.apache.skywalking.apm.plugin.httpClient.v4.define.AbstractHttpClientInstrumentationhttpclient-4.x=org.apache.s...
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
聊聊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
聊聊canal的MysqlDetectingTimeTask
序本文主要研究一下canal的MysqlDetectingTimeTaskMysqlDetectingTimeTaskcanal-1.1.4/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java class MysqlDetectingTimeTask extends TimerTask { private boolean reconnect = fals...
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的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的ServiceResetCommand
序本文主要研究一下skywalking的ServiceResetCommandServiceResetCommandskywalking-6.6.0/apm-protocol/apm-network/src/main/java/org/apache/skywalking/apm/network/trace/component/command/ServiceResetCommand.javapublic class ServiceResetCommand extends BaseCommand impleme...
2024-01-10
