自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

SpringBoot的四種異步處理，寫這篇文章，我自己先學(xué)到了

作者： 丑胖俠二師兄
開(kāi)發(fā) 架構(gòu)
本篇文章我們以SpringBoot中異步的使用(包括：異步調(diào)用和異步方法兩個(gè)維度)來(lái)進(jìn)行講解。

[[382730]]

本文轉(zhuǎn)載自微信公眾號(hào)「程序新視界」，作者丑胖俠二師兄。轉(zhuǎn)載本文請(qǐng)聯(lián)系程序新視界公眾號(hào)。  

前言

在網(wǎng)絡(luò)上有關(guān)于SpringBoot的異步請(qǐng)求和異步調(diào)有兩種說(shuō)法，經(jīng)過(guò)調(diào)用這兩種說(shuō)法本質(zhì)上就是一回事，在《異步請(qǐng)求和異步調(diào)用有區(qū)別?》一種，已經(jīng)做過(guò)解釋了。

同時(shí)，我們也知道了“服務(wù)實(shí)現(xiàn)的異步與同步特性完全獨(dú)立于客戶端調(diào)用的異步和同步特性。也就是說(shuō)客戶端可以異步的去調(diào)用同步服務(wù)，而且客戶端也可以同步的去調(diào)用異步服務(wù)。”

本篇文章我們以SpringBoot中異步的使用(包括：異步調(diào)用和異步方法兩個(gè)維度)來(lái)進(jìn)行講解。

異步請(qǐng)求與同步請(qǐng)求

我們先通過(guò)一張圖來(lái)區(qū)分一下異步請(qǐng)求和同步請(qǐng)求的區(qū)別：

異步與同步

在上圖中有三個(gè)角色：客戶端、Web容器和業(yè)務(wù)處理線程。

兩個(gè)流程中客戶端對(duì)Web容器的請(qǐng)求，都是同步的。因?yàn)樗鼈冊(cè)谡?qǐng)求客戶端時(shí)都處于阻塞等待狀態(tài)，并沒(méi)有進(jìn)行異步處理。

在Web容器部分，第一個(gè)流程采用同步請(qǐng)求，第二個(gè)流程采用異步回調(diào)的形式。

通過(guò)異步處理，可以先釋放容器分配給請(qǐng)求的線程與相關(guān)資源，減輕系統(tǒng)負(fù)擔(dān)，從而增加了服務(wù)器對(duì)客戶端請(qǐng)求的吞吐量。但并發(fā)請(qǐng)求量較大時(shí)，通常會(huì)通過(guò)負(fù)載均衡的方案來(lái)解決，而不是異步。

Servlet3.0中的異步

Servlet 3.0之前，Servlet采用Thread-Per-Request的方式處理請(qǐng)求，即每一次Http請(qǐng)求都由一個(gè)線程從頭到尾處理。當(dāng)涉及到耗時(shí)操作時(shí)，性能問(wèn)題便比較明顯。

Servlet 3.0中提供了異步處理請(qǐng)求?？梢韵柔尫湃萜鞣峙浣o請(qǐng)求的線程與相關(guān)資源，減輕系統(tǒng)負(fù)擔(dān)，從而增加服務(wù)的吞吐量。

Servlet 3.0的異步是通過(guò)AsyncContext對(duì)象來(lái)完成的，它可以從當(dāng)前線程傳給另一個(gè)線程，并歸還初始線程。新的線程處理完業(yè)務(wù)可以直接返回結(jié)果給客戶端。

AsyncContext對(duì)象可以從HttpServletRequest中獲?。?/p> 

  1. @RequestMapping("/async") 
  2. public void async(HttpServletRequest request) { 
  3.     AsyncContext asyncContext = request.getAsyncContext(); 
  4. } 

在AsyncContext中提供了獲取ServletRequest、ServletResponse和添加監(jiān)聽(tīng)(addListener)等功能：

  1. public interface AsyncContext { 
  2.  
  3.     ServletRequest getRequest(); 
  4.  
  5.     ServletResponse getResponse(); 
  6.  
  7.     void addListener(AsyncListener var1); 
  8.      
  9.     void setTimeout(long var1); 
  10.  
  11.     // 省略其他方法 
  12. } 

