C# TCP實現多個客戶端與服務端 數據 傳輸

實現一個客戶端和一個服務端通信
可以同時收發多條信息
使用C#語言，通過socket進行通信，基於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 testServer
{
    class Program
    {
        static void Main(string[] args)
        {
            Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//創建服務端
            EndPoint point = new IPEndPoint(IPAddress.Prase("127.0.0.1"), 8888);
            server.Bind(point);//綁定端口號和IP
            server.Listen(10);//開啟監聽
            Console.WriteLine("服務器開啟。。。。");
            Socket client = server.Accept();//保存連接進來的客戶端
            client.Send(Encoding.UTF8.GetBytes("你已經進入服務"));//給客戶端發送消息，提示客戶端連接成功


            Thread t1 = new Thread(reciveMsg);
            t1.Start(client);//開啟線程接收消息

            Thread t2 = new Thread(sendMsg);
            t2.Start(client);//開啟線程發送消息

        }

        static void reciveMsg(object obj)
        {
            Socket client = obj as Socket;
            while (true)
            {
                byte[] buffer = new byte[1024];
                try
                {
                    int length = client.Receive(buffer);
                    string res = Encoding.UTF8.GetString(buffer, 0, length);
                    Console.WriteLine("接收到的消息：" + res);
                }
                catch (Exception e)
                {
                    IPEndPoint point = client.RemoteEndPoint as IPEndPoint;
                    Console.WriteLine(point.ToString()+"斷開連接。。。");
                    break;
                }

            }

        }

        static void sendMsg(object obj)
        {
            Socket client = obj as Socket;
            while (true)
            {
                string s = Console.ReadLine();
                client.Send(Encoding.UTF8.GetBytes(s));
            }
        }
    }
}

 

客戶端代碼

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 testClient
{
    class Program
    {
       static Socket client;
       static Thread t1;
       static Thread t2;
       static bool isLife = false;//標記是否連接到服務器
        static void Main(string[] args)
        {
             client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//創建客戶端
            client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8888));//將客戶端連接到服務器


            isLife = true;
             t1 = new Thread(reciveMsg);
            t1.Start();//開啟線程接收消息

             t2 = new Thread(sendMsg);
            t2.Start();//開啟線程發送消息

            //Console.ReadKey();
        }

        static void reciveMsg()
        {
            while (isLife)
            {
                byte[] buffer = new byte[1024];
                try{
                    int length = client.Receive(buffer);
                    string res = Encoding.UTF8.GetString(buffer, 0, length);
                    Console.WriteLine("接收到的消息：" + res);
                }catch(Exception e){
                    Console.WriteLine("reciveMsg:  End");
                    break;
                }

            }

        }

        static void sendMsg() {
            while (isLife)
            {
                string s = Console.ReadLine();
                try {
                    client.Send(Encoding.UTF8.GetBytes(s));
                }catch (Exception e){
                    Console.WriteLine("sendMsg:  End");
                    break;
                }

                if(s.Equals("886")){
                    isLife = false;
                    client.Close();
                }
            }
        }
    }
}

 

 

效果圖：