TCP客户端demo

【实例简介】

TCP服务端接收客户端连接

TCP服务端发送和接收消息

【实例截图】

【核心代码】

#endregion

#region 命名空间引用
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Data;
using System.Drawing;
using System.Windows.Forms;
using System.Threading;
using System.Collections.Generic;
using System.ComponentModel;
#endregion

namespace _005_TCP服务端_Template
{
    public partial class frmMain : Form
    {
        #region 回调
        // 显示接收消息回调
        private delegate void ShowReceiveMsgCallBack(string text);
        private ShowReceiveMsgCallBack showReceiveMsgCallBack;
        #endregion

        #region 字段
        // * 网络连接相关 *
        private TcpListener myTcpListener;  // TCP连接侦听器
        private NetworkStream ns;                 // 网络数据流
        private TcpClient tcpClient;              // TCP客户端
        private Thread TcpClientAcceptThread;   // 客户端连接监听线程
        #endregion

        #region 窗体事件
        // 窗体构造方法
        public frmMain()
        {
            InitializeComponent();
        }

        // 窗体启动加载事件
        private void frmMain_Load(object sender, EventArgs e)
        {
            // 初始化回调
            showReceiveMsgCallBack = new ShowReceiveMsgCallBack(ShowReceiveMsg);
        }
        #endregion

        #region 控件事件
        // 开始监听按钮被单击事件
        private void btnStartListen_Click(object sender, EventArgs e)
        {
            try
            {
                // 创建并实例化IP终端结点
                IPEndPoint ipEndPoint =
                    new IPEndPoint(IPAddress.Parse(txtServerIP.Text), Convert.ToInt32(txtServerPort.Text));
                // 实例化TCP连接侦听器
                myTcpListener = new TcpListener(ipEndPoint);
                // 启动TCP连接侦听器
                myTcpListener.Start();
                // 创建并启动TCP连接侦听接受线程
                TcpClientAcceptThread = new Thread(TcpClientAccept);
                TcpClientAcceptThread.IsBackground = true;
                TcpClientAcceptThread.Start();
                // 修改控件状态
                btnStartListen.Enabled = false;
                btnStopListen.Enabled = true;
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }

        // 停止监听按钮被单击事件
        private void btnStopListen_Click(object sender, EventArgs e)
        {
            // 停止监听
            myTcpListener.Stop();
            // 终止监听线程
            TcpClientAcceptThread.Abort();
            // 修改控件状态
            btnStartListen.Enabled = true;
            btnStopListen.Enabled = false;
        }
        #endregion

        #region 线程
        // TCP连接侦听接受线程
        private void TcpClientAccept()
        {
            try
            {
                // 接收TCP客户端
                tcpClient = myTcpListener.AcceptTcpClient();
                // 获取绑定的网络数据流
                ns = tcpClient.GetStream();

                // 循环接收消息
                while (true)
                {
                    int readLen = tcpClient.Available;
                    if (readLen > 0)
                    {
                        // 创建并实例化用于存放数据的字节数组
                        byte[] getData = new byte[readLen];
                        // 从网络数据流中读取数据
                        ns.Read(getData, 0, getData.Length);
                        // 将字节数组转换为文本形式
                        string getMsg = Encoding.Default.GetString(getData);
                        // 将消息添加到接收消息列表中
                        lstReceiveMsg.Invoke(showReceiveMsgCallBack, getMsg);
                        Thread.Sleep(5000);
                        // 返回相同消息给客户端
                        ns.Write(getData, 0, getData.Length);
                    }
                }
            }
            catch (ThreadAbortException)
            {
                // 人为终止线程
            }
            catch (Exception ex)
            {
                // 连接发生异常
                MessageBox.Show(ex.Message);
                // 释放相关系统资源
                if (tcpClient != null)
                    tcpClient.Close();
                if (ns != null)
                    ns.Dispose();
            }
        }
        #endregion

        #region 回调方法
        // 显示接收消息回调方法
        private void ShowReceiveMsg(string text)
        {
            lstReceiveMsg.Items.Add(text);
        }
        #endregion
    }
}