日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢(xún)
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
SpringBoot異步請(qǐng)求和異步調(diào)用，一文搞定！

一、Spring Boot中異步請(qǐng)求的使用

成都創(chuàng)新互聯(lián)公司專(zhuān)業(yè)為企業(yè)提供福安網(wǎng)站建設(shè)、福安做網(wǎng)站、福安網(wǎng)站設(shè)計(jì)、福安網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)與制作、福安企業(yè)網(wǎng)站模板建站服務(wù)，十余年福安做網(wǎng)站經(jīng)驗(yàn)，不只是建網(wǎng)站，更提供有價(jià)值的思路和整體網(wǎng)絡(luò)服務(wù)。

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

特點(diǎn)：

可以先釋放容器分配給請(qǐng)求的線程與相關(guān)資源，減輕系統(tǒng)負(fù)擔(dān)，釋放了容器所分配線程的請(qǐng)求，其響應(yīng)將被延后，可以在耗時(shí)處理完成（例如長(zhǎng)時(shí)間的運(yùn)算）時(shí)再對(duì)客戶(hù)端進(jìn)行響應(yīng)。

一句話：增加了服務(wù)器對(duì)客戶(hù)端請(qǐng)求的吞吐量（實(shí)際生產(chǎn)上我們用的比較少，如果并發(fā)請(qǐng)求量很大的情況下，我們會(huì)通過(guò)nginx把請(qǐng)求負(fù)載到集群服務(wù)的各個(gè)節(jié)點(diǎn)上來(lái)分?jǐn)傉?qǐng)求壓力，當(dāng)然還可以通過(guò)消息隊(duì)列來(lái)做請(qǐng)求的緩沖）。

2、異步請(qǐng)求的實(shí)現(xiàn)

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

 
 
 
 
    
  
  
  
  
  1. @RequestMapping(value = "/email/servletReq", method = GET) 
    2. 
  
  
  
  
  2.   public void servletReq (HttpServletRequest request, HttpServletResponse response) { 
    3. 
  
  
  
  
  3.       AsyncContext asyncContext = request.startAsync(); 
    4. 
  
  
  
  
  4.       //設(shè)置監(jiān)聽(tīng)器:可設(shè)置其開(kāi)始、完成、異常、超時(shí)等事件的回調(diào)處理 
    5. 
  
  
  
  
  5.       asyncContext.addListener(new AsyncListener() { 
    6. 
  
  
  
  
  6.           @Override 
    7. 
  
  
  
  
  7.           public void onTimeout(AsyncEvent event) throws IOException { 
    8. 
  
  
  
  
  8.               System.out.println("超時(shí)了..."); 
    9. 
  
  
  
  
  9.               //做一些超時(shí)后的相關(guān)操作... 
    10. 
  
  
  
  
  10.           } 
    11. 
  
  
  
  
  11.           @Override 
    12. 
  
  
  
  
  12.           public void onStartAsync(AsyncEvent event) throws IOException { 
    13. 
  
  
  
  
  13.               System.out.println("線程開(kāi)始"); 
    14. 
  
  
  
  
  14.           } 
    15. 
  
  
  
  
  15.           @Override 
    16. 
  
  
  
  
  16.           public void onError(AsyncEvent event) throws IOException { 
    17. 
  
  
  
  
  17.               System.out.println("發(fā)生錯(cuò)誤："+event.getThrowable()); 
    18. 
  
  
  
  
  18.           } 
    19. 
  
  
  
  
  19.           @Override
    20. 
  
  
  
  
  20.            public void onComplete(AsyncEvent event) throws IOException { 
    21. 
  
  
  
  
  21.               System.out.println("執(zhí)行完成"); 
    22. 
  
  
  
  
  22.               //這里可以做一些清理資源的操作... 
    23. 
  
  
  
  
  23.           } 
    24. 
  
  
  
  
  24.       }); 
    25. 
  
  
  
  
  25.       //設(shè)置超時(shí)時(shí)間 
    26. 
  
  
  
  
  26.       asyncContext.setTimeout(20000); 
    27. 
  
  
  
  
  27.       asyncContext.start(new Runnable() { 
    28. 
  
  
  
  
  28.           @Override 
    29. 
  
  
  
  
  29.           public void run() { 
    30. 
  
  
  
  
  30.               try { 
    31. 
  
  
  
  
  31.                   Thread.sleep(10000); 
    32. 
  
  
  
  
  32.                   System.out.println("內(nèi)部線程：" + Thread.currentThread().getName()); 
    33. 
  
  
  
  
  33.                   asyncContext.getResponse().setCharacterEncoding("utf-8"); 
    34. 
  
  
  
  
  34.                   asyncContext.getResponse().setContentType("text/html;charset=UTF-8"); 
    35. 
  
  
  
  
  35.                   asyncContext.getResponse().getWriter().println("這是異步的請(qǐng)求返回"); 
    36. 
  
  
  
  
  36.               } catch (Exception e) { 
    37. 
  
  
  
  
  37.                   System.out.println("異常："+e); 
    38. 
  
  
  
  
  38.               } 
    39. 
  
  
  
  
  39.               //異步請(qǐng)求完成通知 
    40. 
  
  
  
  
  40.               //此時(shí)整個(gè)請(qǐng)求才完成 
    41. 
  
  
  
  
  41.               asyncContext.complete(); 
    42. 
  
  
  
  
  42.           } 
    43. 
  
  
  
  
  43.       });
    44. 
  
  
  
  
  44.        //此時(shí)之類(lèi) request的線程連接已經(jīng)釋放了 
    45. 
  
  
  
  
  45.       System.out.println("主線程：" + Thread.currentThread().getName()); 
    46. 
  
  
  
  
  46.   }
    47.