不僅可以通過(guò)AsyncContext獲取Request和Response等信息，還可以設(shè)置異步處理超時(shí)時(shí)間。通常，超時(shí)時(shí)間(單位毫秒)是需要設(shè)置的，不然無(wú)限等下去不就與同步處理一樣了。

通過(guò)AsyncContext的addListener還可以添加監(jiān)聽(tīng)事件，用來(lái)處理異步線程的開(kāi)始、完成、異常、超時(shí)等事件回調(diào)。

addListener方法的參數(shù)AsyncListener的源碼如下：

  1. public interface AsyncListener extends EventListener { 
  2.     // 異步執(zhí)行完畢時(shí)調(diào)用 
  3.     void onComplete(AsyncEvent var1) throws IOException; 
  4.     // 異步線程執(zhí)行超時(shí)調(diào)用 
  5.     void onTimeout(AsyncEvent var1) throws IOException; 
  6.     // 異步線程出錯(cuò)時(shí)調(diào)用 
  7.     void onError(AsyncEvent var1) throws IOException; 
  8.     // 異步線程開(kāi)始時(shí)調(diào)用 
  9.     void onStartAsync(AsyncEvent var1) throws IOException; 
  10. } 

通常，異?；虺瑫r(shí)時(shí)返回調(diào)用方錯(cuò)誤信息，而異常時(shí)會(huì)處理一些清理和關(guān)閉操作或記錄異常日志等。

基于Servlet方式實(shí)現(xiàn)異步請(qǐng)求

下面直接看一個(gè)基于Servlet方式的異步請(qǐng)求示例：

  1. @GetMapping(value = "/email/send") 
  2. public void servletReq(HttpServletRequest request) { 
  3.     AsyncContext asyncContext = request.startAsync(); 
  4.     // 設(shè)置監(jiān)聽(tīng)器:可設(shè)置其開(kāi)始、完成、異常、超時(shí)等事件的回調(diào)處理 
  5.     asyncContext.addListener(new AsyncListener() { 
  6.         @Override 
  7.         public void onTimeout(AsyncEvent event) { 
  8.             System.out.println("處理超時(shí)了..."); 
  9.         } 
  10.  
  11.         @Override 
  12.         public void onStartAsync(AsyncEvent event) { 
  13.             System.out.println("線程開(kāi)始執(zhí)行"); 
  14.         } 
  15.  
  16.         @Override 
  17.         public void onError(AsyncEvent event) { 
  18.             System.out.println("執(zhí)行過(guò)程中發(fā)生錯(cuò)誤：" + event.getThrowable().getMessage()); 
  19.         } 
  20.  
  21.         @Override 
  22.         public void onComplete(AsyncEvent event) { 
  23.             System.out.println("執(zhí)行完成，釋放資源"); 
  24.         } 
  25.     }); 
  26.     //設(shè)置超時(shí)時(shí)間 
  27.     asyncContext.setTimeout(6000); 
  28.     asyncContext.start(new Runnable() { 
  29.         @Override 
  30.         public void run() { 
  31.             try { 
  32.                 Thread.sleep(5000); 
  33.                 System.out.println("內(nèi)部線程：" + Thread.currentThread().getName()); 
  34.                 asyncContext.getResponse().getWriter().println("async processing"); 
  35.             } catch (Exception e) { 
  36.                 System.out.println("異步處理發(fā)生異常：" + e.getMessage()); 
  37.             } 
  38.             // 異步請(qǐng)求完成通知，整個(gè)請(qǐng)求完成 
  39.             asyncContext.complete(); 
  40.         } 
  41.     }); 
  42.     //此時(shí)request的線程連接已經(jīng)釋放了 
  43.     System.out.println("主線程：" + Thread.currentThread().getName()); 
  44. } 

啟動(dòng)項(xiàng)目，訪問(wèn)對(duì)應(yīng)的URL，打印日志如下：

  1. 主線程：http-nio-8080-exec-4 
  2. 內(nèi)部線程：http-nio-8080-exec-5 
  3. 執(zhí)行完成，釋放資源 

可以看出，上述代碼先執(zhí)行完了主線程，也就是程序的最后一行代碼的日志打印，然后才是內(nèi)部線程的執(zhí)行。內(nèi)部線程執(zhí)行完成，AsyncContext的onComplete方法被調(diào)用。

