記一次activiti監(jiān)聽(tīng)器無(wú)法實(shí)例化的錯(cuò)誤解決過(guò)程(SpringBoot Listener)

慢來(lái)比較快，虛心學(xué)技術(shù)

思路永遠(yuǎn)比答案更有價(jià)值

問(wèn)題場(chǎng)景

SpringBoot項(xiàng)目中，activiti某個(gè)流程節(jié)點(diǎn)需要配置監(jiān)聽(tīng)器，當(dāng)前節(jié)點(diǎn)任務(wù)提交完成之后觸發(fā)方法更改遠(yuǎn)程表單的狀態(tài)，具體流程監(jiān)聽(tīng)設(shè)計(jì)如下：

feignClient代碼：MyService.java

@FeignClient(value = "xxxxx")
public interface MyService {

   /**
    * 修改狀態(tài)
    * @param inId
    * @return
    */
   @PutMapping("/myTest/updateState")
   Boolean updateState(@RequestParam("id") Integer id);

}

監(jiān)聽(tīng)器代碼：MyTaskListener.java,此處使用Lombok @AllArgConstructor注解通過(guò)全參構(gòu)造器注入MyService

@AllArgsConstructor
public class MyTaskListener implements TaskListener {

    private MyService myService;

   /**
    * 任務(wù)監(jiān)聽(tīng)修改表單狀態(tài)
    * @param delegateTask 當(dāng)前執(zhí)行提交的任務(wù)
    */
   @Override
   public void notify(DelegateTask delegateTask) {
       。。。。。//獲取到表單id
       myService.updateState(id);
   }
}

任務(wù)提交完成觸發(fā)監(jiān)聽(tīng)器的報(bào)錯(cuò)信息：couldn't instantiate class com.xxx.activiti.listener.MyTaskListener

2019-04-16 19:01:45.592 ERROR [xxx-activiti,b4057cc762e15e24,b4057cc762e15e24,true] 224 --- [  XNIO-1 task-1] o.a.e.impl.interceptor.CommandContext    : Error while closing command context

org.activiti.engine.ActivitiException: Exception while invoking TaskListener: couldn't instantiate class com.xxx.activiti.listener.MyTaskListener
    at org.activiti.engine.impl.persistence.entity.TaskEntity.fireEvent(TaskEntity.java:742)
    at org.activiti.engine.impl.persistence.entity.TaskEntity.complete(TaskEntity.java:184)
    at org.activiti.engine.impl.cmd.CompleteTaskCmd.execute(CompleteTaskCmd.java:52)
    at org.activiti.engine.impl.cmd.CompleteTaskCmd.execute(CompleteTaskCmd.java:24)
    at org.activiti.engine.impl.cmd.NeedsActiveTaskCmd.execute(NeedsActiveTaskCmd.java:59)
    at org.activiti.engine.impl.interceptor.CommandInvoker.execute(CommandInvoker.java:24)
    at org.activiti.engine.impl.interceptor.CommandContextInterceptor.execute(CommandContextInterceptor.java:57)
    at org.activiti.spring.SpringTransactionInterceptor$1.doInTransaction(SpringTransactionInterceptor.java:47)
    at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:140)
    at org.activiti.spring.SpringTransactionInterceptor.execute(SpringTransactionInterceptor.java:45)
    at org.activiti.engine.impl.interceptor.LogInterceptor.execute(LogInterceptor.java:31)
    at org.activiti.engine.impl.cfg.CommandExecutorImpl.execute(CommandExecutorImpl.java:40)
    at org.activiti.engine.impl.cfg.CommandExecutorImpl.execute(CommandExecutorImpl.java:35)
    at org.activiti.engine.impl.TaskServiceImpl.complete(TaskServiceImpl.java:182)
    at xxx.activiti.controller.TaskController.submit(TaskController.java:181)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframewor

原因猜想

對(duì)比項(xiàng)目自帶的請(qǐng)假流程監(jiān)聽(tīng)類

@Slf4j
public class LeaveProcessTaskListener implements TaskListener {

   /**
    * 查詢提交人的上級(jí)
    *
    * @param delegateTask
    */
   @Override
   public void notify(DelegateTask delegateTask) {
     。。。。。
   }
}

發(fā)現(xiàn)，兩者區(qū)別在于 MyTaskListener引入了一個(gè)Spring的Bean，猜想應(yīng)該是Bean注入失敗導(dǎo)致的

猜想認(rèn)證

將MyTaskListener中的Bean注入暫時(shí)去除：

public class MyTaskListener implements TaskListener {