方式二：使用很簡(jiǎn)單，直接返回的參數(shù)包裹一層callable即可，可以繼承WebMvcConfigurerAdapter類(lèi)來(lái)設(shè)置默認(rèn)線程池和超時(shí)處理

 
 
 
 
    
  
  
  
  
  1. @RequestMapping(value = "/email/callableReq", method = GET) 
    2. 
  
  
  
  
  2.   @ResponseBody 
    3. 
  
  
  
  
  3.   public Callable callableReq () { 
    4. 
  
  
  
  
  4.       System.out.println("外部線程：" + Thread.currentThread().getName()); 
    5. 
  
  
  
  
  5.       return new Callable() { 
    6. 
  
  
  
  
  6.           @Override 
    7. 
  
  
  
  
  7.           public String call() throws Exception { 
    8. 
  
  
  
  
  8.               Thread.sleep(10000); 
    9. 
  
  
  
  
  9.               System.out.println("內(nèi)部線程：" + Thread.currentThread().getName()); 
    10. 
  
  
  
  
  10.               return "callable!"; 
    11. 
  
  
  
  
  11.           } 
    12. 
  
  
  
  
  12.       }; 
    13. 
  
  
  
  
  13.   } 
    14. 
  
  
  
  
  14.   @Configuration 
    15. 
  
  
  
  
  15.   public class RequestAsyncPoolConfig extends WebMvcConfigurerAdapter { 
    16. 
  
  
  
  
  16.   @Resource 
    17. 
  
  
  
  
  17.   private ThreadPoolTaskExecutor myThreadPoolTaskExecutor; 
    18. 
  
  
  
  
  18.   @Override 
    19. 
  
  
  
  
  19.   public void configureAsyncSupport(final AsyncSupportConfigurer configurer) { 
    20. 
  
  
  
  
  20.       //處理 callable超時(shí) 
    21. 
  
  
  
  
  21.       configurer.setDefaultTimeout(60*1000); 
    22. 
  
  
  
  
  22.       configurer.setTaskExecutor(myThreadPoolTaskExecutor); 
    23. 
  
  
  
  
  23.       configurer.registerCallableInterceptors(timeoutCallableProcessingInterceptor());
    24. 
  
  
  
  
  24.   } 
    25. 
  
  
  
  
  25.   @Bean 
    26. 
  
  
  
  
  26.   public TimeoutCallableProcessingInterceptor timeoutCallableProcessingInterceptor() { 
    27. 
  
  
  
  
  27.       return new TimeoutCallableProcessingInterceptor(); 
    28. 
  
  
  
  
  28.   } 
    29. 
  
  
  
  
  29. }
    30.

