我們有一個(gè)獨(dú)特的案例,我們需要與外部API接口,這需要我們長(zhǎng)時(shí)間輪詢他們的端點(diǎn)以獲得他們所謂的實(shí)時(shí)事件.

問(wèn)題是我們可能有多達(dá)80,000人/設(shè)備在任何給定時(shí)間點(diǎn)擊此端點(diǎn),監(jiān)聽(tīng)事件,每個(gè)設(shè)備/人1個(gè)連接.

當(dāng)客戶端從我們的Spring服務(wù)發(fā)出請(qǐng)求以對(duì)事件進(jìn)行長(zhǎng)輪詢時(shí),我們的服務(wù)隨后會(huì)對(duì)外部API進(jìn)行異步調(diào)用以對(duì)事件進(jìn)行長(zhǎng)輪詢.外部API已定義最小長(zhǎng)輪詢超時(shí)可設(shè)置為180秒.

所以在這里我們遇到一個(gè)帶隊(duì)列的線程池不能工作的情況,因?yàn)槿绻覀冇幸粋€(gè)類似于(5分鐘,10個(gè)最大值,10個(gè)隊(duì)列)的線程池,那么10個(gè)線程可能會(huì)成為焦點(diǎn),并且隊(duì)列中的10個(gè)將無(wú)法獲得機(jī)會(huì),直到當(dāng)前10個(gè)中的一個(gè)完成.

我們需要服務(wù)它或者失敗它(我們將把負(fù)載平衡器等放在它后面),但是我們不希望在沒(méi)有實(shí)際輪詢的情況下讓客戶端掛起.

我們一直在研究如何使用DeferredResult,并從控制器返回.

一些調(diào)整的東西

@RequestMapping(value = "test/deferredResult",method = RequestMethod.GET)

DeferredResultCompletableFuture.supplyAsync(() -> testService.test()).whenCompleteAsync((result,throwable) -> deferredResult.setResult(result));

return deferredResult;

}

我在質(zhì)疑我是否在正確的道路上,并且我是否應(yīng)該為CompletableFuture.supplyAsync()方法提供執(zhí)行程序和什么樣的執(zhí)行程序(和配置)以最好地完成我們的任務(wù).

我已經(jīng)閱讀了各種文章,帖子等,我想知道是否有人知道可能有助于我們的具體情況.

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的java 长轮询_java – Spring中的长轮询的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。