【有奖调研】来，聊聊TTS音色定制这件事儿
音色个性化定制，一个能让文字转语音服务（TTS）在用户交互过程中注入温度的技术。文能在营销及内容交付中让品牌保持一致性，武能让开发者“音”量加持，创新开发。这个100%钢铁纯技术，也是阿民奋斗路上的“温情”伙伴。阿民生在Y世代，长在春风里，偏爱听新闻和小说，是早期有声阅读的尝...
2024-01-10
聊聊canal的LogFetcher
序本文主要研究一下canal的LogFetcherLogFetchercanal-1.1.4/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogFetcher.javapublic abstract class LogFetcher extends LogBuffer implements Closeable { /** Default initial capacity. */ public static final int DEFA...
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
聊聊debezium的Heartbeat
Heartbeatdebezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/heartbeat/Heartbeat.javapublic interface Heartbeat { public static final String HEARTBEAT_INTERVAL_PROPERTY_NAME = "heartbeat.interval.ms"; @FunctionalInterface public static i...
2024-01-10
聊聊canal的ClientIdentity
序本文主要研究一下canal的ClientIdentityClientIdentitycanal-1.1.4/protocol/src/main/java/com/alibaba/otter/canal/protocol/ClientIdentity.javapublic class ClientIdentity implements Serializable { private static final long serialVersionUID = -8262100681930834834L; ...
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
聊聊carrera的BrokerMonitor
序本文主要研究一下carrera的BrokerMonitorBrokerMonitorDDMQ/carrera-monitor/src/main/java/com/xiaojukeji/carrera/monitor/broker/BrokerMonitor.javapublic class BrokerMonitor extends BaseConfigMonitor { private final static Logger LOGGER = LoggerFactory.getLogger(Bro...
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
聊聊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
聊聊chronos的MasterElection
序本文主要研究一下chronos的MasterElectionMasterElectionDDMQ/carrera-chronos/src/main/java/com/xiaojukeji/chronos/ha/MasterElection.javapublic class MasterElection { private static final Logger SWITCH_LOGGER = LogUtils.SWITCH_LOGGER; private static volatile Ser...
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
聊聊nacossdkgo的NamingProxy
序本文主要研究一下nacos-sdk-go的NamingProxyNamingProxynacos-sdk-go-v0.3.2/clients/naming_client/naming_proxy.gotype NamingProxy struct { clientConfig constant.ClientConfig nacosServer nacos_server.NacosServer}NamingProxy定义了clientConfig、nacosServer属性NewNamingProxyna...
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
聊聊artemis的BaseInterceptor
序本文主要研究一下artemis的BaseInterceptorBaseInterceptoractivemq-artemis-master/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/BaseInterceptor.javapublic interface BaseInterceptor<P> { /** * Intercepts a packet which is received before ...
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
聊聊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
聊聊debezium的ChangeEventQueue
ChangeEventQueueMetricsdebezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueueMetrics.javapublic interface ChangeEventQueueMetrics { int totalCapacity(); int remainingCapacity();}ChangeEventQueueMetrics接口定义了total...
2024-01-10
聊聊SpinalTap的MysqlEventFilter
序本文主要研究一下SpinalTap的MysqlEventFilterMysqlEventFilterSpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/filter/MysqlEventFilter.javapublic abstract class MysqlEventFilter implements Filter<BinlogEvent> { public static Filter<BinlogEven...
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
聊聊artemis的maxDeliveryAttempts
maxDeliveryAttemptsactivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.javapublic class AddressSettings implements Mergeable<AddressSettings>, Serializable, EncodingSupport { //...... publ...
2024-01-10
聊聊CanalEventDownStreamHandler
序本文主要研究一下CanalEventDownStreamHandlerCanalEventDownStreamHandlercanal-1.1.4/sink/src/main/java/com/alibaba/otter/canal/sink/CanalEventDownStreamHandler.javapublic interface CanalEventDownStreamHandler<T> extends CanalLifeCycle { /** * 提交到store之前做一下处理...
2024-01-10
聊聊rocketmq的ConsumeMode.ORDERLY
序本文主要研究一下rocketmq的ConsumeMode.ORDERLYConsumeMode.ORDERLYrocketmq-spring-boot-2.0.4-sources.jar!/org/apache/rocketmq/spring/annotation/ConsumeMode.javapublic enum ConsumeMode { /** * Receive asynchronously delivered messages concurrently */ CO...
2024-01-10
聊聊canal的ApplicationConfigMonitor
ApplicationConfigMonitorcanal-1.1.4/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/ApplicationConfigMonitor.java@Componentpublic class ApplicationConfigMonitor { private static final Logger logger = LoggerFactor...
2024-01-10
聊聊skywalking的RemoteClientManager
序本文主要研究一下skywalking的RemoteClientManagerRemoteClientManagerskywalking-6.6.0/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/remote/client/RemoteClientManager.javapublic class RemoteClientManager implements Service { private sta...
2024-01-10
聊聊rocketmq的CleanCommitLogService
序本文主要研究一下rocketmq的CleanCommitLogServiceCleanCommitLogServicerocketmq-all-4.6.0-source-release/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java class CleanCommitLogService { private final static int MAX_MANUAL_DELETE_FILE_TIM...
2024-01-10
