使用keeplive处理socket网络异常断开
網(wǎng)絡(luò)異常斷開原因主要有那些呢?歸納起來主要有以下兩種:
1、客戶端程序異常。
對(duì)于這種情況,我們很好處理,因?yàn)榭蛻舳顺绦虍惓M顺鰰?huì)在服務(wù)端引發(fā)ConnectionReset的Socket異常(就是WinSock2中的10054異常)。只要在服務(wù)端處理這個(gè)異常就可以了。
2、網(wǎng)絡(luò)鏈路異常。
如:網(wǎng)線拔出、交換機(jī)掉電、客戶端機(jī)器掉電。當(dāng)出現(xiàn)這些情況的時(shí)候服務(wù)端不會(huì)出現(xiàn)任何異常。這樣的話上面的代碼就不能處理這種情況了。對(duì)于這種情況在MSDN里面是這樣處理的,我在這里貼出MSDN的原文:
如果您需要確定連接的當(dāng)前狀態(tài),請(qǐng)進(jìn)行非阻止、零字節(jié)的 Send 調(diào)用。如果該調(diào)用成功返回或引發(fā) WAEWOULDBLOCK 錯(cuò)誤代碼 (10035),則該套接字仍然處于連接狀態(tài);否則,該套接字不再處于連接狀態(tài)。
但是我在實(shí)際應(yīng)用中發(fā)現(xiàn),MSDN說的這種處理方法在很多時(shí)候根本無效,無法檢測(cè)出網(wǎng)絡(luò)已經(jīng)異常斷開了。那我們?cè)撛趺崔k呢?
我們知道,TCP有一個(gè)連接檢測(cè)機(jī)制,就是如果在指定的時(shí)間內(nèi)(一般為2個(gè)小時(shí))沒有數(shù)據(jù)傳送,會(huì)給對(duì)端發(fā)送一個(gè)Keep-Alive數(shù)據(jù)報(bào),使用的序列號(hào)是曾經(jīng)發(fā)出的最后一個(gè)報(bào)文的最后一個(gè)字節(jié)的序列號(hào),對(duì)端如果收到這個(gè)數(shù)據(jù),回送一個(gè)TCP的ACK,確認(rèn)這個(gè)字節(jié)已經(jīng)收到,這樣就知道此連接沒有被斷開。如果一段時(shí)間沒有收到對(duì)方的響應(yīng),會(huì)進(jìn)行重試,重試幾次后,向?qū)Χ税l(fā)一個(gè)reset,然后將連接斷掉。
在Windows中,第一次探測(cè)是在最后一次數(shù)據(jù)發(fā)送的兩個(gè)小時(shí),然后每隔1秒探測(cè)一次,一共探測(cè)5次,如果5次都沒有收到回應(yīng)的話,就會(huì)斷開這個(gè)連接。但兩個(gè)小時(shí)對(duì)于我們的項(xiàng)目來說顯然太長(zhǎng)了。我們必須縮短這個(gè)時(shí)間。那么我們?cè)撊绾巫瞿?#xff1f;我要利用Socket類的IOControl()函數(shù)。我們來看看這個(gè)函數(shù)能干些什么:
使用 IOControlCode 枚舉指定控制代碼,為 Socket 設(shè)置低級(jí)操作模式。
命名空間:System.Net.Sockets 程序集:System(在 system.dll 中)
語法
C# public int IOControl ( IOControlCode ioControlCode, byte[] optionInValue, byte[] optionOutValue )
參數(shù) ioControlCode 一個(gè) IOControlCode 值,它指定要執(zhí)行的操作的控制代碼。
optionInValue Byte 類型的數(shù)組,包含操作要求的輸入數(shù)據(jù)。
optionOutValue Byte 類型的數(shù)組,包含由操作返回的輸出數(shù)據(jù)。
返回值 optionOutValue 參數(shù)中的字節(jié)數(shù)。
如:
socket.IOControl(IOControlCode.KeepAliveValues,?inOptionValues,?null);我們要搞清楚的就是inOptionValues的定義,在C++里它是一個(gè)結(jié)構(gòu)體。我們來看看這個(gè)結(jié)構(gòu)體:
struct?tcp_keepalive?...{?
????u_long??onoff;?//是否啟用Keep-Alive
????u_long??keepalivetime;?//多長(zhǎng)時(shí)間后開始第一次探測(cè)(單位:毫秒)
????u_long??keepaliveinterval;?//探測(cè)時(shí)間間隔(單位:毫秒)
};?
在C#中,我們直接用一個(gè)Byte數(shù)組傳遞給函數(shù):
uint?dummy?=?0;byte[]?inOptionValues?=?new?byte[Marshal.SizeOf(dummy)?*?3];
BitConverter.GetBytes((uint)1).CopyTo(inOptionValues,?0);//是否啟用Keep-Alive
BitConverter.GetBytes((uint)5000).CopyTo(inOptionValues,?Marshal.SizeOf(dummy));//多長(zhǎng)時(shí)間開始第一次探測(cè)
BitConverter.GetBytes((uint)5000).CopyTo(inOptionValues,?Marshal.SizeOf(dummy)?*?2);//探測(cè)時(shí)間間隔
具體實(shí)現(xiàn)代碼:
????????public?static?void?AcceptThread()????????...{
????????????Thread.CurrentThread.IsBackground?=?true;
????????????while?(true)
????????????...{
????????????????uint?dummy?=?0;
????????????????byte[]?inOptionValues?=?new?byte[Marshal.SizeOf(dummy)?*?3];
????????????????BitConverter.GetBytes((uint)1).CopyTo(inOptionValues,?0);
????????????????BitConverter.GetBytes((uint)5000).CopyTo(inOptionValues,?Marshal.SizeOf(dummy));
????????????????BitConverter.GetBytes((uint)5000).CopyTo(inOptionValues,?Marshal.SizeOf(dummy)?*?2);
????????????????try
????????????????...{
????????????????????Accept(inOptionValues);
????????????????}
????????????????catch?...{?}
????????????}
????????}
????????private?static?void?Accept(byte[]?inOptionValues)
????????...{
????????????Socket?socket?=?Public.s_socketHandler.Accept();
????????????socket.IOControl(IOControlCode.KeepAliveValues,?inOptionValues,?null);
????????????UserInfo?info?=?new?UserInfo();
????????????info.socket?=?socket;
????????????int?id?=?GetUserId();
????????????info.Index?=?id;
????????????Public.s_userList.Add(id,?info);
????????????socket.BeginReceive(info.Buffer,?0,?info.Buffer.Length,?SocketFlags.None,?new?AsyncCallback(ReceiveCallBack),?info);
????????}
好了,這樣就成功了。
總結(jié)
以上是生活随笔為你收集整理的使用keeplive处理socket网络异常断开的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: mac下pip install 安装只能
- 下一篇: dp按照规模分类总结