欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springMvc異步的DeferredResult long?polling應用示例解析

 更新時間:2022年03月05日 13:49:35   作者:kl  
這篇文章主要為大家介紹了springMvc中DeferredResult的long?polling應用示例解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

1.了解servlet以及spring mvc中的異步

Spring MVC 3.2開始引入了基于Servlet 3的異步請求處理。相比以前,控制器方法已經(jīng)不一定需要返回一個值,而是可以返回一個java.util.concurrent.Callable的對象,并通過Spring MVC所管理的線程來產(chǎn)生返回值。與此同時,Servlet容器的主線程則可以退出并釋放其資源了,同時也允許容器去處理其他的請求。通過一個TaskExecutor,Spring MVC可以在另外的線程中調用Callable。當Callable返回時,請求再攜帶Callable返回的值,再次被分配到Servlet容器中恢復處理流程。以下代碼給出了一個這樣的控制器方法作為例子:

@RequestMapping(method=RequestMethod.POST)
public CallableprocessUpload(final MultipartFile file) {
    return new Callable() {
        public String call() throws Exception {
            // ...
            return "someView";
        }
    };
}

另一個選擇,是讓控制器方法返回一個DeferredResult的實例。這種場景下,返回值可以由任何一個線程產(chǎn)生,也包括那些不是由Spring MVC管理的線程。舉個例子,返回值可能是為了響應某些外部事件所產(chǎn)生的,比如一條JMS的消息,一個計劃任務,等等。以下代碼給出了一個這樣的控制器作為例子:

@RequestMapping("/quotes")
@ResponseBody
public DeferredResultquotes() {
    DeferredResultdeferredResult = new DeferredResult();
    // Save the deferredResult somewhere..
    return deferredResult;
}
    // In some other thread...
    deferredResult.setResult(data);

如果對Servlet 3.0的異步請求處理特性沒有了解,理解這個特性可能會有點困難。因此,閱讀一下前者的文檔將會很有幫助。

以下給出了這個機制運作背后的一些原理:

一個servlet請求ServletRequest可以通過調用request.startAsync()方法而進入異步模式。這樣做的主要結果就是該servlet以及所有的過濾器都可以結束,但其響應(response)會留待異步處理結束后再返回調用request.startAsync()方法會返回一個AsyncContext對象,可用它對異步處理進行進一步的控制和操作。比如說它也提供了一個與轉向(forward)很相似的dispatch方法,只不過它允許應用恢復Servlet容器的請求處理進程ServletRequest提供了獲取當前DispatherType的方式,后者可以用來區(qū)別當前處理的是原始請求、異步分發(fā)請求、轉向,或是其他類型的請求分發(fā)類型。

有了上面的知識,下面可以來看一下Callable的異步請求被處理時所依次發(fā)生的事件:

  • 控制器先返回一個Callable對象
  • Spring MVC開始進行異步處理,并把該Callable對象提交給另一個獨立線程的執(zhí)行器TaskExecutor處理
  • DispatcherServlet和所有過濾器都退出Servlet容器線程,但此時方法的響應對象仍未返回
  • Callable對象最終產(chǎn)生一個返回結果,此時Spring MVC會重新把請求分派回Servlet容器,恢復處理
  • DispatcherServlet再次被調用,恢復對Callable異步處理所返回結果的處理
  • 對DeferredResult異步請求的處理順序也非常類似,區(qū)別僅在于應用可以通過任何線程來計算返回一個結果:
  • 控制器先返回一個DeferredResult對象,并把它存取在內存(隊列或列表等)中以便存取
  • Spring MVC開始進行異步處理
  • DispatcherServlet和所有過濾器都退出Servlet容器線程,但此時方法的響應對象仍未返回
  • 由處理該請求的線程對 DeferredResult進行設值,然后Spring MVC會重新把請求分派回Servlet容器,恢復處理
  • DispatcherServlet再次被調用,恢復對該異步返回結果的處理

2.簡述polling和long polling的區(qū)別

這里暫拋開某些場景webSocket的解決方案。

