详解Spring-Boot中如何使用多线程处理任务
看到这个标题，相信不少人会感到疑惑，回忆你们自己的场景会发现，在Spring的项目中很少有使用多线程处理任务的，没错，大多数时候我们都是使用SpringMVC开发的web项目，默认的Controller，Service，Dao组件的作用域都是单实例，无状态，然后被并发多线程调用，那么如果我想使用多线程处理任务，该如何做呢？
比如如下场景：
使用spring-boot开发一个监控的项目，每个被监控的业务（可能是一个数据库表或者是一个pid进程）都会单独运行在一个线程中，有自己配置的参数，总结起来就是：
（1）多实例（多个业务，每个业务相互隔离互不影响）
（2）有状态（每个业务，都有自己的配置参数）
如果是非spring-boot项目，实现起来可能会相对简单点，直接new多线程启动，然后传入不同的参数类即可，在spring的项目中，由于Bean对象是spring容器管理的，你直接new出来的对象是没法使用的，就算你能new成功，但是bean里面依赖的其他组件比如Dao，是没法初始化的，因为你饶过了spring，默认的spring初始化一个类时，其相关依赖的组件都会被初始化，但是自己new出来的类，是不具备这种功能的，所以我们需要通过spring来获取我们自己的线程类，那么如何通过spring获取类实例呢，需要定义如下的一个类来获取SpringContext上下文：
/**
*CreatedbyAdministratoron2016/8/18.
*设置Sping的上下文
*/
@Component
publicclassApplicationContextProviderimplementsApplicationContextAware{
privatestaticApplicationContextcontext;
privateApplicationContextProvider(){}
@Override
publicvoidsetApplicationContext(ApplicationContextapplicationContext)throwsBeansException{
context=applicationContext;
}
publicstaticTgetBean(Stringname,ClassaClass){
returncontext.getBean(name,aClass);
}
}
然后定义我们的自己的线程类，注意此类是原型作用域，不能是默认的单例：
@Component("mTask")
@Scope("prototype")
publicclassMoniotrTaskextendsThread{
finalstaticLoggerlogger=LoggerFactory.getLogger(MoniotrTask.class);
//参数封装
privateMonitormonitor;
publicvoidsetMonitor(Monitormonitor){
this.monitor=monitor;
}
@Resource(name="greaterDaoImpl")
privateRuleDaogreaterDaoImpl;
@Override
publicvoidrun(){
logger.info("线程:"+Thread.currentThread().getName()+"运行中.....");
}
}
写个测试例子，测试下使用SpringContext获取Bean，查看是否是多实例：
/**
*CreatedbyAdministratoron2016/8/18.
*/
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes=ApplicationMain.class)
publicclassSpingContextTest{
@Test
publicvoidshow()throwsException{
MoniotrTaskm1=ApplicationContextProvider.getBean("mTask",MoniotrTask.class);
MoniotrTaskm2=ApplicationContextProvider.getBean("mTask",MoniotrTask.class);
MoniotrTaskm3=ApplicationContextProvider.getBean("mTask",MoniotrTask.class);
System.out.println(m1+"=>"+m1.greaterDaoImpl);
System.out.println(m2+"=>"+m2.greaterDaoImpl);
System.out.println(m3+"=>"+m3.greaterDaoImpl);
}
}
运行结果如下：
[INFO][2016-08-2517:36:34]com.test.tools.SpingContextTest[57]-StartedSpingContextTestin2.902seconds(JVMrunningfor4.196) 2016-08-2517:36:34.842INFO8312---[main]com.test.tools.SpingContextTest:StartedSpingContextTestin2.902seconds(JVMrunningfor4.196) Thread[Thread-2,5,main]=>com.xuele.bigdata.xalert.dao.rule.impl.GreaterDaoImpl@285f38f6 Thread[Thread-3,5,main]=>com.xuele.bigdata.xalert.dao.rule.impl.GreaterDaoImpl@285f38f6 Thread[Thread-4,5,main]=>com.xuele.bigdata.xalert.dao.rule.impl.GreaterDaoImpl@285f38f6
可以看到我们的监控类是多实例的，它里面的Dao是单实例的，这样以来我们就可以在spring中使用多线程处理我们的任务了。
如何启动我们的多线程任务类，可以专门定义一个组件类启动也可以在启动Spring的main方法中启动，下面看下，如何定义组件启动：
@Component
publicclassStartTask{
finalstaticLoggerlogger=LoggerFactory.getLogger(StartTask.class);
//定义在构造方法完毕后，执行这个初始化方法
@PostConstruct
publicvoidinit(){
finalListlist=ParseRuleUtils.parseRules();
logger.info("监控任务的总Task数：{}",list.size());
for(inti=0;i
最后备忘下logback.xml，里面可以配置相对和绝对的日志文件路径：
[%-5level][%date{yyyy-MM-ddHH:mm:ss}]%logger{96}[%line]-%msg%n
UTF-8
logs/xalert-%d{yyyy-MM-dd}.%i.log
64MB
DEBUG
true
[%-5level][%date{yyyy-MM-ddHH:mm:ss}]%logger{96}[%line]-%msg%n
UTF-8
INFO
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。