如果通過(guò)瀏覽器訪問(wèn)對(duì)應(yīng)的URL，還可以看到該方法的返回值“async processing”。說(shuō)明內(nèi)部線程的結(jié)果同樣正常的返回到客戶端了。

基于Spring實(shí)現(xiàn)異步請(qǐng)求

基于Spring可以通過(guò)Callable、DeferredResult或者WebAsyncTask等方式實(shí)現(xiàn)異步請(qǐng)求。

基于Callable實(shí)現(xiàn)

對(duì)于一次請(qǐng)求(/email)，基于Callable的處理流程如下：

1、Spring MVC開(kāi)啟副線程處理業(yè)務(wù)(將Callable提交到TaskExecutor);

2、DispatcherServlet和所有的Filter退出Web容器的線程，但是response保持打開(kāi)狀態(tài);

3、Callable返回結(jié)果，SpringMVC將原始請(qǐng)求重新派發(fā)給容器(再重新請(qǐng)求一次/email)，恢復(fù)之前的處理;

4、DispatcherServlet重新被調(diào)用，將結(jié)果返回給用戶;

代碼實(shí)現(xiàn)示例如下：

  1. @GetMapping("/email") 
  2. public Callable<String> order() { 
  3.     System.out.println("主線程開(kāi)始：" + Thread.currentThread().getName()); 
  4.     Callable<String> result = () -> { 
  5.         System.out.println("副線程開(kāi)始：" + Thread.currentThread().getName()); 
  6.         Thread.sleep(1000); 
  7.         System.out.println("副線程返回：" + Thread.currentThread().getName()); 
  8.         return "success"; 
  9.     }; 
  10.  
  11.     System.out.println("主線程返回：" + Thread.currentThread().getName()); 
  12.     return result; 
  13. } 

訪問(wèn)對(duì)應(yīng)URL，控制臺(tái)輸入日志如下：

  1. 主線程開(kāi)始：http-nio-8080-exec-1 
  2.  
  3. 主線程返回：http-nio-8080-exec-1 
  4.  
  5. 副線程開(kāi)始：task-1 
  6.  
  7. 副線程返回：task-1 

通過(guò)日志可以看出，主線程已經(jīng)完成了，副線程才進(jìn)行執(zhí)行。同時(shí)，URL返回結(jié)果“success”。這也說(shuō)明一個(gè)問(wèn)題，服務(wù)器端的異步處理對(duì)客戶端來(lái)說(shuō)是不可見(jiàn)的。

Callable默認(rèn)使用SimpleAsyncTaskExecutor類來(lái)執(zhí)行，這個(gè)類非常簡(jiǎn)單而且沒(méi)有重用線程。在實(shí)踐中，需要使用AsyncTaskExecutor類來(lái)對(duì)線程進(jìn)行配置。

這里通過(guò)實(shí)現(xiàn)WebMvcConfigurer接口來(lái)完成線程池的配置。

  1. @Configuration 
  2. public class WebConfig implements WebMvcConfigurer { 
  3.  
  4.     @Resource 
  5.     private ThreadPoolTaskExecutor myThreadPoolTaskExecutor; 
  6.  
  7.     /** 
  8.      * 配置線程池 
  9.      */ 
  10.     @Bean(name = "asyncPoolTaskExecutor") 
  11.     public ThreadPoolTaskExecutor getAsyncThreadPoolTaskExecutor() { 
  12.         ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor(); 
  13.         taskExecutor.setCorePoolSize(2); 
  14.         taskExecutor.setMaxPoolSize(10); 
  15.         taskExecutor.setQueueCapacity(25); 
  16.         taskExecutor.setKeepAliveSeconds(200); 
  17.         taskExecutor.setThreadNamePrefix("thread-pool-"); 
  18.         // 線程池對(duì)拒絕任務(wù)（無(wú)線程可用）的處理策略，目前只支持AbortPolicy、CallerRunsPolicy；默認(rèn)為后者 
  19.         taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); 
  20.         taskExecutor.initialize(); 
  21.         return taskExecutor; 
  22.     } 
  23.  
  24.     @Override 
  25.     public void configureAsyncSupport(final AsyncSupportConfigurer configurer) { 
  26.         // 處理callable超時(shí) 
  27.         configurer.setDefaultTimeout(60 * 1000); 
  28.         configurer.setTaskExecutor(myThreadPoolTaskExecutor); 
  29.         configurer.registerCallableInterceptors(timeoutCallableProcessingInterceptor()); 
  30.     } 
  31.  
  32.     @Bean 
  33.     public TimeoutCallableProcessingInterceptor timeoutCallableProcessingInterceptor() { 
  34.         return new TimeoutCallableProcessingInterceptor(); 
  35.     } 
  36. } 

