第十三章_异步处理

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

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

13.1、概述

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

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

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

 

13.2、编写异步的Servlet和Filter

WebServlet和WebFilter注解类型可以包含新的asyncSupport属性，为了编写能够支持异步处理的Servlet和Filter，asyncSupported属性必须设为true：

@WebServlet(asyncSupported=true...)

@WebFilter(asyncSupported=true...)

另一种在配置文件中配置

<servlet>

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

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

</servlet>


13.3、编写异步的Servlet

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

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

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

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

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

下面是异步Servlet的doGet或者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、异步监听器

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

void onStartAsync(AsyncEvent event)

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

void onComplete(AsyncEvent event)

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

void onError(AsyncEvent event)

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

void onTimeout(AsyncEvent event)

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

这4个方法都会收到一个AsyncEvent事件，你可以分别通过调用它的getAsyncContext、getSuppliedReqeust和getSuppliedResponse方法从中获得相关的AsyncContext、ServletRequest和ServletResponse实例。

下面的例子和其他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。

相关文章

无人叉车3d激光slam多房间建图定位异常处理方案-墙体画线地图切分方案

无人叉车3d激光slam多房间建图定位异常处理方案-墙体画线地图切分方案

墙体画线地图切分方案 针对问题：墙体两侧特征混淆误匹配，导致建图和定位偏差，表现为过门跳变、外月台走歪等 ·解决思路：预期的根治方案IGICP需要较长时间完成上线，先使用切分地图的工程化方案，即墙体两侧切分为不同地图，在某一侧只使用该侧地图进行定位 方案思路 切分原理：切分地图基于关键帧位置，而非点云。 理论基础：光照是直线的，一帧点云必定只能照射到墙的一侧，无法同时照到两侧实践考虑：关
阅读更多...
【生成模型系列（初级）】嵌入（Embedding）方程——自然语言处理的数学灵魂【通俗理解】

【生成模型系列（初级）】嵌入（Embedding）方程——自然语言处理的数学灵魂【通俗理解】

【通俗理解】嵌入（Embedding）方程——自然语言处理的数学灵魂 关键词提炼 #嵌入方程 #自然语言处理 #词向量 #机器学习 #神经网络 #向量空间模型 #Siri #Google翻译 #AlexNet 第一节：嵌入方程的类比与核心概念【尽可能通俗】 嵌入方程可以被看作是自然语言处理中的“翻译机”，它将文本中的单词或短语转换成计算机能够理解的数学形式，即向量。 正如翻译机将一种语言
阅读更多...
Thymeleaf：生成静态文件及异常处理java.lang.NoClassDefFoundError: ognl/PropertyAccessor

Thymeleaf：生成静态文件及异常处理java.lang.NoClassDefFoundError: ognl/PropertyAccessor

我们需要引入包： <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-thymeleaf</artifactId></dependency><dependency><groupId>org.springframework</groupId><artifactId>sp
阅读更多...
js异步提交form表单的解决方案

js异步提交form表单的解决方案

1.定义异步提交表单的方法 （通用方法） /*** 异步提交form表单* @param options {form:form表单元素,success:执行成功后处理函数}* <span style="color:#ff0000;"><strong>@注意 后台接收参数要解码否则中文会导致乱码 如：URLDecoder.decode(param,"UTF-8")</strong></span>
阅读更多...
jenkins 插件执行shell命令时，提示“Command not found”处理方法

jenkins 插件执行shell命令时，提示“Command not found”处理方法

首先提示找不到“Command not found，可能我们第一反应是查看目标机器是否已支持该命令，不过如果相信能找到这里来的朋友估计遇到的跟我一样，其实目标机器是没有问题的通过一些远程工具执行shell命令是可以执行。奇怪的就是通过jenkinsSSH插件无法执行，经一番折腾各种搜索发现是jenkins没有加载/etc/profile导致。 【解决办法】： 需要在jenkins调用shell脚
阅读更多...
明明的随机数处理问题分析与解决方案

明明的随机数处理问题分析与解决方案

明明的随机数处理问题分析与解决方案 引言问题描述解决方案数据结构设计具体步骤伪代码C语言实现详细解释读取输入去重操作排序操作输出结果复杂度分析 引言 明明生成了N个1到500之间的随机整数，我们需要对这些整数进行处理，删去重复的数字，然后进行排序并输出结果。本文将详细讲解如何通过算法、数据结构以及C语言来解决这个问题。我们将会使用数组和哈希表来实现去重操作，再利用排序算法对结果
阅读更多...
8. 自然语言处理中的深度学习：从词向量到BERT

8. 自然语言处理中的深度学习：从词向量到BERT

引言 深度学习在自然语言处理（NLP）领域的应用极大地推动了语言理解和生成技术的发展。通过从词向量到预训练模型（如BERT）的演进，NLP技术在机器翻译、情感分析、问答系统等任务中取得了显著成果。本篇博文将探讨深度学习在NLP中的核心技术，包括词向量、序列模型（如RNN、LSTM），以及BERT等预训练模型的崛起及其实际应用。 1. 词向量的生成与应用 词向量（Word Embedding）
阅读更多...
使用协程实现高并发的I/O处理

使用协程实现高并发的I/O处理

文章目录 1. 协程简介1.1 什么是协程？1.2 协程的特点1.3 Python 中的协程 2. 协程的基本概念2.1 事件循环2.2 协程函数2.3 Future 对象 3. 使用协程实现高并发的 I/O 处理3.1 网络请求3.2 文件读写 4. 实际应用场景4.1 网络爬虫4.2 文件处理 5. 性能分析5.1 上下文切换开销5.2 I/O 等待时间 6. 最佳实践6.1 使用 as
阅读更多...
Level3 — PART 3 — 自然语言处理与文本分析

Level3 — PART 3 — 自然语言处理与文本分析

目录 自然语言处理概要 分词与词性标注 N-Gram 分词 分词及词性标注的难点 法则式分词法 全切分 FMM和BMM Bi-direction MM 优缺点 统计式分词法 N-Gram概率模型 HMM概率模型 词性标注（Part-of-Speech Tagging） HMM 文本挖掘概要 信息检索（Information Retrieval） 全文扫描 关键词
阅读更多...
PHP7扩展开发之数组处理

PHP7扩展开发之数组处理

前言 这次，我们将演示如何在PHP扩展中如何对数组进行处理。要实现的PHP代码如下： <?phpfunction array_concat ($arr, $prefix) {foreach($arr as $key => $val) {if (isset($prefix[$key]) && is_string($val) && is_string($prefix[$key])) {$arr[
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2