加载中
聊聊flink的AscendingTimestampExtractor

序 本文主要研究一下flink的AscendingTimestampExtractor AscendingTimestampExtractor flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/functions/timestamp...

2018/12/20 15:26
254
聊聊EurekaHealthCheckHandler

序 本文主要研究一下EurekaHealthCheckHandler HealthCheckHandler eureka-client-1.8.8-sources.jar!/com/netflix/appinfo/HealthCheckHandler.java /** * This provides a more granular...

2018/04/30 15:50
157
聊聊sentinel的SentinelResourceAspect

序 本文主要研究一下sentinel的SentinelResourceAspect SentinelResourceAspect com/alibaba/csp/sentinel/annotation/aspectj/SentinelResourceAspect.java @Aspect public class Sentinel...

2018/08/18 23:40
84
聊聊spring cloud gateway的GlobalFilter

序 本文主要研究一下spring cloud gateway的GlobalFilter GatewayAutoConfiguration spring-cloud-gateway-core-2.0.0.RC2-sources.jar!/org/springframework/cloud/gateway/config/Gateway...

2018/06/08 13:38
273
reactor-netty中TcpClient的newHandler过程

序 本文主要研究一下reactor-netty中TcpClient的newHandler过程 maven     <dependency>       <groupId>io.projectreactor.ipc</groupId>       <artifactId>reactor-netty</artifactId>       <versi...

2018/02/21 08:51
158
聊聊flink的SourceFunction

序 本文主要研究一下flink的SourceFunction 实例 // set up the execution environment final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); ....

2018/11/27 14:15
51
聊聊sentinel的SimpleHttpCommandCenter

序 本文主要研究一下sentinel的SimpleHttpCommandCenter SimpleHttpCommandCenter sentinel-transport-simple-http-0.1.1-sources.jar!/com/alibaba/csp/sentinel/transport/command/Simple...

2018/08/14 14:45
62
聊聊sentinel的NettyHttpCommandCenter

序 本文主要研究一下sentinel的NettyHttpCommandCenter NettyHttpCommandCenter com/alibaba/csp/sentinel/transport/command/NettyHttpCommandCenter.java public class NettyHttpCommandC...

2018/08/20 14:30
20
spring cloud config与bus结合

##整体流程 默认gitlab的webhook更新调用config server的/monitor(spring-cloud-config-monitor)触发RefreshRemoteApplicationEvent事件,然后spring cloud bus的StreamListener监听RemoteA...

2016/12/05 11:13
119
聊聊storm的WindowedBoltExecutor

序 本文主要研究一下storm的WindowedBoltExecutor WindowedBoltExecutor storm-2.0.0/storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java /** An {@link IWindowedB...

2018/10/25 13:49
18
聊聊HystrixEventNotifier

序 本文主要研究一下HystrixEventNotifier HystrixEventNotifier /** Abstract EventNotifier that allows receiving notifications for different events with default implementations. <...

2018/06/29 09:43
21
聊聊flink的TimeCharacteristic

序 本文主要研究一下flink的TimeCharacteristic TimeCharacteristic flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/TimeCharacteristic.java /** The time ...

2018/12/18 11:18
70
聊聊flink的log.file配置

序 本文主要研究一下flink的log.file配置 log4j.properties flink-release-1.6.2/flink-dist/src/main/flink-bin/conf/log4j.properties # This affects logging for both user code and Fli...

2018/11/22 16:49
565
聊聊storm的IEventLogger

序 本文主要研究一下storm的IEventLogger IEventLogger storm-2.0.0/storm-client/src/jvm/org/apache/storm/metric/IEventLogger.java /** EventLogger interface for logging the event in...

2018/11/05 09:12
8
聊聊dubbo的AwaitingNonWebApplicationListener

序 本文主要研究一下dubbo的AwaitingNonWebApplicationListener AwaitingNonWebApplicationListener dubbo-spring-boot-project-2.7.3/dubbo-spring-boot-compatible/autoconfigure/src/main...

08/17 11:19
3
聊聊spring cloud eureka的instanceEnabledOnit属性

序 本文主要研究下spring cloud eureka的instanceEnabledOnit属性 EurekaInstanceConfigBean spring-cloud-netflix-eureka-client-2.0.0.RC1-sources.jar!/org/springframework/cloud/netfl...

2018/05/05 20:21
96
聊聊HystrixEventStream

序 本文主要研究一下HystrixEventStream HystrixEventStream hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/metric/HystrixEventStream.java /** Base interface for a stream of ...

2018/07/05 16:17
25
聊聊storm TridentWindowManager的pendingTriggers

序 本文主要研究一下storm TridentWindowManager的pendingTriggers TridentBoltExecutor.finishBatch storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/TridentBoltExecut...

2018/11/13 23:29
11
聊聊rocketmq的AsyncAppender

序 本文主要研究一下rocketmq的AsyncAppender AsyncAppender org/apache/rocketmq/logging/inner/LoggingBuilder.java public static class AsyncAppender extends Appender implements App...

2018/08/13 16:41
20
聊聊resilience4j的CircuitBreakerStateMachine

序 本文主要研究一下resilience4j的CircuitBreakerStateMachine CircuitBreakerStateMachine resilience4j-circuitbreaker-0.13.0-sources.jar!/io/github/resilience4j/circuitbreaker/int...

2018/07/12 10:35
41

没有更多内容

加载失败,请刷新页面

返回顶部
顶部