Ausführliche Erläuterung der beiden asynchronen Anforderungsmethoden von Spring Boot

Die asynchrone Verarbeitung von Anforderungen wurde in Spring 3.2 und späteren Versionen hinzugefügt. In diesem Artikel wird hauptsächlich Spring Boot zur Implementierung asynchroner Anforderungen vorgestellt (Interessierte Freunde können darauf verweisen).

Asynchrone Verarbeitung von Anfragen wurde in Spring 3.2 und späteren Versionen hinzugefügt, um die Verarbeitungsgeschwindigkeit von Anfragen zu erhöhen und den Leistungsverbrauch der Dienste zu reduzieren.

Wir haben in unserer Anfrage eine zeitaufwändige Verarbeitung vorgenommen, um Leistungsprobleme durch langfristige Belegung des Verbindungspools des Webservers zu vermeiden generiert, nachdem der Aufruf zur Verarbeitung erfolgt ist, erhöhen den Durchsatz des Webservers.

Aus diesem Grund hat Servlet 3.0 die asynchrone Verarbeitung von Anforderungen hinzugefügt und Spring hat sie auch auf dieser Basis gekapselt.

Dieser Artikel verwendet weiterhin Codebeispiele, um zu erklären, wie asynchrone Anforderungen in Spring Boot angewendet werden.

Lassen Sie mich zunächst über einige wichtige Punkte sprechen:

1. asyncSupported = true in @WebFilter- und @WebServlet-Annotationen Attribute

Wenn im asynchron verarbeiteten Servlet ein Filter vorhanden ist, sollte die Annotation @WebFilter des Filters auf asyncSupported=true gesetzt werden,

Andernfalls , ein Fehler Ein Filter oder Servlet der aktuellen Kette unterstützt keine asynchronen Vorgänge.

2. @EnableAsync-Annotation

Spring Boot fügt einige hinzu Filter, die standardmäßig /* abfangen. Da /* alle Anfragen abfängt, liegt es nahe, dass wir auch das Attribut asyncSupported=true festlegen. Da diese Filter von Spring Boot initialisiert werden, stellt es die Annotation @EnableAsync für die einheitliche Konfiguration bereit. Diese Annotation ist nur für „Nicht-@WebFilter- und @WebServlet-Annotationen“ gültig, daher muss der von uns definierte Filter weiterhin asyncSupported= true konfigurieren .

3. AsyncContext Object

Rufen Sie das Kontextobjekt einer asynchronen Anfrage ab.

4. asyncContext.setTimeout(20 * 1000L);

Wir können nicht zulassen, dass asynchrone Anforderungen auf unbestimmte Zeit warten, und legen den maximalen Timeout über setTimeout fest.

Testen Sie asynchrone Aufgaben auf zwei Arten:

Fügen Sie zunächst die Annotation @EnableAsync zu SpringBootSampleApplication hinzu.

Überprüfen Sie alle benutzerdefinierten Filter erneut. Wenn die folgenden zwei Situationen vorliegen, müssen Sie asyncSupported=true konfigurieren

1) Benutzerdefinierter Filter fängt /*

2) Ein bestimmter Filter fängt /shanhy/* ab und das asynchrone Anforderungs-Servlet, das wir ausführen müssen, ist /shanhy/testcomet

Methode 1: Native Servlet-Methode

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();
 }
}

Methode 2: Controller-Methode

@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();
   }
  };
 }

}

Schreiben Sie abschließend einen Comet.jsp-Seitentest:

<%@ 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(&#39;${pageContext.request.contextPath }/xs/cometservlet&#39;, function(data){
     console.log(data.result);
     $(&#39;#n1&#39;).html(data.result);
     longPolling();
    });
   }
   longPolling();

   function longPolling2(){
    $.get(&#39;${pageContext.request.contextPath }/async/test&#39;, function(data){
     console.log(data);
     $(&#39;#n2&#39;).html(data);
     longPolling2();
    });
   }
   longPolling2();
  });
 </script>
 </head>

 <body>
 <h1>长连接测试</h1>
 <h2 id="n1"></h2>
 <h2 id="n2"></h2>
 </body>
</html>

[Verwandte Empfehlungen]

1.

Kostenloses Java-Video-Tutorial

2.

Java-Video-Tutorial zur Implementierung gleichproportionaler Miniaturansichten

3 🎜>FastJson Tutorial-Handbuch

Das obige ist der detaillierte Inhalt vonAusführliche Erläuterung der beiden asynchronen Anforderungsmethoden von Spring Boot. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!