Tcp通信示例源码（含服务器端以及客户端）

【实例截图】

【核心代码】

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();
        }

       
    }
}