為了驗(yàn)證打印的線程，我們將實(shí)例代碼中的System.out.println替換成日志輸出，會(huì)發(fā)現(xiàn)在使用線程池之前，打印日志如下：

  1. 2021-02-21 09:45:37.144  INFO 8312 --- [nio-8080-exec-1] c.s.learn.controller.AsynController      : 主線程開(kāi)始：http-nio-8080-exec-1 
  2. 2021-02-21 09:45:37.144  INFO 8312 --- [nio-8080-exec-1] c.s.learn.controller.AsynController      : 主線程返回：http-nio-8080-exec-1 
  3. 2021-02-21 09:45:37.148  INFO 8312 --- [         task-1] c.s.learn.controller.AsynController      : 副線程開(kāi)始：task-1 
  4. 2021-02-21 09:45:38.153  INFO 8312 --- [         task-1] c.s.learn.controller.AsynController      : 副線程返回：task-1 

線程名稱為“task-1”。讓線程池生效之后，打印日志如下：

  1. 2021-02-21 09:50:28.950  INFO 8339 --- [nio-8080-exec-1] c.s.learn.controller.AsynController      : 主線程開(kāi)始：http-nio-8080-exec-1 
  2. 2021-02-21 09:50:28.951  INFO 8339 --- [nio-8080-exec-1] c.s.learn.controller.AsynController      : 主線程返回：http-nio-8080-exec-1 
  3. 2021-02-21 09:50:28.955  INFO 8339 --- [  thread-pool-1] c.s.learn.controller.AsynController      : 副線程開(kāi)始：thread-pool-1 
  4. 2021-02-21 09:50:29.956  INFO 8339 --- [  thread-pool-1] c.s.learn.controller.AsynController      : 副線程返回：thread-pool-1 

線程名稱為“thread-pool-1”，其中前面的“thread-pool”正是我們配置的線程池前綴。

除了線程池的配置，還可以配置統(tǒng)一異常處理，這里就不再演示了。

基于WebAsyncTask實(shí)現(xiàn)

Spring提供的WebAsyncTask是對(duì)Callable的包裝，提供了更強(qiáng)大的功能，比如：處理超時(shí)回調(diào)、錯(cuò)誤回調(diào)、完成回調(diào)等。

  1. @GetMapping("/webAsyncTask") 
  2. public WebAsyncTask<String> webAsyncTask() { 
  3.     log.info("外部線程：" + Thread.currentThread().getName()); 
  4.     WebAsyncTask<String> result = new WebAsyncTask<>(60 * 1000L, new Callable<String>() { 
  5.         @Override 
  6.         public String call() { 
  7.             log.info("內(nèi)部線程：" + Thread.currentThread().getName()); 
  8.             return "success"; 
  9.         } 
  10.     }); 
  11.     result.onTimeout(new Callable<String>() { 
  12.         @Override 
  13.         public String call() { 
  14.             log.info("timeout callback"); 
  15.             return "timeout callback"; 
  16.         } 
  17.     }); 
  18.     result.onCompletion(new Runnable() { 
  19.         @Override 
  20.         public void run() { 
  21.             log.info("finish callback"); 
  22.         } 
  23.     }); 
  24.     return result; 
  25. } 

訪問(wèn)對(duì)應(yīng)請(qǐng)求，打印日志：

  1. 2021-02-21 10:22:33.028  INFO 8547 --- [nio-8080-exec-1] c.s.learn.controller.AsynController      : 外部線程：http-nio-8080-exec-1 
  2. 2021-02-21 10:22:33.033  INFO 8547 --- [  thread-pool-1] c.s.learn.controller.AsynController      : 內(nèi)部線程：thread-pool-1 
  3. 2021-02-21 10:22:33.055  INFO 8547 --- [nio-8080-exec-2] c.s.learn.controller.AsynController      : finish callback 

