XXL-JOB原理--任务调度中心执行器注册（三）

╰+哭是因爲堅強的太久メ 2022-05-12 06:44 243阅读 0赞

在上一篇博客[XXL-JOB学习--执行器注册（一）][XXL-JOB_--]中我们介绍了xxl-job执行器注册到任务调度中心的流程及相关注册信息，接下来我们看看任务调度中心接受任务注册后做了哪些事情。

一、注册地址

地址：[http://127.0.0.1:8080/api][http_127.0.0.1_8080_api]

任务调度中心对外提供注册地址/api用来接受任务执行器注册的相关服务器信息

1、xxl-job admin通过JobApiController来对外提供/api接口

@Controller
    public class JobApiController {
        private static Logger logger = LoggerFactory.getLogger(JobApiController.class);
    
        private RpcResponse doInvoke(HttpServletRequest request) {
            try {
                // deserialize request
                byte[] requestBytes = HttpClientUtil.readBytes(request);
                if (requestBytes == null || requestBytes.length==0) {
                    RpcResponse rpcResponse = new RpcResponse();
                    rpcResponse.setError("RpcRequest byte[] is null");
                    return rpcResponse;
                }
    			//反序列化数据
                RpcRequest rpcRequest = (RpcRequest) HessianSerializer.deserialize(requestBytes, RpcRequest.class);
    
                // invoke
    			//调用服务注册方法
                RpcResponse rpcResponse = NetComServerFactory.invokeService(rpcRequest, null);
                return rpcResponse;
            } catch (Exception e) {
                logger.error(e.getMessage(), e);
    
                RpcResponse rpcResponse = new RpcResponse();
                rpcResponse.setError("Server-error:" + e.getMessage());
                return rpcResponse;
            }
        }
    
    	//对外提供api接口
        @RequestMapping(AdminBiz.MAPPING)
        @PermessionLimit(limit=false)
        public void api(HttpServletRequest request, HttpServletResponse response) throws IOException {
    
            // invoke
            RpcResponse rpcResponse = doInvoke(request);
    
            // serialize response
            byte[] responseBytes = HessianSerializer.serialize(rpcResponse);
    
            response.setContentType("text/html;charset=utf-8");
            response.setStatus(HttpServletResponse.SC_OK);
            //baseRequest.setHandled(true);
    
            OutputStream out = response.getOutputStream();
            out.write(responseBytes);
            out.flush();
        }
    
    }

在NetComServerFactory类中调用invokeService方法，根据反射调用AdminBiz接口的实现类AdminBizImpl的register方法完成服务注册操作

public static RpcResponse invokeService(RpcRequest request, Object serviceBean) {
    		if (serviceBean==null) {
    			serviceBean = serviceMap.get(request.getClassName());
    		}
    		if (serviceBean == null) {
    			// TODO
    		}
    
    		RpcResponse response = new RpcResponse();
    
    		if (System.currentTimeMillis() - request.getCreateMillisTime() > 180000) {
    			response.setResult(new ReturnT<String>(ReturnT.FAIL_CODE, "The timestamp difference between admin and executor exceeds the limit."));
    			return response;
    		}
    		if (accessToken!=null && accessToken.trim().length()>0 && !accessToken.trim().equals(request.getAccessToken())) {
    			response.setResult(new ReturnT<String>(ReturnT.FAIL_CODE, "The access token[" + request.getAccessToken() + "] is wrong."));
    			return response;
    		}
    
    		try {
    			//接口AdminBiz的实现类AdminBizImpl
    			Class<?> serviceClass = serviceBean.getClass();
    			//AdminBiz的register方法
    			String methodName = request.getMethodName();
    			Class<?>[] parameterTypes = request.getParameterTypes();
    			Object[] parameters = request.getParameters();
    
    			FastClass serviceFastClass = FastClass.create(serviceClass);
    			//调用AdminBizImpl的register方法
    			FastMethod serviceFastMethod = serviceFastClass.getMethod(methodName, parameterTypes);
    
    			Object result = serviceFastMethod.invoke(serviceBean, parameters);
    
    			response.setResult(result);
    		} catch (Throwable t) {
    			t.printStackTrace();
    			response.setError(t.getMessage());
    		}
    
    		return response;
    	}

调用的类：

![70][]

参数：基本的服务器信息

![70 1][]

在AdminBiz的实现类AdminBizImpl中调用dao完成注册信息入库操作：

@Override
    public ReturnT<String> registry(RegistryParam registryParam) {
    		//在xxl_job_qrtz_trigger_registry表中添加或更新数据
            int ret = xxlJobRegistryDao.registryUpdate(registryParam.getRegistGroup(), registryParam.getRegistryKey(), registryParam.getRegistryValue());
            if (ret < 1) {
                xxlJobRegistryDao.registrySave(registryParam.getRegistGroup(), registryParam.getRegistryKey(), registryParam.getRegistryValue());
            }
            return ReturnT.SUCCESS;
    }

表中数据：

![70 2][]

在任务调度中心会列表展示数据：

![70 3][]

总结：简单来说执行器将其服务器信息通过http请求发送到任务调度中心，调度中心将相关注册信息插入或更新到xxl\_job\_qrtz\_trigger\_registry表中，在任务调度中心通过列表展示，接下来相关任务执行时会根据服务器信息通过http发送调用请求。

[XXL-JOB_--]: https://blog.csdn.net/qq924862077/article/details/82708610
[http_127.0.0.1_8080_api]: http://127.0.0.1:8080/api
[70]: /images/20220512/58a34bc9cfb945f0845ee8dad3b41b55.png
[70 1]: /images/20220512/19b2c6e88abb416b8c3070b9e26dba02.png
[70 2]: /images/20220512/07f0b76c06704259acca1a080644af48.png
[70 3]: /images/20220512/6318c7f31a9e46aa96ecf06b0a224ca0.png