淺嘗Spring註解開發_Servlet3.0與SpringMVC

来源:https://www.cnblogs.com/wei-ran/archive/2022/05/09/16249482.html
-Advertisement-
Play Games

Servlet、SprigMVC的容器初始化、註解開發、非同步處理等。 ...


淺嘗Spring註解開發_Servlet 3.0 與 SpringMVC

淺嘗Spring註解開發,基於Spring 4.3.12
Servlet3.0新增了註解支持、非同步處理,可以省去web.xml文件,非同步處理更高效。

淺嘗Spring註解開發_自定義註冊組件、屬性賦值、自動裝配
淺嘗Spring註解開發_Bean生命周期及執行過程
淺嘗Spring註解開發_AOP原理及完整過程分析(源碼)
淺嘗Spring註解開發_聲明式事務及原理
淺嘗Spring註解開發_簡單理解BeanFactoryPostProcessor、BeanDefinitionRegistryPostProcessor、ApplicationListener
Spring註解開發_Spring容器創建概述
淺嘗Spring註解開發_Servlet3.0與SpringMVC

Servlet 測試

創建Web動態工程,Servlet3.0需要Tomcat7.0及以上

註解包括@WebServlet()、@WebListener、@WebFilter

  • 發送請求

    <%@ page language="java" contentType="text/html; charset=UTF-8"
        pageEncoding="UTF-8"%>
    <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
    <html>
    <head>
    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
    <title>Insert title here</title>
    </head>
    <body>
    	<a href="hello">hello</a>
    </body>
    </html>
    
  • 處理請求,利用@WebServlet()註解標註

    @WebServlet("/hello")
    public class HelloServlet extends HttpServlet {
    	
    	@Override
    	protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    		// TODO Auto-generated method stub
    		//super.doGet(req, resp);
    		resp.getWriter().write("hello...");
    	}
    }
    

⭐Servlet容器初始化ServletContainerInitializer

Shared libraries(共用庫) / runtimes pluggability(運行時插件能力)

容器在啟動應用的時候,會掃描當前應用每一個jar包裡面META-INF/services/javax.servlet.ServletContainerInitializer指定的實現類,啟動並運行這個實現類的方法,並傳入感興趣的類型

原理

  1. Servlet容器啟動會掃描,當前應用裡面每一個jar包的ServletContainerInitializer的實現
  2. 提供ServletContainerInitializer的實現類
    1. 必須綁定在,META-INF/services/javax.servlet.ServletContainerInitializer文件中
    2. 文件的內容就是ServletContainerInitializer實現類的全類名

應用

  1. 創建一個實現ServletContainerInitializer的類

    public class MyServletContainerInitializer implements ServletContainerInitializer {
    
    	@Override
    	public void onStartup(Set<Class<?>> arg0, ServletContext sc) throws ServletException {
    		// TODO Auto-generated method stub
    		
    	}
    
    }
    
  2. 在src目錄(或idea在resources目錄下)創建META-INF/services/目錄和javax.servlet.ServletContainerInitializer文件,內容為實現類全類名

    com.atguigu.servlet.MyServletContainerInitializer
    
  3. 實現介面方法,兩個參數,一個註解

    1. @HandlesTypes:指定感興趣的類
    2. ServletContext:當前web的ServletContext
    3. Set<Class<?>>:感興趣的類的子類集合
    //容器啟動的時候會將@HandlesTypes指定的這個類型下麵的子類(實現類,子介面等)傳遞過來;
    //傳入感興趣的類型;
    @HandlesTypes(value={HelloService.class})
    public class MyServletContainerInitializer implements ServletContainerInitializer {
    
    	/**
    	 * 應用啟動的時候,會運行onStartup方法;
    	 * 
    	 * Set<Class<?>> arg0:感興趣的類型的所有子類型;
    	 * ServletContext arg1:代表當前Web應用的ServletContext;一個Web應用一個ServletContext;
    	 * 
    	 */
    	@Override
    	public void onStartup(Set<Class<?>> arg0, ServletContext sc) throws ServletException {
    		// TODO Auto-generated method stub
    		System.out.println("感興趣的類型:");
    		for (Class<?> claz : arg0) {
    			System.out.println(claz);
    		}
    		
    	}
    
    }
    
  4. @HandlesTypes的值是感興趣的類,參數Set<Class<?>> arg0的值是感興趣的類的子類、子介面、實現類等

    • 創建介面HelloService,並創建多個繼承或實現此介面的子類
  5. 應用啟動就會獲得指定的類型

