Quartz：ERROR threw an unhandled Exception

詳細的錯誤信息以下：

 1 2016-06-28 17:18:13.366 [DefaultQuartzScheduler_Worker-1] ERROR org.quartz.core.JobRunShell:211 - Job group1.job1 threw an unhandled Exception: 
 2 java.lang.NullPointerException
 3     at com.starunion.java.service.timer.JobEndConference.execute(JobEndConference.java:45) ~[bin/:?]
 4     at org.quartz.core.JobRunShell.run(JobRunShell.java:202) [quartz-2.2.1.jar:?]
 5     at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573) [quartz-2.2.1.jar:?]
 6 2016-06-28 17:18:13.374 [DefaultQuartzScheduler_Worker-1] ERROR org.quartz.core.ErrorLogger:2425 - Job (group1.job1 threw an exception.
 7 org.quartz.SchedulerException: Job threw an unhandled exception.
 8     at org.quartz.core.JobRunShell.run(JobRunShell.java:213) [quartz-2.2.1.jar:?]
 9     at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573) [quartz-2.2.1.jar:?]
10 Caused by: java.lang.NullPointerException
11     at com.starunion.java.service.timer.JobEndConference.execute(JobEndConference.java:45) ~[bin/:?]
12     at org.quartz.core.JobRunShell.run(JobRunShell.java:202) ~[quartz-2.2.1.jar:?]

說說個人解決過程：

1、緣由很明顯：調用了null對象。

根據日誌信息，定位到個人Job對象類的指定行，下圖的21行：

 1 @Component
 2 public class JobEndConference implements Job {
 3 
 4     @Autowired
 5     CallableFsExecCmdProc procExecTask;
 6 
 7     @Override
 8     public void execute(JobExecutionContext JEContext) throws JobExecutionException {
 9 
10         JobDataMap map = JEContext.getJobDetail().getJobDataMap();
11 
12         String meetName = (String) map.get("meetName");
13 
14         StringBuffer buff = new StringBuffer();
15         buff.append("bgapi conference ");
16         buff.append(meetName);
17         buff.append(" kick all");
18         // buff.append(ConstantUtil.FS_CMD_TAIL);
19         20         // SocketFsTcp4SendCMD.fsSendCommand(buff.toString());
21         procExecTask.setSendCmd(buff.toString());
22         Future<Integer> future = StarProxy.executor.submit(procExecTask);
23         try {
24             future.get(5000, TimeUnit.MILLISECONDS);
25         } catch (InterruptedException | ExecutionException | TimeoutException e) {
26             e.printStackTrace();
27         }
28 
29     }
30 
31 }

這個對象爲空，也就意味着沒有經過Spring註解正確的初始化。

肯定這個註解的寫法是正確的，其餘全部的類都是這麼寫的。

2、那問題在哪裏呢？

往上查，看看對這個類的調用狀況。

1 ......
2 JobDetail jobDetail = newJob(JobEndConference.class).withIdentity("job1", "group1").setJobData(dm).build();
3 ......

緣由出來了，newJob傳入的對象參數並不是Spring註解加載的那個對象。

3、解決辦法：

方法1. 從Spring的ApplicationContext獲取JobEndConference對象。

方法2. 取消JobEndConference的自己和參數的註解，用new初始化。