心跳包实现

class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("客务端");
            TcpClient cline;
            // 与服务器连接
            try
            {
                cline = new TcpClient();
                cline.Connect("localhost", 8800);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                Console.ReadKey();
                return;
            }

            string msg = "\"其实我在潜水,请不要抛弃我\"";
            //发往服务器
            NetworkStream streamToServer = cline.GetStream();
            byte[] BString = Encoding.Unicode.GetBytes(msg);

            streamToServer.Write(BString, 0, BString.Length);
            Console.WriteLine("发送:{0}", msg);
            //退出Q
            Console.WriteLine("\n\n输入\"Q\"键退出。");
            ConsoleKey key;
            do
            {
                key = Console.ReadKey(true).Key;
            } while (key != ConsoleKey.Q);
        }
    }

  

class Program
    {
        static void Main(string[] args)
        {
            const int BSize = 8192;
            Console.WriteLine("服务端");
            //设ip和端口
            IPAddress ip = new IPAddress(new byte[] { 127, 0, 0, 1 });
            TcpListener list = new TcpListener(ip, 8800);

            list.Start();  //开始侦听
            Console.WriteLine("开始侦听");
            TcpClient TC = list.AcceptTcpClient();
            // 获得流
            NetworkStream NS = TC.GetStream();
            byte[] BString = new byte[BSize];
            int bytesRead = NS.Read(BString, 0, BSize);
            Console.WriteLine("字节:{0} bytes ...", bytesRead);
            // 获得请求的字符串
            string msg = Encoding.Unicode.GetString(BString, 0, bytesRead);
            Console.WriteLine("收到:{0}", msg);
            //退出Q
            Console.WriteLine("\n\n输入\"Q\"键退出。");
            ConsoleKey key;
            do
            {
                key = Console.ReadKey(true).Key;
            }
            while (key != ConsoleKey.Q);
        }
    }

  

时间: 2024-10-25 18:00:11

心跳包实现的相关文章

TCP连接探测中的Keepalive 和心跳包

采用TCP连接的C/S模式软件,连接的双方在连接空闲状态时,如果任意一方意外崩溃.当机.网线断开或路由器故障,另一方无法得知TCP连接已经失效,除非继续在此连接上发送数据导致错误返回.很多时候,这不是我们需要的.我们希望服务器端和客户端都能及时有效地检测到连接失效,然后优雅地完成一些清理工作并把错误报告给用户. 如何及时有效地检测到一方的非正常断开,一直有两种技术可以运用.一种是由TCP协议层实现的Keepalive,另一种是由应用层自己实现的心跳包. TCP默认并不开启Keepalive功能,

delphi datasnap 心跳包

为了能让我们的服务程序更加稳定,有些细节问题必须解决.就如上一讲中提到的客户端拔掉网线,造成服务器上TCP变成死连接,如果死连接数量过多,对服务器能长期稳定运行是一个巨大的威胁.另外,经过测试,如果服务器上有TCP死连接,那么服务程序连接数据库,也会产生那个一个死连接.这样的话,给数据库服务器也造成威胁.所以,服务器程序编写的好坏,直接影响系统的稳定性!如何解决TCP死连接的问题,有多种方法,其中最有效的就是心跳包技术.我们在DSServer的OnConnect事件中加入心跳包代码 uses I

Signalr 实现心跳包

项目分析: 一个实时的IM坐席系统,客户端和坐席使用IM通信,客户端使用android和ios的app,坐席使用web. web端可以保留自己的登录状态,但为防止意外情况的发生(如浏览器异常关闭,断网,断电),对坐席的实时在线状态造成影响,我们在后台跑一个服务,实时向每个坐席发送一个心跳包,当坐席的状态是在线,但是又不能接收到服务端的心跳包的时候,认为该坐席已经被异常下线. 实时通信Signalr 使用中发现signalr的服务端必须需要 .net frameword4.5及以上版本,对sign

