异步请求中jetty处理ServletRequestListener的坑

标题起得比较诡异,其实并不是坑,而是jetty似乎压根就没做对异步request的ServletRequestListener的特殊处理,如果文中有错误欢迎提出,可能自己有所疏漏了。

之前遇到了一个bug,在Listener中重写requestDestroyed清理资源后,这些资源在异步任务中就不可用了。
这与预期不符,直觉上request应该在任务完成之后才触发requestDestroyed,而不应该是开始异步操作返回后就触发。
正确的触发时机应该是异步任务完成之后。
后来查阅了下,发现servlet 3的规范中只是增加了异步servlet和异步filter的支持,listener如何处理没有定义,也就是各个容器的实现可能会差异(我们自己使用的是jetty)。
但讲道理的话,合理的实现应该判断当前request是否处于异步处理中,如果是的话将销毁的触发的时机放置在AsyncContext完成之后。

自己试了下使用两个容器:Tomcat 8.5.15Jetty 9.4.7.v20170914

测试代码比较简单,为了去除其他框架的影响使用纯的servlet api。
servlet:

@WebServlet(asyncSupported = true, urlPatterns = { "/test" })
public class TestServlet extends HttpServlet {private static final long serialVersionUID = 7395865716615939512L;private ExecutorService pool = Executors.newCachedThreadPool();@Overridepublic void destroy() {pool.shutdown();}@Overrideprotected void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {System.out.println(LocalDateTime.now() + " get start " + request);AsyncContext context = request.startAsync();context.addListener(new AsyncListener() {@Overridepublic void onTimeout(AsyncEvent event) throws IOException {System.out.println(LocalDateTime.now() + " async onTimeout " + event.getSuppliedRequest());}@Overridepublic void onStartAsync(AsyncEvent event) throws IOException {System.out.println(LocalDateTime.now() + " async onStartAsync " + event.getSuppliedRequest());}@Overridepublic void onError(AsyncEvent event) throws IOException {System.out.println(LocalDateTime.now() + " async onError " + event.getSuppliedRequest());}@Overridepublic void onComplete(AsyncEvent event) throws IOException {System.out.println(LocalDateTime.now() + " async onComplete " + event.getSuppliedRequest());}}, request, response);pool.execute(() -> {try {Thread.sleep(TimeUnit.SECONDS.toMillis(5));System.out.println(LocalDateTime.now() + " job done");context.complete();} catch (InterruptedException e) {e.printStackTrace();}});System.out.println(LocalDateTime.now() + " get return");}}

listener:

@WebListener
public class TestListener implements ServletRequestListener {@Overridepublic void requestDestroyed(ServletRequestEvent event) {System.out.println(LocalDateTime.now() + " TestListener requestDestroyed " + event.getServletRequest());}@Overridepublic void requestInitialized(ServletRequestEvent event) {System.out.println(LocalDateTime.now() + " TestListener requestInitialized " + event.getServletRequest());}}

使用tomcat返回的结果:

2017-11-19T16:42:04.256 TestListener requestInitialized org.apache.catalina.connector.RequestFacade@7c2df671
2017-11-19T16:42:04.257 get start org.apache.catalina.connector.RequestFacade@7c2df671
2017-11-19T16:42:04.261 get return
2017-11-19T16:42:09.261 job done
2017-11-19T16:42:09.261 async onComplete org.apache.catalina.connector.RequestFacade@7c2df671
2017-11-19T16:42:09.261 TestListener requestDestroyed org.apache.catalina.connector.RequestFacade@7c2df671

使用jetty返回的结果:

2017-11-19T16:46:35.231 TestListener requestInitialized (GET //localhost:8080/test)@1124787543 org.eclipse.jetty.server.Request@430ae557
2017-11-19T16:46:35.232 get start (GET //localhost:8080/test)@1124787543 org.eclipse.jetty.server.Request@430ae557
2017-11-19T16:46:35.234 get return
2017-11-19T16:46:35.235 TestListener requestDestroyed [GET //localhost:8080/test]@1124787543 org.eclipse.jetty.server.Request@430ae557
2017-11-19T16:46:40.235 job done
2017-11-19T16:46:58.019 async onComplete [GET //localhost:8080/test]@1124787543 org.eclipse.jetty.server.Request@430ae557

jetty果然没有讲道理... ...

先看下讲道理的tomcat,果不其然他做了特殊判断。
StandardHostValveinvoke方法中:

if (!request.isAsync() && !asyncAtStart) {context.fireRequestDestroyEvent(request.getRequest());
}

并且销毁的时机和预想的一样是在AsyncContext完成之后:

1244488-20171119174205312-2127854720.png

    public void fireOnComplete() {List<AsyncListenerWrapper> listenersCopy = new ArrayList<>();listenersCopy.addAll(listeners);ClassLoader oldCL = context.bind(Globals.IS_SECURITY_ENABLED, null);try {for (AsyncListenerWrapper listener : listenersCopy) {try {listener.fireOnComplete(event);} catch (Throwable t) {ExceptionUtils.handleThrowable(t);log.warn("onComplete() failed for listener of type [" +listener.getClass().getName() + "]", t);}}} finally {context.fireRequestDestroyEvent(request.getRequest());clearServletRequestResponse();context.unbind(Globals.IS_SECURITY_ENABLED, oldCL);}}

而jetty没有处理,在ContextHandlerdoHandle中没有异步请求的判断:

finally{// Handle more REALLY SILLY request events!if (new_context){if (!_servletRequestListeners.isEmpty()){final ServletRequestEvent sre = new ServletRequestEvent(_scontext,request);for (int i=_servletRequestListeners.size();i-->0;)_servletRequestListeners.get(i).requestDestroyed(sre);}if (!_servletRequestAttributeListeners.isEmpty()){for (int i=_servletRequestAttributeListeners.size();i-->0;)baseRequest.removeEventListener(_servletRequestAttributeListeners.get(i));}}}

new_content用来在第一次调用返回true之后是false,和异步处理无关。

网上查了些也不清楚为什么jetty没有像tomcat那样实现这个,还是jetty希望用户通过AsyncListener来做处理呢。

转载于:https://www.cnblogs.com/fairjm/p/jetty_ServletRequestListener_async.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/428549.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

华为h22h05服务器做raid_华为V5服务器 RAID控制卡(LSI SAS3008IR)

提供高速接口和模块LSI SAS3008IR的PCIe Core提供PCIe x8接口,每lane速率为8Gb/s,可以兼容x1、x2、x4配置;支持PCIe 3.0规格,兼容PCIe 2.x和PCIe 1.x。LSI SAS3008IR的SAS模块提供SAS功能,并定义支持的硬盘速率。LSI S…

css加了固定定位就不显示内容_前端开发必备,学好”定位“向菜鸟说拜拜

众所周知,前端CSS中,盒模型、浮动、定位为必须掌握的三座大山。今天就来聊聊定位的那些事。定位是什么?先来看看哪些场景用到定位,如下图所示,凡是有盒子压住另一个盒子的地方都可定位,因为用浮动做不了&am…

vscode更换主题的插件_VScode 插件开发(三)主题

咱们上回书说道,安装完基础环境,我们要来玩自己的主题了1. 创建一个主题项目$ yo code选中 New Color Theme接下来照图中所选,完成项目创建(简单英语不做解释)打开项目如图2. 配置文件2.1 themes这个文件夹包含主题配置文件,可以新…

软件工程概论课后作业01

1. 网站系统开发需要掌握的技术 ①java语言 Java语言体系比较庞大,包括多个模块。从WEB项目应用角度讲有JSP,Servlet,JDBC,JavaBean(Application)四部分技术。JDBC可做三件事情:与数据库建立连接…

mysql 参数bug_MySQL 的这个 BUG,坑了多少人?

作者:腾讯数据库技术来源:cloud.tencent.com/developer/article/1367681▌问题描述近期,线上有个重要Mysql客户的表在从5.6升级到5.7后,master上插入过程中出现"Duplicate key"的错误,而且是在主备及RO实例上…

i9 9900k mysql_i9-9900K和9900KS有什么区别?i9-9900KS和i9-9900K区别对比评测

众所周知,i9-9900KF相当于i9-9900K去除核显的版本,其它参考保持一致,所以在性能上也是相同的。不过在近期,intel牌牙膏厂再一次发布了一款九代酷睿i9-9900KS特别版,从产品型号S后缀上来看,确实有点类似于NV…

Memory及其controller芯片整体测试方案(上篇)

如果你最近想买手机,没准儿你一看价格会被吓到手机什么时候偷偷涨价啦! 其实对于手机涨价,手机制造商也是有苦难言,其中一个显著的原因是存储器芯片价格的上涨↗↗↗ >>> 存储器memory的江湖地位 存储器memory&#xff0…

BootStrapJS——modal弹出框

学习参考视频https://ninghao.net/video/1615 1.对话框 - Modal 需要bootstrap的CSS文件引入&#xff0c;以及jQuery的js包 1 <!DOCTYPE html>2 <html lang"en">3 <head>4 <meta charset"UTF-8">5 <title>弹窗测试&…

mysql.ini环境配置_MySQL配置文件mysql.ini参数详解

my.ini(Linux系统下是my.cnf)&#xff0c;当mysql服务器启动时它会读取这个文件&#xff0c;设置相关的运行环境参数。my.ini分为两块&#xff1a;Client Section和Server Section。Client Section用来配置MySQL客户端参数。要查看配置参数可以用下面的命令&#xff1a;show va…

mysql数据备份在哪里_mysql之数据备份与恢复

本文内容&#xff1a; 复制文件法利用mysqldump利用select into outfile其它(列举但不介绍)首发日期&#xff1a;2018-04-19有些时候&#xff0c;在备份之前要先做flush tables &#xff0c;确保所有数据都被写入到磁盘中。复制文件法&#xff1a;对于myisam存储引擎的数据库&a…

python opencv 边缘检测_Python使用Opencv实现边缘检测以及轮廓检测的实现

边缘检测Canny边缘检测器是一种被广泛使用的算法&#xff0c;并被认为是边缘检测最优的算法&#xff0c;该方法使用了比高斯差分算法更复杂的技巧&#xff0c;如多向灰度梯度和滞后阈值化。Canny边缘检测器算法基本步骤&#xff1a;平滑图像&#xff1a;通过使用合适的模糊半径…

web程序入门五(http无状态)

Asp.net中的状态保持方案&#xff1a; ViewState&#xff1a;是donet特有的 微软提供的对象来完成状态保持 ViewState["key1"] 11; 赋值 键值对 形式 object类型 ViewState["key1"] 直接取值&#xff0c;将其转化成相应的类型 原理&#xff1a;本质…

互评Beta版本(Hello World!——SkyHunter)

1 基于NABCD评论作品&#xff0c;及改进建议 SkyHunter这款游戏我很喜欢&#xff0c;小时候总玩飞机类的游戏&#xff0c;这款游戏我上课的时候试玩了&#xff0c;在我电脑上运行是很好玩的&#xff0c;音乐震撼&#xff0c;画面玄幻&#xff0c;富有金属音乐的味道&#xff0c…

unshift() 方法将一个或多个元素添加到数组的开头,并返回新数组的长度

var arr [1, 2];arr.unshift(0); //result of call is 3, the new array length //arr is [0, 1, 2]arr.unshift(-2, -1); // 5 //arr is [-2, -1, 0, 1, 2]arr.unshift( [-3] ); //arr is [[-3], -2, -1, 0, 1, 2]语法 arr.unshift(element1, ..., elementN)参数列表 elemen…

markdown基础语法整理

标题级别(一共六级) &#xff08;建议在#后加一个空格比较标准&#xff09; 通过在文字下方添加“”和“-”&#xff0c;他们分别表示一级标题和二级标题。在文字开头加上 “#”&#xff0c;通过“#”数量表示几级标题。&#xff08;共1~6级标题&#xff0c;级别越小字体越大&a…

安卓源码下载

SetupSecurityPortingTuningCompatibilityReference转到源代码SetupGetting StartedDownloading and Building RequirementsEstablishing a Build EnvironmentDownloading the SourcePreparing to BuildCompiling with JackUsing Reference BoardsRunning BuildsBuilding Kerne…

mysql常用命令英文词汇_MySQL中文全文索引插件 mysqlcft 1.0.0 安装使用文档

MySQL在高并发连接、数据库记录数较多的情况下&#xff0c;SELECT ... WHERE ... LIKE %...%的全文搜索方式不仅效率差&#xff0c;而且以通配符%和_开头作查询时&#xff0c;使用不到索引&#xff0c;需要全表扫描&#xff0c;对数据库的压力也很大。MySQL针对这一问题提供了一…

dobbo 简单框架

转载于:https://www.cnblogs.com/huangjianping/p/7986881.html

spring mysql整合_springboot mybatis mysql 整合

1、pom文件配置mysqlmysql-connector-javaruntimeorg.springframework.bootspring-boot-starter-testtestorg.mybatis.spring.bootmybatis-spring-boot-starter1.2.0org.springframework.bootspring-boot-starter-jdbc2、mybatis 数据库连接配置spring.datasource.driver-class…

微信小程序怎么取mysql_微信小程序如何加载数据库真实数据?

微信小程序要加载网站数据库里面的真实数据&#xff0c;有一个硬性的要求&#xff0c;就是你的网站域名必须是https协议才行&#xff0c;要不然你第一步服务器域名配置你都通过不了&#xff0c;小编我也是前不久申请的https://www.100txy.com&#xff0c;具体申请步骤大家自行去…