【有奖调研】来，聊聊TTS音色定制这件事儿
音色个性化定制，一个能让文字转语音服务（TTS）在用户交互过程中注入温度的技术。文能在营销及内容交付中让品牌保持一致性，武能让开发者“音”量加持，创新开发。这个100%钢铁纯技术，也是阿民奋斗路上的“温情”伙伴。阿民生在Y世代，长在春风里，偏爱听新闻和小说，是早期有声阅读的尝...
2024-01-10
聊聊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
聊聊DebeziumEngine
DebeziumEnginedebezium-v1.1.1.Final/debezium-api/src/main/java/io/debezium/engine/DebeziumEngine.java@Incubatingpublic interface DebeziumEngine<R> extends Runnable, Closeable { //...... public static <T> Builder<T> create(Class<? extends ChangeEventFor...
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
聊聊dubbogo的HystrixFilter
序本文主要研究一下dubbo-go的HystrixFilterHystrixFilterdubbo-go-v1.4.2/filter/filter_impl/hystrix_filter.go// HystrixFilter ...type HystrixFilter struct { COrP bool //true for consumer res map[string][]*regexp.Regexp ifNewMap sync.Map}HystrixFilter定义了COrP、re...
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
聊聊canal的DirectLogFetcher
序本文主要研究一下canal的DirectLogFetcherDirectLogFetchercanal-1.1.4/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/DirectLogFetcher.javapublic final class DirectLogFetcher extends LogFetcher { protected static final Log logger = LogF...
2024-01-10
聊聊artemis的FederatedQueue
FederatedQueueactivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/federation/queue/FederatedQueue.javapublic class FederatedQueue extends FederatedAbstract implements ActiveMQServerConsumerPlugin, Serializable { p...
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
聊聊nacossdkgo的BeatReactor
序本文主要研究一下nacos-sdk-go的BeatReactorBeatReactornacos-sdk-go-v0.3.2/clients/naming_client/beat_reactor.gotype BeatReactor struct { beatMap cache.ConcurrentMap serviceProxy NamingProxy clientBeatInterval int64 beatThreadCount int beatThr...
2024-01-10
聊聊artemis的DiscoveryGroup
DiscoveryGroupactivemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/cluster/DiscoveryGroup.javapublic final class DiscoveryGroup implements ActiveMQComponent { private static final Logger logger = Logger.getLogger(Dis...
2024-01-10
聊聊nacossdkgo的PushReceiver
序本文主要研究一下nacos-sdk-go的PushReceiverPushReceivernacos-sdk-go-v0.3.2/clients/naming_client/push_receiver.gotype PushReceiver struct { port int host string hostReactor *HostReactor}PushReceiver定义了port、host、hostReactor属性NewPushReceviernacos-sdk-go...
2024-01-10
聊聊dubbogo的failsafeCluster
序本文主要研究一下dubbo-go的failsafeClusterfailsafeClusterdubbo-go-v1.4.2/cluster/cluster_impl/failsafe_cluster.gotype failsafeCluster struct{}const failsafe = "failsafe"func init() { extension.SetCluster(failsafe, NewFailsafeCluster)}// NewFailsafeCluster ...func N...
2024-01-10
聊聊rocketmq的AccessValidator
序本文主要研究一下rocketmq的AccessValidatorAccessValidatorrocketmq/acl/src/main/java/org/apache/rocketmq/acl/AccessValidator.javapublic interface AccessValidator { /** * Parse to get the AccessResource(user, resource, needed permission) * * @param req...
2024-01-10
聊聊puma的DefaultTaskExecutor
序本文主要研究一下puma的DefaultTaskExecutorTaskExecutorpuma/puma/src/main/java/com/dianping/puma/taskexecutor/TaskExecutor.javapublic interface TaskExecutor extends LifeCycle { boolean isStop(); boolean isMerging(); void stopUntil(long timestamp); void c...
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
聊聊rocketmq的AclClientRPCHook
序本文主要研究一下rocketmq的AclClientRPCHookRPCHookrocketmq-remoting-4.5.2-sources.jar!/org/apache/rocketmq/remoting/RPCHook.javapublic interface RPCHook { void doBeforeRequest(final String remoteAddr, final RemotingCommand request); void doAfterResponse(final...
2024-01-10
聊聊rocketmq的ConsumeFromWhere
序本文主要研究一下rocketmq的ConsumeFromWhereConsumeFromWhererocketmq-common-4.5.2-sources.jar!/org/apache/rocketmq/common/consumer/ConsumeFromWhere.javapublic enum ConsumeFromWhere { CONSUME_FROM_LAST_OFFSET, @Deprecated CONSUME_FROM_LAST_OFFSET_AND_FROM_MI...
2024-01-10
聊聊dubbogo的ProviderAuthFilter
序本文主要研究一下dubbo-go的ProviderAuthFilterProviderAuthFilterdubbo-go-v1.4.2/filter/filter_impl/auth/provider_auth.gotype ProviderAuthFilter struct {}func init() { extension.SetFilter(constant.PROVIDER_AUTH_FILTER, getProviderAuthFilter)}ProviderAuthFilter的init方法...
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
聊聊dubbogo的ConsumerSignFilter
序本文主要研究一下dubbo-go的ConsumerSignFilterConsumerSignFilterdubbo-go-v1.4.2/filter/filter_impl/auth/consumer_sign.gotype ConsumerSignFilter struct {}func init() { extension.SetFilter(constant.CONSUMER_SIGN_FILTER, getConsumerSignFilter)}ConsumerSignFilter的init方法...
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的dubbo2.7.xplugin
skywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/dubbo-2.7.x-plugin/src/main/resources/skywalking-plugin.defdubbo=org.apache.skywalking.apm.plugin.asf.dubbo.DubboInstrumentationskywalking的dubbo-plugin提供了DubboInstrumentation增强DubboInstrument...
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
聊聊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
