聊聊NPM镜像遇到的坑
前言由于国内网络环境的原因，在执行npm i安装项目依赖过程中，肯定会遇上安装过慢或安装失败的情况。有经验的同学通常会在安装完Node时顺便把NPM镜像设置成国内的淘宝镜像。npm config set registry https://registry.npm.taobao.org/这样就能爽歪歪应付大部分npm i的安装情况了。当然，这只是解决了大部分的...
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
聊聊artemis的ExpiryScanner
startExpiryScanneractivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/PostOfficeImpl.javapublic class PostOfficeImpl implements PostOffice, NotificationListener, BindingsFactory { //...... private Expir...
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
聊聊debezium的BinlogReader
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
聊聊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
聊聊canal的MysqlConnection
序本文主要研究一下canal的MysqlConnectionErosaConnectioncanal-1.1.4/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/ErosaConnection.javapublic interface ErosaConnection { public void connect() throws IOException; public void reconnect() throws IOExcep...
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
聊聊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的jedispulgin
skywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/jedis-2.x-plugin/src/main/resources/skywalking-plugin.defjedis-2.x=org.apache.skywalking.apm.plugin.jedis.v2.define.JedisClusterInstrumentationjedis-2.x=org.apache.skywalking.apm.plugin.jedis...
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
聊聊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
聊聊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
聊聊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的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的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
聊聊puma的ClientPositionService
序本文主要研究一下puma的ClientPositionServiceClientPositionServicepuma/puma/src/main/java/com/dianping/puma/biz/service/ClientPositionService.javapublic interface ClientPositionService { List<ClientPositionEntity> findAll(); ClientPositionEntity find(String cl...
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
聊聊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
聊聊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
聊聊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
聊聊dubbogo的registryAwareCluster
序本文主要研究一下dubbo-go的registryAwareClusterregistryAwareClusterdubbo-go-v1.4.2/cluster/cluster_impl/registry_aware_cluster.gotype registryAwareCluster struct{}func init() { extension.SetCluster("registryAware", NewRegistryAwareCluster)}// NewRegistryAwareCluste...
2024-01-10
聊聊rocketmq的MessageQueueSelector
序本文主要研究一下rocketmq的MessageQueueSelectorMessageQueueSelectorrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/producer/MessageQueueSelector.javapublic interface MessageQueueSelector { MessageQueue select(final List<MessageQueue> mqs, final Mes...
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
聊聊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
