【有奖调研】来，聊聊TTS音色定制这件事儿
音色个性化定制，一个能让文字转语音服务（TTS）在用户交互过程中注入温度的技术。文能在营销及内容交付中让品牌保持一致性，武能让开发者“音”量加持，创新开发。这个100%钢铁纯技术，也是阿民奋斗路上的“温情”伙伴。阿民生在Y世代，长在春风里，偏爱听新闻和小说，是早期有声阅读的尝...
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
聊聊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
聊聊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
聊聊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
聊聊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
聊聊skywalking的CPUProvider
CPUProviderskywalking-6.6.0/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/jvm/cpu/CPUProvider.javapublic enum CPUProvider { INSTANCE; private CPUMetricsAccessor cpuMetricsAccessor; CPUProvider() { int process...
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
聊聊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
聊聊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
聊聊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
聊聊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的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
聊聊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
聊聊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
聊聊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的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
聊聊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
聊聊rocketmq的TransientStorePool
序本文主要研究一下rocketmq的TransientStorePoolTransientStorePoolrocketmq-all-4.6.0-source-release/store/src/main/java/org/apache/rocketmq/store/TransientStorePool.javapublic class TransientStorePool { private static final InternalLogger log = InternalLoggerFactor...
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
聊聊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
聊聊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
聊聊artemis的CriticalAnalyzerPolicy
CriticalAnalyzerPolicyactivemq-artemis-2.11.0/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/critical/CriticalAnalyzerPolicy.javapublic enum CriticalAnalyzerPolicy { HALT, SHUTDOWN, LOG; static { // for URI support on ClusterConne...
2024-01-10