ServletContext註冊Web三大組件

編碼方式註冊Servlet、Filter、Listener

  1. 使用ServletContext註冊Web組件(Servlet、Filter、Listener)
  2. 使用編碼的方式,在項目啟動的時候給ServletContext裡面添加組件
  3. 必須在項目啟動的時候來添加
    1. ServletContainerInitializer得到的ServletContext
    2. ServletContextListener監聽時得到的ServletContext

應用

  1. 自定義Servlet,繼承HttpServlet

    public class UserServlet extends HttpServlet {
    	
    	@Override
    	protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    		// TODO Auto-generated method stub
    		resp.getWriter().write("tomcat...");
    	}
    
    }
    
  2. 自定義Filter,實現Filter

    public class UserFilter implements Filter {
    
    	@Override
    	public void destroy() {
    		// TODO Auto-generated method stub
    		
    	}
    
    	@Override
    	public void doFilter(ServletRequest arg0, ServletResponse arg1, FilterChain arg2)
    			throws IOException, ServletException {
    		// 過濾請求
    		System.out.println("UserFilter...doFilter...");
    		//放行
    		arg2.doFilter(arg0, arg1);
    		
    	}
    
    	@Override
    	public void init(FilterConfig arg0) throws ServletException {
    		// TODO Auto-generated method stub
    		
    	}
    
    }
    
  3. 自定義Listener,實現ServletContextListener

    /**
     * 監聽項目的啟動和停止
     */
    public class UserListener implements ServletContextListener {
    
    	
    	//監聽ServletContext銷毀
    	@Override
    	public void contextDestroyed(ServletContextEvent arg0) {
    		// TODO Auto-generated method stub
    		System.out.println("UserListener...contextDestroyed...");
    	}
    
    	//監聽ServletContext啟動初始化
    	@Override
    	public void contextInitialized(ServletContextEvent arg0) {
    		// TODO Auto-generated method stub
            
    		//在這裡項目啟動前也可以得到的ServletContext
    		ServletContext servletContext = arg0.getServletContext();
    		System.out.println("UserListener...contextInitialized...");
    	}
    
    }
    
    
  4. 註冊

    • ServletContainerInitializer的一個參數是ServletContext
    • 另外在上面Listener監聽時也能得到ServletContext
    //容器啟動的時候會將@HandlesTypes指定的這個類型下麵的子類(實現類,子介面等)傳遞過來;
    //傳入感興趣的類型;
    @HandlesTypes(value={HelloService.class})
    public class MyServletContainerInitializer implements ServletContainerInitializer {
    
    	/**
    	 * 應用啟動的時候,會運行onStartup方法;
    	 * 
    	 * Set<Class<?>> arg0:感興趣的類型的所有子類型;
    	 * ServletContext arg1:代表當前Web應用的ServletContext;一個Web應用一個ServletContext;
    	 * 
    	 * 1)、使用ServletContext註冊Web組件(Servlet、Filter、Listener)
    	 * 2)、使用編碼的方式,在項目啟動的時候給ServletContext裡面添加組件;
    	 * 		必須在項目啟動的時候來添加;
    	 * 		1)、ServletContainerInitializer得到的ServletContext;
    	 * 		2)、ServletContextListener得到的ServletContext;
    	 */
    	@Override
    	public void onStartup(Set<Class<?>> arg0, ServletContext sc) throws ServletException {
    		// TODO Auto-generated method stub
    		System.out.println("感興趣的類型:");
    		for (Class<?> claz : arg0) {
    			System.out.println(claz);
    		}
    		
    		//註冊組件  ServletRegistration  
    		ServletRegistration.Dynamic servlet = sc.addServlet("userServlet", new UserServlet());
    		//配置servlet的映射信息
    		servlet.addMapping("/user");
    		
    		
    		//註冊Listener
    		sc.addListener(UserListener.class);
    		
    		//註冊Filter  FilterRegistration
    		FilterRegistration.Dynamic filter = sc.addFilter("userFilter", UserFilter.class);
    		//配置Filter的映射信息,另一個方法參數是直接使用Servlet攔截
    		filter.addMappingForUrlPatterns(EnumSet.of(DispatcherType.REQUEST), true, "/*");
    		
    	}
    
    }
    