舉一個生活中的列子來說明長輪詢比輪詢好在哪里:電商云集的時代,大家肯定都有查詢快遞的經(jīng)歷,怎么最快知道快遞的進度呢?polling和long polling的方式分別如下:

  • polling:如果我想在兩分鐘內看到快遞的變化,那么,輪詢會每隔兩分鐘去像服務器發(fā)起一次快遞變更的查詢請求,如果快遞其實是一個小時變更一次,那么polling的方式在獲取一次真實有效信息時需要發(fā)起30次
  • long polling:首先發(fā)起查詢請求,服務端沒有更新的話就不回復,直到一個小時變更時才將結果返回給客戶,然后客戶發(fā)起下次查詢請求。長輪詢保證了每次發(fā)起的查詢請求都是有效的,極大的減少了與服務端的交互,基于web異步處理技術,大大的提升了服務性能

如果在發(fā)散的觸類旁通一下,long polling的方式和發(fā)布訂閱的模式有點類似之處,只是每次拿到了發(fā)布的結果之后需要再次發(fā)起消息訂閱

3.因為DeferredResult,所以long polling

因為DeferredResult技術,所以使得long polling不會一直占用容器資源,使得長輪詢成為可能。長輪詢的應用有很多,簡述下就是:需要及時知道某些消息的變更的場景都可以用長輪詢來解決,當然,你可能又想起了發(fā)布訂閱了,哈哈

  • 比如:在線聊天?一個服務端,多個客戶端,服務端管理所有的人的消息,客戶端向服務端發(fā)起給自己的消息的請求,服務端處理后給返回,然后客戶端再次發(fā)起?
  • 在比如類發(fā)布訂閱的例子:配置中心服務,當配置中心的配置變更好,相關的客戶端程序需要及時更新最新的配置。disconf就是基于zookeeper的發(fā)布訂閱來做的,apollo就是采用的DeferredResult的long polling來做的,客戶端發(fā)起長輪詢,配置中心監(jiān)聽器監(jiān)聽到配置變更后,將結果響應給客戶端。

apollo的具體做法可見

  • 服務端:com/ctrip/framework/apollo/configservice/controller/NotificationControllerV2.java 
  • 客戶端:com/ctrip/framework/apollo/internals/RemoteConfigLongPollService.java

4.簡單的測試用例

多個請求的結果,使用另一個請求控制他的響應返回。本實例構建在spring boot 1.5.7上。

1.定義異步接口

/**
 * Created by kl on 2017/9/27.
 * Content :
 */
@RestController
@RequestMapping("/async")
public class AsyncController {
    final Map deferredResultMap=new ConcurrentReferenceHashMap<>();
    @GetMapping("/longPolling")
    public DeferredResultlongPolling(){
        DeferredResultdeferredResult=new DeferredResult(0L);
        deferredResultMap.put(deferredResult.hashCode(),deferredResult);
        deferredResult.onCompletion(()->{
            deferredResultMap.remove(deferredResult.hashCode());
            System.err.println("還剩"+deferredResultMap.size()+"個deferredResult未響應");
        });
        return deferredResult;
    }
    @GetMapping("/returnLongPollingValue")
    public void returnLongPollingValue(){
        for (Map.Entry entry:deferredResultMap.entrySet()){
            entry.getValue().setResult("kl");
        }
    }
}

2.定義接口訪問實例,使用fegin

/**
 * Created by kl on 2017/9/27.
 * Content :
 */
@FeignClient(url = "localhost:8976",name = "async")
public interface AsyncFeginService {
    @GetMapping("/async/longPolling")
    String longPolling();
    @GetMapping("/async/returnLongPollingValue")
     void returnLongPollingValue();
}

3.測試用例

@RunWith(SpringRunner.class)
@SpringBootTest
public class LongPollingdemoApplicationTests {
	@Autowired
	AsyncFeginService asyncFeginService;
	/**
	 * 模擬多個瀏覽器客戶端發(fā)起長輪詢請求,等待testLongPolling測試用例請求通知服務端返回各瀏覽器的請求結果
	 * @throws Exception
	 */
	@Test
	public void contextLoads() throws Exception{
		ExecutorService executorService=Executors.newFixedThreadPool(4);
		for (int i=0;i<=3;i++){
			executorService.execute(()->{
				String kl=asyncFeginService.longPolling();
				System.err.println("收到響應:"+kl);
			});
		}
		System.in.read();
	}
	/**
	 * 通知服務端返回上個測試的長輪詢結果
	 */
	@Test
	public void testLongPolling(){
		asyncFeginService.returnLongPollingValue();
	}
}