基于DeferredResult實(shí)現(xiàn)

DeferredResult使用方式與Callable類似，但在返回結(jié)果時(shí)不一樣，它返回的時(shí)實(shí)際結(jié)果可能沒(méi)有生成，實(shí)際的結(jié)果可能會(huì)在另外的線程里面設(shè)置到DeferredResult中去。

DeferredResult的這個(gè)特性對(duì)實(shí)現(xiàn)服務(wù)端推技術(shù)、訂單過(guò)期時(shí)間處理、長(zhǎng)輪詢、模擬MQ的功能等高級(jí)應(yīng)用非常重要。

關(guān)于DeferredResult的使用先來(lái)看一下官方的例子和說(shuō)明：

  1. @RequestMapping("/quotes") 
  2. @ResponseBody 
  3. public DeferredResult<String> quotes() { 
  4.   DeferredResult<String> deferredResult = new DeferredResult<String>(); 
  5.   // Save the deferredResult in in-memory queue ... 
  6.   return deferredResult; 
  7. } 
  8.  
  9. // In some other thread... 
  10. deferredResult.setResult(data); 

上述示例中我們可以發(fā)現(xiàn)DeferredResult的調(diào)用并不一定在Spring MVC當(dāng)中，它可以是別的線程。官方的解釋也是如此：

In this case the return value will also be produced from a separate thread. However, that thread is not known to Spring MVC. For example the result may be produced in response to some external event such as a JMS message, a scheduled task, etc.

也就是說(shuō)，DeferredResult返回的結(jié)果也可能是由MQ、定時(shí)任務(wù)或其他線程觸發(fā)。來(lái)個(gè)實(shí)例：

  1. @Controller 
  2. @RequestMapping("/async/controller") 
  3. public class AsyncHelloController { 
  4.  
  5.     private List<DeferredResult<String>> deferredResultList = new ArrayList<>(); 
  6.  
  7.     @ResponseBody 
  8.     @GetMapping("/hello") 
  9.     public DeferredResult<String> helloGet() throws Exception { 
  10.         DeferredResult<String> deferredResult = new DeferredResult<>(); 
  11.  
  12.         //先存起來(lái)，等待觸發(fā) 
  13.         deferredResultList.add(deferredResult); 
  14.         return deferredResult; 
  15.     } 
  16.  
  17.     @ResponseBody 
  18.     @GetMapping("/setHelloToAll") 
  19.     public void helloSet() throws Exception { 
  20.         // 讓所有hold住的請(qǐng)求給與響應(yīng) 
  21.         deferredResultList.forEach(d -> d.setResult("say hello to all")); 
  22.     } 
  23. } 

第一個(gè)請(qǐng)求/hello，會(huì)先將deferredResult存起來(lái)，前端頁(yè)面是一直等待(轉(zhuǎn)圈)狀態(tài)。直到發(fā)第二個(gè)請(qǐng)求：setHelloToAll，所有的相關(guān)頁(yè)面才會(huì)有響應(yīng)。

整個(gè)執(zhí)行流程如下：

  • controller返回一個(gè)DeferredResult，把它保存到內(nèi)存里或者List里面(供后續(xù)訪問(wèn));
  • Spring MVC調(diào)用request.startAsync()，開(kāi)啟異步處理;與此同時(shí)將DispatcherServlet里的攔截器、Filter等等都馬上退出主線程，但是response仍然保持打開(kāi)的狀態(tài);
  • 應(yīng)用通過(guò)另外一個(gè)線程(可能是MQ消息、定時(shí)任務(wù)等)給DeferredResult#setResult值。然后SpringMVC會(huì)把這個(gè)請(qǐng)求再次派發(fā)給servlet容器;
  • DispatcherServlet再次被調(diào)用，然后處理后續(xù)的標(biāo)準(zhǔn)流程;