方式三：和方式二差不多，在Callable外包一層，給WebAsyncTask設(shè)置一個(gè)超時(shí)回調(diào)，即可實(shí)現(xiàn)超時(shí)處理

 
 
 
 
    
  
  
  
  
  1. @RequestMapping(value = "/email/webAsyncReq", method = GET) 
    2. 
  
  
  
  
  2.     @ResponseBody 
    3. 
  
  
  
  
  3.     public WebAsyncTask webAsyncReq () { 
    4. 
  
  
  
  
  4.         System.out.println("外部線程：" + Thread.currentThread().getName()); 
    5. 
  
  
  
  
  5.         Callable result = () -> { 
    6. 
  
  
  
  
  6.             System.out.println("內(nèi)部線程開(kāi)始：" + Thread.currentThread().getName()); 
    7. 
  
  
  
  
  7.             try { 
    8. 
  
  
  
  
  8.                 TimeUnit.SECONDS.sleep(4); 
    9. 
  
  
  
  
  9.             } catch (Exception e) { 
    10. 
  
  
  
  
  10.                 // TODO: handle exception 
    11. 
  
  
  
  
  11.             } 
    12. 
  
  
  
  
  12.             logger.info("副線程返回"); 
    13. 
  
  
  
  
  13.             System.out.println("內(nèi)部線程返回：" + Thread.currentThread().getName()); 
    14. 
  
  
  
  
  14.             return "success"; 
    15. 
  
  
  
  
  15.         }; 
    16. 
  
  
  
  
  16.         WebAsyncTask wat = new WebAsyncTask(3000L, result); 
    17. 
  
  
  
  
  17.         wat.onTimeout(new Callable() { 
    18. 
  
  
  
  
  18.             @Override 
    19. 
  
  
  
  
  19.             public String call() throws Exception { 
    20. 
  
  
  
  
  20.                 // TODO Auto-generated method stub 
    21. 
  
  
  
  
  21.                 return "超時(shí)"; 
    22. 
  
  
  
  
  22.             } 
    23. 
  
  
  
  
  23.         }); 
    24. 
  
  
  
  
  24.         return wat; 
    25. 
  
  
  
  
  25.     }
    26.

方式四：DeferredResult可以處理一些相對(duì)復(fù)雜一些的業(yè)務(wù)邏輯，最主要還是可以在另一個(gè)線程里面進(jìn)行業(yè)務(wù)處理及返回，即可在兩個(gè)完全不相干的線程間的通信。

 
 
 
 
    
  
  
  
  
  1. @RequestMapping(value = "/email/deferredResultReq", method = GET) 
    2. 
  
  
  
  
  2.     @ResponseBody 
    3. 
  
  
  
  
  3.     public DeferredResult deferredResultReq () { 
    4. 
  
  
  
  
  4.         System.out.println("外部線程：" + Thread.currentThread().getName()); 
    5. 
  
  
  
  
  5.         //設(shè)置超時(shí)時(shí)間 
    6. 
  
  
  
  
  6.         DeferredResult result = new DeferredResult(60*1000L); 
    7. 
  
  
  
  
  7.         //處理超時(shí)事件 采用委托機(jī)制 
    8. 
  
  
  
  
  8.         result.onTimeout(new Runnable() { 
    9. 
  
  
  
  
  9.             @Override 
    10. 
  
  
  
  
  10.             public void run() { 
    11. 
  
  
  
  
  11.                 System.out.println("DeferredResult超時(shí)"); 
    12. 
  
  
  
  
  12.                 result.setResult("超時(shí)了!"); 
    13. 
  
  
  
  
  13.             } 
    14. 
  
  
  
  
  14.         }); 
    15. 
  
  
  
  
  15.         result.onCompletion(new Runnable() { 
    16. 
  
  
  
  
  16.             @Override 
    17. 
  
  
  
  
  17.             public void run() { 
    18. 
  
  
  
  
  18.                 //完成后 
    19. 
  
  
  
  
  19.                 System.out.println("調(diào)用完成"); 
    20. 
  
  
  
  
  20.             } 
    21. 
  
  
  
  
  21.         }); 
    22. 
  
  
  
  
  22.         myThreadPoolTaskExecutor.execute(new Runnable() { 
    23. 
  
  
  
  
  23.             @Override 
    24. 
  
  
  
  
  24.             public void run() { 
    25. 
  
  
  
  
  25.                 //處理業(yè)務(wù)邏輯 
    26. 
  
  
  
  
  26.                 System.out.println("內(nèi)部線程：" + Thread.currentThread().getName()); 
    27. 
  
  
  
  
  27.                 //返回結(jié)果 
    28. 
  
  
  
  
  28.                 result.setResult("DeferredResult!!"); 
    29. 
  
  
  
  
  29.             } 
    30. 
  
  
  
  
  30.         }); 
    31. 
  
  
  
  
  31.        return result; 
    32. 
  
  
  
  
  32.     }
    33.