Servlet與SpringMVC整合

原理分析

web容器啟動,掃描指定位置類名,發現感興趣的類,然後從這個類的子類中選擇創建組件對象

  1. 導入jar包

            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-webmvc</artifactId>
                <version>4.3.11.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>javax.servlet</groupId>
                <artifactId>javax.servlet-api</artifactId>
                <version>3.0.1</version>
                <scope>provided</scope>
            </dependency>
    
  2. web容器在啟動的時候,會掃描每個jar包下的META-INF/services/javax.servlet.ServletContainerInitializer,打開spring-web.jar目錄下的文件

    org.springframework.web.SpringServletContainerInitializer
    
  3. 載入這個文件指定的類SpringServletContainerInitializer,發現@HandlesTypes註解中感興趣的類是WebApplicationInitializer

  4. Spring的應用一啟動會載入感興趣的WebApplicationInitializer介面的下的所有組件,並且為WebApplicationInitializer組件創建對象(組件不是介面,不是抽象類)

    @HandlesTypes(WebApplicationInitializer.class)
    public class SpringServletContainerInitializer implements ServletContainerInitializer {
    	@Override
    	public void onStartup(Set<Class<?>> webAppInitializerClasses, ServletContext servletContext)
    			throws ServletException {
    				//...
    				//防禦:一些 servlet 容器為我們提供了無效的類,不管@HandlesTypes 說什麼......
    				if (!waiClass.isInterface() && !Modifier.isAbstract(waiClass.getModifiers()) &&
    						WebApplicationInitializer.class.isAssignableFrom(waiClass)) {
    						initializers.add((WebApplicationInitializer) waiClass.newInstance());
    				}
    				//...
    }
    
  5. 關於感興趣的類WebApplicationInitializer的子類(子介面、抽象)三個抽象類:

    1. AbstractContextLoaderInitializer:創建根容器;createRootApplicationContext()
    2. AbstractDispatcherServletInitializer:
      1. 創建一個web的ioc容器:createServletApplicationContext()
      2. 創建了DispatcherServlet:createDispatcherServlet()
      3. 將創建的DispatcherServlet添加到ServletContext中:servletContext.addServlet(servletName, dispatcherServlet)
      4. 保留一個抽象方法待實現,返回將註冊 DispatcherServlet 的名稱:getServletMappings()
    3. AbstractAnnotationConfigDispatcherServletInitializer:註解方式配置的DispatcherServlet初始化器
      1. 創建根容器:createRootApplicationContext()
      2. 保留一個抽象方法待實現,傳入一個配置類:getRootConfigClasses()
      3. 創建web的ioc容器: createServletApplicationContext()
      4. 保留一個抽象方法待實現,獲取配置類:getServletConfigClasses()
  6. 總結:以註解方式來啟動SpringMVC,可以選擇其中一個抽象類,例如繼承AbstractAnnotationConfigDispatcherServletInitializer,實現抽象方法指定DispatcherServlet的配置信息

整合

SpringMVC官方文檔Web on Servlet Stack (spring.io)

Spring關於DispatcherServlet的解釋,將DispatcherServlet分為具有上下繼承關係的兩部分,其中可在多個實例之間共用的Root WebApplicationContext包含中間服務層Service、數據源Repositories,和可在特定於Servlet的子項被覆蓋的控制器Controllers、視圖解析器ViewResolver、處理器映射器HandlerMapping其他與web相關的bean)

  講過上節分析,選擇感興趣的類WebApplicationInitializer的其中一個子介面AbstractAnnotationConfigDispatcherServletInitializer來實現

  1. 實現AbstractAnnotationConfigDispatcherServletInitializer介面並配置

    //web容器啟動的時候創建對象;調用方法來初始化容器以前前端控制器
    public class MyWebAppInitializer extends AbstractAnnotationConfigDispatcherServletInitializer {
    
    	//獲取根容器的配置類;(Spring的配置文件)   父容器;
    	@Override
    	protected Class<?>[] getRootConfigClasses() {
    		// TODO Auto-generated method stub
    		return new Class<?>[]{RootConfig.class};
    	}
    
    	//獲取web容器的配置類(SpringMVC配置文件)  子容器;
    	@Override
    	protected Class<?>[] getServletConfigClasses() {
    		// TODO Auto-generated method stub
    		return new Class<?>[]{AppConfig.class};
    	}
    
    	//獲取DispatcherServlet的映射信息
    	//  /:攔截所有請求(包括靜態資源(xx.js,xx.png)),但是不包括*.jsp;
    	//  /*:攔截所有請求;連*.jsp頁面都攔截;jsp頁面是tomcat的jsp引擎解析的;
    	@Override
    	protected String[] getServletMappings() {
    		// TODO Auto-generated method stub
    		return new String[]{"/"};
    	}
    
    }
    
  2. 創建兩個配置

    1. Spring的配置文件,根容器

      //Spring的容器不掃描controller;父容器
      @ComponentScan(value="com.atguigu",excludeFilters={
      		@Filter(type=FilterType.ANNOTATION,classes={Controller.class})
      })
      public class RootConfig {
      
      }
      
    2. SpringMVC配置文件,web容器

      //SpringMVC只掃描Controller;子容器
      //useDefaultFilters=false 禁用預設的過濾規則;
      @ComponentScan(value="com.atguigu",includeFilters={
      		@Filter(type=FilterType.ANNOTATION,classes={Controller.class})
      },useDefaultFilters=false)
      public class AppConfig  extends WebMvcConfigurerAdapter  {
      
      }
      
  3. 創建業務

    1. Service

      @Service
      public class HelloService implements ApplicationContextAware {
      
      	public String sayHello(String name){
      
      		return "Hello "+name;
      	}
      
      }
      
    2. Controller

      @Controller
      public class HelloController {
      	
      	@Autowired
      	HelloService helloService;
      	
      	@ResponseBody
      	@RequestMapping("/hello")
      	public String hello(){
      		String hello = helloService.sayHello("tomcat..");
      		return hello;
      	}
      }
      

