第十三章_异步处理

2024-08-22 23:48
文章标签 处理 异步 第十三章

本文主要是介绍第十三章_异步处理,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

13.1、概述

计算机的内存是有限的。Servlet/JSP容器的设计者很清楚这一点,因此他们提供了一些可以进行配置的设置,以确保容器能够在宿主机器中正常运行。例如,在Tomcat7中,处理进来请求的最多线程数量为200。如果是多处理器的服务器,则可以放心地增加线程数量,不过建议你还是尽量使用这个默认值。

ServletFilter一直占用着请求处理线程,直到它完成任务。如果完成任务花费了很长时间,并发用户的数量就会超过线程数量,容器将会遇到超出线程的风险。如果发生这种情况,TOmcat就会将超出的请求堆放在一个内部服务器Socket中(其他容器的处理方式可能会有所不同)。如果继续进来更多的请求,它们将会遭到拒绝,直到有资源可以处理请求为止。

异步处理特性可以帮助你节省容器线程。这项特性适用于长时间运行的操作。它的工作是等待任务完成,并释放请求处理线程,以便另一个请求能够使用该线程。注意,异步支持只适用于长时间运行的任务,并且你想让用户知道任务的执行结果。如果只有长时间运行的任务,但用户不需要知道处理的结果,那么则只要提供一个RunnableExecutor,并立即返回。例如,如果需要产生一份报表,并在保镖准备就绪之后通过电子邮件将报表发送出去,那么就不适合使用异步处理特性了。相反,如果需要产生一份报表,并且报表完成之后要展示给用户看,那么就可以使用异步处理。

 

13.2、编写异步的ServletFilter

WebServletWebFilter注解类型可以包含新的asyncSupport属性,为了编写能够支持异步处理的ServletFilterasyncSupported属性必须设为true

@WebServlet(asyncSupported=true...)

@WebFilter(asyncSupported=true...)

另一种在配置文件中配置

<servlet>

<servlet-name>AsyncServlet</servlet-name>

<servlet-class>servlet.MyAsyncServlet</servlet-class>

</servlet>


13.3、编写异步的Servlet

编写异步的SerlvetFilter相对比较简单。如果你有一个任务需要相对比较长时间才能完成,最好创建一个异步的Servlet或者Filter,在异步的Servlet或者Filter类中需要完成以下工作:

1、在ServletRequest中调用startAsync方法。startAsync会返回一个AsyncContext

2、在AsyncContext中调用setTimeout()方法,设置一个容器必须等待指定任务完成的毫秒数。这个步骤是可选的,但是如果没有设置这个时限,将会采用容器的默认时间。如果任务没能在规定实限内完成,将会抛出异常。

3、调用asyncContext.start方法,传递一个执行长时间任务的Runnable

4、任务完成时,通过Runnable调用asyncContext.complete方法或者asyncContext.dispatch方法。

下面是异步ServletdoGet或者doPost方法的主要内容:

final AsyncContext asyncContext = servletRequest.startAsync();

asyncContext.setTimeout( ... );

asyncContext.start(new Runnable(){

@Override

 public void run(){

//long running task

asyncContext.complete() or asyncContext.dispatch()

}

})

下面是个例子:

AsyncDispatchServlet.java

package servlet;import java.io.IOException;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;
@WebServlet(name="AsyncDispatchServlet", urlPatterns={"/asyncDispatch"},asyncSupported=true)
public class AsyncDispatchServlet extends HttpServlet {private static final long serialVersionUID = 1L;@Overridepublic void doGet(final HttpServletRequest request,HttpServletResponse response)throws ServletException, IOException{final AsyncContext asyncContext = request.startAsync() ;request.setAttribute("mainThread", Thread.currentThread().getName());asyncContext.setTimeout(5000);asyncContext.start(new Runnable(){@Overridepublic void run() {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}request.setAttribute("workerThread", Thread.currentThread().getName());asyncContext.dispatch("/ThreadNames.jsp");}});}
}

ThreadNames.jsp

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%><!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html><head><base href="<%=basePath%>"><title>Asynchronous Servlet</title><meta http-equiv="pragma" content="no-cache"><meta http-equiv="cache-control" content="no-cache"><meta http-equiv="expires" content="0">    <meta http-equiv="keywords" content="keyword1,keyword2,keyword3"><meta http-equiv="description" content="This is my page"><!--<link rel="stylesheet" type="text/css" href="styles.css">--></head><body>Main Thread:${mainThread}<br/>Worker Thread:${workerThread}</body>
</html>

