最近在做一個“溫濕度控制”的項目，項目要求通過用戶設(shè)定的溫濕度數(shù)值和實時采集到的數(shù)值進行比對分析，因為數(shù)據(jù)的對比與分析是一個通過前端頁面控制的定時任務(wù)，經(jīng)理要求在用戶開啟定時任務(wù)時，單獨開啟一個線程進行數(shù)據(jù)的對比分析，并將采集到的溫濕度數(shù)值存入數(shù)據(jù)庫中的歷史數(shù)據(jù)表，按照我們正常的邏輯應(yīng)該是用戶在請求開啟定時任務(wù)時，前端頁面通過調(diào)用后端接口，創(chuàng)建一個新的線程來執(zhí)行定時任務(wù)，然后在線程類中使用 @Autowired 注解注入保存歷史數(shù)據(jù)的service層，在線程類中調(diào)用service層保存歷史數(shù)據(jù)的方法實現(xiàn)溫濕度數(shù)據(jù)的保存，這時就出現(xiàn)了一個很尷尬的問題，在新開啟的線程中使用 @Autowired 注解無法注入需要的bean(即：保存歷史數(shù)據(jù)的service層)，程序一直在報 NullPointerException 。
成都創(chuàng)新互聯(lián)公司是一家專業(yè)從事網(wǎng)站設(shè)計、成都網(wǎng)站設(shè)計的網(wǎng)絡(luò)公司。作為專業(yè)網(wǎng)站建設(shè)公司,成都創(chuàng)新互聯(lián)公司依托的技術(shù)實力、以及多年的網(wǎng)站運營經(jīng)驗,為您提供專業(yè)的成都網(wǎng)站建設(shè)、營銷型網(wǎng)站及網(wǎng)站設(shè)計開發(fā)服務(wù)！
這是controller層，方法 startExperiment 和 stopExperiment 分別是開始定時任務(wù)和停止定時任務(wù)的方法，getData方法不屬于本次討論范圍，不用管
重慶分公司
重慶分公司
package com.backstage.controller;
import com.alibaba.fastjson.JSONObject;
import com.backstage.entity.JsonResponse;
import com.backstage.entity.Threshold;
import com.backstage.service.MainPageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
/**
* @ProjectName:
* @Package: com.backstage.controller
* @ClassName: MainPageController
* @Description: 主頁面相關(guān)操作控制器
* @Author: wangzhilong
* @CreateDate: 2018/8/29 9:49
* @Version: 1.0
*/
@RestController
@RequestMapping("/main")
public class MainPageController {
@Autowired
private MainPageService mainPageService;
/**
* 開始實驗
*
* @param threshold
*/
@RequestMapping("/startExperiment")
public JsonResponse startExperiment(HttpServletRequest request, Threshold threshold) {
return mainPageService.startExperiment(request, threshold);
}
/**
* 停止實驗
*/
@RequestMapping("/stopExperiment")
public JsonResponse stopExperiment() {
return mainPageService.stopExperiment();
}
/**
* 獲取實時數(shù)據(jù)
*
* @return
*/
@RequestMapping("/getData")
public JSONObject getData() {
return null;
}
}service 層接口代碼，沒什么好說的，直接上代碼：
package com.backstage.service;
import com.alibaba.fastjson.JSONObject;
import com.backstage.entity.JsonResponse;
import com.backstage.entity.Threshold;
import javax.servlet.http.HttpServletRequest;
/**
* @ProjectName:
* @Package: com.backstage.service
* @ClassName: MainPageService
* @Description: 主頁面相關(guān)操作業(yè)務(wù)層接口
* @Author: wangzhilong
* @CreateDate: 2018/8/29 9:51
* @Version: 1.0
*/
public interface MainPageService {
/**
* 開始實驗
*
* @param threshold
*/
JsonResponse startExperiment(HttpServletRequest request, Threshold threshold);
/**
* 停止實驗
*/
JsonResponse stopExperiment();
/**
* 獲取實時數(shù)據(jù)
*
* @return
*/
JSONObject getData();
}service 層實現(xiàn)類代碼，關(guān)于springboot項目使用多線程進行業(yè)務(wù)處理不屬于本章節(jié)的討論范圍，如有需要，請留言，我會在看到留言后第一時間更新相關(guān)技術(shù)文章，由于這里刪除了一些與本章節(jié)無關(guān)的代碼，如果復(fù)制到開發(fā)工具內(nèi)有報錯問題，麻煩大家提醒我一下，以便修改，非常感謝
package com.backstage.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.backstage.entity.*;
import com.backstage.monitor.TimingMonitoring;
import com.backstage.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Service;
import javax.servlet.http.HttpServletRequest;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ScheduledFuture;
/**
* @ProjectName:
* @Package: com.backstage.service.impl
* @ClassName: MainPageServiceImpl
* @Description: 主頁面相關(guān)操作業(yè)務(wù)層實現(xiàn)類
* @Author: wangzhilong
* @CreateDate: 2018/8/29 9:51
* @Version: 1.0
*/
@Service
public class MainPageServiceImpl implements MainPageService {
@Autowired
private ThreadPoolTaskScheduler threadPoolTaskScheduler;
private ScheduledFuture<?> future2;
@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
return new ThreadPoolTaskScheduler();
}
/**
* 開始實驗
*
* @param threshold
*/
@Override
public JsonResponse startExperiment(HttpServletRequest request, Threshold threshold) {
TimingMonitoring timingMonitoring = new TimingMonitoring();
timingMonitoring.setThreshold(threshold, list, experiment.getId(), experimentData.getId());
future2 = threadPoolTaskScheduler.schedule(new TimingMonitoring(), new Trigger() {
@Override
public Date nextExecutionTime(TriggerContext triggerContext) {
//設(shè)置定時任務(wù)的執(zhí)行時間為3秒鐘執(zhí)行一次
return new CronTrigger("0/10 * * * * ?").nextExecutionTime(triggerContext);
}
});
return new JsonResponse(0,"開始實驗!");
}
/**
* 停止實驗
*/
@Override
public JsonResponse stopExperiment() {
if (future2 != null) {
experimentService.upd(getTime());
future2.cancel(true);
}
return new JsonResponse(0,"結(jié)束實驗!");
}
/**
* 獲取實時數(shù)據(jù)
*
* @return
*/
@Override
public JSONObject getData() {
return null;
}
protected String getTime() {
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
return format.format(new Date());
}
}重點，線程類代碼，大家注意看，我在代碼最開始使用了spring的 @Autowired 注解注入需要的service，可在調(diào)用service中的add方法時，程序報空指針異常，一直認(rèn)為是add方法或者sql語句有問題，找了一上午，也沒發(fā)現(xiàn)任何問題，后來單獨調(diào)用這個add方法是可以正常插入數(shù)據(jù)的，唯獨在這個線程類中調(diào)用時報錯，感覺和線程有莫大的關(guān)系，百度一搜，還真找到了，原來，在線程中為了線程安全，是防注入的，沒辦法，要用到這個類啊。只能從bean工廠里拿個實例了，繼續(xù)往下看
package com.backstage.monitor;
import com.backstage.entity.DetailedData;
import com.backstage.entity.Threshold;
import com.backstage.entity.ValveValue;
import com.backstage.service.DetailedDataService;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* @ProjectName:
* @Package: com.backstage.monitor
* @ClassName: TimingMonitoring
* @Description: 定時監(jiān)測溫(濕)度 數(shù)據(jù)
* @Author: wangzhilong
* @CreateDate: 2018/8/29 10:11
* @Version: 1.0
*/
public class TimingMonitoring implements Runnable{
//歷史數(shù)據(jù)業(yè)務(wù)層接口
@Autowired
public DetailedDataService detailedDataService;
private Threshold threshold; //閾值實體類
private List settingData; //設(shè)定的溫濕度數(shù)據(jù)
private Integer id; //實驗記錄id
private Integer dataId; //歷史數(shù)據(jù)主表id
public void setThreshold(Threshold threshold, List settingData, Integer id, Integer dataId) {
this.threshold = threshold;
this.settingData = settingData;
this.id = id;
this.dataId = dataId;
}
@Override
public void run() {
//模擬從PLC獲取到的數(shù)據(jù)
String data = "001,50.5,002,37,003,45.6,004,40,005,55.2,006,58";
if (data == null || data.trim() == "") {
return; //若獲取到的數(shù)據(jù)為空，則直接停止該方法的執(zhí)行
}
double temperature = 0.0; //溫度
double humidity = 0.0; //濕度
Integer type = null; //數(shù)據(jù)類型，1是溫度，2是濕度
//解析數(shù)據(jù)，并將數(shù)據(jù)保存到歷史數(shù)據(jù)數(shù)據(jù)庫
String[] str = data.split(",");
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SS");
for (int i = 0; i < str.length; i++) {
if (i == 1 || i == 5 || i == 9) { //溫度
type = 1;
temperature += Double.parseDouble(str[i]);
//System.out.println("溫度" + i + " -》 " + str[i-1] + ":" + str[i]);
detailedDataService.add(new DetailedData(null, type, Double.parseDouble(str[i]), format.format(new Date()), str[i - 1], dataId));
}
if (i == 3 || i == 7 || i == 11) { //濕度
type = 2;
humidity += Double.parseDouble(str[i]);
//System.out.println("濕度" + i + " -》 " + str[i-1] + ":" + str[i]);
detailedDataService.add(new DetailedData(null, type, Double.parseDouble(str[i]), format.format(new Date()), str[i - 1], dataId));
}
}
}
/**
* 獲取當(dāng)前時間，精確到毫秒
* @return
*/
protected String getTime() {
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SS");
return format.format(new Date());
}
} 獲取bean對象的工具類，既然程序無法通過注解拿到需要的bean，那就只好自己寫個工具類來獲取嘍，下面是工具類代碼
package com.backstage.config;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
/**
* @ProjectName:
* @Package: com.backstage.config
* @ClassName: ApplicationContextProvider
* @Description: 獲取bean對象的工具類
* @Author: wangzhilong
* @CreateDate: 2018/8/31 13:26
* @Version: 1.0
*/
/**
* Author:ZhuShangJin
* Date:2018/7/3
*/
@Component
public class ApplicationContextProvider implements ApplicationContextAware {
/**
* 上下文對象實例
*/
private static ApplicationContext applicationContext;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}
/**
* 獲取applicationContext
*
* @return
*/
public static ApplicationContext getApplicationContext() {
return applicationContext;
}
/**
* 通過name獲取 Bean.
*
* @param name
* @return
*/
public static Object getBean(String name) {
return getApplicationContext().getBean(name);
}
/**
* 通過class獲取Bean.
*
* @param clazz
* @param
* @return
*/
public static T getBean(Class clazz) {
return getApplicationContext().getBean(clazz);
}
/**
* 通過name,以及Clazz返回指定的Bean
*
* @param name
* @param clazz
* @param
* @return
*/
public static T getBean(String name, Class clazz) {
return getApplicationContext().getBean(name, clazz);
}
} 這樣呢，就可以在線程類中寫一個無參的構(gòu)造方法，在構(gòu)造方法中，通過調(diào)用工具類中的 getBean() 方法就可以拿到實例了，程序在調(diào)用這個線程類時，會自動調(diào)用其無參的構(gòu)造方法，在構(gòu)造方法中我們將需要的bean對象注入，然后就可以正常使用了，下邊是線程類修改后的代碼，由于別的地方?jīng)]有改動，所以這里只給大家改動的代碼，省得大家看到一大堆代碼頭疼。
public TimingMonitoring() {
//new的時候注入需要的bean
this.detailedDataService = ApplicationContextProvider.getBean(DetailedDataService.class);
}
總結(jié)
以上所述是小編給大家介紹的SpringBoot項目使用多線程處理任務(wù)時無法通過@Autowired注入bean 問題，希望對大家有所幫助，如果大家有任何疑問歡迎給我留言，小編會及時回復(fù)大家的！
