我要评论什么是心跳机制？
心跳机制出现在tcp长连接中，客户端和服务器之见定时发送一种特殊的数据包通知对方还在线，以确保tcp链接地可靠性，有可能tcp链接由于某些原因(列入网线被拔了，突然断电)导致客户端断了，但是服务器不知道客户端断了，服务器还保持与客户端连接的状态，所以为了不浪费资源，需要知道客户端非正常中断，服务器把断开客户端断开链接，需要加入心跳包机制
控制台应用项目
program.cs
internal class program
{
static server server;
static void main(string[] args)
{
server server = new server(ipaddress.any,3333);
server.start();// 除了服务器监听方法，监听客户连接的方法，扫描客户端是否在线的方法
//如果监听到有客户端连接的时候，打印哪个终端连入到服务器了 使用时间封装
server.有客户端连入的事件 += 有客户端连入服务器方法;// 绑定事件
server.客户端断开事件 += f2;
server.接受到消息的事件 += f3;
console.readkey();
}
// 相当于点击之后的毁掉方法，在客户端连接成功之后调用这个方法
public static void 有客户端连入服务器方法(object obj)
{
tcpclient t1 = obj as tcpclient;
console.writeline(t1.client.remoteendpoint+"连接到服务器");
}
public static void f2(object obj)
{
console.writeline(obj.tostring()+"断开连接");
}
public static void f3(tcpclient t1, byte[] b1)
{
t1.getstream().write(b1, 0, b1.length);
}
}server.cs
internal class server
{
tcplistener listen;
// 1 通过构造函数创建服务器对象
public server(ipaddress ip,int port)
{
listen = new tcplistener(ip, port);
}
// 2 封装开启监听的方法
public void start()
{
listen.start(100);// 开启监听
// 接受客户端的连接
startconnect();
// 扫描心跳方法
saomiao();
}
// 3 接受客户端的连接 封装一监听客户端连接的方法
// 保存所有的客户端字典，键是ip 值是客户端
dictionary<string, tcpclient> clientdic = new dictionary<string, tcpclient>();
// 字段保存客户端和当前连接服务器时间点
dictionary<string, datetime> heartdic = new dictionary<string, datetime>();
public event action<tcpclient> 有客户端连入的事件;
void startconnect()
{
task.run(() =>
{
while (true)// 接入多个客户端
{
tcpclient client = listen.accepttcpclient();
string ip = client.client.remoteendpoint.tostring();// 获取远程ip
// 保存当前客户端
clientdic.add(ip, client);
// 记录当前客户端心跳 链接成功的时候记录当前客户端时间点
heartdic.add(ip, datetime.now);
// 调用事件函数 触发事件
有客户端连入的事件?.invoke(client);
// 4接受客户端发来的消息
receivmsg(client);
}
});
}
// 4 接受客户端发来的消息
// 封装接受的消息
public event action<string> 客户端断开事件;// 当客户端断开时候调用
public event action<tcpclient, byte[]> 接受到消息的事件;// 接收到消息调用
void receivmsg(tcpclient t1)
{
networkstream stream = t1.getstream();
string ip = t1.client.remoteendpoint.tostring();
byte[] bs = new byte[1024];
task.run(() =>
{
try
{
while (true)
{
int count = stream.read(bs, 0, bs.length);
// 必须判断是否是心跳包 事先约定好
if (count == 0)
{
// 客户端断开
throw new exception("客户端断开连接");
}
// 如果接收数据长度不为0
// 必须判断是否心跳包 事先约定好：如果数据第一位是0的时候，当成普通包
// 如果数据第一位是1说明是心跳包
switch (bs[0]) // 判断第一位数据是不是0
{
case 0: // 普通数据 取出来的时候不需要显示第一位标识符
// skip 从第一位开始截取
// take 到指定位置的元素为止
// 第一位0、1代表是否心跳包标识符
//
byte[] body = bs.skip(1).take(count-1).toarray();
// 要么群发 要么单发
接受到消息的事件?.invoke(t1,body);
break;
case 1: // 发的是心跳包
// 修改是心跳包发的时间点
heartdic[ip] = datetime.now;
break;
}
}
}
catch (exception e)
{
// 从字典里把客户端清除掉
clientdic.remove(ip);
// 如果客户端打开了，打印客户
客户端断开事件?.invoke(ip);
//删除心跳记录
heartdic.remove(ip);
}
});
}
// 遍历所有客户端 扫描是否在未超时时间内
void saomiao()
{
task.run(() =>
{
while (true)
{
thread.sleep(4000);// 线程休眠4s
datetime now1 = datetime.now;
foreach (var item in heartdic) // 遍历所以的心跳记录
{
// now1 当前时间点
// item.value 服务器接受客户端发来的心跳包时间
if (now1-item.value>new timespan(0,0,4))
{
console.writeline(item.key+"掉线了");
}
else
{
console.writeline(item.key+"在线");
}
}
}
});
}
// 无参数的构造函数
public server()
{
}
// 群发方法
public void send()
{
}
// 指定给谁发
public void send指定()
{
}
//指定给哪些客户端发
}到此这篇关于c#心跳机制服务器的示例代码的文章就介绍到这了,更多相关c#心跳机制内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论