spring-boot集成elastic-job 并实现http类型作业

spring-boot集成elastic-job 并实现http类型作业 1.安装zookeeper 3.6.3（elastic-jon实现http类型作业 要求zookeeper版本在3.6以上）

1.1 pom.xml

            org.apache.shardingsphere.elasticjob
            elasticjob-lite-spring-boot-starter
            3.0.1
        
        
            org.apache.shardingsphere.elasticjob
            elasticjob-lite-lifecycle
            3.0.1
        

1.2 配置文件

elasticjob.reg-center.server-lists=127.0.0.1:2181
elasticjob.reg-center.namespace=elastic-job-zhangmr
elasticjob.reg-center.maxRetries=3
elasticjob.reg-center.baseSleepTimeMilliseconds=1000
elasticjob.reg-center.maxSleepTimeMilliseconds=3000
elasticjob.reg-center.session-timeout-milliseconds=3000
elasticjob.reg-center.connection-timeout-milliseconds=3000
elasticjob.shardingTotalCount = 4

1.3 demo代码

@Service
public class TaskServer {

    @Value("${elasticjob.reg-center.server-lists}")
    private String serverLists;
    @Value("${elasticjob.reg-center.namespace}")
    private String namespace;
    @Value("${elasticjob.shardingTotalCount}")
    private int shardingTotalCount;

    @Autowired
    private ZookeeperRegistryCenter zookeeperRegistryCenter;


    public void addTask(){
        JobConfiguration jobConfiguration = JobConfiguration.newBuilder("javaHttpJob", shardingTotalCount)
                .setProperty(HttpJobProperties.URI_KEY, "http://127.0.0.1:8082/job/excutor")
                .setProperty(HttpJobProperties.METHOD_KEY, "POST")
                .setProperty(HttpJobProperties.DATA_KEY, "source=ejob")
                .cron("* * * * * ? *")
                .shardingItemParameters("0=test0,1=test1, 2=test2, 3=test3")
                .failover(true)
                .misfire(true)
                .overwrite(true)
                .build();

        ScheduleJobBootstrap scheduleJobBootstrap = new ScheduleJobBootstrap(zookeeperRegistryCenter, "HTTP", jobConfiguration);
        scheduleJobBootstrap.schedule();
    }
}

1.4 调用添加方法

@RestController
@RequestMapping("/job")
public class TaskController {

    @Autowired
    private TaskServer taskServer;

    @RequestMapping("/excutor")
    @ResponseBody
    public String excutor(){
        System.out.println("123");

        return "log info success";
    }
    @RequestMapping("/add")
    public String add(){
        taskServer.addTask();
        return "log info success";
    }
}

1.5 查看zookeeper信息

1.6 查看接口文本信息

注意 ：一开始使用linux服务器上的zookeeper3.6.3,一直连接不上zookeeper ,注册不上，后来在本地安装了个zookeeper3.6.3 使用127.0.0.1：2181 可以正常连接（找了2天原因，没找到）