实现一个线程继承了Thread或实现Runnable接口,想在run方法中使用spring依赖注入(操作数据库),此时报错为空指针,就是说没有注入进来。
实验了几种方式,分别说一下优缺点。
1:写了工具类,实现ApplicationContextAware接口,做一个通过name获取实例的方式,代码如下:
public class SpringUtil implements ApplicationContextAware { private static ApplicationContext ctx = null; @Override
public void setApplicationContext(ApplicationContext applicationContext)
throws BeansException { if (SpringUtil.ctx == null) {
SpringUtil.ctx = applicationContext;
}
} public static ApplicationContext getCtx() {
return ctx;
} public static Object getBean(String name) {
return getCtx().getBean(name);
} }
这种方式有个缺陷,需要web容器相应之后才有值,也就说是懒加载了,线程如果比web容器先响应的时候还是为null值。
2:内部类,这个不多说了,实际上属于绕过去了,我自己认为这样写破坏了结构,也不好维护。
3:构造注入,我认为这个方式最好,注入类依旧被spring管理,代码结构简单清晰。
在线程中提供一个构造方法,比如(注意:public RecvThread(boolean flag, DBmapper dbMapper) ):
@Component("RecvThread")
public class RecvThread extends Observable implements Runnable { private boolean flag; private DBmapper dbMapper; private QueueModel model; private static HashMap<String, String> map = new HashMap<String, String>(); public RecvThread() {
super();
} public RecvThread(boolean flag, DBmapper dbMapper) {
this.flag = flag;
this.dbMapper = dbMapper;
} public void ob(){
if(true){
super.setChanged();
}
notifyObservers();
} @Override
public void run() {
while (flag) {
try {
在启动线程的地方注入:
@Component("SystemStartBean")
public class SystemStartBean extends SpringBeanAutowiringSupport implements Servlet { @Autowired
private DBmapper dbMapper; @Override
public void init(ServletConfig arg0) throws ServletException { RecvThread rt = new RecvThread(true, dbMapper);
rt.addObserver(new RecvThreadListener());
new Thread(rt).start();
}