详解Spring-Boot中如何使用多线程处理任务

首页 > 软件编程 > java 更新日期: 2017-09-10
本篇文章主要介绍了详解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> T getBean(String name,Class<T> 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] => [email protected]
Thread[Thread-3,5,main] => [email protected]
Thread[Thread-4,5,main] => [email protected]

可以看到我们的监控类是多实例的,它里面的Dao是单实例的,这样以来我们就可以在spring中使用多线程处理我们的任务了。

如何启动我们的多线程任务类,可以专门定义一个组件类启动也可以在启动Spring的main方法中启动,下面看下,如何定义组件启动:

@Component
public class StartTask  {

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

    final List<Monitor> list = ParseRuleUtils.parseRules();
    logger.info("监控任务的总Task数:{}",list.size());
    for(int i=0;i<list.size();i++) {
      MoniotrTask moniotrTask=  ApplicationContextProvider.getBean("mTask", MoniotrTask.class);
      moniotrTask.setMonitor(list.get(i));
      moniotrTask.start();
      logger.info("第{}个监控task: {}启动 !",(i+1),list.get(i).getName());
    }

  }


}

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

<!-- Logback configuration. See http://logback.qos.ch/manual/index.html -->
<configuration scan="true" scanPeriod="10 seconds">
 <!-- Simple file output -->
 <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
  <!--<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">-->
  <!-- encoder defaults to ch.qos.logback.classic.encoder.PatternLayoutEncoder -->
  <encoder>
    <pattern>
      [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
    </pattern>
    <charset>UTF-8</charset> <!-- 此处设置字符集 -->
  </encoder>

  <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
   <!-- rollover daily 配置日志所生成的目录以及生成文件名的规则,默认是相对路径 -->
   <fileNamePattern>logs/xalert-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
    <!--<property name="logDir" value="E:/testlog" />-->
    <!--绝对路径定义-->
   <!--<fileNamePattern>${logDir}/logs/xalert-%d{yyyy-MM-dd}.%i.log</fileNamePattern>-->
   <timeBasedFileNamingAndTriggeringPolicy
     class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
    <!-- or whenever the file size reaches 64 MB -->
    <maxFileSize>64 MB</maxFileSize>
   </timeBasedFileNamingAndTriggeringPolicy>
  </rollingPolicy>


  <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
   <level>DEBUG</level>
  </filter>
  <!-- Safely log to the same file from multiple JVMs. Degrades performance! -->
  <prudent>true</prudent>
 </appender>


 <!-- Console output -->
 <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
  <!-- encoder defaults to ch.qos.logback.classic.encoder.PatternLayoutEncoder -->
   <encoder>
     <pattern>
       [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
     </pattern>
     <charset>UTF-8</charset> <!-- 此处设置字符集 -->
   </encoder>
  <!-- Only log level WARN and above -->
  <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
   <level>INFO</level>
  </filter>
 </appender>


 <!-- Enable FILE and STDOUT appenders for all log messages.
    By default, only log at level INFO and above. -->
 <root level="INFO">
   <appender-ref ref="STDOUT" />
   <appender-ref ref="FILE" />

 </root>

 <!-- For loggers in the these namespaces, log at all levels. -->
 <logger name="pedestal" level="ALL" />
 <logger name="hammock-cafe" level="ALL" />
 <logger name="user" level="ALL" />
  <include resource="org/springframework/boot/logging/logback/base.xml"/>
  <jmxConfigurator/>
</configuration>

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


> 本站内容系网友提交或本网编辑转载,其目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责。如涉及作品内容、版权和其它问题,请及时与本网联系,我们将在第一时间删除内容!

相关文章
  • 详解C语言中条件判断语句if和switch的用法
    这篇文章主要介绍了详解C语言中条件判断语句if和switch的用法,是C语言入门学习中的基础知识,需要的朋友可以参考下if 语句 用 if 语句可以构成分支结构,它根据给的条件进行判定,以决定执行哪个分支程序段. C 语言的 if 语句有三种基本形式 第一种形式: if(条件表达式) { 语句1: } if(条件表达式) { 语句1: } 这种形式运行顺序为 ...
  • 详解C++编程中的静态成员与可变数据成员
    这篇文章主要介绍了详解C++编程中的静态成员与可变数据成员,是C++入门学习中的基础知识,需要的朋友可以参考下静态成员类可以包含静态成员数据和成员函数.当数据成员被声明为"静态"时,只会为类的所有对象保留一个数据副本.静态数据成员不是给定的类类型的对象的一部分.因此,静态数据成员的声明不被视为一个定义.在类范围中声明数据成员,但在文件范围 ...
  • 详解WordPress开发中get_header()获取头部函数的用法
    这篇文章主要介绍了详解WordPress开发中get_header获取头部的用法,get_header函数在WordPress主题的制作中一定会用到,需要的朋友可以参考下函数意义详解从当前主题调用header.php文件.是不是很简单?好吧,如果你是新手的话这里要提醒一下,这里的get和get_children().get_category中的get略有不同 ...
  • 详解Java编程中final,finalize,finally的区别
    这篇文章主要介绍了详解Java编程中final,finalize,finally的区别,这个在Java面试题中简直是太常见了...需要的朋友可以参考下final:final可以让你控制你的成员.方法或者是一个类是否可被覆写或继承等功能,这些特点使final在Java中拥有了一个不可或缺的地位,也是学习Java时必须要知道和掌握的关键字之一.final成员当你 ...
  • 详解C#编程中构造函数的使用
    这篇文章主要介绍了详解C#编程中构造函数的使用,是C#入门学习中的基础知识,需要的朋友可以参考下当类或结构创建时,其构造函数调用.构造函数与选件类或结构相同,并且,它们通常用于初始化新对象的数据成员.在下面的示例中,使用一个简单的构造函数定义了名为 Taxi 的类.然后使用 new 运算符来实例化该类.在为新对象分配内存之后,new 运算符立即调用 Taxi ...
  • 详解C++编程中多级派生时的构造函数和访问属性
    详解C++编程中多级派生时的构造函数和访问属性
    这篇文章主要介绍了详解C++编程中多级派生时的构造函数和访问属性,是C++入门学习中的基础知识,需要的朋友可以参考下C++多层派生时的构造函数一个类不仅可以派生出一个派生类,派生类还可以继续派生,形成派生的层次结构.在上面叙述的基础上,不难写出在多级派生情况下派生类的构造函数. 通过例下面的程序,读者可以了解在多级派生情况下怎样定义派生类的构造函数.相信大家 ...
猜你喜欢