运行结果:



下面这个例子的Servlet每秒钟发送一次进程更新,以便用户能够追踪进程。它发送HTML响应和一个简单的javaScript代码,用来更新一个HTML div元素。

AsyncCompleteServlet.java

package servlet;import java.io.IOException;
import java.io.PrintWriter;import javax.servlet.AsyncContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;public class AsyncCompleteServlet extends HttpServlet {private static final long serialVersionUID = 1L;@Overridepublic void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {response.setContentType("text/html");final PrintWriter writer = response.getWriter() ;writer.println("<html><head><title>" + "Async Servlet</title></head>");writer.println("<body><div id='progress'></div>");final AsyncContext asyncContext = request.startAsync() ;asyncContext.setTimeout(60000);asyncContext.start(new Runnable(){@Overridepublic void run() {System.out.println("new thread:" + Thread.currentThread());for(int i=0; i<10; i++){writer.println("<script>");writer.println("document.getElementById(" + "'progress').innerHTML = '" + (i*10) + "% complete'");writer.println("</script>") ;writer.flush();try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}writer.println("<script>");writer.println("document.getElementById(" + "'progress').innerHTML='DONE'");writer.println("</script>");writer.println("</body></html>");asyncContext.complete();}});}
}

部署配置文件

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://xmlns.jcp.org/xml/ns/javaee" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" id="WebApp_ID" version="3.1"><display-name>AsyncServlet</display-name><servlet><servlet-name>AsyncComplete</servlet-name><servlet-class>servlet.AsyncCompleteServlet</servlet-class><async-supported>true</async-supported></servlet><servlet-mapping><servlet-name>AsyncComplete</servlet-name><url-pattern>/asyncComplete</url-pattern></servlet-mapping>
</web-app>


运行结果:


13.4、异步监听器

除了支持ServletFilter执行异步操作之外,Servlet3.0还新增了一个AsyncListener接口,以便通知用户在异步处理期间发生的情况。AsyncListener接口定义了以下方法,当某个事件发生时,其中某一个方法就会被调用。

void onStartAsync(AsyncEvent event)

在刚启动一个异步操作时调用这个方法

void onComplete(AsyncEvent event)

当一个异步操作已经完成时调用这个方法

void onError(AsyncEvent event)

当一个异步操作失败时调用这个方法

void onTimeout(AsyncEvent event)

当一个异步操作已经超时的时候调用这个方法,即当它没能在规定时限内完成的时候。

4个方法都会收到一个AsyncEvent事件,你可以分别通过调用它的getAsyncContextgetSuppliedReqeustgetSuppliedResponse方法从中获得相关的AsyncContextServletRequestServletResponse实例。

下面的例子和其他Web监听器不同的是,它没有用@WebListener标注AsyncListener的实现。

MyAsyncListener.java

