欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

使用Spring開(kāi)啟@Async異步方式(javaconfig配置)

 更新時(shí)間：2021年08月27日 11:52:18   作者：allsmallpig  
這篇文章主要介紹了使用Spring開(kāi)啟@Async異步方式(javaconfig配置)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

Spring開(kāi)啟@Async異步(javaconfig配置)

在Spring中，基于@Async標(biāo)注的方法，稱(chēng)之為異步方法；這些方法將在執(zhí)行的時(shí)候，將會(huì)在獨(dú)立的線程中被執(zhí)行，調(diào)用者無(wú)需等待它的完成，即可繼續(xù)其他的操作。

應(yīng)用場(chǎng)景

  • 某些耗時(shí)較長(zhǎng)的而用戶(hù)不需要等待該方法的處理結(jié)果
  • 某些耗時(shí)較長(zhǎng)的方法，后面的程序不需要用到這個(gè)方法的處理結(jié)果時(shí)

代碼

創(chuàng)建AsyncTask

/**
 * 異步任務(wù)
 *
 * @author Peng
 */
public class AsyncTask {
    @Async
    public void doAsyncTask() throws InterruptedException {
        // 假設(shè)執(zhí)行一個(gè)很耗時(shí)的任務(wù)
        Thread.sleep(10 * 1000);
        System.out.println("執(zhí)行完成，我執(zhí)行了10秒");
    }
}

創(chuàng)建spring配置AppConfig

/**
 * spring 配置
 *
 * @author Peng
 */
@Configuration
@EnableAsync
public class AppConfig {
    /**
     * 聲明異步任務(wù)bean
     *
     * @return
     */
    @Bean
    public AsyncTask asyncTask() {
        return new AsyncTask();
    }
}

測(cè)試

/**
 * 異步測(cè)試
 *
 * @author Peng
 */
public class AppTest {
    public static void main(String[] args) throws InterruptedException {
        ApplicationContext ctx = new AnnotationConfigApplicationContext(AppConfig.class);
        AsyncTask task = ctx.getBean(AsyncTask.class);
        task.doAsyncTask();
        System.out.println("異步任務(wù)調(diào)用成功，返回客戶(hù)端執(zhí)行成功，異步任務(wù)繼續(xù)執(zhí)行");
    }
}

執(zhí)行結(jié)果

異步任務(wù)調(diào)用成功，返回客戶(hù)端執(zhí)行成功，異步任務(wù)繼續(xù)執(zhí)行

執(zhí)行完成，我執(zhí)行了10秒

從結(jié)果可以看出，異步任務(wù)測(cè)試成功！

Spring @Async Demo

模擬一個(gè)業(yè)務(wù)場(chǎng)景：系統(tǒng)新用戶(hù)注冊(cè)成功后，異步發(fā)送郵件。

Project Directory

Maven Dependency

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>org.fool.springasync</groupId>
	<artifactId>springasync</artifactId>
	<name>springasync</name>
	<packaging>war</packaging>
	<version>1.0.0-BUILD-SNAPSHOT</version>
	<properties>
		<org.springframework-version>4.2.8.RELEASE</org.springframework-version>
	</properties>
	<dependencies>
		<!-- Spring -->
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${org.springframework-version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-webmvc</artifactId>
			<version>${org.springframework-version}</version>
		</dependency>
		<dependency>
			<groupId>com.fasterxml.jackson.core</groupId>
			<artifactId>jackson-databind</artifactId>
			<version>2.8.1</version>
		</dependency>
		<dependency>
			<groupId>com.google.guava</groupId>
			<artifactId>guava</artifactId>
			<version>19.0</version>
		</dependency>
		<dependency>
			<groupId>org.apache.commons</groupId>
			<artifactId>commons-lang3</artifactId>
			<version>3.4</version>
		</dependency>
		<!-- @Inject -->
		<dependency>
			<groupId>javax.inject</groupId>
			<artifactId>javax.inject</artifactId>
			<version>1</version>
		</dependency>
		<!-- Servlet -->
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>javax.servlet-api</artifactId>
			<version>3.1.0</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>javax.servlet.jsp</groupId>
			<artifactId>javax.servlet.jsp-api</artifactId>
			<version>2.3.1</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>jstl</artifactId>
			<version>1.2</version>
		</dependency>
		<!-- Test -->
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.12</version>
			<scope>test</scope>
		</dependency>
	</dependencies>
	<build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-eclipse-plugin</artifactId>
				<version>2.10</version>
				<configuration>
					<additionalProjectnatures>
						<projectnature>org.springframework.ide.eclipse.core.springnature</projectnature>
					</additionalProjectnatures>
					<additionalBuildcommands>
						<buildcommand>org.springframework.ide.eclipse.core.springbuilder</buildcommand>
					</additionalBuildcommands>
					<downloadSources>true</downloadSources>
					<downloadJavadocs>true</downloadJavadocs>
				</configuration>
			</plugin>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<version>3.5.1</version>
				<configuration>
					<source>1.8</source>
					<target>1.8</target>
					<compilerArgument>-Xlint:all</compilerArgument>
					<showWarnings>true</showWarnings>
					<showDeprecation>true</showDeprecation>
				</configuration>
			</plugin>
			<plugin>
				<groupId>org.eclipse.jetty</groupId>
				<artifactId>jetty-maven-plugin</artifactId>
				<version>9.3.11.v20160721</version>
				<configuration>
					<scanIntervalSeconds>10</scanIntervalSeconds>
					<httpConnector>
						<port>8888</port>
					</httpConnector>
					<webApp>
						<contextPath>/springasync</contextPath>
					</webApp>
				</configuration>
			</plugin>
		</plugins>
	</build>
</project>

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee"
	xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
	id="WebApp_ID" version="3.0">
	<!-- The definition of the Root Spring Container shared by all Servlets and Filters -->
	<context-param>
		<param-name>contextConfigLocation</param-name>
		<param-value>/WEB-INF/spring/root-context.xml</param-value>
	</context-param>
	<!-- Creates the Spring Container shared by all Servlets and Filters -->
	<listener>
		<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
	</listener>
	<!-- Processes application requests -->
	<servlet>
		<servlet-name>appServlet</servlet-name>
		<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
		<init-param>
			<param-name>contextConfigLocation</param-name>
			<param-value>/WEB-INF/spring/appServlet/servlet-context.xml</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>appServlet</servlet-name>
		<url-pattern>/</url-pattern>
	</servlet-mapping>
</web-app>

root-context.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
	
	<!-- Root Context: defines shared resources visible to all other web components -->		
</beans>

servlet-context.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:beans="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"
	xmlns:task="http://www.springframework.org/schema/task" 
	xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
		http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd">
	<!-- DispatcherServlet Context: defines this servlet's request-processing infrastructure -->
	
	<!-- Enables the Spring MVC @Controller programming model -->
	<annotation-driven />
	<!-- Handles HTTP GET requests for /resources/** by efficiently serving up static resources in the ${webappRoot}/resources 
		directory -->
	<resources mapping="/resources/**" location="/resources/" />
	<!-- Resolves views selected for rendering by @Controllers to .jsp resources in the /WEB-INF/views directory -->
	<beans:bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
		<beans:property name="prefix" value="/WEB-INF/views/" />
		<beans:property name="suffix" value=".jsp" />
	</beans:bean>
	<context:component-scan base-package="org.fool.springasync" />
</beans:beans>

AsyncConfig.java

package org.fool.springasync; 
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor; 
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
@Configuration
@EnableAsync
@PropertySource("classpath:async.properties")
public class AsyncConfig {
	/** Set the ThreadPoolExecutor's core pool size. */ 
	@Value("${core.pool.size}")
    private Integer corePoolSize;
	
    /** Set the ThreadPoolExecutor's maximum pool size. */
	@Value("${max.pool.size}")
    private Integer maxPoolSize;
	
    /** Set the capacity for the ThreadPoolExecutor's BlockingQueue. */
	@Value("${queue.capacity}")
    private Integer queueCapacity;  
  
	@Value("${thread.name.prefix}")
    private String ThreadNamePrefix;
	
	@Bean  
    public static PropertySourcesPlaceholderConfigurer propertySourcesPlaceholderConfig() {  
        return new PropertySourcesPlaceholderConfigurer();  
    } 
    
    @Bean  
    public Executor getAsyncExecutor() {  
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  
        executor.setCorePoolSize(corePoolSize);  
        executor.setMaxPoolSize(maxPoolSize);  
        executor.setQueueCapacity(queueCapacity);  
        executor.setThreadNamePrefix(ThreadNamePrefix);  
  
        // rejection-policy：當(dāng)pool已經(jīng)達(dá)到max size的時(shí)候，如何處理新任務(wù)  
        // CALLER_RUNS：不在新線程中執(zhí)行任務(wù)，而是有調(diào)用者所在的線程來(lái)執(zhí)行  
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());  
        executor.initialize();         
        return executor;  
    }
}

Note:

AsyncConfig使用Annotation進(jìn)行Spring Async的配置，當(dāng)然也可以用XML的方式進(jìn)行配置，只需要在servlet-context.xml中添加task的命名空間，同時(shí)加下如下兩行配置：

<!-- Enables Spring Async -->
<task:annotation-driven executor="asyncExecutor"/>
<task:executor id="asyncExecutor" pool-size="2-4" queue-capacity="10"/>

<task:executor />配置參數(shù)：

id：當(dāng)配置多個(gè)executor時(shí)，被@Async("id")指定使用；也被作為線程名的前綴。

pool-size：

  • core size：最小的線程數(shù)，缺省：1
  • max size：最大的線程數(shù)，缺省：Integer.MAX_VALUE

queue-capacity：當(dāng)最小的線程數(shù)已經(jīng)被占用滿(mǎn)后，新的任務(wù)會(huì)被放進(jìn)queue里面，當(dāng)這個(gè)queue的capacity也被占滿(mǎn)之后，pool里面會(huì)創(chuàng)建新線程處理這個(gè)任務(wù)，直到總線程數(shù)達(dá)到了max size，這時(shí)系統(tǒng)會(huì)拒絕這個(gè)任務(wù)并拋出TaskRejectedException異常（缺省配置的情況下，可以通過(guò)rejection-policy來(lái)決定如何處理這種情況）。缺省值為：Integer.MAX_VALUE

keep-alive：超過(guò)core size的那些線程，任務(wù)完成后，再經(jīng)過(guò)這個(gè)時(shí)長(zhǎng)（秒）會(huì)被結(jié)束掉

rejection-policy：當(dāng)pool已經(jīng)達(dá)到max size的時(shí)候，如何處理新任務(wù)

  • ABORT（缺?。簰伋鯰askRejectedException異常，然后不執(zhí)行
  • DISCARD：不執(zhí)行，也不拋出異常
  • DISCARD_OLDEST：丟棄queue中最舊的那個(gè)任務(wù)
  • CALLER_RUNS：不在新線程中執(zhí)行任務(wù)，而是有調(diào)用者所在的線程來(lái)執(zhí)行

MailService.java

package org.fool.springasync; 
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component; 
@Component
public class MailService {
 
	@Async
	public void sendMail(String username) {
		System.out.println("Send Mail initialization...");
		System.out.println("Execute method asynchronously - " + Thread.currentThread().getName());
 
		try {
			Thread.sleep(5000);
			System.out.println("Welcome " + username);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
 
		System.out.println("Send Mail Async done!!!");
	} 
}

User.java

package org.fool.springasync; 
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle; 
public class User {
	private Long id;
	private String username;
	private String password; 
	public User() { 
	}
 
	public User(Long id, String username, String password) {
		this.id = id;
		this.username = username;
		this.password = password;
	}
 
	public Long getId() {
		return id;
	}
 
	public void setId(Long id) {
		this.id = id;
	}
 
	public String getUsername() {
		return username;
	}
 
	public void setUsername(String username) {
		this.username = username;
	}
 
	public String getPassword() {
		return password;
	}
 
	public void setPassword(String password) {
		this.password = password;
	}
 
	@Override
	public String toString() {
		return ToStringBuilder.reflectionToString(this, ToStringStyle.SHORT_PREFIX_STYLE);
	}
}

UserService.java

package org.fool.springasync; 
import javax.inject.Inject; 
import org.springframework.stereotype.Service; 
@Service
public class UserService {	
	@Inject
	private MailService mailService;	
	public void registerUser(User user) {
		System.out.println("insert user to db..."); 
		mailService.sendMail(user.getUsername()); 
		System.out.println("register done, please check the email later!!!");
	}	
}

UserController.java

package org.fool.springasync; 
import javax.inject.Inject; 
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
 
@Controller
@RequestMapping("/user")
public class UserController {	
	@Inject
	private UserService userService;	
	@RequestMapping(value = "/testasync", method = RequestMethod.POST)
	@ResponseBody
	public User register(@RequestBody User user) {
		System.out.println(user);		
		userService.registerUser(user);		
		return user;
	} 
}

Test

http://localhost:8888/springasync/user/testasync

POST請(qǐng)求（send兩次）

Console Output

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

相關(guān)文章

  • SpringBoot接收與響應(yīng)xml報(bào)文請(qǐng)求的實(shí)現(xiàn)

    SpringBoot接收與響應(yīng)xml報(bào)文請(qǐng)求的實(shí)現(xiàn)

    我們?cè)谶M(jìn)行接口對(duì)接時(shí),會(huì)出現(xiàn)報(bào)文形式的信息傳遞,這篇文章主要給大家介紹了關(guān)于SpringBoot接收與響應(yīng)xml報(bào)文請(qǐng)求的相關(guān)資料,需要的朋友可以參考下
    2023-06-06
  • Mybatis操作多數(shù)據(jù)源的實(shí)現(xiàn)

    Mybatis操作多數(shù)據(jù)源的實(shí)現(xiàn)

    本文主要介紹了Mybatis操作多數(shù)據(jù)源，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2023-05-05
  • JAVA導(dǎo)出EXCEL表格的實(shí)例教學(xué)

    JAVA導(dǎo)出EXCEL表格的實(shí)例教學(xué)

    在本文中我們給大家整理了關(guān)于JAVA導(dǎo)出EXCEL表格的實(shí)例教學(xué)以及相關(guān)知識(shí)點(diǎn)，需要的朋友們學(xué)習(xí)下。
    2019-02-02
  • Spring?Boot如何實(shí)現(xiàn)統(tǒng)一數(shù)據(jù)返回

    Spring?Boot如何實(shí)現(xiàn)統(tǒng)一數(shù)據(jù)返回

    這篇文章主要介紹了Spring?Boot如何實(shí)現(xiàn)統(tǒng)一數(shù)據(jù)返回,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧
    2024-07-07
  • java版十大排序經(jīng)典算法:完整代碼(4)

    java版十大排序經(jīng)典算法:完整代碼(4)

    優(yōu)秀的文章也不少，但是Java完整版的好像不多，我把所有的寫(xiě)一遍鞏固下，同時(shí)也真誠(chéng)的希望閱讀到這篇文章的小伙伴們可以自己去從頭敲一遍，不要粘貼復(fù)制！希望我的文章對(duì)你有所幫助，每天進(jìn)步一點(diǎn)點(diǎn)
    2021-07-07
  • SpringMVC中的@RequestMapping注解的使用詳細(xì)教程

    SpringMVC中的@RequestMapping注解的使用詳細(xì)教程

    @RequestMapping注解的作用就是將請(qǐng)求和處理請(qǐng)求的控制器方法關(guān)聯(lián)起來(lái)，建立映射關(guān)系，本文主要來(lái)和大家詳細(xì)講講它的具體使用，感興趣的可以了解一下
    2023-07-07
  • Java多線程實(shí)現(xiàn)方塊賽跑小游戲

    Java多線程實(shí)現(xiàn)方塊賽跑小游戲

    這篇文章主要為大家詳細(xì)介紹了Java多線程實(shí)現(xiàn)方塊賽跑小游戲，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2020-07-07
  • Java實(shí)現(xiàn)PDF轉(zhuǎn)Word的示例代碼(無(wú)水印無(wú)頁(yè)數(shù)限制)

    Java實(shí)現(xiàn)PDF轉(zhuǎn)Word的示例代碼(無(wú)水印無(wú)頁(yè)數(shù)限制)

    這篇文章主要為大家詳細(xì)介紹了如何利用Java語(yǔ)言實(shí)現(xiàn)PDF轉(zhuǎn)Word文件的效果，并可以無(wú)水印、無(wú)頁(yè)數(shù)限制。文中的示例代碼講解詳細(xì)，需要的可以參考一下
    2022-05-05
  • Java聊天室之實(shí)現(xiàn)接收和發(fā)送Socket

    Java聊天室之實(shí)現(xiàn)接收和發(fā)送Socket

    這篇文章主要為大家詳細(xì)介紹了Java簡(jiǎn)易聊天室之實(shí)現(xiàn)接收和發(fā)送Socket功能，文中的示例代碼講解詳細(xì)，具有一定的借鑒價(jià)值，需要的可以了解一下
    2022-10-10
  • 解決netty中spring對(duì)象注入失敗的問(wèn)題

    解決netty中spring對(duì)象注入失敗的問(wèn)題

    這篇文章主要介紹了解決netty中spring對(duì)象注入失敗的問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2022-02-02

最新評(píng)論