1.BindException: Address already in use: bind at sun.nio.ch.Net.bind0(Native Method)

初看的时候还以为是端口占用:Address already in use: bind,不要被错误提示蒙蔽了,实则是 xxl-job 的执行器注解 @Bean 配置的问题。

在低版本的 xxl-job 中, 初始化 XxlJobSpringExecutor 执行器需要在 @Bean 中加上 initMethod = “start”, destroyMethod = “destroy”。

    @Bean(initMethod = "start", destroyMethod = "destroy")
    public XxlJobSpringExecutor xxlJobExecutor() {

但是在高版本的 xxl-job(如 2.2.0)则需要删除 initMethod = “start”, destroyMethod = “destroy”
变为:

 @Bean
    public XxlJobSpringExecutor xxlJobExecutor() {

修改后项目启动就没有报错了

2.新增执行器自动注册无法获取ip

具体不知道是什么原因但是可以从两方面下手:
a.核对所用jar包是否和调度中心的jar包对应
b.实在不行就复制XxlJobExecutorApplication项目的示例代码

3.测试时新增执行器名称使用“测试执行器”但是任务管理中出现两个测试执行器的分组

名称是复制的但还是两个分组,无法理解。
推荐测试时AppName使用xxl-job-executor-sample然后编辑原本的默认执行器,选择自动注册然后保存,就可以把测试的ip也添加进去了,如下。这样在查看任务管理时就比较方便了,不用切分组。

1. http://127.0.0.1:8888/
2. http://127.0.0.1:9999/

4.替换为更高版本时无法获取参数,参数为null

阅读官方文档发现,新版修改了获取参数的方式

 版本 v2.3.0 Release Notes[2021-02-09]
 4、【优化】任务核心类 “IJobHandler” 的 “execute” 方法取消出入参设计。改为通过 “XxlJobHelper.getJobParam” 获取任务参数并替代方法入参,通过 “XxlJobHelper.handleSuccess/handleFail” 设置任务结果并替代方法出参,示例代码如下;
@XxlJob("demoJobHandler")
public void execute() {
String param = XxlJobHelper.getJobParam();    // 获取参数
XxlJobHelper.handleSuccess();                 // 设置任务结果
}

================================================
使用的依赖

<dependency>
            <groupId>com.xuxueli</groupId>
            <artifactId>xxl-job-core</artifactId>
            <version>2.2.0</version>
        </dependency>

配置文件

### xxl-job admin address list:调度中心部署跟地址:如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册""任务结果回调"。
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin

### xxl-job executor address:执行器"AppName"和地址信息配置:AppName执行器心跳注册分组依据;地址信息用于"调度中心请求并触发任务""执行器注册"。执行器默认端口为9999,执行器IP默认为空表示自动获取IP,多网卡时可手动设置指定IP,该IP不会绑定Host仅作为通讯实用。单机部署多个执行器时,注意要配置不同执行器端口;
xxl.job.executor.appname=xxl-job-executor-sample
xxl.job.executor.ip=
xxl.job.executor.port=8888
# # 执行器注册 [选填]:优先使用该配置作为注册地址,为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。
xxl.job.executor.address=

### xxl-job, access token:执行器通讯TOKEN,非空时启用
xxl.job.accessToken=

### xxl-job log path:执行器运行日志文件存储的磁盘位置,需要对该路径拥有读写权限
xxl.job.executor.logpath=log/xxl-job/jobhandler

### xxl-job log retention days:执行器Log文件定期清理功能,指定日志保存天数,日志文件过期自动删除。限制至少保持3天,否则功能不生效;选填
xxl.job.executor.logretentiondays=-1

配置类

@Slf4j
@Configuration
public class XxlJobConfig {

    @Value("${xxl.job.admin.addresses}")
    private String adminAddresses;

    @Value("${xxl.job.accessToken}")
    private String accessToken;

    @Value("${xxl.job.executor.appname}")
    private String appname;

    @Value("${xxl.job.executor.address}")
    private String address;

    @Value("${xxl.job.executor.ip}")
    private String ip;

    @Value("${xxl.job.executor.port}")
    private int port;

    @Value("${xxl.job.executor.logpath}")
    private String logPath;

    @Value("${xxl.job.executor.logretentiondays}")
    private int logRetentionDays;

    @Bean
    public XxlJobSpringExecutor xxlJobExecutor() {
        log.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
        xxlJobSpringExecutor.setAppname(appname);
        xxlJobSpringExecutor.setAddress(address);
        xxlJobSpringExecutor.setIp(ip);
        xxlJobSpringExecutor.setPort(port);
        xxlJobSpringExecutor.setAccessToken(accessToken);
        xxlJobSpringExecutor.setLogPath(logPath);
        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);

        return xxlJobSpringExecutor;
    }

@Slf4j
@Component
public class XxlJobService {

    /**
     * 1、简单任务示例(Bean模式)
     */
    @XxlJob("testJobHandler")
    public ReturnT<String> demoJobHandler(String param) throws Exception {
        XxlJobLogger.log("XXL-JOB, Hello World.");
        log.info("====testJobHandler=======");
        return ReturnT.SUCCESS;
    }
}
Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