聊聊spring-cloud-kubernetes-client-loadbalancer

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

聊聊spring-cloud-kubernetes-client-discovery

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

聊聊arthas的HttpTermServer

2 月 21 日
阅读 8 分钟
126
序本文主要研究一下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 分钟
115
ArthasBootstrap的构造器执行initFastjson、initSpy、initArthasEnvironment、LogUtil.initLogger(arthasEnvironment)、enhanceClassLoader、initBeans、bind,最后注册shutdownHook来执行destroy方法

聊聊arthas的spring-boot-starter

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

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

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

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

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

聊聊PowerJob的CleanService

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

聊聊PowerJob的InstanceStatusCheckService

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

聊聊PowerJob的任务调度

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

聊聊PowerJob Server的高可用

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

聊聊PowerJob Worker的ServerAddress

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

聊聊PowerJob的ServerController

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

聊聊PowerJob的AppInfoController

2 月 5 日
阅读 4 分钟
96
序本文主要研究一下PowerJob的AppInfoControllerAppInfoControllertech/powerjob/server/web/controller/AppInfoController.java {代码...} AppInfoController提供了save、assert、delete、list方法AppInfoServicetech/powerjob/server/core/service/AppInfoService.java {代码...} AppInfoService定义了assertApp方法Ap...

聊聊PowerJob的UserInfoController

2 月 4 日
阅读 7 分钟
61
序本文主要研究一下PowerJob的UserInfoControllerUserInfoControllertech/powerjob/server/web/controller/UserInfoController.java {代码...} UserInfoController提供了save、list方法,其中save方法用到了userService.saveUserServicetech/powerjob/server/core/service/UserService.java {代码...} UserService提供了...

聊聊PowerJob日志的上报及存储

2 月 3 日
阅读 17 分钟
67
序本文主要研究一下PowerJob的日志上报及存储OmsLoggerFactory.buildtech/powerjob/worker/log/OmsLoggerFactory.java {代码...} 默认logConfig为null,cfg是new LogConfig(),其build出来的是OmsServerLoggerOmsServerLoggertech/powerjob/worker/log/impl/OmsServerLogger.java {代码...} OmsServerLogger的process方...

聊聊PowerJob的ContainerTemplateGenerator

2 月 2 日
阅读 5 分钟
48
ContainerTemplateGenerator的generate方法提供了生成外置动态加载的代码模版,它从classpath读取oms-template-origin.zip文件,然后解压到临时目录,之后按行读取pom.xml文件,替换掉group、name、javaVersion信息,接着在src/main/java下面写入包名对应的目录,然后替换src/main/resources/oms-worker-container-sprin...

聊聊PowerJob的ServerDeployContainerRequest

2 月 1 日
阅读 11 分钟
49
ServerDeployContainerRequest定义了containerId、containerName、version、downloadURL属性

聊聊PowerJob的ContainerController

1 月 31 日
阅读 19 分钟
64
ContainerController提供了downloadJar、downloadContainerTemplate、jarUpload、save、delete、list、listDeployedWorker接口,其中downloadJar、jarUpload、save、delete委托给了containerService

聊聊PowerJob的InstanceController

1 月 30 日
阅读 13 分钟
75
InstanceController提供了stop、retry、detail、log、downloadLogUrl、downloadLog、downloadLog4Console、list方法;其中stop、retry、detail委托给了instanceService;log、downloadLogUrl、downloadLog、downloadLog4Console委托给了instanceLogService;list委托给了instanceInfoRepository

聊聊PowerJob的SystemInfoController

1 月 29 日
阅读 9 分钟
68
SystemInfoController提供了listWorker、getSystemOverview方法;listWorker则是根据当前登录的appId来获取其WorkerInfo;getSystemOverview则是统计了当前appId的总任务数量、运行任务数、近期失败任务数

聊聊PowerJob的JobController

1 月 28 日
阅读 12 分钟
64
JobController提供了save、copy、export、disable、delete、run、list方法;除了list外其他均委托给了jobService

聊聊PowerJob的BroadcastProcessor

1 月 27 日
阅读 14 分钟
63
BroadcastProcessor接口继承了BasicProcessor,它定义了preProcess、postProcess、defaultResult方法,其中preProcess默认返回成功的ProcessResult,postProcess返回defaultResult,它会根据taskResults计算最终的success与否

聊聊PowerJob的MapReduceProcessor

1 月 26 日
阅读 4 分钟
52
序本文主要研究一下PowerJob的MapReduceProcessorMapReduceProcessor {代码...} MapReduceProcessor继承了MapProcessor,它新增了reduce方法TaskResulttech/powerjob/worker/core/processor/TaskResult.java {代码...} TaskResult定义了taskId、success、result属性handleLastTasktech/powerjob/worker/core/processor/r...

聊聊PowerJob的ProcessorTracker

1 月 25 日
阅读 8 分钟
49
ProcessorTracker接收TaskTrackerStartTaskReq参数,然后初始化线程池、初始化定时任务、初始化processorBean,它提供了submitTask、destroy方法

聊聊PowerJob的MapProcessor

1 月 24 日
阅读 15 分钟
71
MapProcessor接口继承了BasicProcessor,它提供了默认的map方法用于分发子任务,它主要是构造了ProcessorMapTaskRequest,通过TransportUtils.reliableMapTask发送请求;它还提供了isRootTask方法用于判断当前任务是不是根任务

聊聊PowerJob的ThreadPoolConfig

1 月 23 日
阅读 5 分钟
81
ThreadPoolConfig定义了PowerJobTimingPool、PowerJobBackgroundPool、PowerJobLocalDbPool四个线程池,以及一个taskScheduler,这里使用的是spring的ThreadPoolTaskExecutor及ThreadPoolTaskScheduler,他们都继承了ExecutorConfigurationSupport

聊聊PowerJob的HashedWheelTimer

1 月 22 日
阅读 12 分钟
116
Timer接口定义了schedule方法,用于在指定时间之后调度TimerTask,它返回TimerFuture;stop方法返回未处理的TimerTask

聊聊PowerJob的UserService

1 月 21 日
阅读 4 分钟
56
序本文主要研究一下PowerJob的UserServiceUserServicetech/powerjob/server/core/service/UserService.java {代码...} UserService提供了save及fetchNotifyUserList方法,基于UserInfoRepository来实现UserInfoDOtech/powerjob/server/persistence/remote/model/UserInfoDO.java {代码...} UserInfoDO定义了username、em...

聊聊PowerJob的AliOssService

1 月 20 日
阅读 7 分钟
47
序本文主要研究一下PowerJob的AliOssServiceDFsServicetech/powerjob/server/extension/dfs/DFsService.java {代码...} DFsService接口定义了store、download、fetchFileMeta、cleanExpiredFiles方法AbstractDFsServicetech/powerjob/server/persistence/storage/AbstractDFsService.java {代码...} AbstractDFsService...