using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;

namespace TCPServer
{
    public partial class Form1 : Form
    {
        // TCP監(jiān)聽(tīng)套接字（核心對(duì)象，負(fù)責(zé)監(jiān)聽(tīng)客戶端連接）
        private TcpListener tcpListener;
        // 客戶端連接套接字（與客戶端建立連接后，用于接收消息）
        private TcpClient clientSocket;
        // 監(jiān)聽(tīng)線程（將監(jiān)聽(tīng)操作放入后臺(tái)線程，防止界面卡死）
        private Thread listenThread;
        // 服務(wù)端IP和端口（同一臺(tái)電腦固定用本地回環(huán)地址127.0.0.1，端口可自定義，需與客戶端一致）
        private readonly string ip = "127.0.0.1";
        private readonly int port = 8888;

        public Form1()
        {
            InitializeComponent();
            // 綁定窗體關(guān)閉事件，關(guān)閉時(shí)釋放所有資源，避免內(nèi)存泄漏
            this.FormClosing += Form1_FormClosing;
        }

        // 「啟動(dòng)監(jiān)聽(tīng)」按鈕點(diǎn)擊事件
        private void btnStart_Click(object sender, EventArgs e)
        {
            // 啟動(dòng)后臺(tái)監(jiān)聽(tīng)線程，避免阻塞主線程（界面卡死）
            listenThread = new Thread(StartListen);
            listenThread.IsBackground = true; // 設(shè)為后臺(tái)線程，關(guān)閉程序時(shí)自動(dòng)退出
            listenThread.Start();
            // 向消息框添加狀態(tài)提示
            AppendMsg("服務(wù)端已啟動(dòng)監(jiān)聽(tīng)：" + ip + ":" + port);
        }

        // 核心方法：?jiǎn)?dòng)TCP監(jiān)聽(tīng)，等待客戶端連接
        private void StartListen()
        {
            try
            {
                // 創(chuàng)建TCP監(jiān)聽(tīng)對(duì)象，綁定IP和端口
                tcpListener = new TcpListener(IPAddress.Parse(ip), port);
                // 啟動(dòng)監(jiān)聽(tīng)服務(wù)
                tcpListener.Start();
                AppendMsg("等待客戶端連接...");

                // 死循環(huán)監(jiān)聽(tīng)（阻塞方法，必須放在線程中），持續(xù)等待客戶端連接
                while (true)
                {
                    // 接受客戶端的連接請(qǐng)求，建立連接
                    clientSocket = tcpListener.AcceptTcpClient();
                    AppendMsg("客戶端已連接！");

                    // 開(kāi)啟新線程接收該客戶端的消息（多線程支持，可擴(kuò)展多客戶端連接）
                    Thread receiveThread = new Thread(ReceiveMsg);
                    receiveThread.IsBackground = true;
                    receiveThread.Start(clientSocket);
                }
            }
            catch (Exception ex)
            {
                // 捕獲異常，避免程序崩潰，提示異常信息
                AppendMsg("監(jiān)聽(tīng)異常：" + ex.Message);
            }
        }

        // 接收客戶端發(fā)送的消息
        private void ReceiveMsg(object obj)
        {
            // 將傳入的參數(shù)轉(zhuǎn)為TcpClient對(duì)象（與當(dāng)前連接的客戶端綁定）
            TcpClient client = (TcpClient)obj;
            // 獲取網(wǎng)絡(luò)數(shù)據(jù)流，用于讀取客戶端發(fā)送的數(shù)據(jù)
            NetworkStream stream = client.GetStream();

            try
            {
                byte[] buffer = new byte[1024]; // 數(shù)據(jù)緩沖區(qū)，用于存儲(chǔ)接收的字節(jié)數(shù)據(jù)（1024字節(jié)足夠日常使用）
                int len; // 實(shí)際讀取到的字節(jié)長(zhǎng)度

                // 循環(huán)讀取客戶端消息（stream.Read()是阻塞方法，客戶端斷開(kāi)連接時(shí)會(huì)拋出異常）
                while ((len = stream.Read(buffer, 0, buffer.Length)) > 0)
                {
                    // 將字節(jié)數(shù)據(jù)轉(zhuǎn)為UTF-8編碼的字符串（與客戶端編碼一致，避免亂碼）
                    string msg = Encoding.UTF8.GetString(buffer, 0, len);
                    // 顯示客戶端發(fā)送的消息
                    AppendMsg("客戶端說(shuō)：" + msg);
                }
            }
            catch
            {
                // 客戶端斷開(kāi)連接時(shí)，提示狀態(tài)
                AppendMsg("客戶端斷開(kāi)連接");
            }
        }

        // 「停止監(jiān)聽(tīng)」按鈕點(diǎn)擊事件
        private void btnStop_Click(object sender, EventArgs e)
        {
            // 停止監(jiān)聽(tīng)，釋放監(jiān)聽(tīng)資源
            tcpListener?.Stop();
            // 關(guān)閉客戶端連接，釋放連接資源
            clientSocket?.Close();
            AppendMsg("服務(wù)端已停止監(jiān)聽(tīng)");
        }

        // 窗體關(guān)閉事件：釋放所有資源
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            // 安全釋放資源，避免程序異常
            tcpListener?.Stop();
            clientSocket?.Close();
        }

