xxl-job使用遇到的問題(二)


xxl-job使用遇到的問題(二)

關聯閱讀 xxl-job使用遇到的問題(一)

1、問題現象

最近有個老定時任務遷移到xxl-job的時候,遇到一個小問題。雖然很快解決,但是還是有必要記錄一下~

job遷移的時候,在執行方法上標記@XxlJob("test"),然后在管理控制台上,添加任務,點擊執行一次的時候,調度日志提示

>>>>>>>>>>>觸發調度<<<<<<<<<<<
觸發調度:
address:http://10.25.31.45:9999/
code:500
msg:job handler [test] not found.

檢查了下代碼,沒啥問題。注解加了,XxlJobSpringExecutor也有,properties配置也ok,為啥提示找不到呢?

大致代碼也貼一下

public interface ITestJob {
    void method1();
}


@Service
public class TestJobImpl implements ITestJob {

    @XxlJob("test")
    public ReturnT<String> demoJobHandler() throws Exception {
        // job業務邏輯【歷史代碼】
        return ReturnT.SUCCESS;
    }

    // 歷史代碼方法
    @Override
    @Async
    public void method1() {
        // 歷史代碼邏輯
    }
}

其實就是在歷史代碼的基礎上,改了下方法返回值,加了個@XxlJob("test")注解。其他沒動

2、排查

既然提示找不到job handler,那問題肯定是出在客戶端了。

前面閱讀源碼的時候,已經看過,@XxlJob注解的解析是在 XxlJobSpringExecutor類里面。快讀看了下這個類,重點看了下initJobHandlerMethodRepository方法

private void initJobHandlerMethodRepository(ApplicationContext applicationContext) {
        if (applicationContext == null) {
            return;
        }
        // init job handler from method
        String[] beanDefinitionNames = applicationContext.getBeanNamesForType(Object.class, false, true);
        for (String beanDefinitionName : beanDefinitionNames) {
            Object bean = applicationContext.getBean(beanDefinitionName);

            Map<Method, XxlJob> annotatedMethods = null;   // referred to :org.springframework.context.event.EventListenerMethodProcessor.processBean
            try {
                annotatedMethods = MethodIntrospector.selectMethods(bean.getClass(),
                        new MethodIntrospector.MetadataLookup<XxlJob>() {
                            @Override
                            public XxlJob inspect(Method method) {
                                return AnnotatedElementUtils.findMergedAnnotation(method, XxlJob.class);
                            }
                        });
            } catch (Throwable ex) {
                logger.error("xxl-job method-jobhandler resolve error for bean[" + beanDefinitionName + "].", ex);
            }
            if (annotatedMethods==null || annotatedMethods.isEmpty()) {
                continue;
            }
 
            
            
            ......
            
 }

在這塊加個斷點看看,果然拿到的 annotatedMethods 是空的,難怪提示找不到呢!

3、原因

上面的demoJobHandler方法頭上標記了注解的,為什么annotatedMethods是空的呢?

這是因為下面這行代碼取到的bean,不是TestJobImpl這個類

Object bean = applicationContext.getBean(beanDefinitionName);

而是一個代理類,並且是jdk的動態代理的類。

jdk動態代理,啥特性?

嗯,基於接口的~~,接口里面只申明了一個方法 method1,那【MethodIntrospector.selectMethods】肯定找不到有XxlJob注解的方法了!

3.1、 解決辦法

知道了這一點,那就好解決了。

可供參考的解決辦法:

方法一、把job這個方法單獨拎出來

方法二、去掉接口,讓Spring使用cglib的代理。這樣取到的代理類就包含2個方法了,就可以找到有注解的那個方法了

方法三、如果上面2個都不想改,那就在接口里面申明一個demoJobHandler方法,並且在接口方法申明上標記@XxlJob("test")注解


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM