`

Spring @Async Demo

 
阅读更多

原创转载请注明出处:http://agilestyle.iteye.com/blog/2327025

 

模拟一个业务场景:系统新用户注册成功后,异步发送邮件。

 

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:当pool已经达到max size的时候,如何处理新任务  
        // CALLER_RUNS:不在新线程中执行任务,而是有调用者所在的线程来执行  
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());  
        executor.initialize(); 
        
        return executor;  
    }
}

Note:

AsyncConfig使用Annotation进行Spring Async的配置,当然也可以用XML的方式进行配置,只需要在servlet-context.xml中添加task的命名空间,同时加下如下两行配置:

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

<task:executor />配置参数:

id:当配置多个executor时,被@Async("id")指定使用;也被作为线程名的前缀。

pool-size:

  • core size:最小的线程数,缺省:1
  • max size:最大的线程数,缺省:Integer.MAX_VALUE

queue-capacity:当最小的线程数已经被占用满后,新的任务会被放进queue里面,当这个queue的capacity也被占满之后,pool里面会创建新线程处理这个任务,直到总线程数达到了max size,这时系统会拒绝这个任务并抛出TaskRejectedException异常(缺省配置的情况下,可以通过rejection-policy来决定如何处理这种情况)。缺省值为:Integer.MAX_VALUE

keep-alive:超过core size的那些线程,任务完成后,再经过这个时长(秒)会被结束掉

rejection-policy:当pool已经达到max size的时候,如何处理新任务

  • ABORT(缺省):抛出TaskRejectedException异常,然后不执行
  • DISCARD:不执行,也不抛出异常
  • DISCARD_OLDEST:丢弃queue中最旧的那个任务
  • CALLER_RUNS:不在新线程中执行任务,而是有调用者所在的线程来执行

  

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请求(send两次)


 

Console Output

Reference

http://docs.spring.io/spring/docs/current/spring-framework-reference/html/scheduling.html#scheduling-annotation-support

Spring异步任务处理,@Async的配置和使用

 

  • 大小: 23.5 KB
  • 大小: 26.9 KB
  • 大小: 39 KB
分享到:
评论

相关推荐

    Spring中@Async注解实现异步调详解

    Spring中@Async注解实现异步调用详解 在Spring框架中,@Async注解是实现异步调用的一个重要机制。异步调用是指在程序执行过程中,不需要等待某个方法的执行结果,而是继续执行下一个方法。这种机制可以极大地提高...

    Spring里的Async注解实现异步操作的方法步骤

    Spring里的Async注解实现异步操作的方法步骤 在 Spring 框架中,Async 注解是一个非常重要的功能,它可以帮助我们实现异步操作,从而提高系统的性能和响应速度。在本文中,我们将详细介绍 Spring里的Async注解实现...

    Spring Boot多线程demo

    Spring Boot 多线程 Demo Spring Boot 中使用多线程的方式有很多种,最简单的方式就是使用 @Async 注解来实现。下面我们将详细介绍如何使用 @Async 注解来实现多线程编程。 多线程前言 在 Java 中,多线程编程是...

    Concurrent-MultiThread-Async:多线程的使用,concurrent包的使用,并发队列的时候,@ Async方法返回值的异步处理,

    在Spring框架中,`@Async`注解用于标记一个方法为异步执行。这意味着该方法不会阻塞调用它的线程,而是将其放入任务队列中,由后台线程池异步执行。使用`@Async`可以显著提高性能,尤其是在处理耗时操作时。要使用`...

    AsyncDemo.zip

    这个简单的Demo演示了如何使用`@Async`来提高应用的性能,尤其是在处理耗时操作时,如大数据计算、网络请求等。现在,我们将深入探讨`@Async`注解及其在Spring Boot中的使用方法。 首先,`@Async`是Spring提供的一...

    Java Spring多线程demo代码

    在"Java Spring多线程demo代码"中,可能包含使用`@Async`和`@Scheduled`注解的示例,以及如何配置和自定义`ThreadPoolTaskExecutor`和`ThreadPoolTaskScheduler`的代码。通过这些示例,你可以学习到如何在Spring应用...

    spring boot web demo

    11. 异步处理:Spring Boot支持异步方法调用,通过`@Async`注解,可以在后台线程中执行耗时操作,提高应用性能。 12. 安全管理:Spring Security是Spring Boot默认的安全框架,提供身份验证和授权功能。通过简单的...

    使用Spring Task开发定时任务的Demo

    Spring Task还支持异步执行任务,通过`@Async`注解,可以将任务方法标记为异步执行,提高系统并发性能。 ```java @Service @EnableAsync public class AsyncService { @Async public void longRunningTask() { ...

    springboot异步任务案例

    Spring Boot提供了简单易用的API和注解来支持异步任务的实现,特别是通过`@Async`注解和定时任务`@Scheduled`。下面我们将深入探讨这两个核心概念。 ### `@Async` 注解 `@Async`是Spring提供的一个注解,用于标记...

    spring mvc demo实例

    - 异步处理,使用`@Async`注解实现非阻塞操作。 通过这个简单的Spring MVC示例,你可以逐步掌握如何构建一个完整的Web应用。随着对Spring MVC框架的理解加深,你将能够开发出更复杂、功能丰富的Web应用程序。

    Spring Boot 自定义异步线程池的两种方式Demo

    本文将详细介绍两种在Spring Boot中实现自定义异步线程池的方法,并通过具体的Demo进行说明。 ### 方法一:使用`@Async`注解和`ThreadPoolTaskExecutor` 1. **配置类:** 首先,我们需要创建一个配置类,用于定义...

    简单的Spring boot demo

    - 使用`@Async`注解标记方法为异步执行,Spring Boot内部使用ExecutorService实现。 **10. 日志** - Spring Boot默认使用Logback作为日志框架,也可以切换到其他框架如Log4j2。 - 通过`logging.level.*`配置日志...

    spring3.0异步

    Spring 3.0引入了`@Async`注解,该注解可以标记在方法上,声明该方法为异步执行。为了启用异步处理,需要配置`AsyncConfigurer`接口或者`&lt;task:annotation-driven/&gt;`元素,并提供一个`Executor` bean来处理异步任务...

    Spring3.0 mvc 定时器及多线程任务demo

    在Spring 3.0 MVC框架中,定时器和多线程任务是两个关键概念,用于构建高效、自动化的Web应用程序。下面将详细讲解这两个概念及其在实际应用中的使用。 一、Spring 3.0 MVC定时器 在Spring 3.0中,我们可以使用...

    springdemo.zip

    本文将深入探讨Spring框架中注解的应用,从1.x版本到最新的5.x版本的演变过程,并通过具体的文件"springdemo"来解析注解的实践。 1. **Spring注解的起源** 在Spring 1.x时代,依赖注入(DI)主要通过XML配置文件...

    spring boot集成demo大全.zip

    `spring boot demo` 是一个用来深度学习并实战 `spring boot` 的项目,目前总共包含 **`63`** 个集成demo,已经完成 **`51`** 个。 该项目已成功集成 actuator(`监控`)、admin(`可视化监控`)、logback(`日志`)、aop...

    Spring MVC demo

    - `@Async`: 用于标记一个方法为异步执行,Spring会使用线程池处理该方法,提高系统响应速度。 - `@EnableAsync`: 在配置类上添加此注解开启异步支持。 3. **文件上传** - `@RequestParam("file") MultipartFile...

    单库分表(springboot + mybatisplus + m-split-table-async-demo.zip

    【描述】"单库分表(springboot + mybatisplus + m-split-table-async-demo" 提到的项目是基于SpringBoot框架的,SpringBoot简化了Spring应用的初始搭建以及开发过程。MyBatisPlus是MyBatis的增强工具,提供了更方便...

    Spring的多线程应用

    在【描述】中提到的"一个简单的spring的多线程demo",我们可以理解为一个示例项目,旨在帮助开发者理解如何在Spring中实现和管理多线程。 在Java中,多线程主要用于提高应用程序的执行效率,尤其是在处理I/O密集型...

    springboot-scheduler定时任务学习demo源码

    此外,Spring Boot的定时任务还支持异步执行,通过配合`@Async`注解,可以在不阻塞主线程的情况下执行任务。同时,可以通过实现`TaskScheduler`接口或者使用`ThreadPoolTaskScheduler`来自定义调度策略。 总之,...

Global site tag (gtag.js) - Google Analytics