基於C# Socket實現多人網絡聊天室

首先不多說，最終實現界面如下，可以通過點擊啟動服務，開啟TCP服務器：

 

 

開啟TCP服務器之后，可以通過點擊客戶端，打開一個獨立的TCP客戶端，打開客戶端之后，輸入正確的IP地址和端口號，可以進行連接服務器，這里可以同時開啟多個客戶端：

 

 

每個客戶端連接成功后，服務器的列表中會多出一個EndPoint，連接成功后，服務器和客戶端之間就可以自由通話了，可以發送消息，也可以發送文件。

其實這就是QQ等即時通信工具的雛形，如果兩個客戶端之間需要通信，就通過服務器進行中轉。

由於服務器代碼量較大，下面上傳一下客戶端的代碼，僅供參考：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace MyTCPServer
{
    delegate void FileSaveDelegate(byte[] bt,int length);

    public partial class FrmClient : Form
    {
        public FrmClient()
        {
            InitializeComponent();

            //委托對象綁定方法
            MyShowMsg += ShowMsg;

            MyFileSave += FileSave;
        }

        //運行標志位
        private bool IsRun = true;

        //創建連接服務器的Socket
        Socket sockClient = null;

        //創建接收服務器消息的線程
        Thread thrClient = null;

        //創建委托對象
        ShowMsgDelegate MyShowMsg;

        FileSaveDelegate MyFileSave;

        private void btnConnect_Click(object sender, EventArgs e)
        {
            //獲取IP對象
            IPAddress address = IPAddress.Parse(this.txtIp.Text.Trim());

            //根據IP對象和端口號創建網絡節點對象
            IPEndPoint endPoint = new IPEndPoint(address, int.Parse(this.txtPort.Text.Trim()));

            //創建負責連接的套接字，注意其中參數：[IPV4地址，字節流，TCP協議]
            sockClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            try
            {
                Invoke(MyShowMsg, "與服務器連接中......");
                sockClient.Connect(endPoint);
            }
            catch (Exception ex)
            {
                MessageBox.Show("建立連接失敗：" + ex.Message, "建立連接");
                return;
            }

            Invoke(MyShowMsg, "與服務器連接成功！");

            thrClient = new Thread(ReceiveMsg);
            thrClient.IsBackground = true;
            thrClient.Start();

            this.btnConnect.Enabled = false;
        }

        private void FileSave(byte[] arrMsgRec, int length)
        {
            try
            {
                SaveFileDialog sfd = new SaveFileDialog();

                if (sfd.ShowDialog(this) == DialogResult.OK)
                {

                    string fileSavePath = sfd.FileName;// 獲得文件保存的路徑；
                    // 創建文件流，然后根據路徑創建文件；
                    using (FileStream fs = new FileStream(fileSavePath, FileMode.Create))
                    {
                        fs.Write(arrMsgRec, 1, length - 1);
                        Invoke(MyShowMsg, "文件保存成功：" + fileSavePath);
                    }
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }

        }

        private void ReceiveMsg()
        {
           while(IsRun)
            {
                // 定義一個2M的緩存區
                byte[] arrMsgRec = new byte[1024 * 1024 * 2];

                // 將接受到的數據存入到輸入 arrMsgRec中
                int length = -1;
                try
                {
                    length = sockClient.Receive(arrMsgRec); // 接收數據，並返回數據的長度；
                }
                catch (SocketException)
                {
                    return;
                }
                catch (Exception e)
                {
                    Invoke(MyShowMsg, "連接斷開：" + e.Message);
                    return;
                }
                if (arrMsgRec[0] == 0) // 表示接收到的是消息數據；
                {
                    string strMsg = System.Text.Encoding.UTF8.GetString(arrMsgRec, 1, length - 1);// 將接受到的字節數據轉化成字符串；
                    Invoke(MyShowMsg, strMsg);
                }
                if (arrMsgRec[0] == 1) // 表示接收到的是文件數據；
                {
                    Invoke(MyFileSave, arrMsgRec, length);
                }
            }
        }

        private void ShowMsg(string str)
        {
            txtMsg?.AppendText(str + Environment.NewLine);
        }

        private void btnSend_Click(object sender, EventArgs e)
        {
            string strMsg = txt_Name.Text.Trim() + Environment.NewLine + "    -->" + txtMsgSend.Text.Trim() + Environment.NewLine;
            byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(strMsg);
            byte[] arrSendMsg = new byte[arrMsg.Length + 1];
            arrSendMsg[0] = 0; // 用來表示發送的是消息數據
            Buffer.BlockCopy(arrMsg, 0, arrSendMsg, 1, arrMsg.Length);
            sockClient.Send(arrSendMsg); // 發送消息；
            Invoke(MyShowMsg, strMsg);
            txtMsgSend.Clear();
        }

        private void btnSendFile_Click(object sender, EventArgs e)
        {
            if (string.IsNullOrEmpty(txtSelectFile.Text))
            {
                MessageBox.Show("請選擇要發送的文件！！！");
            }
            else
            {
                // 用文件流打開用戶要發送的文件；
                using (FileStream fs = new FileStream(txtSelectFile.Text, FileMode.Open))
                {
                    //在發送文件以前先給好友發送這個文件的名字+擴展名，方便后面的保存操作；
                    string fileName = System.IO.Path.GetFileName(txtSelectFile.Text);
                    string fileExtension = System.IO.Path.GetExtension(txtSelectFile.Text);
                    string strMsg = "發送的文件為： " + fileName + Environment.NewLine;
                    byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(strMsg);
                    byte[] arrSendMsg = new byte[arrMsg.Length + 1];
                    arrSendMsg[0] = 0; // 用來表示發送的是消息數據
                    Buffer.BlockCopy(arrMsg, 0, arrSendMsg, 1, arrMsg.Length);
                    sockClient.Send(arrSendMsg); // 發送消息；

                    byte[] arrFile = new byte[1024 * 1024 * 2];
                    int length = fs.Read(arrFile, 0, arrFile.Length);  // 將文件中的數據讀到arrFile數組中；
                    byte[] arrFileSend = new byte[length + 1];
                    arrFileSend[0] = 1; // 用來表示發送的是文件數據；
                    Buffer.BlockCopy(arrFile, 0, arrFileSend, 1, length);
                    // 還有一個 CopyTo的方法，但是在這里不適合； 當然還可以用for循環自己轉化；
                    sockClient.Send(arrFileSend);// 發送數據到服務端；
                    txtSelectFile.Clear();
                }
            }
        }

        private void btnSelectFile_Click(object sender, EventArgs e)
        {
            OpenFileDialog ofd = new OpenFileDialog();
            ofd.InitialDirectory = "D:\\";
            if (ofd.ShowDialog() == System.Windows.Forms.DialogResult.OK)
            {
                txtSelectFile.Text = ofd.FileName;
            }
        }

        private void FrmClient_FormClosing(object sender, FormClosingEventArgs e)
        {
            IsRun  = false;
            sockClient?.Close();
        }
    }
}

 　如果大家還有什么不明白的地方，可以關注一下微信公眾號：dotNet工控上位機