二、Spring Boot中異步調(diào)用的使用

1、介紹

異步請(qǐng)求的處理。除了異步請(qǐng)求，一般上我們用的比較多的應(yīng)該是異步調(diào)用。通常在開(kāi)發(fā)過(guò)程中，會(huì)遇到一個(gè)方法是和實(shí)際業(yè)務(wù)無(wú)關(guān)的，沒(méi)有緊密性的。比如記錄日志信息等業(yè)務(wù)。這個(gè)時(shí)候正常就是啟一個(gè)新線程去做一些業(yè)務(wù)處理，讓主線程異步的執(zhí)行其他業(yè)務(wù)。

2、使用方式（基于spring下）

需要在啟動(dòng)類(lèi)加入@EnableAsync使異步調(diào)用@Async注解生效

在需要異步執(zhí)行的方法上加入此注解即可@Async("threadPool"),threadPool為自定義線程池。

代碼略。。。就倆標(biāo)簽，自己試一把就可以了

3、注意事項(xiàng)

在默認(rèn)情況下，未設(shè)置TaskExecutor時(shí)，默認(rèn)是使用SimpleAsyncTaskExecutor這個(gè)線程池，但此線程不是真正意義上的線程池，因?yàn)榫€程不重用，每次調(diào)用都會(huì)創(chuàng)建一個(gè)新的線程?？赏ㄟ^(guò)控制臺(tái)日志輸出可以看出，每次輸出線程名都是遞增的。所以最好我們來(lái)自定義一個(gè)線程池。

調(diào)用的異步方法，不能為同一個(gè)類(lèi)的方法（包括同一個(gè)類(lèi)的內(nèi)部類(lèi)），簡(jiǎn)單來(lái)說(shuō)，因?yàn)镾pring在啟動(dòng)掃描時(shí)會(huì)為其創(chuàng)建一個(gè)代理類(lèi)，而同類(lèi)調(diào)用時(shí)，還是調(diào)用本身的代理類(lèi)的，所以和平常調(diào)用是一樣的。

其他的注解如@Cache等也是一樣的道理，說(shuō)白了，就是Spring的代理機(jī)制造成的。所以在開(kāi)發(fā)中，最好把異步服務(wù)單獨(dú)抽出一個(gè)類(lèi)來(lái)管理。下面會(huì)重點(diǎn)講述。。

4、什么情況下會(huì)導(dǎo)致@Async異步方法會(huì)失效？

調(diào)用同一個(gè)類(lèi)下注有@Async異步方法：

