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,Class aClass){ 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.842 INFO8312---[ 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 以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。