定製SpringMVC

與之前使用xml文件相似,可以配置視圖解析器、靜態資源訪問、攔截器

可參考Spring文檔Web on Servlet Stack (spring.io)

  1. @EnableWebMvc:開啟SpringMVC定製配置功能,與xml中的<mvc:annotation-driven>相同

  2. 配置組件,實現WebMvcConfigurer(Spring4中用WebMvcConfigurerAdapter)

    //SpringMVC只掃描Controller;子容器
    //useDefaultFilters=false 禁用預設的過濾規則;
    @ComponentScan(value="com.atguigu",includeFilters={
    		@Filter(type=FilterType.ANNOTATION,classes={Controller.class})
    },useDefaultFilters=false)
    @EnableWebMvc
    public class AppConfig  extends WebMvcConfigurerAdapter  {
    
    	//定製
    	
    	//視圖解析器
    	@Override
    	public void configureViewResolvers(ViewResolverRegistry registry) {
    		// TODO Auto-generated method stub
    		//預設所有的頁面都從 /WEB-INF/ xxx .jsp
    		//registry.jsp();
    		registry.jsp("/WEB-INF/views/", ".jsp");
    	}
    	
    	//靜態資源訪問
    	@Override
    	public void configureDefaultServletHandling(DefaultServletHandlerConfigurer configurer) {
    		// TODO Auto-generated method stub
    		configurer.enable();
    	}
    	
    	//攔截器
    	@Override
    	public void addInterceptors(InterceptorRegistry registry) {
    		// TODO Auto-generated method stub
    		//super.addInterceptors(registry);
    		registry.addInterceptor(new MyFirstInterceptor()).addPathPatterns("/**");
    	}
    
    }
    

    攔截器

    public class MyFirstInterceptor implements HandlerInterceptor {
    
    	//目標方法運行之前執行
    	@Override
    	public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
    			throws Exception {
    		// TODO Auto-generated method stub
    		System.out.println("preHandle..."+request.getRequestURI());
    		return true;
    	}
    
    	//目標方法執行正確以後執行
    	@Override
    	public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
    			ModelAndView modelAndView) throws Exception {
    		// TODO Auto-generated method stub
    		System.out.println("postHandle...");
    
    	}
    
    	//頁面響應以後執行
    	@Override
    	public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex)
    			throws Exception {
    		// TODO Auto-generated method stub
    		System.out.println("afterCompletion...");
    	}
    
    }
    