   /**
    * 任務(wù)監(jiān)聽(tīng)修改表單狀態(tài)
    * @param delegateTask 當(dāng)前執(zhí)行提交的任務(wù)
    */
   @Override
   public void notify(DelegateTask delegateTask) {
       。。。。。//獲取到表單id
       System.out.println("執(zhí)行任務(wù)完成=========");
   }
}

再次執(zhí)行任務(wù)提交觸發(fā)監(jiān)聽(tīng)器輸出：

執(zhí)行任務(wù)完成=========

猜想正確

資料查詢

①Listener中無(wú)法通過(guò)構(gòu)造函數(shù)進(jìn)行Bean注入，必須通過(guò)setter方法注入

更改MyTaskListener中的Bean注入方式

public class MyTaskListener implements TaskListener {
    @Autowired
    private MyService myService;

   /**
    * 任務(wù)監(jiān)聽(tīng)修改表單狀態(tài)
    * @param delegateTask 當(dāng)前執(zhí)行提交的任務(wù)
    */
   @Override
   public void notify(DelegateTask delegateTask) {
       。。。。。//獲取到表單id
       myService.updateState(id);
   }
}

執(zhí)行任務(wù)提交報(bào)錯(cuò)：Exception while invoking TaskListener: null，錯(cuò)誤NullPointException源于MyService空

2019-04-16 19:14:59.049 ERROR [xxx-activiti,b88f0f9fd6ab86e1,b88f0f9fd6ab86e1,true] 14508 --- [  XNIO-1 task-2] t.t.c.s.c.GlobalExceptionHandlerResolver : 全局異常信息 ex=Exception while invoking TaskListener: Exception while invoking TaskListener: null

org.activiti.engine.ActivitiException: Exception while invoking TaskListener: Exception while invoking TaskListener: null
    at org.activiti.engine.impl.persistence.entity.TaskEntity.fireEvent(TaskEntity.java:742)
    at org.activiti.engine.impl.persistence.entity.TaskEntity.complete(TaskEntity.java:184)
    at org.activiti.engine.impl.cmd.CompleteTaskCmd.execute(CompleteTaskCmd.java:52)
    at org.activiti.engine.impl.cmd.CompleteTaskCmd.execute(CompleteTaskCmd.java:24)
    at org.activiti.engine.impl.cmd.NeedsActiveTaskCmd.execute(NeedsActiveTaskCmd.java:59)
    at org.activiti.engine.impl.interceptor.CommandInvoker.execute(CommandInvoker.java:24)
    at org.activiti.engine.impl.interceptor.CommandContextInterceptor.execute(CommandContextInterceptor.java:57)
    at org.activiti.spring.SpringTransactionInterceptor$1.doInTransaction(SpringTransactionInterceptor.java:47)
    at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:140)
    at org.activiti.spring.SpringTransactionInterceptor.execute(SpringTransactionInterceptor.java:45)
    at org.activiti.engine.impl.interceptor.LogInterceptor.execute(LogInterceptor.java:31)
    at org.activiti.engine.impl.cfg.CommandExecutorImpl.execute(CommandExecutorImpl.java:40)
    at org.activiti.engine.impl.cfg.CommandExecutorImpl.execute(CommandExecutorImpl.java:35)
    at org.activiti.engine.impl.TaskServiceImpl.complete(TaskServiceImpl.java:182)
    at com.xxx.activiti.controller.TaskController.submit(TaskController.java:181)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at or

②以上述結(jié)果為基礎(chǔ)進(jìn)行查詢，一說(shuō)Listener未被Spring容器進(jìn)行管理，所以注入為空，我們可以在MyTaskListener上添加@Component注解，將MyTaskListener裝配到Spring容器中

@Component
public class MyTaskListener implements TaskListener {
    @Autowired
    private MyService myService;

   /**
    * 任務(wù)監(jiān)聽(tīng)修改表單狀態(tài)
    * @param delegateTask 當(dāng)前執(zhí)行提交的任務(wù)
    */
   @Override
   public void notify(DelegateTask delegateTask) {
       。。。。。//獲取到表單id
       myService.updateState(id);
   }
}

執(zhí)行任務(wù)提交報(bào)錯(cuò)：Exception while invoking TaskListener: null

一樣的結(jié)果

③此時(shí)懷疑是否MyTaskListener沒(méi)有成功裝配到Spring容器中，所以編寫一個(gè)工具類輸出當(dāng)前ApplicationContext所有被裝配的類

@Component
public class SpringUtil implements ApplicationContextAware {

   /**
    * 當(dāng)前IOC
    */
   private static ApplicationContext applicationContext;

   @Override
   public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
      this.applicationContext = applicationContext;
   }

   /**
    * 輸出當(dāng)前容器中所有被裝配的類的id/bean名稱
    */
   public static void showClass(){
      String[] beanDefinitionNames = applicationContext.getBeanDefinitionNames();
      for(String beanDefinitionName : beanDefinitionNames){
         System.out.println(beanDefinitionName);
      }
   }
}