通過(guò)上述流程可以發(fā)現(xiàn)：利用DeferredResult可實(shí)現(xiàn)一些長(zhǎng)連接的功能，比如當(dāng)某個(gè)操作是異步時(shí)，可以先保存對(duì)應(yīng)的DeferredResult對(duì)象，當(dāng)異步通知回來(lái)時(shí)，再找到這個(gè)DeferredResult對(duì)象，在setResult處理結(jié)果即可。從而提高性能。

SpringBoot中的異步實(shí)現(xiàn)

在SpringBoot中將一個(gè)方法聲明為異步方法非常簡(jiǎn)單，只需兩個(gè)注解即可@EnableAsync和@Async。其中@EnableAsync用于開(kāi)啟SpringBoot支持異步的功能，用在SpringBoot的啟動(dòng)類上。@Async用于方法上，標(biāo)記該方法為異步處理方法。

需要注意的是@Async并不支持用于被@Configuration注解的類的方法上。同一個(gè)類中，一個(gè)方法調(diào)用另外一個(gè)有@Async的方法，注解也是不會(huì)生效的。

@EnableAsync的使用示例：

  1. @SpringBootApplication 
  2. @EnableAsync 
  3. public class App { 
  4.  
  5.     public static void main(String[] args) { 
  6.         SpringApplication.run(App.class, args); 
  7.     } 
  8. } 

@Async的使用示例：

  1. @Service 
  2. public class SyncService { 
  3.      
  4.     @Async 
  5.     public void asyncEvent() { 
  6.         // 業(yè)務(wù)處理 
  7.     } 
  8. } 

@Async注解的使用與Callable有類似之處，在默認(rèn)情況下使用的都是SimpleAsyncTaskExecutor線程池，可參考Callable中的方式來(lái)自定義線程池。

下面通過(guò)一個(gè)實(shí)例來(lái)驗(yàn)證一下，啟動(dòng)類上使用@EnableAsync，然后定義Controller類：

  1. @RestController 
  2. public class IndexController { 
  3.      
  4.     @Resource 
  5.     private UserService userService; 
  6.      
  7.     @RequestMapping("/async") 
  8.     public String async(){ 
  9.         System.out.println("--IndexController--1"); 
  10.         userService.sendSms(); 
  11.         System.out.println("--IndexController--4"); 
  12.         return "success"; 
  13.     } 
  14. } 

定義Service及異步方法：

  1. @Service 
  2. public class UserService { 
  3.  
  4.     @Async 
  5.     public void sendSms(){ 
  6.         System.out.println("--sendSms--2"); 
  7.         IntStream.range(0, 5).forEach(d -> { 
  8.             try { 
  9.                 Thread.sleep(1000); 
  10.             } catch (InterruptedException e) { 
  11.                 e.printStackTrace(); 
  12.             } 
  13.         }); 
  14.         System.out.println("--sendSms--3"); 
  15.     } 
  16. } 

如果先注釋掉@EnableAsync和@Async注解，即正常情況下的業(yè)務(wù)請(qǐng)求，打印日志為：

  1. --IndexController--1 
  2. --sendSms--2 
  3. --sendSms--3 
  4. --IndexController--4 

使用@EnableAsync和@Async注解時(shí)，打印日志如下：

  1. --IndexController--1 
  2. --IndexController--4 
  3. --sendSms--2 
  4. --sendSms--3 

通過(guò)日志的對(duì)比我們可以看出，使用了@Async的方法，會(huì)被當(dāng)成一個(gè)子線程。所以，整個(gè)sendSms方法會(huì)在主線程執(zhí)行完了之后執(zhí)行。

這樣的效果是不是跟我們上面使用的其他形式的異步異曲同工?所以在文章最開(kāi)始已經(jīng)說(shuō)到，網(wǎng)絡(luò)上所謂的“異步調(diào)用與異步請(qǐng)求的區(qū)別”是并不存儲(chǔ)在的，本質(zhì)上都是一回事，只不過(guò)實(shí)現(xiàn)形式不同而已。這里所提到異步方法，也就是將方法進(jìn)行異步處理而已。

@Async、WebAsyncTask、Callable、DeferredResult的區(qū)別

所在的包不同：

  • @Async：org.springframework.scheduling.annotation;
  • WebAsyncTask：org.springframework.web.context.request.async;
  • Callable：java.util.concurrent;
  • DeferredResult：org.springframework.web.context.request.async;

