c# tcp/ip通信

服務端

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

namespace csharpService
{
    public partial class Service : Form
    {
        public Service()
        {
            InitializeComponent();

            ///多線程編程中，如果子線程需要使用主線程中創建的對象和控件，最好在主線程中體現進行檢查取消
            ///
            CheckForIllegalCrossThreadCalls = false;

            /// 獲取本地IP
            textBox_current_address.Text = IPAddress.Any.ToString();
        }

        /// 創建一個字典，用來存儲記錄服務器與客戶端之間的連接(線程問題)
        ///
        private Dictionary<string, Socket> clientList = new Dictionary<string, Socket>();

        /// 創建連接
        private void button_connect_Click(object sender, EventArgs e)
        {
            Thread myServer = new Thread(MySocket);
            //設置這個線程是后台線程
            myServer.IsBackground = true;
            myServer.Start();
        }

        //①:創建一個用於監聽連接的Socket對象；
        //②:用指定的端口號和服務器的Ip建立一個EndPoint對象；
        //③:用Socket對象的Bind()方法綁定EndPoint；
        //④:用Socket對象的Listen()方法開始監聽；
        //⑤:接收到客戶端的連接，用Socket對象的Accept()方法創建一個新的用於和客戶端進行通信的Socket對象；
        //⑥:通信結束后一定記得關閉Socket。

        /// 創建連接的方法
        private void MySocket()
        {
            //1.創建一個用於監聽連接的Socket對象；
            Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);

            //2.用指定的端口號和服務器的Ip建立一個EndPoint對象；
            IPAddress iP = IPAddress.Parse(textBox_current_address.Text);
            IPEndPoint endPoint = new IPEndPoint(iP, int.Parse(textBox_port.Text));

            //3.用Socket對象的Bind()方法綁定EndPoint；
            server.Bind(endPoint);

            //4.用Socket對象的Listen()方法開始監聽；

            //同一時刻內允許同時加入鏈接的最大數量
            server.Listen(20);
            listBox_log.Items.Add("服務器已經成功開啟!");

            //5.接收到客戶端的連接，用Socket對象的Accept()方法創建一個新的用於和客戶端進行通信的Socket對象；
            while (true)
            {
                //接受接入的一個客戶端
                Socket connectClient = server.Accept();
                if (connectClient != null)
                {
                    string infor = connectClient.RemoteEndPoint.ToString();
                    clientList.Add(infor, connectClient);

                    listBox_log.Items.Add(infor + "加入服務器!");

                    ///服務器將消息發送至客服端
                    string msg = infor + "已成功進入到聊天室!";

                    SendMsg(msg);

                    //每有一個客戶端接入時，需要有一個線程進行服務

                    Thread threadClient = new Thread(ReciveMsg);//帶參的方法可以把傳遞的參數放到start中
                    threadClient.IsBackground = true;

                    //創建的新的對應的Socket和客戶端Socket進行通信
                    threadClient.Start(connectClient);
                }
            }
        }

        /// 服務器接收到客戶端發送的消息
        private void ReciveMsg(object o)
        {
            //Socket connectClient = (Socket)o; //與下面效果一樣

            Socket connectClient = o as Socket;//connectClient負責客戶端的通信
            IPEndPoint endPoint = null;
            while (true)
            {
                try
                {
                    ///定義服務器接收的字節大小
                    byte[] arrMsg = new byte[1024 * 1024];

                    ///接收到的信息大小(所占字節數)
                    int length = connectClient.Receive(arrMsg);

                    

                    if (length > 0)
                    {
                        string recMsg = Encoding.UTF8.GetString(arrMsg, 0, length);
                        //獲取客戶端的端口號
                        endPoint = connectClient.RemoteEndPoint as IPEndPoint;
                        //服務器顯示客戶端的端口號和消息
                        listBox_log.Items.Add(DateTime.Now + "[" + endPoint.Port.ToString() + "]：" + recMsg);

                        //服務器(connectClient)發送接收到的客戶端信息給客戶端
                        SendMsg("[" + endPoint.Port.ToString() + "]：" + recMsg);
                    }
                }
                catch (Exception)
                {
                    ///移除添加在字典中的服務器和客戶端之間的線程
                    clientList.Remove(endPoint.ToString());

                    connectClient.Dispose();

                    


                }
            }
        }

        /// 服務器發送消息，客戶端接收
        private void SendMsg(string str)
        {
            ///遍歷出字典中的所有線程
            foreach (var item in clientList)
            {
                byte[] arrMsg = Encoding.UTF8.GetBytes(str);

                ///獲取鍵值(服務器），發送消息
                item.Value.Send(arrMsg);
            }
        }
    }
}

客戶端：

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

namespace csharp_Client
{
    public partial class Client : Form
    {
        public Client()
        {
            InitializeComponent();

            ///多線程編程中，如果子線程需要使用主線程中創建的對象和控件，最好在主線程中體現進行檢查取消
            CheckForIllegalCrossThreadCalls = false;
        }

        /// 創建客戶端
        private Socket client;

        private void button_connect_Click(object sender, EventArgs e)
        {
            ///創建客戶端
            client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
            ///IP地址
            IPAddress ip = IPAddress.Parse(textBox_address.Text);
            ///端口號
            IPEndPoint endPoint = new IPEndPoint(ip, int.Parse(textBox_port.Text));
            ///建立與服務器的遠程連接
            try
            { 
                client.Connect(endPoint);
            }
            catch(Exception)
            {
                MessageBox.Show("地址或端口錯誤！！！！");
                return;
            }
            ///線程問題
            Thread thread = new Thread(ReciveMsg);
            thread.IsBackground = true;
            thread.Start(client);
        }

        /// 客戶端接收到服務器發送的消息
        private void ReciveMsg(object o)
        {
            Socket client = o as Socket;
            while (true)
            {
                try
                {
                    ///定義客戶端接收到的信息大小
                    byte[] arrList = new byte[1024 * 1024];
                    ///接收到的信息大小(所占字節數)
                    int length = client.Receive(arrList);
                    string msg = DateTime.Now + Encoding.UTF8.GetString(arrList, 0, length);
                    listBox_log.Items.Add(msg);
                }
                catch (Exception)
                {
                    ///關閉客戶端
                    client.Close();
                }
            }
        }

        /// 客戶端發送消息給服務端
        private void button_send_Click(object sender, EventArgs e)
        {
            if (textBox_message.Text != "")
            {
                SendMsg(textBox_message.Text);
            }
        }

        /// 客戶端發送消息，服務端接收
        private void SendMsg(string str)
        {
            byte[] arrMsg = Encoding.UTF8.GetBytes(str);
            client.Send(arrMsg);
        }


        private void Client_FormClosed(object sender, FormClosedEventArgs e)
        {
            if(client!=null) client.Close();
        }
    }
}