        // 跨線程安全更新界面消息（子線程不能直接操作窗體控件，需通過(guò)Invoke實(shí)現(xiàn)）
        private void AppendMsg(string msg)
        {
            // 判斷是否需要跨線程調(diào)用
            if (txtMsg.InvokeRequired)
            {
                // 跨線程調(diào)用，更新消息框內(nèi)容
                txtMsg.Invoke(new Action(() =>
                {
                    txtMsg.AppendText(DateTime.Now.ToString("HH:mm:ss ") + msg + Environment.NewLine);
                }));
            }
            else
            {
                // 主線程直接更新
                txtMsg.AppendText(DateTime.Now.ToString("HH:mm:ss ") + msg + Environment.NewLine);
            }
        }
    }
}

using System;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;

namespace TCPClient
{
    public partial class Form1 : Form
    {
        // TCP客戶端套接字（核心對(duì)象，用于連接服務(wù)端并發(fā)送消息）
        private TcpClient clientSocket;
        // 服務(wù)端IP和端口（必須與服務(wù)端完全一致，否則無(wú)法連接）
        private readonly string serverIp = "127.0.0.1";
        private readonly int serverPort = 8888;

        public Form1()
        {
            InitializeComponent();
            // 綁定窗體關(guān)閉事件，釋放資源
            this.FormClosing += Form1_FormClosing;
        }

        // 「連接服務(wù)端」按鈕點(diǎn)擊事件
        private void btnConnect_Click(object sender, EventArgs e)
        {
            try
            {
                // 創(chuàng)建TCP客戶端對(duì)象
                clientSocket = new TcpClient();
                // 連接服務(wù)端（IP和端口必須與服務(wù)端一致）
                clientSocket.Connect(serverIp, serverPort);
                AppendMsg("成功連接到服務(wù)端！");

                // 開(kāi)啟線程接收服務(wù)端消息（本案例服務(wù)端暫只接收消息，可擴(kuò)展雙向通信）
                Thread receiveThread = new Thread(ReceiveMsg);
                receiveThread.IsBackground = true;
                receiveThread.Start();
            }
            catch (Exception ex)
            {
                // 連接失敗時(shí)提示異常信息（常見(jiàn)原因：服務(wù)端未啟動(dòng)、端口不一致）
                AppendMsg("連接失?。? + ex.Message);
            }
        }

        // 接收服務(wù)端發(fā)送的消息（可擴(kuò)展雙向通信，目前預(yù)留）
        private void ReceiveMsg()
        {
            try
            {
                // 獲取與服務(wù)端通信的網(wǎng)絡(luò)數(shù)據(jù)流
                NetworkStream stream = clientSocket.GetStream();
                byte[] buffer = new byte[1024]; // 數(shù)據(jù)緩沖區(qū)
                int len; // 實(shí)際讀取的字節(jié)長(zhǎng)度

                // 循環(huán)讀取服務(wù)端消息
                while ((len = stream.Read(buffer, 0, buffer.Length)) > 0)
                {
                    string msg = Encoding.UTF8.GetString(buffer, 0, len);
                    AppendMsg("服務(wù)端說(shuō)：" + msg);
                }
            }
            catch
            {
                // 與服務(wù)端斷開(kāi)連接時(shí)提示
                AppendMsg("與服務(wù)端斷開(kāi)連接");
            }
        }

        // 「發(fā)送消息」按鈕點(diǎn)擊事件
        private void btnSend_Click(object sender, EventArgs e)
        {
            // 先判斷是否已連接服務(wù)端，未連接則提示
            if (clientSocket == null || !clientSocket.Connected)
            {
                MessageBox.Show("請(qǐng)先連接服務(wù)端！");
                return;
            }

            try
            {
                // 獲取輸入框中的消息，去除前后空格
                string sendMsg = txtSend.Text.Trim();
                if (string.IsNullOrEmpty(sendMsg)) return; // 空消息不發(fā)送

                // 將字符串轉(zhuǎn)為UTF-8編碼的字節(jié)流（與服務(wù)端編碼一致）
                byte[] buffer = Encoding.UTF8.GetBytes(sendMsg);
                // 獲取網(wǎng)絡(luò)數(shù)據(jù)流，發(fā)送消息到服務(wù)端
                NetworkStream stream = clientSocket.GetStream();
                stream.Write(buffer, 0, buffer.Length);

                // 顯示自己發(fā)送的消息
                AppendMsg("你說(shuō)：" + sendMsg);
                txtSend.Clear(); // 發(fā)送后清空輸入框
            }
            catch (Exception ex)
            {
                // 發(fā)送失敗時(shí)提示異常信息
                AppendMsg("發(fā)送失?。? + ex.Message);
            }
        }

        // 窗體關(guān)閉事件：釋放客戶端資源
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            clientSocket?.Close();
        }

        // 跨線程安全更新界面消息（與服務(wù)端邏輯一致）
        private void AppendMsg(string msg)
        {
            if (txtMsg.InvokeRequired)
            {
                txtMsg.Invoke(new Action(() =>
                {
                    txtMsg.AppendText(DateTime.Now.ToString("HH:mm:ss ") + msg + Environment.NewLine);
                }));
            }
            else
            {
                txtMsg.AppendText(DateTime.Now.ToString("HH:mm:ss ") + msg + Environment.NewLine);
            }
        }
    }
}