淺嘗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
  • C#自增運算符詳解：++i與i++的區別及應用場景
    概述：在C#中，++i和i++都是自增運算符，其中++i先增加值再返回，而i++先返回值再增加。應用場景根據需求選擇，首碼適合先增後用，尾碼適合先用後增。詳細示例提供清晰的代碼演示這兩者的操作時機和實際應用。 在C#中，++i 和 i++ 都是自增運算符，但它們在操作上有細微的差異，主要體現在操作的 ...
  • Taurus.MVC 性能壓力測試（ap 壓測 和 linux 下wrk 壓測）：.NET 版本
    上次發佈了：Taurus.MVC 性能壓力測試（ap 壓測 和 linux 下wrk 壓測）：.NET Core 版本，今天計劃準備壓測一下 .NET 版本，來測試並記錄一下 Taurus.MVC 框架在 .NET 版本的性能，以便後續持續優化改進。 為了方便對比，本文章的電腦環境和測試思路，儘量和... ...
  • 一文讀懂.NET WebAPI中FromRoute、FromQuery、FromBody的關鍵角色與用法
    .NET WebAPI作為一種構建RESTful服務的強大工具，為開發者提供了便捷的方式來定義、處理HTTP請求並返迴響應。在設計API介面時，正確地接收和解析客戶端發送的數據至關重要。.NET WebAPI提供了一系列特性，如[FromRoute]、[FromQuery]和[FromBody]，用 ...
  • WPF/C#實現圖像濾鏡優化方案：打造炫目視覺體驗！
    原因：我之所以想做這個項目，是因為在之前查找關於C#/WPF相關資料時，我發現講解圖像濾鏡的資源非常稀缺。此外，我註意到許多現有的開源庫主要基於CPU進行圖像渲染。這種方式在處理大量圖像時，會導致CPU的渲染負擔過重。因此，我將在下文中介紹如何通過GPU渲染來有效實現圖像的各種濾鏡效果。 生成的效果 ...
  • Bogus 實戰：使用 Bogus 和 EFCore 生成模擬數據和種子數據【完整教程】
    引言 上一章我們介紹了在xUnit單元測試中用xUnit.DependencyInject來使用依賴註入，上一章我們的Sample.Repository倉儲層有一個批量註入的介面沒有做單元測試，今天用這個示例來演示一下如何用Bogus創建模擬數據 ，和 EFCore 的種子數據生成 Bogus 的優 ...
  • WPF隨筆收錄-實時繪製心率曲線
    一、前言 在自己的項目中，涉及到實時心率曲線的繪製，項目上的曲線繪製，一般很難找到能直接用的第三方庫，而且有些還是定製化的功能，所以還是自己繪製比較方便。很多人一聽到自己畫就害怕，感覺很難，今天就分享一個完整的實時心率數據繪製心率曲線圖的例子；之前的博客也分享給DrawingVisual繪製曲線的方 ...
  • wpf程式修改啟動入口註意事項
    如果你在自定義的 Main 方法中直接使用 App 類並啟動應用程式，但發現 App.xaml 中定義的資源沒有被正確載入，那麼問題可能在於如何正確配置 App.xaml 與你的 App 類的交互。 確保 App.xaml 文件中的 x:Class 屬性正確指向你的 App 類。這樣，當你創建 Ap ...
  • 記一次 .NET某爐膛鍋爐檢測系統 崩潰分析
    一：背景 1. 講故事 上個月有個朋友在微信上找到我，說他們的軟體在客戶那邊隔幾天就要崩潰一次，一直都沒有找到原因，讓我幫忙看下怎麼回事，確實工控類的軟體環境複雜難搞，朋友手上有一個崩潰的dump，剛好丟給我來分析一下。 二：WinDbg分析 1. 程式為什麼會崩潰 windbg 有一個厲害之處在於 ...
  • 一個.NET內置依賴註入的小型強化版
    前言 .NET生態中有許多依賴註入容器。在大多數情況下，微軟提供的內置容器在易用性和性能方面都非常優秀。外加ASP.NET Core預設使用內置容器，使用很方便。 但是筆者在使用中一直有一個頭疼的問題：服務工廠無法提供請求的服務類型相關的信息。這在一般情況下並沒有影響，但是內置容器支持註冊開放泛型服 ...
  • WPF隨筆收錄-DataGrid固定右側列
    一、前言 在項目開發過程中，DataGrid是經常使用到的一個數據展示控制項，而通常表格的最後一列是作為操作列存在，比如會有編輯、刪除等功能按鈕。但WPF的原始DataGrid中，預設只支持固定左側列，這跟大家習慣性操作列放最後不符，今天就來介紹一種簡單的方式實現固定右側列。（這裡的實現方式參考的大佬 ...
所有分類