在spring中像@Async和@Transactional、cache等注解本質(zhì)使用的是動(dòng)態(tài)代理，其實(shí)Spring容器在初始化的時(shí)候Spring容器會(huì)將含有AOP注解的類(lèi)對(duì)象“替換”為代理對(duì)象（簡(jiǎn)單這么理解），那么注解失效的原因就很明顯了，就是因?yàn)檎{(diào)用方法的是對(duì)象本身而不是代理對(duì)象，因?yàn)闆](méi)有經(jīng)過(guò)Spring容器，那么解決方法也會(huì)沿著這個(gè)思路來(lái)解決。

調(diào)用的是靜態(tài)(static )方法

調(diào)用(private)私有化方法

5、解決4中問(wèn)題1的方式（其它2,3兩個(gè)問(wèn)題自己注意下就可以了）

將要異步執(zhí)行的方法單獨(dú)抽取成一個(gè)類(lèi)，原理就是當(dāng)你把執(zhí)行異步的方法單獨(dú)抽取成一個(gè)類(lèi)的時(shí)候，這個(gè)類(lèi)肯定是被Spring管理的，其他Spring組件需要調(diào)用的時(shí)候肯定會(huì)注入進(jìn)去，這時(shí)候?qū)嶋H上注入進(jìn)去的就是代理類(lèi)了。

其實(shí)我們的注入對(duì)象都是從Spring容器中給當(dāng)前Spring組件進(jìn)行成員變量的賦值，由于某些類(lèi)使用了AOP注解，那么實(shí)際上在Spring容器中實(shí)際存在的是它的代理對(duì)象。那么我們就可以通過(guò)上下文獲取自己的代理對(duì)象調(diào)用異步方法。

 
 
 
 
    
  
  
  
  
  1. @Controller 
    2. 
  
  
  
  
  2. @RequestMapping("/app") 
    3. 
  
  
  
  
  3. public class EmailController { 
    4. 
  
  
  
  
  4.     //獲取ApplicationContext對(duì)象方式有多種,這種最簡(jiǎn)單,其它的大家自行了解一下 
    5. 
  
  
  
  
  5.     @Autowired 
    6. 
  
  
  
  
  6.     private ApplicationContext applicationContext; 
    7. 
  
  
  
  
  7.     @RequestMapping(value = "/email/asyncCall", method = GET) 
    8. 
  
  
  
  
  8.     @ResponseBody 
    9. 
  
  
  
  
  9.     public Map asyncCall () { 
    10. 
  
  
  
  
  10.         Map resMap = new HashMap(); 
    11. 
  
  
  
  
  11.         try{ 
    12. 
  
  
  
  
  12.             //這樣調(diào)用同類(lèi)下的異步方法是不起作用的 
    13. 
  
  
  
  
  13.             //this.testAsyncTask(); 
    14. 
  
  
  
  
  14.             //通過(guò)上下文獲取自己的代理對(duì)象調(diào)用異步方法 
    15. 
  
  
  
  
  15.             EmailController emailController = (EmailController)applicationContext.getBean(EmailController.class); 
    16. 
  
  
  
  
  16.             emailController.testAsyncTask(); 
    17. 
  
  
  
  
  17.             resMap.put("code",200); 
    18. 
  
  
  
  
  18.         }catch (Exception e) { 
    19. 
  
  
  
  
  19.             resMap.put("code",400); 
    20. 
  
  
  
  
  20.             logger.error("error!",e); 
    21. 
  
  
  
  
  21.         } 
    22. 
  
  
  
  
  22.         return resMap; 
    23. 
  
  
  
  
  23.     }  
    24. 
  
  
  
  
  24.     //注意一定是public,且是非static方法 
    25. 
  
  
  
  
  25.     @Async 
    26. 
  
  
  
  
  26.     public void testAsyncTask() throws InterruptedException { 
    27. 
  
  
  
  
  27.         Thread.sleep(10000); 
    28. 
  
  
  
  
  28.         System.out.println("異步任務(wù)執(zhí)行完成！"); 
    29. 
  
  
  
  
  29.     } 
    30. 
  
  
  
  
  30. }
    31.