⭐Servlet3.0 非同步請求

  在Servlet3.0之前,Servlet才採用Thread—Per—Request的方式處理請求。即每一次http請求都由一個線程從頭到尾負責處理。

  如果一個請求需要進行IO操作,比如訪問資料庫,調用第三方服務介面等,那麼其所對應的線程將同步地等待IO操作完成,而IO操作是非常慢的,所以此時的線程並不能及時的釋放回線程池以供後續使用,在併發量越來越大的情況下,這將帶來嚴重的新能問題。即便像Spring、struts這樣的高層框架也脫離不了這樣的問題,因為他們都是建立在Servlet之上的。為瞭解決這樣的問題,Servlet3.0引入了一步處理,然後在Servlet3.1中又引入了非阻塞IO來進行增加一步處理的性能。

同步請求

每次請求時從線程池獲取一個線程,然後處理請求,直到處理完成,仍由這個線程響應。如果一個線程等待時間過長,其他請求就會占滿線程池

image

驗證

  1. 發送一個請求,獲取處理請求前後的線程

    @WebServlet("/hello")
    public class HelloServlet extends HttpServlet {
    	
    	@Override
    	protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    		// TODO Auto-generated method stub
    		//super.doGet(req, resp);
    		System.out.println(Thread.currentThread()+" start...");
    		try {
    			sayHello();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		resp.getWriter().write("hello...");
    		System.out.println(Thread.currentThread()+" end...");
    	}
    	
    	public void sayHello() throws Exception{
    		System.out.println(Thread.currentThread()+" processing...");
    		Thread.sleep(3000);
    	}
    
    }
    
  2. 輸出

    • 整個請求都是由一個線程處理
    Thread[http-nio-8888-exec-10,5,main] start...
    Thread[http-nio-8888-exec-10,5,main] processing...
    Thread[http-nio-8888-exec-10,5,main] end...
    

非同步請求

當請求過來時,由主線程池中一條線程處理,當開始非同步處理時,主線程就結束返回,等待其他請求,非同步處理線程的一條線程同時開始處理請求。

image

