实际上是继承自JobHandler的java类代码#xff0c;在执行器中运行#xff0c;可以使用Resource/Autowire注入执行器里中的其他服务.

在执行器中添加service

任务以源码的形式去维护调度中心支持实时编译无需指定JobHandler。

实际上是继承自JobHandler的java类代码在执行器中运行可以使用Resource/Autowire注入执行器里中的其他服务.

在执行器中添加service

methodA(){System.out.println(执行MethodA的方法);}public

void

methodB(){System.out.println(执行MethodB的方法);}

调度中心添加Gule任务在gule

com.xxl.job.service.handler;import

cn.wolfcode.xxljobdemo.service.HelloService;

import

com.xxl.job.core.handler.IJobHandler;

import

org.springframework.beans.factory.annotation.Autowired;public

class

启动两个springboot项目修改tomcat端口号和执行器端口号

-Dserver.port8093

每个任务按照Hash算法固定选择某一台机器且所有任务均匀散列在不同机器上。

LEAST_FREQUENTLY_USED最不经常使用使用频率最低的机器优先被选举

LEAST_RECENTLY_USED最近最久未使用最久未使用的机器优先被选举

FAILOVER故障转移按照顺序依次进行心跳检测第一个心跳检测成功的机器选定为目标执行器并发起调度

BUSYOVER忙碌转移按照顺序依次进行空闲检测第一个空闲检测成功的机器选定为目标执行器并发起调度

广播触发对应集群中所有机器执行一次任务同时系统自动传递分片参数可根据分片参数开发分片任务

分片广播

1.将所有请求分配个各个结点由每个结点承担具体分片策略由逻辑代码决定调度中心知识让所有的结点执行。

2.XXL-JOB为每个注册结点分配一个index同样XXL-JOB会记录结点总数

int

XxlJobHelper.getShardIndex();结点数

int

XxlJobHelper.getShardTotal();结点总数

1.添加依赖

dependencygroupIdorg.mybatis.spring.boot/groupIdartifactIdmybatis-spring-boot-starter/artifactIdversion1.2.0/version

/dependency

dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactId

/dependency

dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdscopeprovided/scope

/dependency

dependencygroupIdcom.alibaba/groupIdartifactIddruid/artifactIdversion1.1.10/version

/dependency

spring.datasource.urljdbc:mysql://localhost:3306/xxl_job_demo?serverTimezoneGMT%2B8useUnicodetruecharacterEncodingUTF-8

spring.datasource.driverClassNamecom.mysql.jdbc.Driver

spring.datasource.typecom.alibaba.druid.pool.DruidDataSource

spring.datasource.passwordWolfCode_2017

3.添加实体类

mod(id,#{shardingTotal})#{shardingIndex})ListUserMobilePlan

selectByMod(Param(shardingIndex)

Integer

shardingIndex,Param(shardingTotal)Integer

from

t_user_mobile_plan)ListUserMobilePlan

selectAll();

Exception{System.out.println(任务开始时间:new

Date());int

XxlJobHelper.getShardTotal();int

shardIndex

XxlJobHelper.getShardIndex();ListUserMobilePlan

userMobilePlans

null;if(shardTotal1){//如果没有分片就直接查询所有数据userMobilePlans

userMobilePlanMapper.selectAll();}else{userMobilePlans

userMobilePlanMapper.selectByMod(shardIndex,shardTotal);}System.out.println(处理任务数量:userMobilePlans.size());Long

startTime

System.currentTimeMillis();userMobilePlans.forEach(item-{try

{TimeUnit.MILLISECONDS.sleep(10);}

catch

{e.printStackTrace();}});System.out.println(任务结束时间:new

Date());System.out.println(任务耗时:(System.currentTimeMillis()-startTime)毫秒);