websocket VS 輪詢htpp請求
首先為什么會出現(xiàn)這兩種情況的比較呢。
最近公司在一個APP項目中出現(xiàn)了一個問題,就是當(dāng)APP后臺管理審批同意后APP沒有得到及時的更新,需要重新登錄才能更新础锐。
這時候我們前后端一起討論解決方案,大家都提出的是websocket
的解決方案,但是websocket
會存在以下問題婿屹。
-
websocket的問題:
- 第一個問題就是麻煩,由于我們的后端架構(gòu)是微服務(wù)的架構(gòu)推溃,并且使用了
redis
緩存昂利,如果使用websocket
那么我們將為這一個小功能耗費大量的時間。
麻煩在哪铁坎? 首先由于是微服務(wù)架構(gòu)多臺機(jī)器蜂奸,所以需要將建立連接的
socket
存入緩存,不然不知道是哪臺機(jī)器建立了連接硬萍。其次就是需要寫心跳扩所,保持連接,避免斷開等的情況朴乖。
+ 第二個問題就是兼容性祖屏,由于我們這個項目可能需要做web端,那么肯定存在兼容性問題寒砖,當(dāng)然很多情況都可以不去考慮兼容性問題赐劣。可以使用scokjs.js
- 第一個問題就是麻煩,由于我們的后端架構(gòu)是微服務(wù)的架構(gòu)推溃,并且使用了
-
websocket的優(yōu)點:
- 性能消耗小哩都,通信非常高效魁兼,由于是tcp連接基本是不斷的,來回發(fā)送消息效率開銷會小很多不用每次都建立連接。
- 相對于web端來講沒有同源限制咐汞。
-
輪詢http請求
- 這里有兩種方式
- 第一種是輪詢每隔一段時間向服務(wù)器發(fā)送請求
- 第二種是長輪詢盖呼,建立連接后一直持續(xù)在等待響應(yīng)的過程中,直到超時或者接收到響應(yīng)后再重新建立連接化撕,這個是阻塞的几晤。
- 他們的缺點:
- 性能開銷大,每次都要重新發(fā)起新的請求
- 第一種輪詢需要后臺有一定的處理強(qiáng)度植阴,用戶多起來的時候蟹瘾,請求會非常的多。
- 第二種長輪詢需要后臺有一定的并發(fā)處理能力掠手,同樣用戶一多憾朴,阻塞的請求將會非常之多。
- 他們有沒有優(yōu)點呢喷鸽?(看場景)
- 第一兼容性好众雷。
-
第二好實現(xiàn),不麻煩做祝。我知道砾省,當(dāng)我寫出這句話肯定很多人會反對,你個程序員這點事情還怕麻煩.....可是你想想我們這個功能真的是一個非常小的功能混槐。有句話說的好"殺雞焉用牛刀"编兄,就是這個道理。
- 這里有兩種方式
所以我們的項目中用了阻塞式http声登,也就是長輪詢翻诉。
最后放上java
的實現(xiàn)代碼(同事的),看了一下感覺不錯捌刮。
public static final Map<String, Thread> threadMap = new ConcurrentHashMap<>();
public static final Map<String, Boolean> haveUpdateMap = new ConcurrentHashMap<>();
public void haveUpdate(HttpServletRequest request, HttpServletResponse response, String cellphone, String mac) {
if(threadMap.get(cellphone) == null){
// 第一次調(diào)用
threadMap.put(cellphone, Thread.currentThread());
LockSupport.park();
}else{
Thread thread = threadMap.get(cellphone);
LockSupport.unpark(thread);
threadMap.put(cellphone, Thread.currentThread());
LockSupport.park();
}
Boolean haveUpdate = haveUpdateMap.get(cellphone);
if(haveUpdate != null){
// 已更新
haveUpdateMap.remove(cellphone);
PrintWriter writer = null;
response.setCharacterEncoding("UTF-8");
response.setContentType("text/html; charset=utf-8");
try {
Result success = Result.success("success");
writer = response.getWriter();
String s = JSON.toJSONString(success);
writer.print(s);
} catch (IOException e) {
e.printStackTrace();
} finally {
if (writer != null){
writer.close();
}
}
}else{
System.out.println("=========offer=================");
return;
}
}