聊聊jetcache的BroadcastManager

6 月 21 日
阅读 14 分钟
344
jetcache-core/src/main/java/com/alicp/jetcache/support/BroadcastManager.java

聊聊jetcache的CacheMonitor

6 月 20 日
阅读 21 分钟
353
CacheMonitor是一个FunctionalInterface,它定义了afterOperation方法用于消费CacheEvent,它有两个实现类,分别是DefaultCacheMonitor、CacheNotifyMonitor

聊聊jetcache的ProxyCache

6 月 19 日
阅读 24 分钟
330
序本文主要研究一下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...

聊聊jetcache的MultiLevelCache

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

聊聊jetcache的CacheManager

6 月 17 日
阅读 8 分钟
345
CacheManager定义了getCache、putCache、getBroadcastManager、putBroadcastManager、getOrCreateCache方法,并提供了aera为default的默认getCache、putCache、putBroadcastManager方法

聊聊JetCacheProxyConfiguration

6 月 13 日
阅读 19 分钟
361
序本文主要研究一下JetCacheProxyConfigurationJetCacheProxyConfigurationcom/alicp/jetcache/anno/config/JetCacheProxyConfiguration.java {代码...} JetCacheProxyConfiguration定义了JetCacheInterceptor、CacheAdvisorJetCacheInterceptorcom/alicp/jetcache/anno/aop/JetCacheInterceptor.java {代码...} JetCach...

聊聊mybatis-plus的DefaultIdentifierGenerator

5 月 11 日
阅读 9 分钟
230
MybatisSqlSessionFactoryBuilder的build方法,在globalConfig.getIdentifierGenerator()为null的时候创建并使用DefaultIdentifierGenerator

聊聊powerjob的maxResultLength

5 月 8 日
阅读 11 分钟
112
powerjob-worker/src/main/java/tech/powerjob/worker/common/PowerJobWorkerConfig.java

再聊HttpClient的NoHttpResponseException

4 月 28 日
阅读 10 分钟
259
序本文主要研究一下抛出NoHttpResponseException的调用链异常堆栈 {代码...} HttpRequestExecutor.executeorg/apache/http/protocol/HttpRequestExecutor.java {代码...} doSendRequest返回null,则执行doReceiveResponse,这里会抛出NoHttpResponseExceptiondoReceiveResponseorg/apache/http/protocol/HttpRequestExec...

聊聊redisson的RRateLimiter

4 月 23 日
阅读 23 分钟
253
RRateLimiter继承了RRateLimiterAsync、RExpirable接口,它主要定义了trySetRate、setRate、tryAcquire、acquire、getConfig、availablePermits方法

聊聊linux的文件缓存

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

聊聊docker容器的memory限制

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

聊聊k8s服务发现的优缺点

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

Java22的新特性

3 月 25 日
阅读 14 分钟
1k
Java语言特性系列Java5的新特性Java6的新特性Java7的新特性Java8的新特性Java9的新特性Java10的新特性Java11的新特性Java12的新特性Java13的新特性Java14的新特性Java15的新特性Java16的新特性Java17的新特性Java18的新特性Java19的新特性Java20的新特性Java21的新特性Java22的新特性Java23的新特性序本文主要讲述一下Ja...

聊聊powerjob的执行机器地址

3 月 16 日
阅读 4 分钟
176
powerjob-common/src/main/java/tech/powerjob/common/request/http/SaveJobInfoRequest.java

聊聊powerjob的failedTaskNum

3 月 15 日
阅读 19 分钟
178
powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/heavy/HeavyTaskTracker.java

聊聊powerjob的单机线程并发度

3 月 12 日
阅读 13 分钟
214
powerjob-worker/src/main/java/tech/powerjob/worker/pojo/model/InstanceInfo.java

聊聊spring-cloud-kubernetes-client-loadbalancer

2 月 26 日
阅读 12 分钟
332
org/springframework/cloud/loadbalancer/core/ServiceInstanceListSupplier.java

聊聊spring-cloud-kubernetes-client-discovery

2 月 23 日
阅读 8 分钟
222
spring-cloud-commons提供了DiscoveryClient接口,它定义了description、getInstances、getServices、probe、getOrder方法

聊聊arthas的HttpTermServer

2 月 21 日
阅读 8 分钟
303
序本文主要研究一下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...

聊聊arthas的ArthasBootstrap

2 月 20 日
阅读 17 分钟
268
ArthasBootstrap的构造器执行initFastjson、initSpy、initArthasEnvironment、LogUtil.initLogger(arthasEnvironment)、enhanceClassLoader、initBeans、bind,最后注册shutdownHook来执行destroy方法

聊聊arthas的spring-boot-starter

2 月 19 日
阅读 7 分钟
359
arthas-spring-boot-starter/src/main/java/com/alibaba/arthas/spring/ArthasConfiguration.java

聊聊如何停止某个pod的流量

2 月 18 日
阅读 4 分钟
480
org/springframework/boot/actuate/availability/ReadinessStateHealthIndicator.java

聊聊如何变更pod的流量路由

2 月 13 日
阅读 5 分钟
450
可以看到原来10.244.0.8:8080的pod由于label被更新了,所以被移除了,但因为需要保持3个副本,因而点多生成了一个pod(10.244.0.11:8080)

聊聊PowerJob的CleanService

2 月 11 日
阅读 5 分钟
358
timingClean先执行WorkerClusterManagerService.cleanUp()释放本地缓存,之后通过cleanLocal释放本地磁盘空间,最后执行cleanByOneServer删除历史数据

聊聊PowerJob的InstanceStatusCheckService

2 月 10 日
阅读 15 分钟
467
InstanceStatus定义了任务实例的状态,广义运行中的状态为WAITING_DISPATCH、WAITING_WORKER_RECEIVE、RUNNING;终态为FAILED、SUCCEED、CANCELED、STOPPED

聊聊PowerJob的任务调度

2 月 9 日
阅读 13 分钟
406
CoreScheduleTaskManager在afterPropertiesSet的时候会启动一系列的线程,它们都是LoopRunnable类型的,分别调度powerScheduleService.scheduleNormalJob(TimeExpressionType.CRON)、powerScheduleService.scheduleNormalJob(TimeExpressionType.DAILY_TIME_INTERVAL)、powerScheduleService::scheduleCronWorkflow、pow...

聊聊PowerJob Server的高可用

2 月 8 日
阅读 15 分钟
403
PowerJobSpringWorker实现了InitializingBean接口,其afterPropertiesSet会创建powerJobWorker,然后执行其init方法

聊聊PowerJob Worker的ServerAddress

2 月 7 日
阅读 6 分钟
372
PowerJobAutoConfiguration读取powerjob.worker.server-address属性,解析逗号分隔,赋值给PowerJobWorkerConfig的serverAddress

聊聊PowerJob的ServerController

2 月 6 日
阅读 9 分钟
302
ServerController实现了ServerInfoAware接口,它提供了assert、assertV2、acquire、hello接口;其中assert接口用于判断指定的appName是否存在,assertV2返回的是WorkerAppInfo;acquire委托给了serverElectionService.elect(request);hello接口返回server端的localhost、serverInfo、serverTime等信息