C#用wcf通信中,心跳包如何实现 ????

C#用wcf通信中,心跳包如何实现 ????

用C#做聊天室,WCF通信发送消息时,如何及时的知道用户的上下线提示

用户异常了如何及时的知道呢,并让其下线呢

具体如何实现啊???


万千封印
浏览 1157回答 2
2回答

一只名叫tom的猫

创建一个socket实例,设置该socket的属性为keepAlives,(socket.SetSocketOption())。然后设置keepAlives的等待时间,发送间隔,发送次数,就ok了,你可以google一下关键词keepAlives。下面是在网上找的。希望对你有用。TCP有一个连接检测机制,就是如果在指定的时间内(一般为2个小时)没有数据传送,会给对端发送一个Keep-Alive数据报,使用的序列号是曾经发出的最后一个报文的最后一个字节的序列号,对端如果收到这个数据,回送一个TCP的ACK,确认这个字节已经收到,这样就知道此连接没有被断开。如果一段时间没有收到对方的响应,会进行重试,重试几次后,向对端发一个reset,然后将连接断掉。  在Windows中,第一次探测是在最后一次数据发送的两个小时,然后每隔1秒探测一次,一共探测5次,如果5次都没有收到回应的话,就会断开这个连接。但两个小时对于我们的项目来说显然太长了。我们必须缩短这个时间。那么我们该如何做呢?我要利用Socket类的IOControl()函数。我们来看看这个函数能干些什么:使用 IOControlCode 枚举指定控制代码,为 Socket 设置低级操作模式。 命名空间:System.Net.Sockets 程序集:System(在 system.dll 中) 语法 C# public int IOControl ( IOControlCode ioControlCode, byte[] optionInValue, byte[] optionOutValue ) 参数 ioControlCode 一个 IOControlCode 值,它指定要执行的操作的控制代码。 optionInValue Byte 类型的数组,包含操作要求的输入数据。 optionOutValue Byte 类型的数组,包含由操作返回的输出数据。 返回值 optionOutValue 参数中的字节数。如: socket.IOControl(IOControlCode.KeepAliveValues, inOptionValues, null); 我们要搞清楚的就是inOptionValues的定义,在C++里它是一个结构体。我们来看看这个结构体: struct tcp_keepalive {     u_long  onoff; //是否启用Keep-Alive    u_long  keepalivetime; //多长时间后开始第一次探测(单位:毫秒)    u_long  keepaliveinterval; //探测时间间隔(单位:毫秒)};  在C#中,我们直接用一个Byte数组传递给函数: uint dummy = 0;byte[] inOptionValues = new byte[Marshal.SizeOf(dummy) * 3];BitConverter.GetBytes((uint)1).CopyTo(inOptionValues, 0);//是否启用Keep-AliveBitConverter.GetBytes((uint)5000).CopyTo(inOptionValues, Marshal.SizeOf(dummy));//多长时间开始第一次探测BitConverter.GetBytes((uint)5000).CopyTo(inOptionValues, Marshal.SizeOf(dummy) * 2);//探测时间间隔 具体实现代码:         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);        }  好了,这样就成功了。
打开App,查看更多内容
随时随地看视频慕课网APP