Servlet3.0+Spring-Boot测试新特性-异步处理Servlet、Filter 概念部分参考：
基于原⽂的⼀些问题，修复和改进了⼀些地⽅的描述和事例
⼀、浅谈Servlet
在Servlet 3.0 之前，⼀个普通 Servlet 的主要⼯作流程⼤致如下：
其中黄⾊阶段通常是最耗时的，因为业务处理⼀般涉及数据库操作，还会受到⽹络等的影响，⽽在此过程中，Servlet 线程⼀直处于阻塞状态，直到业务处理完毕。在处理业务的过程中，Servlet 资源⼀直被占⽤⽽得不到释放，对于并发较⼤的应⽤，这有可能造成性能的瓶颈。对此，在以前通常是采⽤私有解决⽅案来提前结束 Servlet 线程，并及时释放资源。
为解决这个问题，Servlet 3.0 就开始⽀持异步处理了，这与 Ajax 异步不⼀样，之前的 Servlet 处理流程
可以调整为如下的过程：
⾸先，Servlet 接收到请求之后，可能⾸先需要对请求携带的数据进⾏⼀些预处理；接着，Servlet 线程将请求转交给⼀个异步线程来执⾏业务处理，线程本⾝返回⾄容器，此时 Servlet 还没有⽣成响应数据，异步线程处理完业务以后，可以直接⽣成响应数据（异步线程拥有 ServletRequest 和 ServletResponse 对象的引⽤），或者将请求继续转发给其它 Servlet。如此⼀来， Servlet 线程不再是⼀直处于阻塞状态以等待业务逻辑的处理，⽽是启动异步线程之后可以⽴即返回。
⼆、启⽤异步处理
异步处理特性可以应⽤于 Servlet 和过滤器两种组件。在默认情况下，Servlet 和过滤器并没有开启异步处理特性，因为异步处理的⼯作模式和普通⼯作模式在实现上有着本质的区别，因此如果希望使⽤该特性，则必须按照如下的⽅式启⽤：
1. 在 l ⽂件中启动
Servlet3.0 默认是没有 l ⽂件的，但 Servlet3.0 也是⽀持 l ⽂件的，较 Servlet之前的版本，Servlet 3.0 在
<servlet>和 <filter> 标签中增加了 <async-supported> ⼦标签，该标签默认是 false 。如果想启⽤异步⽀持，只需要置为 true 即可。例如：
<!-- servlet -->
<servlet>
<servlet-name>asynServlet</servlet-name>
<servlet-class>com.servlet.AsynServlet</servlet-class>
<async-supported>true</async-supported>
</servlet>
<!-- Filter -->
<filter>
<filter-name>asynFilter</filter-name>
<filter-class>com.filter.AsynFilter</filter-class>
<async-supported>true</async-supported>
</filter>
2. 通过注解开启异步⽀持
Servlet 3.0 提供的 @WebServlet 和 @WebFilter 进⾏ Servlet 或 Filter 配置的情况，这两个注解都提供了 asyncSupported 属性，默认该属性的取值为 false。如果想启⽤异步⽀持，只需要置为 true 即可。例如：
@WebServlet(value="/asyn-servlet",asyncSupported=true)
public class ServletAsyn extends HttpServlet {...}
@WebFilter(value="/*",asyncSupported=true)
public class FilterAsyn implements Filter {...}
三、异步处理的代码实现⽅式
Servlet 和 Filter 使⽤异步⽀持的实现⽅式是⼀模⼀样的操作。这⾥只以 Servlet 的实现⽅式为例。
1. 模拟注册发信息到邮件的简单的异步处理 Servlet ⽰例代码：
package thinking.in.spring.boot;
import javax.servlet.AsyncContext;
import javax.servlet.AsyncEvent;
import javax.servlet.AsyncListener;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
@WebServlet(value="/asyn-servlet",asyncSupported=true)
springboot结构public class ServletAsyn extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
System.out.println("Servlet is start");
//1.获得异步上下⽂对象
AsyncContext asyncContext = request.startAsync();
asyncContext.addListener(new AsyncListener() {
@Override
public void onTimeout(AsyncEvent event) throws IOException {
System.out.println("超时了：");
//做⼀些超时后的相关操作
}
}
@Override
public void onStartAsync(AsyncEvent event) throws IOException {
// TODO Auto-generated method stub
System.out.println("线程开始");
}
@Override
public void onError(AsyncEvent event) throws IOException {
System.out.println("发⽣错误：");
}
@Override
public void onComplete(AsyncEvent event) throws IOException {
System.out.println("执⾏完成");
//这⾥可以做⼀些清理资源的操作
}
});
/
/2.启动⼀个耗时的⼦线程
ThreadTask tt = new ThreadTask(asyncContext);
//3.可设置异步超时对象，需在启动异步上下⽂对象前设置
/*
* 设置超时后，若⼦线程的执⾏时间超过设置的描述，则会抛出异常：
* 此时分2种情况：
* 1、主线程中带有response write（"xxx"），则页⾯显⽰正常，展⽰xxx，但程序后台会报错
* java.lang.IllegalStateException: The request associated with the AsyncContext has already completed processing.
* 2、主线程中不带有response write输出内容，页⾯直接报错
* 切记servlet主线程response write后，flush⼀次，否则也会报错
*
* 若设置的超时时间⼤于⼦线程的运⾏时间，则servlet正常执⾏，优先输出servlet主线程的response write，
* 待⼦线程执⾏完后，展⽰输出⼦线程的内容，后续截图中会给出效果
*/
asyncContext.setTimeout(100000);
//4.开启异步上下⽂对象
asyncContext.start(tt);
//主线程结束向客户端发送消息
System.out.println("currentThread = " + Thread.currentThread().getName() + "Servlet is end");
response.setContentType("text/html;charset=utf-8");
//set();
}
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doGet(request, response);
}
}
异步线程的执⾏类：
package thinking.in.spring.boot;
import javax.servlet.AsyncContext;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import java.util.Date;
public class ThreadTask implements Runnable{
private AsyncContext ac; //定义⼀个异步上下⽂
public ThreadTask(AsyncContext ac) {
super();
this.ac = ac;
}
@Override
public void run() {
/*
* 服务端异步典型应⽤是注册时向邮箱发送验证码
*/
try {
//进⾏异步的⼀些处理
HttpServletRequest requst = (HttpServletRequest) ac.getRequest();
HttpSession session = Session();
System.out.println("asyn-task start" + new Date());
for(int i=5;i>0; i--) {
System.out.println(i);
Thread.sleep(1000);
}
//将结果放到session等⽅式
session.setAttribute("message", "This is the result of asyn");
System.out.println("currentThread = " + Thread.currentThread().getName() + " asyn-task end" + new Date());
//通知主线程已经处理完成
/*
* 除了使⽤ acplete() ⽅法，结束这次异步处理，通知主线程及listener已经处理完
* 还可以使⽤ ac.dispatch() ⽅法重定向到⼀个页⾯
*/
ac.dispatch("/test");
//acplete();
} catch (Exception e) {
e.printStackTrace();
}
}
}
由于是⽤spring-boot搭建的简单项⽬，所以 /test 跳转去了⼀个配置好的 RequestMapping，配置了⼀个简单的thymeleaf⽤作跳转页⾯。注：由于在springboot的框架内，所以需要加上 @ServletComponentScan 扫描 @WebServlet 注解
主程序和maven配置如下：
<project xmlns="/POM/4.0.0" xmlns:xsi="/2001/XMLSchema-instance" xsi:schemaLocation="/POM/4.0.0 /maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.2.RELEASE</version>
</parent>
<groupId>thinking-in-spring-boot</groupId>
<artifactId>first-spring-boot-application</artifactId>
<packaging>jar</packaging>
<version>1.0.0-SNAPSHOT</version>
<name>first-spring-boot-application</name>
<url></url>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>2.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.16.10</version>
</dependency>
</dependencies>
</project>
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论