【有奖调研】来，聊聊TTS音色定制这件事儿
音色个性化定制，一个能让文字转语音服务（TTS）在用户交互过程中注入温度的技术。文能在营销及内容交付中让品牌保持一致性，武能让开发者“音”量加持，创新开发。这个100%钢铁纯技术，也是阿民奋斗路上的“温情”伙伴。阿民生在Y世代，长在春风里，偏爱听新闻和小说，是早期有声阅读的尝...
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
聊聊canal的BooleanMutex
BooleanMutexcanal-1.1.4/common/src/main/java/com/alibaba/otter/canal/common/utils/BooleanMutex.javapublic class BooleanMutex { private Sync sync; public BooleanMutex(){ sync = new Sync(); set(false); } public BooleanMutex(Boolean ...
2024-01-10
聊聊kingbus的DumpBinlogAt
序本文主要研究一下kingbus的DumpBinlogAtDumpBinlogAtkingbus/server/binlog_server.go//DumpBinlogAt implements dump binlog event by slave executed gtid setfunc (s *BinlogServer) DumpBinlogAt(ctx context.Context, startRaftIndex uint64, slaveGtids *gomysql.MysqlGTIDSet, ...
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
聊聊debezium的RecordMakers
RecordMakersdebezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/RecordMakers.javapublic class RecordMakers { private final Logger logger = LoggerFactory.getLogger(getClass()); private final MySqlSchema schema; ...
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
聊聊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
聊聊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
聊聊rocketmq的consumeThread
序本文主要研究一下rocketmq的consumeThreadDefaultMQPushConsumerrocketmq-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的broadcastCluster
序本文主要研究一下dubbo-go的broadcastClusterbroadcastClusterdubbo-go-v1.4.2/cluster/cluster_impl/broadcast_cluster.gotype broadcastCluster struct{}const broadcast = "broadcast"func init() { extension.SetCluster(broadcast, NewBroadcastCluster)}// NewBroadcastCluster ...
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的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
聊聊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的LitePullConsumer
序本文主要研究一下rocketmq的LitePullConsumerLitePullConsumerrocketmq-all-4.6.0-source-release/client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.javapublic interface LitePullConsumer { void start() throws MQClientException; void shutdown...
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
聊聊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
聊聊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
聊聊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
聊聊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
聊聊artemis的ActiveMQMetricsPlugin
ActiveMQMetricsPluginactivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/metrics/ActiveMQMetricsPlugin.javapublic interface ActiveMQMetricsPlugin extends Serializable { ActiveMQMetricsPlugin init(Map<String, Strin...
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
聊聊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
聊聊rocketmq的pullThresholdForQueue
序本文主要研究一下rocketmq的pullThresholdForQueuepullThresholdForQueuerocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.javapublic class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { //...... /**...
2024-01-10
