Spring-Boot中如何使用多執行緒處理任務
阿新 • • 發佈：2019-01-01
看到這個標題，相信不少人會感到疑惑，回憶你們自己的場景會發現，在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("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]285f38f6
Thread[Thread-3,5,main] => [email protected]285f38f6
Thread[Thread-4,5,main] => [email protected]285f38f6可以看到我們的監控類是多例項的，它裡面的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有什麼問題可以掃碼關注微信公眾號：我是攻城師(woshigcs)，在後臺留言諮詢。 技術債不能欠，健康債更不能欠， 求道之路，與君同行。