Spring Boot实现异步请求（Servlet 3.0）
作者：catoop 发布时间：2023-11-27 06:26:47
标签：spring,boot,servlet
在spring 3.2 及以后版本中增加了对请求的异步处理，旨在提高请求的处理速度降低服务性能消耗。
在我们的请求中做了耗时处理，当并发请求的情况下，为了避免web server的连接池被长期占用而引起性能问题，调用后生成一个非web的服务线程来处理，增加web服务器的吞吐量。
为此 Servlet 3.0 新增了请求的异步处理，Spring 也在此基础上做了封装处理。
本文还是以代码例子的方式说明如何在 Spring Boot 中应用异步请求。
首先说一下几个要点：
1、@WebFilter 和 @WebServlet 注解中的 asyncSupported = true 属性
异步处理的servlet若存在过滤器，则过滤器的注解@WebFilter应设置asyncSupported=true，
否则会报错 A filter or servlet of the current chain does not support asynchronous operations.
2、@EnableAsync 注解
Spring Boot 默认添加了一些拦截 /* 的过滤器，因为 /* 会拦截所有请求，按理说我们也要设置 asyncSupported=true 属性。因为这些过滤器都是 Spring Boot 初始化的，所以它提供了 @EnableAsync 注解来统一配置，该注解只针对 “非 @WebFilter 和 @WebServlet 注解的有效”，所以我们自己定义的 Filter 还是需要自己配置 asyncSupported=true 的。
3、AsyncContext 对象
获取一个异步请求的上下文对象。
4、asyncContext.setTimeout(20 * 1000L);
我们不能让异步请求无限的等待下去，通过 setTimeout 来设定最大超时时间。
下面通过两种方式来测试异步任务：
先在 SpringBootSampleApplication 上添加 @EnableAsync 注解。
再检查所有自定义的Filter，如存在如下两种情况需要配置 asyncSupported=true
1) 自定义Filter 拦截了 /*
2) 某Filter 拦截了 /shanhy/* ，我们需要执行的异步请求的 Servlet 为 /shanhy/testcomet
方法一：原生Servlet方式
package org.springboot.sample.servlet;
import java.io.IOException;
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import javax.servlet.AsyncContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* HTTP长连接实现
*
* @author 单红宇(365384722)
* @myblog http://blog.csdn.net/catoop/
* @create 2016年3月29日
*/
@WebServlet(urlPatterns = "/xs/cometservlet", asyncSupported = true)
//异步处理的servlet若存在过滤器，则过滤器的注解@WebFilter应设置asyncSupported=true，
//否则会报错A filter or servlet of the current chain does not support asynchronous operations.
public class CometServlet extends HttpServlet {
private static final long serialVersionUID = -8685285401859800066L;
private final Queue<AsyncContext> asyncContexts = new LinkedBlockingQueue<>();
private final Thread generator = new Thread("Async Event generator") {
@Override
public void run() {
while (!generator.isInterrupted()) {// 线程有效
try {
while (!asyncContexts.isEmpty()) {// 不为空
TimeUnit.SECONDS.sleep(10);// 秒，模拟耗时操作
AsyncContext asyncContext = asyncContexts.poll();
HttpServletResponse res = (HttpServletResponse) asyncContext.getResponse();
res.getWriter().write("{\"result\":\"OK - "+System.currentTimeMillis()+"\"}");
res.setStatus(HttpServletResponse.SC_OK);
res.setContentType("application/json");
asyncContext.complete();// 完成
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
};
@Override
public void init() throws ServletException {
super.init();
generator.start();
}
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
System.out.println(">>>>>>>>>>CometServlet Request<<<<<<<<<<<");
doPost(req, resp);
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
AsyncContext asyncContext = req.startAsync();
asyncContext.setTimeout(20 * 1000L);
asyncContexts.offer(asyncContext);
}
@Override
public void destroy() {
super.destroy();
generator.interrupt();
}
}
方法二：Controller 方式
@Controller
public class PageController {
@RequestMapping("/async/test")
@ResponseBody
public Callable<String> callable() {
// 这么做的好处避免web server的连接池被长期占用而引起性能问题，
// 调用后生成一个非web的服务线程来处理，增加web服务器的吞吐量。
return new Callable<String>() {
@Override
public String call() throws Exception {
Thread.sleep(3 * 1000L);
return "小单 - " + System.currentTimeMillis();
}
};
}
}
最后写一个comet.jsp页面测试：
<％@ page pageEncoding="UTF-8"％>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<title>长连接测试</title>
<script type="text/javascript" src="${pageContext.request.contextPath }/webjarslocator/jquery/jquery.js"></script>
<script type="text/javascript">
$(function(){
function longPolling(){
$.getJSON('${pageContext.request.contextPath }/xs/cometservlet', function(data){
console.log(data.result);
$('#n1').html(data.result);
longPolling();
});
}
longPolling();
function longPolling2(){
$.get('${pageContext.request.contextPath }/async/test', function(data){
console.log(data);
$('#n2').html(data);
longPolling2();
});
}
longPolling2();
});
</script>
</head>
<body>
<h1>长连接测试</h1>
<h2 id="n1"></h2>
<h2 id="n2"></h2>
</body>
</html>
来源：http://blog.csdn.net/catoop/article/details/51034866
0
投稿猜你喜欢
- 刚实现了App内手机横/竖放置时，屏幕横/竖屏的切换。记录一下中间需要的关键信息和实现过程。开门见山的说，实现屏幕自动/手动旋转的方式有两种
protected 来谈谈protected访问权限问题。看下面示例1：Test.javaclass MyObject {}public c- 为公司系统业务需要，这几天了解了一下微信和支付宝扫码支付的接口，并用c#实现了微信和支付宝扫码支付的功能。微信支付分为6种支付模式：1.付款
- 本文实例为大家分享了Android实现记事本功能的具体代码，供大家参考，具体内容如下MainActivity.java代码:package
- 场景yitter-idgenerator 是基于雪花算法进行改造的分布式ID自增算法，集成时需要为每个服务设置唯一的机器号，才能保证生成的I
- spring cloud zuul增加header传输在使用OAuth2.0传输权限认证，为了再调用其他的项目的时候获取token，必须在t
- list.remove最近做项目的过程中，需要用到list.remove()方法，结果发现两个有趣的坑，经过分析后找到原因，记录一下跟大家分
- 实例如下：static void testLock1(){final AtomicInteger waitCount = new Atomi
- 前言继续动画探索，今天用Flutter制作一个心碎的感觉，灵感来源于今天的股市，哎，心哇凉哇凉的。废话不多说，开始。效果图先上：实现步骤1、
- 什么是POM？POM是项目对象模型(Project Object Model)的简称,它是Maven项目中的文件，使用XML表示，名称叫做p
- 可能导致问题的原因：1.nacos中的配置文件名不规范，官网有命名规则：“前缀”-&ldqu
- 上一篇文章自定义viewgroup（1）地址：https://www.jb51.net/article/100608.htm这里直接代码：p
- Docker现在很火，容器技术看上不无所不能，但这实际上是一种误解，不要被炒作出来的泡沫迷住双眼，本文抛去炒作，理性地从Java程序员的角度
- 实现网页版的在线聊天室的方法有很多，在没有来到HTML5之前，常见的有：定时轮询、长连接+长轮询、基于第三方插件（如FLASH的Socket
- 安装 Tomcat 之前请一定先安装 Java ，然后才能安装 Tomcat 。安装 Java 、环境变量 path 的设置以及 cmd 小
- Parallel类(https://www.jb51.net/article/244267.htm)的并行任务需要结束后才能运行后面的代码，
- TBS视频播放 TBS视频播放器可以支持市面上几乎所有的视频格式，包括mp4, flv, avi, 3gp, webm, ts,
- 最近工作需要，自定了一个颜色选择器，效果图如下：颜色种类是固定的，圆环上有个指示器，指示选中的颜色，这个定义起来应该是很简单了，直接上代码。
- 最近因为fastjson安全漏洞，升级jar包时，踩了一些坑。新版本FastJsonHttpMessageConverter初始化，默认设置
- import java.text.ParseException;import java.text.SimpleDateFormat;impo