開(kāi)啟cglib代理，手動(dòng)獲取Spring代理類(lèi),從而調(diào)用同類(lèi)下的異步方法。首先，在啟動(dòng)類(lèi)上加上@EnableAspectJAutoProxy(exposeProxy = true)注解。代碼實(shí)現(xiàn)，如下：

 
 
 
 
    
  
  
  
  
  1. @Service 
    2. 
  
  
  
  
  2. @Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class) 
    3. 
  
  
  
  
  3. public class EmailService { 
    4. 
  
  
  
  
  4.     @Autowired 
    5. 
  
  
  
  
  5.     private ApplicationContext applicationContext; 
    6. 
  
  
  
  
  6.     @Async 
    7. 
  
  
  
  
  7.     public void testSyncTask() throws InterruptedException { 
    8. 
  
  
  
  
  8.         Thread.sleep(10000); 
    9. 
  
  
  
  
  9.         System.out.println("異步任務(wù)執(zhí)行完成！"); 
    10. 
  
  
  
  
  10.     } 
    11. 
  
  
  
  
  11.     public void asyncCallTwo() throws InterruptedException { 
    12. 
  
  
  
  
  12.         //this.testSyncTask(); 
    13. 
  
  
  
  
  13. //        EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class); 
    14. 
  
  
  
  
  14. //        emailService.testSyncTask(); 
    15. 
  
  
  
  
  15.         boolean isAop = AopUtils.isAopProxy(EmailController.class);//是否是代理對(duì)象； 
    16. 
  
  
  
  
  16.         boolean isCglib = AopUtils.isCglibProxy(EmailController.class);  //是否是CGLIB方式的代理對(duì)象； 
    17. 
  
  
  
  
  17.         boolean isJdk = AopUtils.isJdkDynamicProxy(EmailController.class);  //是否是JDK動(dòng)態(tài)代理方式的代理對(duì)象； 
    18. 
  
  
  
  
  18.         //以下才是重點(diǎn)!!! 
    19. 
  
  
  
  
  19.         EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class); 
    20. 
  
  
  
  
  20.         EmailService proxy = (EmailService) AopContext.currentProxy(); 
    21. 
  
  
  
  
  21.         System.out.println(emailService == proxy ? true : false); 
    22. 
  
  
  
  
  22.         proxy.testSyncTask(); 
    23. 
  
  
  
  
  23.         System.out.println("end!!!"); 
    24. 
  
  
  
  
  24.     } 
    25. 
  
  
  
  
  25. }
    26.

三、異步請(qǐng)求與異步調(diào)用的區(qū)別

兩者的使用場(chǎng)景不同，異步請(qǐng)求用來(lái)解決并發(fā)請(qǐng)求對(duì)服務(wù)器造成的壓力，從而提高對(duì)請(qǐng)求的吞吐量；而異步調(diào)用是用來(lái)做一些非主線流程且不需要實(shí)時(shí)計(jì)算和響應(yīng)的任務(wù)，比如同步日志到kafka中做日志分析等。

異步請(qǐng)求是會(huì)一直等待response相應(yīng)的，需要返回結(jié)果給客戶(hù)端的；而異步調(diào)用我們往往會(huì)馬上返回給客戶(hù)端響應(yīng)，完成這次整個(gè)的請(qǐng)求，至于異步調(diào)用的任務(wù)后臺(tái)自己慢慢跑就行，客戶(hù)端不會(huì)關(guān)心。

四、總結(jié)

異步請(qǐng)求和異步調(diào)用的使用到這里基本就差不多了，有問(wèn)題還希望大家多多指出。這邊文章提到了動(dòng)態(tài)代理，而spring中Aop的實(shí)現(xiàn)原理就是動(dòng)態(tài)代理，后續(xù)會(huì)對(duì)動(dòng)態(tài)代理做詳細(xì)解讀，還望多多支持哈~


本文名稱(chēng)：SpringBoot異步請(qǐng)求和異步調(diào)用，一文搞定！
分享鏈接：http://m.5511xx.com/article/codedds.html