淺嘗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
更多相關文章
  • maccms10二開批量入庫和資源打包
    #批量入庫 因為maccms自帶的採集採集起來很慢，而且很多資源站的採集介面不能對內容排序，導致最舊的數據最後入庫。用java寫個採集程式，採集完入庫的時候發現不能一次性入庫多個數據，導致入庫也很慢，所以就在入庫控制器寫了個方法批量入庫。 Receive.php public function fo ...
  • HttpClient源碼如何下載呢？
    Spring Bean的創建剛開始進行了一些準備工作，比如轉換服務的初始化，占位符解析器的初始化，BeanDefinition元數據的凍結等操作，都是為了在創建Bean的過程中保證Bean的正確的創建，接下來開始進行對Bean的創建進行解析。 Bean 的創建步驟 在Spring源碼中對Bean的創 ...
  • Spring與Web環境集成
    Spring與Web環境集成 1. ApplicationContext應用上下文獲取方式 應用上下文對象是通過 new ClassPathXmlApplicationContext(Spring配置文件) 方式獲取的，但是每次從容器中獲取Bean時都要編寫 new ClassPathXmlAppl ...
  • 藍橋杯歷屆真題（python B組 ）
    第十一屆藍橋杯大賽第二次模擬（軟體類）真題 Python組 【問題描述】在電腦存儲中，12.5MB是多少位元組？【答案提交】這是一 道結果填空的題，你只需要算出結果後提交即可。本題的結果為一個整數，在提交答案時只 填寫這個整數，填寫多餘的內容將無法得分。 ''' 這裡註意是byte不是bit,byt ...
  • 如何使用appnium爬取視頻數據
    要先安裝Appium，並用它來查找對應元素的id、xpath等信息 from appium import webdriver from appium.webdriver.extensions.android.nativekey import AndroidKey from selenium.webd ...
  • 哈工大軟體構造Lab1（2022）
    哈爾濱工業大學2022春軟體構造Lab1實驗經歷與實驗心得，可供後來學子借鑒 ...
  • C++進階實例3--基於STL的演講比賽流程管理系統
    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: ...
  • Java 14中對switch的增強，終於可以不寫break了
    面對這樣的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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類