測試時,先啟動contextLoads會發(fā)起四個異步請求,一直等待請求結果響應,直到testLongPolling通知服務端返回deferredResult的值。

以上就是springMvc中DeferredResult的long polling應用示例解析內容,更多關于springMvc DeferredResult的long polling應用的資料請關注腳本之家其它相關文章!

相關文章

  • 使用IDEA如何把Java程序打包成jar

    使用IDEA如何把Java程序打包成jar

    這篇文章主要介紹了使用IDEA把Java程序打包成jar,本文通過圖文并茂的形式給大家介紹的非常詳細,對大家的學習或工作具有一定參考借鑒價值,需要的朋友可以參考下
    2023-08-08
  • Spring中@Scheduled功能的使用方法詳解

    Spring中@Scheduled功能的使用方法詳解

    @Scheduled 由Spring定義,用于將方法設置為調度任務,下面這篇文章主要給大家介紹了關于Spring中@Scheduled功能的使用方法,文中通過示例代碼介紹的非常詳細,需要的朋友可以參考下
    2022-04-04
  • Java運行時動態(tài)生成對象的方法小結

    Java運行時動態(tài)生成對象的方法小結

    Java是一門靜態(tài)語言,通常,我們需要的class在編譯的時候就已經(jīng)生成了,為什么有時候我們還想在運行時動態(tài)生成class呢?今天通過本文給大家分享Java運行時動態(tài)生成對象的方法小結,需要的朋友參考下吧
    2021-08-08
  • Netty結合Protobuf進行編解碼的方法

    Netty結合Protobuf進行編解碼的方法

    這篇文章主要介紹了Netty結合Protobuf進行編解碼,通過文檔表述和代碼實例充分說明了如何進行使用和操作,需要的朋友可以參考下
    2021-06-06
  • Java微信支付-微信紅包

    Java微信支付-微信紅包

    本篇文章介紹了Java微信支付-微信紅包,可以實現(xiàn)微信公眾號發(fā)紅包功能,具有一定的參考價值,有需要的可以了解一下。
    2016-10-10
  • MyBatis游標Cursor的正確使用和百萬數(shù)據(jù)傳輸?shù)膬却鏈y試

    MyBatis游標Cursor的正確使用和百萬數(shù)據(jù)傳輸?shù)膬却鏈y試

    這篇文章主要介紹了MyBatis游標Cursor的正確使用和百萬數(shù)據(jù)傳輸?shù)膬却鏈y試,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-01-01
  • ServletContext中常用方法介紹

    ServletContext中常用方法介紹

    本篇文章是對ServletContext中的常用方法進行了詳細的分析介紹,需要的朋友參考下
    2013-07-07
  • 詳細分析JVM類加載機制

    詳細分析JVM類加載機制

    JVM將class文件字節(jié)碼文件加載到內存中,?并將這些靜態(tài)數(shù)據(jù)轉換成方法區(qū)中的運行時數(shù)據(jù)結構,在堆(并不一定在堆中,HotSpot在方法區(qū)中)中生成一個代表這個類的java.lang.Class?對象,作為方法區(qū)類數(shù)據(jù)的訪問入口,接下來將詳細講解JVM類加載機制
    2022-04-04
  • spring+maven實現(xiàn)發(fā)送郵件功能

    spring+maven實現(xiàn)發(fā)送郵件功能

    這篇文章主要為大家詳細介紹了spring+maven實現(xiàn)發(fā)送郵件功能,利用spring提供的郵件工具來發(fā)送郵件,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2018-07-07
  • Spring?Validation接口入?yún)⑿r炇纠a

    Spring?Validation接口入?yún)⑿r炇纠a

    Spring?Validation是一種用于實現(xiàn)數(shù)據(jù)校驗的框架,它提供了一系列的校驗器,針對不同的數(shù)據(jù)類型可以使用不同的校驗器進行校驗,下面這篇文章主要給大家介紹了關于Spring?Validation接口入?yún)⑿r灥南嚓P資料,需要的朋友可以參考下
    2023-06-06

最新評論