xxljob客户端架构流程

　　一、xxljob的调度流程和配置
　　任务调度器和执行器使用http协议通信，各自有轮询线程处理不同业务。
　　二、XXLJOB客户端启动流程加载Bean：从spring容器获取所有对象，并遍历查找方法上标记XxlJob注解的方法将xxljob配置的jobname作为key，对象Handle作为value注册Map中ConcurrentMapjobHandlerRepository的Map中维护；创建执行任务的线程池；启动内嵌的Netty服务；启动注册线程，每隔30s上报一次注册信息。
　　publicclassEmbedServer｛publicvoidstart（finalStringaddress，finalintport，finalStringappname，finalStringaccessToken）｛executorBiznewExecutorBizImpl（）；threadnewThread（newRunnable（）｛Overridepublicvoidrun（）｛paramEventLoopGroupbossGroupnewNioEventLoopGroup（）；EventLoopGroupworkerGroupnewNioEventLoopGroup（）；ThreadPoolExecutorbizThreadPoolnewThreadPoolExecutor（0，200，60L，TimeUnit。SECONDS，newLinkedBlockingQueueRunnable（2000））；startserverServerBootstrapbootstrapnewServerBootstrap（）；bootstrap。group（bossGroup，workerGroup）。channel（NioServerSocketChannel。class）。childHandler（newChannelInitializerSocketChannel（）｛OverridepublicvoidinitChannel（SocketChannelchannel）throwsException｛channel。pipeline（）。addLast（newIdleStateHandler（0，0，303，TimeUnit。SECONDS））beat3N，closeifidle。addLast（newHttpServerCodec（））。addLast（newHttpObjectAggregator（510241024））mergerequestreponsetoFULL。addLast（newEmbedHttpServerHandler（executorBiz，accessToken，bizThreadPool））；｝｝）。childOption（ChannelOption。SOKEEPALIVE，true）；ChannelFuturefuturebootstrap。bind（port）。sync（）；startregistrystartRegistry（appname，address）；waitutilstopfuture。channel（）。closeFuture（）。sync（）；｝｝）；thread。setDaemon（true）；daemon，servicejvm，userthreadleavedaemonleavejvmleavethread。start（）；｝｝三、任务的下发与执行
　　任务的下发与执行（服务端发送给客户端）：
　　收到服务器不动执行进行任务分发：
　　privateObjectprocess（HttpMethodhttpMethod，Stringuri，StringrequestData，StringaccessTokenReq）｛switch（uri）｛casebeat：returnexecutorBiz。beat（）；caseidleBeat：IdleBeatParamidleBeatParamGsonTool。fromJson（requestData，IdleBeatParam。class）；returnexecutorBiz。idleBeat（idleBeatParam）；caserun：TriggerParamtriggerParamGsonTool。fromJson（requestData，TriggerParam。class）；returnexecutorBiz。run（triggerParam）；casekill：KillParamkillParamGsonTool。fromJson（requestData，KillParam。class）；returnexecutorBiz。kill（killParam）；caselog：LogParamlogParamGsonTool。fromJson（requestData，LogParam。class）；returnexecutorBiz。log（logParam）；default：returnnewReturnTString（ReturnT。FAILCODE，invalidrequest，urimapping（uri）notfound。）；｝｝1beat：心跳保活检测
　　直接returnsuccess，用户服务器探活；2idleBeat：任务执行策略配置为忙碌转移时使用；
　　等待队列如果存在待执行任务时，返回
　　等待队列为空时：返回3run：接收到执行任务指令
　　将任务提交到执行队列中，并返回
　　队列满或handler不存在时返回4kill：中断任务
　　对执行任务的线程执行JobThread。interrupt（）；
　　每个任务Id会有一个线程，Kill仅杀死执行该任务Id的线程，下次再下发任务发现线程已中断会重新创建线程。5log：获取执行log
　　返回客户端执行的本地log给服务端。四、客户端注册和执行结果上报
　　客户端注册和执行结果上报（客户端发送给服务端）
　　OverridepublicReturnTStringcallback（ListHandleCallbackParamcallbackParamList）｛returnXxlJobRemotingUtil。postBody（addressUrlapicallback，accessToken，timeout，callbackParamList，String。class）；｝OverridepublicReturnTStringregistry（RegistryParamregistryParam）｛returnXxlJobRemotingUtil。postBody（addressUrlapiregistry，accessToken，timeout，registryParam，String。class）；｝OverridepublicReturnTStringregistryRemove（RegistryParamregistryParam）｛returnXxlJobRemotingUtil。postBody（addressUrlapiregistryRemove，accessToken，timeout，registryParam，String。class）；｝1registry：注册客户端信息
　　启动线程定时注册自己的服务到调度器；
　　创建线程，30s轮询一次，上报注册信息。2registryRemove：移出执行器请求
　　将自己从执行器列表移除；
　　程序退出时会调用一次，在Netty的finally代码块自动执行。3callback：异步回调结果
　　执行器异步回调给调度器执行任务结果；
　　每次任务完成时上报。五、附录1网络通信格式：
　　（1）客户端注册
　　http：127。0。0。1：8080xxljobadminapiregistry｛registryGroup：EXECUTORregistryKey：xxljobexecutorsampleregistryValue：http：172。30。0。67：9999｝Response：｛code：200msg：nullcontent：null｝
　　（2）客户端移除注册
　　http：127。0。0。1：8080xxljobadminapiregistryRemove｛registryGroup：EXECUTORregistryKey：xxljobexecutorsampleregistryValue：http：xxljobaxzo。cn｝Response：｛code：200msg：nullcontent：null｝
　　（3）客户端执行任务结果上报
　　http：127。0。0。1：8080xxljobadminapicallback｛logId：1238logDateTim：1667197980007handleCode：200｝Response：｛code：200msg：nullcontent：null｝
　　（4）执行器下发任务：同步回调仅代表任务是否发送成功
　　http：172。30。0。67：9999run｛jobId：4executorHandler：demoJobHandlerexecutorParams：executorBlockStrategy：SERIALEXECUTIONexecutorTimeout：0logId：1238logDateTime：1667197980007glueType：BEANglueSource：glueUpdatetime：1666683613000broadcastIndex：0broadcastTotal：1｝Response：｛code：200msg：nullcontent：null｝2Token配置详解
　　1。配置了token后，client发送的每隔http请求头会带上XXLJOBACCESSTOKEN：｛xxl。job。accessToken｝；
　　2。该参数不会对请求参数加密；
　　3。如果配置不匹配，客户端请求报错：
　　｛code：500msg：Theaccesstokeniswrong。content：null｝
　　4。发送配置token的请求，Header中新增了Token参数
　　5。配置错token的返回
　　程序员的核心竞争力其实还是技术，因此对技术还是要不断的学习，关注IT巅峰技术公众号，该公众号内容定位：中高级开发、架构师、中层管理人员等中高端岗位服务的，除了技术交流外还有很多架构思想和实战案例。
　　作者是《消息中间件RocketMQ技术内幕》一书作者，同时也是RocketMQ上海社区联合创始人，曾就职于拼多多、德邦等公司，现任上市快递公司架构负责人，主要负责开发框架的搭建、中间件相关技术的二次开发和运维管理、混合云及基础服务平台的建设。