[转] Socket心跳包异常检测的C语言实现,服务器与客户端代码案例

转载自:zxh2075的专栏 在Socket心跳机制中,心跳包可以由服务器发送给客户端,也可以由客户端发送给服务器,不过比较起来,前者开销可能较大.本文实现的是由客户端给服务器发送心跳包,服务器不必返回应答包,而是通过判断客户在线会话记录中的计数标志值来实现心跳异常的检测,以此决定客户端是否已经断开连接以及删除其在线会话记录. 基本思路: ①客户端定时给服务器发送心跳包(案例中定时时间为3秒): ②服务器创建一个心跳检测的线程,线程中每隔3秒对用户在线会话记录中的计数器进行加1操作(初始值为0)

Netty5.0 实现心跳包

这是一个netty自带的echo案例,添加了心跳包的设置而已,关键代码如下: /* * Copyright 2012 The Netty Project * * The Netty Project licenses this file to you under the Apache License, * version 2.0 (the "License"); you may not use this file except in compliance * with the Licen

长连接和心跳包

第一种设置:通过设置socket的keepalive属性#include    "/usr/include/linux/tcp.h"#include "/usr/include/linux/socket.h"////KeepAlive实现,单位秒//下面代码要求有ACE,如果没有包含ACE,则请把用到的ACE函数改成linux相应的接口int keepAlive = 1;//设定KeepAliveint keepIdle = 5;//开始首次KeepAlive探测前

心跳包 WPF Unity 数据库搭建

1.心跳包如何发送: 主要是客户机发送给服务器,服务器接收到后,再回复. //之前做的项目,WPF与U3D进行通信,WPF端是处于监听端,而U3D属于客户端,不断的发心跳包给WPF //WPF端代码如下: //嵌入U3D窗口 void initU3D() { //将Exehost 控件添加到 Winformhost控件中 if (UserData.enableEmbU3d) { ExeHost exehost = new ExeHost(); //formview.formHost.Child

心跳包

转自:http://blog.csdn.net/gao5528/article/details/6029160 心跳包就是在客户端和服务器间定时通知对方自己状态的一个自己定义的命令字,按照一定的时间间隔发送,类似于心跳,所以叫做心跳包. 用来判断对方(设备,进程或其它网元)是否正常运行,采用定时发送简单的通讯包,如果在指定时间段内未收到对方响应,则判断对方已经离线.用于检测TCP的异常断开.基本原因是服务器端不能有效的判断客户端是否在线,也就是说,服务器无法区分客户端是长时间在空闲,还是已经掉线

闲说HeartBeat心跳包和TCP协议的KeepAlive机制

很多应用层协议都有HeartBeat机制,通常是客户端每隔一小段时间向服务器发送一个数据包,通知服务器自己仍然在线,并传输一些可能必要的数据.使用心跳包的典型协议是IM,比如QQ/MSN/飞信等协议. 学过TCP/IP的同学应该都知道,传输层的两个主要协议是UDP和TCP,其中UDP是无连接的.面向packet的,而TCP协议是有连接.面向流的协议. 所以非常容易理解,使用UDP协议的客户端(例如早期的“OICQ”,听说OICQ.com这两天被抢注了来着,好古老的回忆)需要定时向服务器发送心跳包

心跳包机制原理

心跳包的发送,通常有两种技术 方法1:应用层自己实现的心跳包 由应用程序自己发送心跳包来检测连接是否正常,大致的方法是:服务器在一个 Timer事件中定时 向客户端发送一个短小精悍的数据包,然后启动一个低级别的线程,在该线程中不断检测客户端的回应, 如果在一定时间内没有收到客户端的回应,即认为客户端已经掉线:同样,如果客户端在一定时间内没 有收到服务器的心跳包,则认为连接不可用. 方法2:TCP的KeepAlive保活机制 因为要考虑到一个服务器通常会连接多个客户端,因此由用户在应用层自己实现心