WebSocket加入心跳包防止自動斷開連接

近日,在公司中開發(fā)一個使用websocket為前端推送消息的功能時,發(fā)現(xiàn)一個問題:就是每隔一段時間如果不傳送數(shù)據(jù)的話,與前段的連接就會自動斷開挟冠;

剛開始以為是session的原因,因為web session 的默認時間是30分鐘袍睡;但是通過日志發(fā)現(xiàn)斷開時間間隔時間遠遠不到30分鐘知染;認真分析發(fā)現(xiàn)不操作間隔恰好為90秒

它就會在自動斷開;隨恍然大悟斑胜;原來是我們的使用nginx 代理控淡,nginx配置了訪問超時時間為90s嫌吠;

WebSocket是html5中用來實現(xiàn)長連接的一個協(xié)議。
在同時使用nginx反向代理和websocket的時候,因為websocket的通信管道必須都要一直處于開啟狀態(tài)掺炭。

proxy_read_timeout 90辫诅;

解決方案:

1. 修改nginx配置
nginx 通過在客戶端和后端服務(wù)器之間建立起一條隧道來支持WebSocket。
為了使nginx可以將來自客戶端的Upgrade請求發(fā)送給后端服務(wù)器涧狮,Upgrade和Connection的頭信息必須被顯式的設(shè)置炕矮。如下所示:

location /web/count {
        proxy_pass http://tomcat-server;
        proxy_redirect off;
        proxy_http_version 1.1;

        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";

        proxy_set_header Host $host:$server_port;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;    
}

一旦我們完成以上設(shè)置,nginx就可以處理WebSocket連接了者冤。
注意肤视,必須要有

proxy_set_header Host $host:$server_port;   

這個配置
否則,會報:
WebSocket connection to 'ws://192.168.1.104:9080/web/count' failed: Error during WebSocket handshake: Unexpected response code: 403的錯誤

2. 也可以在前端頁面也添加心跳機制保持連接涉枫。

var userId=$("#userId").val();
var lockReconnect = false;  //避免ws重復連接
var ws = null;          // 判斷當前瀏覽器是否支持WebSocket
var wsUrl = serverConfig.cyberhouse_ws+userId;
createWebSocket(wsUrl);   //連接ws

function createWebSocket(url) {
    try{
        if('WebSocket' in window){
            ws = new WebSocket(url);
        }else if('MozWebSocket' in window){  
            ws = new MozWebSocket(url);
        }else{
            layui.use(['layer'],function(){
              var layer = layui.layer;
              layer.alert("您的瀏覽器不支持websocket協(xié)議,建議使用新版谷歌邢滑、火狐等瀏覽器,請勿使用IE10以下瀏覽器愿汰,360瀏覽器請使用極速模式殊鞭,不要使用兼容模式!"); 
            });
        }
        initEventHandle();
    }catch(e){
        reconnect(url);
        console.log(e);
    }     
}

