CnReconnect客户端与服务端之间通讯监听断线自动重连好的

【实例截图】

【核心代码】

客户端代码如下：

//www.networkcomms.cn  
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using NetworkCommsDotNet;
using DPSBase;
using System.Net;
using System.Threading;

namespace AppClient
{
    public partial class Form1 : Form
    {
        //连接信息类
        public ConnectionInfo connnectionInfo = null;

        //连接类
        Connection connection;


        public Form1()
        {
            InitializeComponent();
          
        }

        //在窗体上显示新信息
        void Form_ConnectionStatusNotify(object sender, StringEventArgs e)
        {
            if (this.InvokeRequired)
            {

                this.Invoke(new EventHandler<StringEventArgs>(this.Form_ConnectionStatusNotify), sender, e);
            }
            else
            {

                lblLink.Text = e.Text;
                lblLink.ForeColor = Color.Blue;
            }
        }

        private bool ServerNotifyClose = false;

        public event EventHandler<StringEventArgs> ConnectionStatusNotify;

        void connnectionInfo_StateChanged(object sender, StringEventArgs e)
        {
            //如果不是服务器通知关闭，则自动重连，如果是服务器通知关闭，则不作处理
            //本Demo中没有使用ServerNotifyClose
            if (ServerNotifyClose == false)
            {
                //更新连接信息类  设置为重连模式
                connnectionInfo.ReconnectFlag = true;
                 
                ConnectionStatusNotify.Raise(this, new StringEventArgs("可能由于服务器的故障，与服务器端的连接已断开"));

                int num = 0;
                int retryCount = 30;
                int retrySpanInMSecs = 5000;


                do
                {
                    try
                    {
                        NetworkComms.ClearDic();

                        connection = TCPConnection.GetConnection(connnectionInfo);
                         
                          
                        ConnectionStatusNotify.Raise(this, new StringEventArgs("重连成功"));

                        connnectionInfo.ReconnectFlag = false;

                        break;
                    }
                    catch (Exception ex)
                    {
                        num  ;
                        if (num < retryCount)
                        {
                            
                            ConnectionStatusNotify.Raise(this, new StringEventArgs("正在进行第"   num   "次重连"));
                            Thread.Sleep(retrySpanInMSecs);
                        }
                    }
                }
                while (num < retryCount);

            }
        }
         

        private void button1_Click(object sender, EventArgs e)
        { 

            connnectionInfo = new ConnectionInfo(txtIP.Text, int.Parse(txtPort.Text));

            //如果不成功，会弹出异常信息
            connection = TCPConnection.GetConnection(connnectionInfo);

            button1.Enabled = false;
            button1.Text = "连接成功";

            //订阅连接信息类中的连接状态改变事件
            connnectionInfo.StateChanged  = new EventHandler<StringEventArgs>(connnectionInfo_StateChanged);
            this.ConnectionStatusNotify  = new EventHandler<StringEventArgs>(Form_ConnectionStatusNotify);
        }

        //获取水果相关信息
        private void button2_Click(object sender, EventArgs e)
        {
            if (listBox1.SelectedIndex > -1)
            { 
                string resMsg = connection.SendReceiveObject<string>("ReqFruitEngName", "ResFruitEngName", 5000, listBox1.Text);
                 
                MessageBox.Show("您选择的水果的英文名称是："   resMsg);

            }
            else
            {
                MessageBox.Show("请选择一项");
            }
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            this.Dispose();
            this.Close();
        }

       
    }
}

服务器端代码如下：

//www.networkcomms.cn  
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using NetworkCommsDotNet;
using DPSBase;
using System.Net;

namespace AppServer
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        //开始监听
        private void button1_Click(object sender, EventArgs e)
        {
            //服务器开始监听客户端的请求
        
            IPEndPoint thePoint = new IPEndPoint(IPAddress.Parse(txtIP.Text), int.Parse(txtPort.Text));  
            //开始监听某T端口
            TCPConnection.StartListening(thePoint, false);
            button1.Text = "监听中";
            button1.Enabled = false;

            //此方法中包含服务器具体的处理方法。
            StartListening();
        }


        private void StartListening()
        {
 

            //禁用日志记录  服务器端正式使用时，禁用日志记录
            NetworkComms.DisableLogging();
            
          
            //服务器端处理收到的消息
            //为简单起见，此示例中我们只处理字符类型的信息，也返回字符类型的信息。
            //处理的信息可以使自定义类，具体见下一个Demo
            NetworkComms.AppendGlobalIncomingPacketHandler<string>("ReqFruitEngName", IncomingMsgHandle);
  
        }

        //处理某个具体的请求
        private void IncomingMsgHandle(PacketHeader header, Connection connection, string msg)
        {
            try
            {
                string resMsg = "";

                if (msg == "苹果")
                    resMsg = "Apple";
                else if (msg == "桔子")
                    resMsg = "Tangerine";
                else if (msg == "香蕉")
                    resMsg = "Banana";


                connection.SendObject("ResFruitEngName", resMsg);
            }
            catch (Exception ex)
            {
               
            }
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            NetworkComms.Shutdown();
            this.Dispose();
            this.Close();
        }

       
    }
}