jetcache-core/src/main/java/com/alicp/jetcache/support/BroadcastManager.java

CacheMonitor是一个FunctionalInterface，它定义了afterOperation方法用于消费CacheEvent，它有两个实现类，分别是DefaultCacheMonitor、CacheNotifyMonitor

序本文主要研究一下jetcache的ProxyCacheProxyCachejetcache-core/src/main/java/com/alicp/jetcache/ProxyCache.java {代码...} ProxyCache继承了Cache接口，它定义了getTargetCache方法，并默认实现了unwrap方法SimpleProxyCachejetcache-core/src/main/java/com/alicp/jetcache/SimpleProxyCache.java {代码...} Simp...

Cache接口主要是定义了大写的GET、GET_ALL、PUT、PUT_ALL、REMOVE、REMOVE_ALL、PUT_IF_ABSENT方法，以及基于这些大写方法包装的小写default方法V get(K key)这样的方法虽然用起来方便，但有功能上的缺陷，当get返回null的时候，无法断定是对应的key不存在，还是访问缓存发生了异常，所以JetCache针对部分操作提供了另外...

CacheManager定义了getCache、putCache、getBroadcastManager、putBroadcastManager、getOrCreateCache方法，并提供了aera为default的默认getCache、putCache、putBroadcastManager方法

序本文主要研究一下JetCacheProxyConfigurationJetCacheProxyConfigurationcom/alicp/jetcache/anno/config/JetCacheProxyConfiguration.java {代码...} JetCacheProxyConfiguration定义了JetCacheInterceptor、CacheAdvisorJetCacheInterceptorcom/alicp/jetcache/anno/aop/JetCacheInterceptor.java {代码...} JetCach...

MybatisSqlSessionFactoryBuilder的build方法，在globalConfig.getIdentifierGenerator()为null的时候创建并使用DefaultIdentifierGenerator

powerjob-worker/src/main/java/tech/powerjob/worker/common/PowerJobWorkerConfig.java

序本文主要研究一下抛出NoHttpResponseException的调用链异常堆栈 {代码...} HttpRequestExecutor.executeorg/apache/http/protocol/HttpRequestExecutor.java {代码...} doSendRequest返回null，则执行doReceiveResponse，这里会抛出NoHttpResponseExceptiondoReceiveResponseorg/apache/http/protocol/HttpRequestExec...

RRateLimiter继承了RRateLimiterAsync、RExpirable接口，它主要定义了trySetRate、setRate、tryAcquire、acquire、getConfig、availablePermits方法

linux使用page cache来缓存最近读取的文件，也有目录结构(dcache: Directory Entry Cache)缓存及inode缓存，它们都使用了LRU算法来管理这些page及dentries cache

所谓Cache，就是为了弥补高速设备和低速设备之间的矛盾而设立的一个中间层。缓冲（Buffer）是根据磁盘的读写设计的，它把分散的写操作集中进行，减少磁盘碎片和硬盘的反复寻道，从而提高系统性能。

这里有张spring cloud与kubernetes的对比，如果将微服务部署到kubernetes上面，二者有不少功能是重复的，可否精简。这里主要是讲述一下如果不使用独立的服务发现，而是使用k8s的服务发现的优缺点

Java语言特性系列Java5的新特性Java6的新特性Java7的新特性Java8的新特性Java9的新特性Java10的新特性Java11的新特性Java12的新特性Java13的新特性Java14的新特性Java15的新特性Java16的新特性Java17的新特性Java18的新特性Java19的新特性Java20的新特性Java21的新特性Java22的新特性Java23的新特性Java24的新特性序本文...

powerjob-common/src/main/java/tech/powerjob/common/request/http/SaveJobInfoRequest.java

powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/heavy/HeavyTaskTracker.java

powerjob-worker/src/main/java/tech/powerjob/worker/pojo/model/InstanceInfo.java

org/springframework/cloud/loadbalancer/core/ServiceInstanceListSupplier.java

spring-cloud-commons提供了DiscoveryClient接口，它定义了description、getInstances、getServices、probe、getOrder方法

序本文主要研究一下arthas的HttpTermServerTermServercom/taobao/arthas/core/shell/term/TermServer.java {代码...} TermServer是一个抽象类，它定义了termHandler、listen、actualPort、close抽象方法HttpTermServercom/taobao/arthas/core/shell/term/impl/HttpTermServer.java {代码...} HttpTermServer继承了TermSe...

ArthasBootstrap的构造器执行initFastjson、initSpy、initArthasEnvironment、LogUtil.initLogger(arthasEnvironment)、enhanceClassLoader、initBeans、bind，最后注册shutdownHook来执行destroy方法

arthas-spring-boot-starter/src/main/java/com/alibaba/arthas/spring/ArthasConfiguration.java

org/springframework/boot/actuate/availability/ReadinessStateHealthIndicator.java

可以看到原来10.244.0.8:8080的pod由于label被更新了，所以被移除了，但因为需要保持3个副本，因而点多生成了一个pod(10.244.0.11:8080)

timingClean先执行WorkerClusterManagerService.cleanUp()释放本地缓存，之后通过cleanLocal释放本地磁盘空间，最后执行cleanByOneServer删除历史数据

InstanceStatus定义了任务实例的状态，广义运行中的状态为WAITING_DISPATCH、WAITING_WORKER_RECEIVE、RUNNING；终态为FAILED、SUCCEED、CANCELED、STOPPED

CoreScheduleTaskManager在afterPropertiesSet的时候会启动一系列的线程，它们都是LoopRunnable类型的，分别调度powerScheduleService.scheduleNormalJob(TimeExpressionType.CRON)、powerScheduleService.scheduleNormalJob(TimeExpressionType.DAILY_TIME_INTERVAL)、powerScheduleService::scheduleCronWorkflow、pow...

PowerJobSpringWorker实现了InitializingBean接口，其afterPropertiesSet会创建powerJobWorker，然后执行其init方法

PowerJobAutoConfiguration读取powerjob.worker.server-address属性，解析逗号分隔，赋值给PowerJobWorkerConfig的serverAddress

ServerController实现了ServerInfoAware接口，它提供了assert、assertV2、acquire、hello接口；其中assert接口用于判断指定的appName是否存在，assertV2返回的是WorkerAppInfo；acquire委托给了serverElectionService.elect(request)；hello接口返回server端的localhost、serverInfo、serverTime等信息