C#socket編程之實現一個簡單的TCP通信

TCP（TransmissionControl Protocol）傳輸控制協議。

是一種可靠的、面向連接的協議（eg:打電話）、傳輸效率低全雙工通信（發送緩存&接收緩存）、面向字節流。使用TCP的應用：Web瀏覽器；電子郵件、文件傳輸程序。

TCP編程的服務器端一般步驟是：

　　1、創建一個socket，用函數socket()。

　　2、設置socket屬性。

　　3、綁定本機的IP地址、端口等信息到socket上，用函數bind()。

　　4、開啟監聽，用函數listen()。

      5、接收客戶端上來的連接，用函數accept()。

      6、通過accept()返回相應客戶端的socket建立專用的通信通道。

　　7、收發數據，用函數send()和recv()，或者read()和write()。

　　8、關閉網絡連接。

　　9、關閉監聽。

TCP編程的客戶端一般步驟是：

　　1、創建一個socket，用函數socket()。

　　2、設置socket屬性。　

　　3、設置要連接的對方的IP地址和端口等屬性。

　　4、連接服務器，用函數connect()。

　　5、收發數據，用函數send()和recv()，或者read()和write()。

　　6、關閉網絡連接。　

---------------------
作者：subin_iecas
來源：CSDN
原文：https://blog.csdn.net/subin_iecas/article/details/80289513 

 

 

---

 

下面是一個簡單的TCP的通信程序源碼

主要功能是模擬一個群聊，當多個客戶端連接進來后，任意一個客戶端發送的消息都將被服務器端接收並群發給所有客戶端

---

 

服務器端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace _037_test
{
    class Program
    {
        static void Main(string[] args)
        {
            Server s = new Server("192.168.0.105", 8888);
            s.Start();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace _037_test
{
    class Server
    {
        Socket serverSock;
        List<Socket> clientList = new List<Socket>();
        public Server(string ip, int port)
        {
            //創建socket套接字
            serverSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //檢測ip地址是否有誤
            IPAddress ipAdd;
            if (!IPAddress.TryParse(ip, out ipAdd))
            {
                Console.WriteLine("ip有誤，服務器創建失敗");
                return;
            }
            //綁定ip地址和端口；
            IPEndPoint point = new IPEndPoint(ipAdd, port);
            serverSock.Bind(point);
            //無限監聽接收
            serverSock.Listen(0);

        }

        public void Start()
        {
            Thread th = new Thread(AcceptClient);
            th.Start();
            SendToAll();
        }

        public void AcceptClient()
        {
            Console.WriteLine("等待連接");
            while (true)
            {
                Socket client = serverSock.Accept();//等待接收用戶的連接，並返回連接成功的用戶
                IPEndPoint clientPoint = client.RemoteEndPoint as IPEndPoint;//獲取所連接的用戶的ip
                Console.WriteLine(clientPoint.Address+"已連接");
                clientList.Add(client);
                Thread clientT = new Thread(ReceiveMessage);
                clientT.Start(client);
            }
        }

        public void SendToAll()
        {
            while (true)
            {
                string message = "管理員："+Console.ReadLine();
                byte[] messageBytes = Encoding.Default.GetBytes(message);
                for (int i = 0; i < clientList.Count; i++)
                {
                    try
                    {
                        clientList[i].Send(messageBytes);
                    }
                    catch (SocketException)
                    {
                        Console.WriteLine("有一個客戶端下線");
                        clientList.RemoveAt(i);
                        i--;
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine(e.Message);
                    }
                }
            }
        }

        public void ReceiveMessage(object obj)
        {
            while (true)
            {
                Socket client = obj as Socket;//將線程的start方法傳入的obj轉回socket類型
                byte[] messageBytes = new byte[100 * 1024];//數據容器
                try
                {
                    int num = client.Receive(messageBytes);//receive方法返回字節長度，並把內容存在傳入的數組中
                    IPEndPoint clientPoint = client.RemoteEndPoint as IPEndPoint;//獲取所連接的用戶的ip
                    Console.WriteLine(clientPoint.Address+"：" + Encoding.Default.GetString(messageBytes, 0, num));

                    //服務器端負責將從客戶端收到的消息轉發給所有客戶端
                    string message = clientPoint.Address + ":" + Encoding.Default.GetString(messageBytes, 0, num);
                    foreach (var item in clientList)
                    {
                        if (item!=client)
                        {
                            item.Send(Encoding.Default.GetBytes(message));
                        }
                    }
                }
                catch (Exception)
                {
                    Console.WriteLine("有一個客戶端離開");
                    clientList.Remove(client);
                    break;
                }
            }
            
        }
    }
}

---

客戶端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace _038_test
{
    class Program
    {
        static void Main(string[] args)
        {
            Client c = new Client("192.168.0.105", 8888);
            c.Start();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace _038_test
{
    class Client
    {
        Socket clientSock;
        public Client(string ip, int port)
        {
            clientSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                IPEndPoint point = new IPEndPoint(IPAddress.Parse(ip), port);
                clientSock.Connect(point);
            }
            catch (Exception)
            {
                Console.WriteLine("服務器沒有開啟");
                return;
            }

            Console.WriteLine("已連接服務器");
        }

        public void Start()
        {
            Thread th = new Thread(SendMessage);
            th.Start();
            ReceiveMessage();
        }

        public void SendMessage()
        {
            try
            {
                while (true)
                {
                    string message = Console.ReadLine();
                    byte[] messageBytes = Encoding.Default.GetBytes(message);
                    clientSock.Send(messageBytes);
                }
            }
            catch (Exception)
            {
                Console.WriteLine("服務器斷開");
                return;
            }
            
        }

        public void ReceiveMessage()
        {
            try
            {
                while (true)
                {
                    byte[] messageBytes = new byte[100 * 1024];
                    int num = clientSock.Receive(messageBytes);
                    Console.WriteLine(Encoding.Default.GetString(messageBytes, 0, num));
                }
            }
            catch (Exception)
            {
                Console.WriteLine("服務器斷開");
                return;
            }
        }

    }
}

---

運行結果：