驗證

  1. 非同步對象AsyncContext可以開始和完成非同步處理,同時開啟註解@WebServlet(value="/xxx",asyncSupported=true)

    @WebServlet(value="/async",asyncSupported=true)
    public class HelloAsyncServlet extends HttpServlet {
    	
    	@Override
    	protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    		//1、支持非同步處理asyncSupported=true
    		//2、開啟非同步模式
    		//主線程開始
    		System.out.println("main thread start..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    		AsyncContext startAsync = req.startAsync();
    		
    		//3、業務邏輯進行非同步處理;開始非同步處理
    		startAsync.start(new Runnable() {
    			@Override
    			public void run() {
    				try {
    					//副線程開始
    					System.out.println("vice thread start..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    					sayHello();
    					startAsync.complete();
    					//獲取到非同步上下文
    					//AsyncContext asyncContext = req.getAsyncContext();
    					//4、獲取響應
    					//使用asyncContext.getResponse()副線程不能結束,仍使用startAsync.getResponse()獲取響應
    					//ServletResponse response = asyncContext.getResponse();
    					ServletResponse response = startAsync.getResponse();
    					response.getWriter().write("hello async...");
    					//副線程結束
    					System.out.println("vice thread end..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    				} catch (Exception e) {
    				}
    			}
    		});		
    		//主線程結束
    		System.out.println("main thread end..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    	}
        
    	//處理過程
    	public void sayHello() throws Exception{
    		System.out.println(Thread.currentThread()+" processing...");
    		Thread.sleep(3000);
    	}
    }
    
  2. 輸出

    • 主線程開啟後遇到非同步處理立刻結束
    • 主線程結束同時副線程開始處理非同步請求
    //主線程
    main thread start...Thread[http-nio-8888-exec-5,5,main]==>1651997065639
    main thread end...Thread[http-nio-8888-exec-5,5,main]==>1651997065648
    //副線程
    vice thread start...Thread[http-nio-8888-exec-7,5,main]==>1651997065648
    Thread[http-nio-8888-exec-7,5,main] processing...
    vice thread end...Thread[http-nio-8888-exec-7,5,main]==>1651997068656
    

⭐SpringMVC非同步處理

參考SpringMVC官方文檔Web on Servlet Stack (spring.io)

返回Callable

Controller返回Callable類型的返回值,非同步處理在Callable類中進行

過程

Callable處理過程

  1. 控制器返回Callable
  2. SpringMVC非同步處理,將Callable 提交到 TaskExecutor 使用一個隔離的線程進行執行
  3. DispatcherServlet和所有的Filter退出web容器的線程,但是response 保持打開狀態
  4. Callable返回結果,SpringMVC將請求重新派發給容器,恢復之前的處理
  5. 根據Callable返回的結果。SpringMVC繼續進行視圖渲染流程等(從收請求-視圖渲染)
  6. 對於非同步處理,普通攔截器不能攔截非同步中的代碼,使用非同步攔截器
    1. 原生API的AsyncListener
    2. SpringMVC:實現AsyncHandlerInterceptor

應用

  1. 非同步處理

    @Controller
    public class AsyncController {
        
    	@ResponseBody
    	@RequestMapping("/async01")
    	public Callable<String> async01(){
    		//主線程開始
    		System.out.println("main thread start..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    
    		Callable<String> callable = new Callable<String>() {
    			@Override
    			public String call() throws Exception {
    				//副線程開始
    				System.out.println("vice thread start..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    
    				//處理業務
    				Thread.sleep(2000);
    				//副線程開始
    				System.out.println("vice thread end..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    
    				return "Callable<String> async01()";
    			}
    		};
    		
    		//主線程結束
    		System.out.println("main thread end..."+Thread.currentThread()+"==>"+System.currentTimeMillis());
    
    		return callable;
    	}
    }
    
  2. 輸出

    • 主線程和副線程不是同一線程
    • 攔截器攔截了兩次同一個請求
    • 上面兩處都是Callable的原因,Callable會另起一個線程,並且結束前端控制器,等非同步處理完在恢復前端控制器繼續執行,所以有兩次攔截器,並且要使用非同步攔截器
    //攔截器
    preHandle.../springmvc_annotation_war/async01
    
    //主線程,執行完DispatcherServlet及所有的Filter退出線程
    main thread start...Thread[http-nio-8888-exec-10,5,main]==>1652003199856
    main thread end...Thread[http-nio-8888-exec-10,5,main]==>1652003199860
    
    //副線程,等待Callable執行
    vice thread start...Thread[MvcAsync1,5,main]==>1652003199873
    vice thread end...Thread[MvcAsync1,5,main]==>1652003201875
    
    //攔截器,再次收到之前重發過來的請求
    preHandle.../springmvc_annotation_war/async01
    postHandle...
    afterCompletion...
    

DeferredResult

上面的Callable使用與簡單場景,可以處理當前簡單業務,對於多應用複雜業務可以使用DeferredResult類型,在當前應用處理請求,然後繼續向下執行,當其他應用完成請求之後,通知DeferredResult就可以響應結果結束請求。對應下圖:

應用1是當前應用,負責接受請求,中間隔著其他組件,應用2負責非同步處理請求,然後將結果返回給當前應用1。

image

官方文檔

  在 Servlet 容器中啟用非同步請求處理功能後,控制器方法可以使用 DeferredResult 包裝任何支持的控制器方法返回值,如以下示例所示:

@GetMapping("/quotes")
@ResponseBody
public DeferredResult<String> quotes() {
    DeferredResult<String> deferredResult = new DeferredResult<String>();
    // Save the deferredResult somewhere..
    // 將deferredResult保存到某個地方。
    return deferredResult;
}

// From some other thread...
// 從其他線程...
deferredResult.setResult(result);

  控制器可以從不同的線程非同步生成返回值 — 例如,響應外部事件(JMS 消息)、計劃任務或其他事件。

應用

  1. 請求

    • 在當前應用接收請求,然後將DeferredResult保存起來
    • 然後返回
    @Controller
    public class AsyncController {
    	
    	
    	@ResponseBody
    	@RequestMapping("/createOrder")
    	public DeferredResult<Object> createOrder(){
    		//使用超時值和要使用的預設結果創建DeferredResult
    		DeferredResult<Object> deferredResult = new DeferredResult<>((long)3000, "create fail...");
    			
    		DeferredResultQueue.save(deferredResult);
    		
    		return deferredResult;
    	}
    }
    
  2. 保存DeferredResult隊列

    • 有存取功能
    public class DeferredResultQueue {
    	
    	private static Queue<DeferredResult<Object>> queue = new ConcurrentLinkedQueue<DeferredResult<Object>>();
    	
    	public static void save(DeferredResult<Object> deferredResult){
    		queue.add(deferredResult);
    	}
    	
    	public static DeferredResult<Object> get( ){
    		return queue.poll();
    	}
    
    }
    
  3. 模擬另一個應用,非同步處理業務

    • 真實請情況可以是另一個應用或線程
    	@ResponseBody
    	@RequestMapping("/create")
    	public String create(){
    		//創建訂單
    		String order = UUID.randomUUID().toString();
            //取出DeferredResult
    		DeferredResult<Object> deferredResult = DeferredResultQueue.get();
            //放入結果,同時應用1完成非同步處理
    		deferredResult.setResult(order);
    		return "success===>"+order;
    	}
    
  4. 結果

    成功
    52917142-3a12-4df5-9c89-258cbf0d0c3a
    success===>52917142-3a12-4df5-9c89-258cbf0d0c3a
    失敗
    create fail...
    
  5. DeferredResult部分文檔

    DeferredResult 提供了使用 Callable 進行非同步請求處理的替代方法。 雖然代表應用程式同時執行 Callable,但使用 DeferredResult 應用程式可以從其選擇的線程中生成結果。
    子類可以擴展此類以輕鬆地將附加數據或行為與 DeferredResult 關聯。 例如,可能希望通過擴展類併為用戶添加一個附加屬性來關聯用於創建 DeferredResult 的用戶。 這樣,以後可以很容易地訪問用戶,而無需使用數據結構來進行映射。
    
    將附加行為與此類關聯的示例可以通過擴展類以實現附加介面來實現。 例如,您可能希望實現 Comparable 以便在將 DeferredResult 添加到 PriorityQueue 時以正確的順序對其進行處理。
    
    onCompletion
    public void onCompletion(Runnable callback)
    註冊代碼在非同步請求完成時調用。
    當非同步請求因任何原因(包括超時和網路錯誤)完成時,從容器線程調用此方法。
    這對於檢測延遲實例不再可用很有用。
    
    public boolean setResult(T result)
    設置DeferredResult的值並處理它。
    

更詳細的文章推薦:

DeferredResult的使用場景及用法 - 胡桃同學的個人空間 - OSCHINA - 中文開源技術交流社區


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • #批量入庫 因為maccms自帶的採集採集起來很慢,而且很多資源站的採集介面不能對內容排序,導致最舊的數據最後入庫。用java寫個採集程式,採集完入庫的時候發現不能一次性入庫多個數據,導致入庫也很慢,所以就在入庫控制器寫了個方法批量入庫。 Receive.php public function fo ...
  • Spring Bean的創建剛開始進行了一些準備工作,比如轉換服務的初始化,占位符解析器的初始化,BeanDefinition元數據的凍結等操作,都是為了在創建Bean的過程中保證Bean的正確的創建,接下來開始進行對Bean的創建進行解析。 Bean 的創建步驟 在Spring源碼中對Bean的創 ...
  • Spring與Web環境集成 1. ApplicationContext應用上下文獲取方式 應用上下文對象是通過 new ClassPathXmlApplicationContext(Spring配置文件) 方式獲取的,但是每次從容器中獲取Bean時都要編寫 new ClassPathXmlAppl ...
  • 第十一屆藍橋杯大賽第二次模擬(軟體類)真題 Python組 【問題描述】在電腦存儲中,12.5MB是多少位元組?【答案提交】這是一 道結果填空的題,你只需要算出結果後提交即可。本題的結果為一個整數,在提交答案時只 填寫這個整數,填寫多餘的內容將無法得分。 ''' 這裡註意是byte不是bit,byt ...
  • 要先安裝Appium,並用它來查找對應元素的id、xpath等信息 from appium import webdriver from appium.webdriver.extensions.android.nativekey import AndroidKey from selenium.webd ...
  • 哈爾濱工業大學2022春軟體構造Lab1實驗經歷與實驗心得,可供後來學子借鑒 ...
  • C++進階實例3--基於STL的演講比賽流程管理系統 1. 頭文件 1.1 speaker.h 1 #pragma once 2 #include<iostream> 3 4 using namespace std; 5 6 // 創建選手類 7 class Speaker { 8 public: ...
  • 面對這樣的if語句,你是不是很難受呢? if (flag == 1) { log.info("didispace.com: 1"); } else if (flag == 2) { log.info("didispace.com: 2"); } else if (flag == 3) { log.i ...
一周排行
    -Advertisement-
    Play Games
  • 前言 本文將以 C# 語言來實現一個簡單的布隆過濾器,為簡化說明,設計得很簡單,僅供學習使用。 感謝@時總百忙之中的指導。 布隆過濾器簡介 布隆過濾器(Bloom filter)是一種特殊的 Hash Table,能夠以較小的存儲空間較快地判斷出數據是否存在。常用於允許一定誤判率的數據過濾及防止緩存 ...
  • 目錄 一.簡介 二.效果演示 三.源碼下載 四.猜你喜歡 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 基礎 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 轉場 零基礎 O ...
  • 「簡單有價值的事情長期堅持做」 這是成功最簡單,但也最難學的秘訣。不經過訓練,人很難意識到時間複利的威力。 仙劍奇俠傳的「十里坡劍神」和金庸群俠傳的「十級野球拳」,就是簡單的事情持之以恆反覆做,最後就有巨大的威力 唐家三少成為網文收入第一,最重要的一步是十四年從未斷日更 這樣的案例很多,一開始可能成 ...
  • 迎面走來了你的面試官,身穿格子衫,挺著啤酒肚,髮際線嚴重後移的中年男子。 手拿泡著枸杞的保溫杯,胳膊夾著MacBook,MacBook上還貼著公司標語:“我愛加班”。 面試開始,直入正題。 面試官: 看你簡歷上面寫著精通MySQL,我先問你事務的特性是什麼? 老生常談,這個還有誰不會背的嗎? 我: ...
  • 基礎知識 python是一門腳本語言,它是解釋執行的。 python使用縮進做為語法,而且python2環境下同一個py文件中不能同時存在tab和空格縮進,否則會出錯,建議在IDE中顯示縮進符。 python在聲明變數時不寫數據類型,可以type(xx)來獲取欄位的類型,然後可以int(),list ...
  • 為什麼要多線程下載 俗話說要以終為始,那麼我們首先要明確多線程下載的目標是什麼,不外乎是為了更快的下載文件。那麼問題來了,多線程下載文件相比於單線程是不是更快? 對於這個問題可以看下圖。 橫坐標是線程數,縱坐標是使用對應線程數下載對應文件時花費的時間,藍橙綠代表下載文件的大小,每個線程下載對應文件2 ...
  • 詳細講解python爬蟲代碼,爬微博搜索結果的博文數據。 爬取欄位: 頁碼、微博id、微博bid、微博作者、發佈時間、微博內容、轉發數、評論數、點贊數。 爬蟲技術: 1、requests 發送請求 2、datetime 時間格式轉換 3、jsonpath 快速解析json數據 4、re 正則表達式提... ...
  • 背景: 一般我們可以用HashMap做本地緩存,但是HashMap功能比較弱,不支持Key過期,不支持數據範圍查找等。故在此實現了一個簡易的本地緩存,取名叫fastmap。 功能: 1.支持數據過期 2.支持等值查找 3.支持範圍查找 4.支持key排序 實現思路: 1.等值查找採用HashMap2 ...
  • 目錄 一.簡介 二.效果演示 三.源碼下載 四.猜你喜歡 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 基礎 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 轉場 零基礎 O ...
  • 本章是系列文章的第八章,用著色演算法進行寄存器的分配過程。 本文中的所有內容來自學習DCC888的學習筆記或者自己理解的整理,如需轉載請註明出處。周榮華@燧原科技 寄存器分配 寄存器分配是為程式處理的值找到存儲位置的問題 這些值可以存放到寄存器,也可以存放在記憶體中 寄存器更快,但數量有限 記憶體很多,但 ...