xxl-job @RefreshScope 与XxlJobSpringExecutor不兼容

hrysbysz 于 2022-04-21 发布在 Java

关注(0)|答案(1)|浏览(359)

Please answer some questions before submitting your issue. Thanks!

Which version of XXL-JOB do you using?

2.0.1

Expected behavior

@RefreshScope
@Bean( initMethod = "start", destroyMethod = "destroy" )
public XxlJobSpringExecutor xxlJobExecutor() {
    logger.info( ">>>>>>>>>>> xxl-job config init." );
    XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
    xxlJobSpringExecutor.setAdminAddresses( adminAddresses );
    // todo 版本冲突
    xxlJobSpringExecutor.setAppName( appName );
    xxlJobSpringExecutor.setIp( ip );
    xxlJobSpringExecutor.setPort( port );
    xxlJobSpringExecutor.setAccessToken( accessToken );
    xxlJobSpringExecutor.setLogPath( logPath );
    xxlJobSpringExecutor.setLogRetentionDays( logRetentionDays );

    return xxlJobSpringExecutor;
}
通过@RefreshScope注解实现配置中心的动态更新配置

Actual behavior

xxljob服务没有启动

Steps to reproduce the behavior

@RefreshScope
@configuration
public class XxlJobConfig {
private Logger logger = LoggerFactory.getLogger( XxlJobConfig.class );

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

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

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

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

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

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

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

@RefreshScope
@Bean( initMethod = "start", destroyMethod = "destroy" )
public XxlJobSpringExecutor xxlJobExecutor() {
    logger.info( ">>>>>>>>>>> xxl-job config init." );
    XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
    xxlJobSpringExecutor.setAdminAddresses( adminAddresses );
    // todo 版本冲突
    xxlJobSpringExecutor.setAppName( appName );
    xxlJobSpringExecutor.setIp( ip );
    xxlJobSpringExecutor.setPort( port );
    xxlJobSpringExecutor.setAccessToken( accessToken );
    xxlJobSpringExecutor.setLogPath( logPath );
    xxlJobSpringExecutor.setLogRetentionDays( logRetentionDays );

    return xxlJobSpringExecutor;
}

}