package listener;import java.io.IOException;import javax.servlet.AsyncEvent;
import javax.servlet.AsyncListener;public class MyAsyncListener implements AsyncListener{@Overridepublic void onComplete(AsyncEvent arg0) throws IOException {// TODO Auto-generated method stubSystem.out.println("MyAsyncListener.onComplete()");}@Overridepublic void onError(AsyncEvent arg0) throws IOException {// TODO Auto-generated method stubSystem.out.println("MyAsyncListener.onError()");}@Overridepublic void onStartAsync(AsyncEvent arg0) throws IOException {// TODO Auto-generated method stubSystem.out.println("MyAsyncListener.onStartAsync()");}@Overridepublic void onTimeout(AsyncEvent arg0) throws IOException {// TODO Auto-generated method stubSystem.out.println("MyAsyncListener.onTimeout()");}}

AsyncListenerServlet.java

package servlet;import java.io.IOException;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;import listener.MyAsyncListener;
@WebServlet(name="AsyncListenerServlet",urlPatterns={"/asyncListener"},asyncSupported=true)
public class AsyncListenerServlet extends HttpServlet{private static final long serialVersionUID = 1L;@Overridepublic void doGet(final HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {final AsyncContext asyncContext = request.startAsync() ;asyncContext.setTimeout(5000);asyncContext.addListener(new MyAsyncListener());asyncContext.start(new Runnable(){@Overridepublic void run() {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}String greeting = "hi from listener" ;System.out.println("wait...");request.setAttribute("greeting", greeting);asyncContext.dispatch("/index.jsp");}});}
}


这篇关于第十三章_异步处理的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1097748

相关文章

Java堆转储文件之1.6G大文件处理完整指南

《Java堆转储文件之1.6G大文件处理完整指南》堆转储文件是优化、分析内存消耗的重要工具,:本文主要介绍Java堆转储文件之1.6G大文件处理的相关资料,文中通过代码介绍的非常详细,需要的朋友可... 目录前言文件为什么这么大?如何处理这个文件?分析文件内容(推荐)删除文件(如果不需要)查看错误来源如何避

使用Python构建一个高效的日志处理系统

《使用Python构建一个高效的日志处理系统》这篇文章主要为大家详细讲解了如何使用Python开发一个专业的日志分析工具,能够自动化处理、分析和可视化各类日志文件,大幅提升运维效率,需要的可以了解下... 目录环境准备工具功能概述完整代码实现代码深度解析1. 类设计与初始化2. 日志解析核心逻辑3. 文件处

Java docx4j高效处理Word文档的实战指南

《Javadocx4j高效处理Word文档的实战指南》对于需要在Java应用程序中生成、修改或处理Word文档的开发者来说,docx4j是一个强大而专业的选择,下面我们就来看看docx4j的具体使用... 目录引言一、环境准备与基础配置1.1 Maven依赖配置1.2 初始化测试类二、增强版文档操作示例2.

MyBatis-Plus通用中等、大量数据分批查询和处理方法

《MyBatis-Plus通用中等、大量数据分批查询和处理方法》文章介绍MyBatis-Plus分页查询处理,通过函数式接口与Lambda表达式实现通用逻辑,方法抽象但功能强大,建议扩展分批处理及流式... 目录函数式接口获取分页数据接口数据处理接口通用逻辑工具类使用方法简单查询自定义查询方法总结函数式接口

SpringBoot结合Docker进行容器化处理指南

《SpringBoot结合Docker进行容器化处理指南》在当今快速发展的软件工程领域,SpringBoot和Docker已经成为现代Java开发者的必备工具,本文将深入讲解如何将一个SpringBo... 目录前言一、为什么选择 Spring Bootjavascript + docker1. 快速部署与

Python使用vllm处理多模态数据的预处理技巧

《Python使用vllm处理多模态数据的预处理技巧》本文深入探讨了在Python环境下使用vLLM处理多模态数据的预处理技巧,我们将从基础概念出发,详细讲解文本、图像、音频等多模态数据的预处理方法,... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

Spring Boot @RestControllerAdvice全局异常处理最佳实践

《SpringBoot@RestControllerAdvice全局异常处理最佳实践》本文详解SpringBoot中通过@RestControllerAdvice实现全局异常处理,强调代码复用、统... 目录前言一、为什么要使用全局异常处理?二、核心注解解析1. @RestControllerAdvice2

电脑提示xlstat4.dll丢失怎么修复? xlstat4.dll文件丢失处理办法

《电脑提示xlstat4.dll丢失怎么修复?xlstat4.dll文件丢失处理办法》长时间使用电脑,大家多少都会遇到类似dll文件丢失的情况,不过,解决这一问题其实并不复杂,下面我们就来看看xls... 在Windows操作系统中,xlstat4.dll是一个重要的动态链接库文件,通常用于支持各种应用程序

SQL Server数据库死锁处理超详细攻略

《SQLServer数据库死锁处理超详细攻略》SQLServer作为主流数据库管理系统,在高并发场景下可能面临死锁问题,影响系统性能和稳定性,这篇文章主要给大家介绍了关于SQLServer数据库死... 目录一、引言二、查询 Sqlserver 中造成死锁的 SPID三、用内置函数查询执行信息1. sp_w

Java对异常的认识与异常的处理小结

《Java对异常的认识与异常的处理小结》Java程序在运行时可能出现的错误或非正常情况称为异常,下面给大家介绍Java对异常的认识与异常的处理,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参... 目录一、认识异常与异常类型。二、异常的处理三、总结 一、认识异常与异常类型。(1)简单定义-什么是