C#使用使用Socket实现心跳的方法示例实现心跳的方法示例
主要介绍了C#使用Socket实现心跳的方法示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具
有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
Server端代码：
class Program
{
static SocketListener listener;
public static void Main(string[] args)
{
//实例化Timer类，设置间隔时间为5000毫秒；
System.Timers.Timer t = new System.Timers.Timer(5000);
t.Elapsed += new System.Timers.ElapsedEventHandler(CheckListen);
//到达时间的时候执行事件；
t.AutoReset = true;
t.Start();
listener = new SocketListener();
listener.ReceiveTextEvent += new SocketListener.ReceiveTextHandler(ShowText);
listener.StartListen();
Console.ReadKey();
}
private static void ShowText(string text)
{
Console.WriteLine(text);
}
private static void CheckListen(object sender, System.Timers.ElapsedEventArgs e)
{
if (listener != null && listener.Connection != null)
{
Console.WriteLine("连接数：" + listener.Connection.Count.ToString());
}
}
}
public class Connection
{
Socket _connection;
public Connection(Socket socket)
{
_connection = socket;
}
public void WaitForSendData(object connection)
{
try
{
while (true)
{
byte[] bytes = new byte[1024];
string data = "";
//等待接收消息
int bytesRec = this._connection.Receive(bytes);
if (bytesRec == 0)
{
// ReceiveText("客户端[" + _connection.RemoteEndPoint.ToString() + "]连接关闭...");
break;
}
data += Encoding.UTF8.GetString(bytes, 0, bytesRec);
ReceiveText("收到消息：" + data);
string sendStr = "服务端已经收到信息！";
byte[] bs = Encoding.UTF8.GetBytes(sendStr);
_connection.Send(bs, bs.Length, 0);
}
}
catch (Exception)
{
ReceiveText("客户端[" + _connection.RemoteEndPoint.ToString() + "]连接已断开...");
评论0