通過(guò)所在的包，我們應(yīng)該隱隱約約感到一些區(qū)別，比如@Async是位于scheduling包中，而WebAsyncTask和DeferredResult是用于Web(Spring MVC)的，而Callable是用于concurrent(并發(fā))處理的。

對(duì)于Callable，通常用于Controller方法的異步請(qǐng)求，當(dāng)然也可以用于替換Runable的方式。在方法的返回上與正常的方法有所區(qū)別：

  1. // 普通方法 
  2. public String aMethod(){ 
  3. } 
  4.  
  5. // 對(duì)照Callable方法 
  6. public Callable<String>  aMethod(){ 
  7. } 

而WebAsyncTask是對(duì)Callable的封裝，提供了一些事件回調(diào)的處理，本質(zhì)上區(qū)別不大。

DeferredResult使用方式與Callable類似，重點(diǎn)在于跨線程之間的通信。

@Async也是替換Runable的一種方式，可以代替我們自己創(chuàng)建線程。而且適用的范圍更廣，并不局限于Controller層，而可以是任何層的方法上。

當(dāng)然，大家也可以從返回結(jié)果，異常處理等角度來(lái)分析一下，這里就不再展開(kāi)了。

小結(jié)

經(jīng)過(guò)上述的一步步分析，大家應(yīng)該對(duì)于Servlet3.0及Spring中對(duì)異步處理有所了解。當(dāng)了解了這些基礎(chǔ)理論，實(shí)戰(zhàn)實(shí)例，使用方法及注意事項(xiàng)之后，想必更能夠?qū)W(wǎng)絡(luò)上的相關(guān)知識(shí)能夠進(jìn)一步的去偽存真。

盡信書則不如無(wú)書，帶大家一起學(xué)習(xí)，一起研究，一起去偽存真，追求真正有用的知識(shí)。

參考文章：

https://blog.csdn.net/f641385712/article/details/88692534

https://blog.lqdev.cn/2018/08/16/springboot/chapter-twenty/

https://blog.lqdev.cn/2018/08/17/springboot/chapter-twenty-one/

https://cloud.tencent.com/developer/article/1559230

https://docs.spring.io/spring-framework/docs/3.2.1.RELEASE/spring-framework-reference/html/mvc.html

https://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/scheduling/annotation/Async.html

https://www.cnblogs.com/xuwenjin/p/8858050.html

https://stackoverflow.com/questions/17167020/when-to-use-spring-async-vs-callable-controller-async-controller-servlet-3

https://stackoverflow.com/questions/17855852/difference-between-spring-mvcs-async-deferredresult-and-callable

 

責(zé)任編輯：武曉燕 來(lái)源： 程序新視界
SpringBoot異步網(wǎng)絡(luò)
相關(guān)推薦

2025-01-06 08:33:10

2023-04-24 08:39:01

閱讀源碼方式

2019-05-30 09:32:49

2015-09-06 09:23:23

Android異步更新

2020-10-30 12:40:04

Reac性能優(yōu)化

2020-11-25 08:25:02

二叉樹(shù)樹(shù)節(jié)點(diǎn)

2017-08-09 15:07:08

大數(shù)據(jù)數(shù)據(jù)分析戶畫像

2024-12-19 08:00:00

2019-10-31 09:48:53

MySQL數(shù)據(jù)庫(kù)事務(wù)

2022-04-14 10:10:59

Nginx開(kāi)源Linux

2021-03-09 09:55:02

Vuejs前端代碼

2010-07-28 22:35:25

ADSL掉線

2017-12-05 09:30:27

2017-03-30 22:41:55

虛擬化操作系統(tǒng)軟件

2020-08-10 00:30:55

備份密碼iPhone移動(dòng)安全

2022-10-09 18:16:01

Flowable設(shè)置ReceiveTas

2020-12-18 13:35:41

人工智能機(jī)器學(xué)習(xí)算法

2023-11-30 08:27:38

泛化調(diào)用架構(gòu)

2018-04-13 16:24:59

區(qū)塊鏈數(shù)據(jù)庫(kù)去中心化

2017-03-07 15:35:26

Android適配 界面
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)