任務(wù)提交后調(diào)用SpringUtil.showClass()，輸出結(jié)果：

。
。
。
myTaskListener
。
。
。
com.xxx.activiti.feign.MyService
。

證明MyTaskListener及MyService都被裝配成功

④繼續(xù)查找，得到下述解釋：

(1)Listener的生命周期是由servlet容器（例如tomcat）管理的，項(xiàng)目啟動(dòng)時(shí)上例中的ConfigListener是由servlet容器實(shí)例化并調(diào)用其contextInitialized方法，而servlet容器并不認(rèn)得@Autowired注解，因此導(dǎo)致ConfigService實(shí)例注入失敗。

(2)而spring容器中的bean的生命周期是由spring容器管理的。

注解的方式執(zhí)行的位置，spring的注入是在filter和listener之后的，（順序:listener >> filter >> servlet >> spring ）。

如果在監(jiān)聽(tīng)器中有需要對(duì)容器中bean進(jìn)行引用，就不能采用注解的方式了。只能手動(dòng)的進(jìn)行配置文件的讀取

個(gè)人理解，上述過(guò)程中MyTaskListenre雖然存在于Spring容器中，但未被Spring容器所管理，所以@Autowired失效

嘗試解決，既然注解方式不可以，那么可以考慮使用xml配置的傳統(tǒng)方式，但是SpringBoot早已拋棄了xml配置方式，所以可以使用JAVA配置的老方法，手動(dòng)從容器中取出Bean：

改寫SpringUtil，提供手動(dòng)獲取Bean的方法

 @Component
public class SpringUtil implements ApplicationContextAware {

   /**
    * 當(dāng)前IOC
    *
    */
   private static ApplicationContext applicationContext;
    /**
     * 設(shè)置applicationContext
     */
   @Override
   public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
      this.applicationContext = applicationContext;
   }

   /**
    * 從當(dāng)前IOC獲取bean
    */
   public static <T> T getObject(Class<T> clazz){
       return applicationContext.getBean(clazz);
   }

   public static void showClass(){
      String[] beanDefinitionNames = applicationContext.getBeanDefinitionNames();
      for(String beanDefinitionName : beanDefinitionNames){
         System.out.println(beanDefinitionName);
      }
   }
}

改寫監(jiān)聽(tīng)器,更改MyService的獲取方式：

@Component
public class MyTaskListener implements TaskListener {

   /**
    * 任務(wù)監(jiān)聽(tīng)修改表單狀態(tài)
    * @param delegateTask 當(dāng)前執(zhí)行提交的任務(wù)
    */
   @Override
   public void notify(DelegateTask delegateTask) {
       MyService myService= SpringUtil.getObject(MyService.class);
       。。。。。//獲取到表單id
       myService.updateState(id);
   }
}

測(cè)試運(yùn)行，問(wèn)題解決

解決方案

手動(dòng)獲取Bean（如上）：

 @Component
public class SpringUtil implements ApplicationContextAware {

   /**
    * 當(dāng)前IOC
    *
    */
   private static ApplicationContext applicationContext;

    /**
     * 設(shè)置applicationContext
     */
   @Override
   public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
      this.applicationContext = applicationContext;
   }

   public static <T> T getObject(Class<T> clazz){
       return applicationContext.getBean(clazz);
   }
 }

思路推演

|------activiti執(zhí)行任務(wù)觸發(fā)監(jiān)聽(tīng)器報(bào)錯(cuò)：couldn't instantiate class com.xxx.activiti.listener.MyTaskListener
|
|------比對(duì)正常監(jiān)聽(tīng)類，發(fā)現(xiàn)區(qū)別在于注入的Bean
|
|------確認(rèn)問(wèn)題所在，第一次嘗試使用@Autowired方式注入失敗，新報(bào)錯(cuò)：Exception while invoking TaskListener: null,錯(cuò)誤NullPointException源于MyService空
|
|-----問(wèn)題定位轉(zhuǎn)移：SpringBoot中監(jiān)聽(tīng)器注入Spring Bean空？
|
|-----獲得解決方案且知悉原理，手動(dòng)獲取Bean

備注

當(dāng)初考慮過(guò)是否因?yàn)镸yService在Spring容器中注冊(cè)的ID為：com.xxx.activiti.feign.MyService 而不是myService從而導(dǎo)致無(wú)法注入。而后一想，controller中可以正常注入且變量命名隨意，證明@Autowired并不是根據(jù)Bean的id進(jìn)行，而是默認(rèn)根據(jù)類型去獲取bean（Spring基礎(chǔ)知識(shí)）

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容