HeavyTaskTracker的dispatchTask方法通过TransportUtils.ttStartPtTask将任务派发到ProcessorTracker

序本文主要研究一下PowerJob的StoreStrategyStoreStrategytech/powerjob/worker/common/constants/StoreStrategy.java {代码...} StoreStrategy枚举定义了DISK、MEMORY两个枚举ConnectionFactorytech/powerjob/worker/persistence/ConnectionFactory.java {代码...} ConnectionFactory在initDatasource的时候会根据Store...

HeavyTaskTracker继承了TaskTracker，它也是个抽象类，其构造器主要是创建了ProcessorTrackerStatusHolder、taskId2BriefInfo、SegmentLock；它定义了抽象方法initTaskTracker；它提供了updateAppendedWfContext、updateTaskStatus、submitTask、receiveProcessorTrackerHeartbeat、broadcast方法；它实现了destroy、sto...

TaskTracker是个抽象类，其构造器接收ServerScheduleJobReq、WorkerRuntime，然后根据ServerScheduleJobReq构建InstanceInfo；它定义了destroy、stopTask、fetchRunningStatus抽象方法

序本文主要研究一下PowerJob的RemoteEngineRemoteEnginetech/powerjob/remote/framework/engine/RemoteEngine.java {代码...} RemoteEngine定义了start及close方法，其中start接收EngineConfig参数返回EngineOutputEngineConfigtech/powerjob/remote/framework/engine/EngineConfig.java {代码...} EngineConfig定义了se...

WorkerHealthReporter实现了Runnable接口，其run方法先获取currentServer，再获取systemMetrics，接着构建WorkerHeartbeat，最后通过TransportUtils.reportWorkerHeartbeat上报

OmsLogHandler提供了submitLog方法，它先判断logQueue大小是否超过REPORT_SIZE(1024)，超过则通过异步线程执行logSubmitter；接着将内容包装为InstanceLogContent，然后放入到logQueue

ServerDiscoveryService定义了currentServerAddress、ip2Address、服务发现url模版，失败次数，最大失败次数

序本文主要研究一下PowerJob的ProcessorLoaderProcessorLoadertech/powerjob/worker/processor/ProcessorLoader.java {代码...} ProcessorLoader定义了load方法，用于根据ProcessorDefinition加载ProcessorBeanProcessorDefinitiontech/powerjob/worker/extension/processor/ProcessorDefinition.java {代码...} Process...

Worker定义了enabled、appName、port(默认27777)、serverAddress(支持多个ip:port用逗号分隔)、protocol(默认为akka，也支持http)、storeStrategy(默认为disk，也支持memory，主要是配置H2数据库的存储模式)、maxResultLength(返回结果的最大长度，默认为8192)、enableTestMode(默认为false，主要用于没有部署server的场...

h2的Profiler的getRunnableStackTraces方法通过Thread.getAllStackTraces()来收集线程堆栈

LoggingEventAsyncDisruptorAppender继承了DelegatingAsyncDisruptorAppender，它定义了includeCallerData属性，其prepareForDeferredProcessing在includeCallerData为true时执行event.getCallerData()

AsyncAppender继承了ContextAwareBase，同时实现了Appender、AppenderAttachable、CoreSubscriber接口

ListenableFuture继承了java.util.concurrent.Future，它定义了done、abort、touch、addListener、toCompletableFuture方法

SignatureCalculator定义了calculateAndAddSignature接口，它首先计算签名，然后添加到requestBuilder

ClientStats通过Map<String, HostStats>维护了每个host对应的统计；它提供了getStatsPerHost、getTotalConnectionCount、getTotalActiveConnectionCount、getTotalIdleConnectionCount方法

序本文主要研究一下AsyncHttpClient的TimeoutTimerTaskTimerTaskio/netty/util/TimerTask.java {代码...} netty的TimerTask接口定义了run方法，其入参为TimeoutTimeoutio/netty/util/Timeout.java {代码...} Timeout接口定义了timer()、task()、isExpired()、isCancelled()、cancel()方法TimeoutTimerTaskorg/asynchttpc...

序本文主要研究一下AsyncHttpClient的IOExceptionFilterIOExceptionFilterorg/asynchttpclient/filter/IOExceptionFilter.java {代码...} IOExceptionFilter接口定义了filter方法，在捕获到IOException的时候执行ResumableIOExceptionFilterorg/asynchttpclient/handler/resumable/ResumableIOExceptionFilter.java {代...

序本文主要研究一下AsyncHttpClient的RequestFilterRequestFilterorg/asynchttpclient/filter/RequestFilter.java {代码...} RequestFilter定义了filter方法ThrottleRequestFilterorg/asynchttpclient/filter/ThrottleRequestFilter.java {代码...} ThrottleRequestFilter实现了RequestFilter接口，它使用Semaphore来对r...

序本文主要研究一下AsyncHttpClient的KeepAliveStrategyKeepAliveStrategyorg/asynchttpclient/channel/KeepAliveStrategy.java {代码...} KeepAliveStrategy接口定义了keepAlive方法用于决定是否对该connection进行keep aliveDefaultKeepAliveStrategyorg/asynchttpclient/channel/DefaultKeepAliveStrategy.java {代码...

序本文主要研究一下AsyncHttpClient的exceptionChannelClosedExceptionorg/asynchttpclient/exception/ChannelClosedException.java {代码...} ChannelClosedException用于表示Channel closed的异常handleUnexpectedClosedChannelorg/asynchttpclient/netty/request/NettyRequestSender.java {代码...} NettyRequestSend...

org/springframework/boot/autoconfigure/web/servlet/WebMvcProperties.java

ChannelPool定义了offer、poll、removeAll、isOpen、destroy、flushPartitions、getIdleChannelCountPerHost方法，它有两个实现类，分别是NoopChannelPool及DefaultChannelPool

ConnectionSemaphore主要用于控制连接的maxConnections及maxConnectionsPerHost；它定义了freeChannels表示可用连接的信号量，定义了freeChannelsPerHost维护每个host的可用连接新用量，类型是NonBlockingSemaphoreLike；它提供了tryAcquireGlobal用于获取全局的空闲连接，tryAcquirePerHost用于获取指定host的空闲连接...

AsyncHttpClientConfig接口定义了一系列获取配置的接口，比如getMaxConnections、getConnectTimeout、getReadTimeout、getPooledConnectionIdleTimeout等

nginx的1.19.10版本新增了keepalive_time参数，用于限制一个keep-alive连接处理请求的最长时间。当达到这个时间后，连接会在后续请求处理完成后关闭。

默认是75s，客户端的一个keep-alive连接在服务端保持open的时间，为0表示禁用keep-alive，可选指定header_timeout，若有指定则response header会有Keep-Alive: timeout=time，该header能被Mozilla和Konqueror浏览器识别，MSIE浏览器大概在60s会关闭keep-alive连接

ThrowableHandlingConverter继承了ClassicConverter，其handlesThrowable方法返回true

序本文主要研究一下springboot的logging.groupLoggersEndpointorg/springframework/boot/actuate/logging/LoggersEndpoint.java {代码...} LoggersEndpoint提供了loggers、loggerLevels、configureLogLevel方法LoggerGroupsorg/springframework/boot/logging/LoggerGroups.java {代码...} LoggerGroups实现了Iterable接...

org/springframework/boot/actuate/autoconfigure/metrics/MetricsProperties.java