xxl-job（三）带参数执行和高可用部署

我就是我 2022-10-14 10:48 452阅读 0赞

一、job获取参数：xxl-job通过以下方式获取参数：

String param = XxlJobHelper.getJobParam();

1、单参数：

package com.job.client.jobhandle;
    import com.xxl.job.core.biz.model.ReturnT;
    import com.xxl.job.core.context.XxlJobHelper;
    import com.xxl.job.core.handler.annotation.XxlJob;
    import org.springframework.stereotype.Component;
    import static com.xxl.job.core.biz.model.ReturnT.SUCCESS;
    
    @Component
    public class TestOneHandler {
    
        @XxlJob("TestOneHandler")
        public ReturnT<String> jobDemo(String s) throws Exception {
            String param = XxlJobHelper.getJobParam();
            System.out.println("TestOneHandler执行参数:"+param);
            return SUCCESS;
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70][]

后台：

![20210521092308728.png][]

2、多参数：自定义分割方式

package com.job.client.jobhandle;
    import com.xxl.job.core.biz.model.ReturnT;
    import com.xxl.job.core.context.XxlJobHelper;
    import com.xxl.job.core.handler.annotation.XxlJob;
    import org.springframework.stereotype.Component;
    import static com.xxl.job.core.biz.model.ReturnT.SUCCESS;
    
    @Component
    public class TestOneHandler {
    
        @XxlJob("TestOneHandler")
        public ReturnT<String> jobDemo(String s) throws Exception {
            String param = XxlJobHelper.getJobParam();
            String[] methodParams = param.split(",");
            System.out.println("TestOneHandler执行参数1:"+methodParams[0]);
            System.out.println("TestOneHandler执行参数2:"+methodParams[1]);
            return SUCCESS;
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 1][]

后台：

![20210521092621950.png][]

二、多节点部署：admin服务端只部署一个节点（xxx.xx.xxx.141），Job客户端部署两个节点（一个是xxx.xx.xxx.141,一个是我本地机器xxx.xx.xxx.191，两台机器在一个内网环境下）

代码改动：如我新增一张表，job1执行时往这张表塞入数据：

CREATE TABLE `t_record` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `msg` varchar(255) DEFAULT NULL,
      `params` varchar(255) DEFAULT NULL,
      `ip` varchar(255) DEFAULT NULL,
      `create_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4;

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 2][]

package com.job.client.jobhandle;
    import com.job.client.dto.RecordDTO;
    import com.job.client.service.RecordService;
    import com.xxl.job.core.biz.model.ReturnT;
    import com.xxl.job.core.context.XxlJobHelper;
    import com.xxl.job.core.handler.annotation.XxlJob;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    import static com.xxl.job.core.biz.model.ReturnT.SUCCESS;
    
    @Component
    public class TestOneHandler {
    
        @Autowired
        private RecordService recordService;
    
        @XxlJob("TestOneHandler")
        public ReturnT<String> jobDemo(String s) throws Exception {
            String param = XxlJobHelper.getJobParam();
            System.out.println("TestOneHandler执行参数:"+param);
            RecordDTO record = new RecordDTO();
            record.setIp("");
            record.setParams(param);
            recordService.insert(record);
            return SUCCESS;
        }
    }

pom文件加上打包命令：

<packaging>jar</packaging> 
    <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <executions>
                        <execution>
                            <goals>
                                <goal>repackage</goal>
                            </goals>
                        </execution>
                    </executions>
                </plugin>
            </plugins>
        </build>

1、部署xxl-job-admin服务端：

在xxl-job-admin项目下执行mvn clean package打包，把生成的jar包上传到141服务器上并执行启动命令

java -jar xxl-job-admin-2.3.0.jar &

启动后访问：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 3][]

2、job-client部署：把job中的ip改为141，并修改xxl.job.admin.addresses的值为http://xxx.xx.xxx.141:7777/xxl-job-admin。

在job-client项目下也执行mvn clean package把打包后的jar包上传到141上，执行java -jar job-client-1.0-SNAPSHOT.jar &启动。

3、本地节点启动：修改xxl.job.executor.port的值为5555（不为9999即可）；修改xxl.job.admin.addresses的值为http://xxx.xx.xxx.141:7777/xxl-job-admin。

并把job中的ip改为localhost。启动项目

4、测试：

编辑执行器，机器地址改为141和我本地的机器191

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 4][]

并修改jobOne的执行策略为轮询：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 5][]

1）job自动执行一段时间，观察下数据库，可以看到同一个任务不会被多次执行：

![20210521110829519.png][]

2）手动执行一次，也不会被多次执行：

![20210521110959898.png][]

3）这时候把141的job节点停掉：

![20210521111112138.png][]

![2021052111174369.png][]

可以看到都是localhost节点在执行。

三、高可用部署：上面已经验证了job客户端支持多节点部署，下面将admin服务端也部署多节点，实现高可用，只要保证连接的是同一个数据库，就不会出现job重复执行的情况。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70]: /images/20221014/5f67ff7a0a6f4355aa01cadb27df8c2e.png
[20210521092308728.png]: /images/20221014/3f93b5426c9e4c4b8ce7b49970e4d2b4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 1]: /images/20221014/8625b04b81664dd3b96a1150acbacf9c.png
[20210521092621950.png]: /images/20221014/11c16a6c6f7e4d9d84a361086a426997.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 2]: /images/20221014/fde89db22b64472a809bbd0249e723eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 3]: /images/20221014/8fbfdec12df54ba8a2ffc56b3ac07e63.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 4]: /images/20221014/5a742418cc42460390218bca0a9153c5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70 5]: /images/20221014/f0d2ae8c777445409eb82464dad1abba.png
[20210521110829519.png]: /images/20221014/35d7e5f936f1457c9885f36b1c718275.png
[20210521110959898.png]: /images/20221014/3544629693164cc8ae70be183cdfa768.png
[20210521111112138.png]: /images/20221014/bea39164c52444a0aa328b879ca7d0af.png
[2021052111174369.png]: /images/20221014/8ec18feefd4c4b8aada4dd74d6cee4d7.png