function initEventHandle() {
    ws.onclose = function () {
        reconnect(wsUrl);
        console.log("llws連接關(guān)閉!"+new Date().toUTCString());
    };
    ws.onerror = function () {
        reconnect(wsUrl);
        console.log("llws連接錯誤!");
    };
    ws.onopen = function () {
        heartCheck.reset().start();      //心跳檢測重置
        console.log("llws連接成功!"+new Date().toUTCString());
    };
    ws.onmessage = function (event) {    //如果獲取到消息尼桶,心跳檢測重置
        heartCheck.reset().start();      //拿到任何消息都說明當前連接是正常的
        console.log("llws收到消息啦:" +event.data);
        if(event.data!='pong'){
            var obj=eval("("+event.data+")");
            layui.use(['layim'], function(layim){
                if(obj.type=="onlineStatus"){
                    layim.setFriendStatus(obj.id, obj.content);
                }else if(obj.type=="friend" || obj.type=="group"){
                    layim.getMessage(obj);  
                } 
    };
}
// 監(jiān)聽窗口關(guān)閉事件操灿,當窗口關(guān)閉時,主動去關(guān)閉websocket連接泵督,防止連接還沒斷開就關(guān)閉窗口趾盐,server端會拋異常。
window.onbeforeunload = function() {
    ws.close();
}  

function reconnect(url) {
    if(lockReconnect) return;
    lockReconnect = true;
    setTimeout(function () {     //沒連接上會一直重連小腊,設(shè)置延遲避免請求過多
        createWebSocket(url);
        lockReconnect = false;
    }, 2000);
}

//心跳檢測
var heartCheck = {
    timeout: 540000,        //9分鐘發(fā)一次心跳
    timeoutObj: null,
    serverTimeoutObj: null,
    reset: function(){
        clearTimeout(this.timeoutObj);
        clearTimeout(this.serverTimeoutObj);
        return this;
    },
    start: function(){
        var self = this;
        this.timeoutObj = setTimeout(function(){
            //這里發(fā)送一個心跳救鲤,后端收到后,返回一個心跳消息秩冈,
            //onmessage拿到返回的心跳就說明連接正常
            ws.send("ping");
            console.log("ping!")
            self.serverTimeoutObj = setTimeout(function(){//如果超過一定時間還沒重置本缠,說明后端主動斷開了
                ws.close();     //如果onclose會執(zhí)行reconnect,我們執(zhí)行ws.close()就行了.如果直接執(zhí)行reconnect 會觸發(fā)onclose導致重連兩次
            }, self.timeout)
        }, this.timeout)
    }
}
// 收到客戶端消息后調(diào)用的方法 
    @OnMessage  
    public void onMessage(String message, Session session) {  
        if(message.equals("ping")){
        }else{
        入问。丹锹。。芬失。
        }
   }

系統(tǒng)發(fā)現(xiàn)websocket每隔10分鐘自動斷開連接楣黍,搜了很多博客都說設(shè)置一下nginx的
keepalive_timeout
proxy_connect_timeout
proxy_send_timeout
proxy_read_timeout
這四個字段的時長即可,然而好像并不奏效棱烂。遂采取心跳包的方式每隔9分鐘客戶端自動發(fā)送ping消息給服務(wù)端租漂,服務(wù)端不需要返回。即可解決問題。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末哩治,一起剝皮案震驚了整個濱河市秃踩,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌业筏,老刑警劉巖吞瞪,帶你破解...
    沈念sama閱讀 216,591評論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異驾孔,居然都是意外死亡,警方通過查閱死者的電腦和手機惯疙,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,448評論 3 392
  • 文/潘曉璐 我一進店門翠勉,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人霉颠,你說我怎么就攤上這事对碌。” “怎么了蒿偎?”我有些...
    開封第一講書人閱讀 162,823評論 0 353
  • 文/不壞的土叔 我叫張陵朽们,是天一觀的道長。 經(jīng)常有香客問我诉位,道長骑脱,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,204評論 1 292
  • 正文 為了忘掉前任苍糠,我火速辦了婚禮叁丧,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘岳瞭。我一直安慰自己拥娄,他們只是感情好,可當我...
    茶點故事閱讀 67,228評論 6 388
  • 文/花漫 我一把揭開白布瞳筏。 她就那樣靜靜地躺著稚瘾,像睡著了一般。 火紅的嫁衣襯著肌膚如雪姚炕。 梳的紋絲不亂的頭發(fā)上摊欠,一...
    開封第一講書人閱讀 51,190評論 1 299
  • 那天,我揣著相機與錄音柱宦,去河邊找鬼凄硼。 笑死,一個胖子當著我的面吹牛捷沸,可吹牛的內(nèi)容都是我干的摊沉。 我是一名探鬼主播,決...
    沈念sama閱讀 40,078評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼痒给,長吁一口氣:“原來是場噩夢啊……” “哼说墨!你這毒婦竟也來了骏全?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 38,923評論 0 274
  • 序言:老撾萬榮一對情侶失蹤尼斧,失蹤者是張志新(化名)和其女友劉穎姜贡,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體棺棵,經(jīng)...
    沈念sama閱讀 45,334評論 1 310
  • 正文 獨居荒郊野嶺守林人離奇死亡楼咳,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,550評論 2 333
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了烛恤。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片母怜。...
    茶點故事閱讀 39,727評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖缚柏,靈堂內(nèi)的尸體忽然破棺而出苹熏,到底是詐尸還是另有隱情,我是刑警寧澤币喧,帶...
    沈念sama閱讀 35,428評論 5 343
  • 正文 年R本政府宣布轨域,位于F島的核電站,受9級特大地震影響杀餐,放射性物質(zhì)發(fā)生泄漏干发。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,022評論 3 326
  • 文/蒙蒙 一史翘、第九天 我趴在偏房一處隱蔽的房頂上張望油湖。 院中可真熱鬧耻蛇,春花似錦绣版、人聲如沸蚂四。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,672評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽自点。三九已至,卻和暖如春脉让,著一層夾襖步出監(jiān)牢的瞬間桂敛,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,826評論 1 269
  • 我被黑心中介騙來泰國打工溅潜, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留术唬,地道東北人。 一個月前我還...
    沈念sama閱讀 47,734評論 2 368
  • 正文 我出身青樓滚澜,卻偏偏與公主長得像粗仓,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 44,619評論 2 354

推薦閱讀更多精彩內(nèi)容

  • Spring Web MVC Spring Web MVC 是包含在 Spring 框架中的 Web 框架借浊,建立于...
    Hsinwong閱讀 22,394評論 1 92
  • 當你遇到選擇1時塘淑,你選擇勤奮心態(tài)和懶惰心態(tài)的概率均為50%。如果你選擇了蚂斤,勤奮存捺,那么當你遇到選擇2的時候,你選擇勤...
    魚豆腐_閱讀 276評論 0 0
  • 權(quán)力有外部文化因素的浸染曙蒸,也有內(nèi)部的自發(fā)結(jié)構(gòu)捌治;權(quán)力雖然有強烈的工具性,并且指向控制他人纽窟,但是適度的控制卻是相互依賴...
    Foonew閱讀 295評論 0 0
  • 我能記住的模樣有多少 天上的白云變幻 怎樣都很美好 當真空氣可以藏住陽光 卻被赤裸的假象 鋪得我滿身傷 每一顆貝殼...
    李譯閱讀 648評論 3 5