Spring-Boot中如何使用多线程处理任务方法

看到这个标题,相信不少人会感到疑惑,回忆你们自己的场景会发现,在Spring的项目中很少有使用多线程处理任务的,没错,大多数时候我们都是使用Spring MVC开发的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上下文:

/**
 * Created by Administrator on 2016/8/18.
 * 设置Sping的上下文
 */
@Component
public class ApplicationContextProvider implements ApplicationContextAware {

 private static ApplicationContext context;

 private ApplicationContextProvider(){}

 @Override
 public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
  context = applicationContext;
 }

 public static  T getBean(String name,Class aClass){
  return context.getBean(name,aClass);
 }
}

然后定义我们的自己的线程类,注意此类是原型作用域,不能是默认的单例:

@Component("mTask")
@Scope("prototype")
public class MoniotrTask extends Thread {

 final static Logger logger= LoggerFactory.getLogger(MoniotrTask.class);
 //参数封装
 private Monitor monitor;
 
 public void setMonitor(Monitor monitor) {
  this.monitor = monitor;
 }

 @Resource(name = "greaterDaoImpl")
 private RuleDao greaterDaoImpl;

 @Override
 public void run() {
  logger.info("线程:"+Thread.currentThread().getName()+"运行中.....");
 }

}

写个测试例子,测试下使用SpringContext获取Bean,查看是否是多实例:

/**
 * Created by Administrator on 2016/8/18.
 */
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes =ApplicationMain.class)
public class SpingContextTest {



 @Test
 public void show()throws Exception{
  MoniotrTask m1= ApplicationContextProvider.getBean("mTask", MoniotrTask.class);
  MoniotrTask m2=ApplicationContextProvider.getBean("mTask", MoniotrTask.class);
  MoniotrTask m3=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-25 17:36:34] com.test.tools.SpingContextTest [57] - Started SpingContextTest in 2.902 seconds (JVM running for 4.196)
2016-08-25 17:36:34.842  INFO 8312 --- [           main] com.test.tools.SpingContextTest          : Started SpingContextTest in 2.902 seconds (JVM running for 4.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
public class StartTask {

 final static Logger logger= LoggerFactory.getLogger(StartTask.class);
 
 //定义在构造方法完毕后,执行这个初始化方法
 @PostConstruct
 public void init(){

  final List list = ParseRuleUtils.parseRules();
  logger.info("监控任务的总Task数:{}",list.size());
  for(int i=0;i

最后备忘下logback.xml,里面可以配置相对和绝对的日志文件路径:



 
 
 
 
 
  
   [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
  
  UTF-8 
 

 
  
  logs/xalert-%d{yyyy-MM-dd}.%i.log
  
  
  
  
  
  64 MB
  
 


 
  DEBUG
 
 
 true
 


 
 
 
  
   
    [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
   
   UTF-8 
  
 
 
  INFO
 
 


 
 
  
  

 

 
 
 
 
 
 

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持创新互联。


网页标题:Spring-Boot中如何使用多线程处理任务方法
文章起源:http://pwwzsj.com/article/gschgd.html