看到這個標題，相信不少人會感到疑惑，回憶你們自己的場景會發現，在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上下文：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
/** * created by administrator on 2016/8/18. * 設置sping的上下文 */@componentpublic 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); }} |
然后定義我們的自己的線程類，注意此類是原型作用域，不能是默認的單例：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
@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，查看是否是多實例：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
/** * 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方法中啟動，下面看下，如何定義組件啟動：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
@componentpublic 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，里面可以配置相對和絕對的日志文件路徑：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
<!-- 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> |
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://www.cnblogs.com/qindongliang/p/5808145.html
