中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

如何實現C# Socket的多線程通信

c#
小樊
88
2024-09-04 06:42:34
欄目: 編程語言

在C#中,使用Socket實現多線程通信可以通過創建一個服務器端和客戶端并為每個連接創建單獨的線程來完成。這里是一個簡單的示例,展示了如何實現多線程Socket通信:

  1. 首先,創建一個服務器端:
using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;

class Server
{
    private TcpListener _listener;

    public void Start(int port)
    {
        _listener = new TcpListener(IPAddress.Any, port);
        _listener.Start();

        Console.WriteLine("Server started on port: " + port);

        while (true)
        {
            // Accept incoming connections and create a new thread for each connection
            TcpClient client = _listener.AcceptTcpClient();
            Thread clientThread = new Thread(HandleClient);
            clientThread.Start(client);
        }
    }

    private void HandleClient(object obj)
    {
        TcpClient client = (TcpClient)obj;
        NetworkStream stream = client.GetStream();

        // Read and process data from the client
        byte[] buffer = new byte[256];
        int bytesRead = stream.Read(buffer, 0, buffer.Length);
        string receivedData = System.Text.Encoding.ASCII.GetString(buffer, 0, bytesRead);

        Console.WriteLine("Received data: " + receivedData);

        // Send response to the client
        string response = "Server received: " + receivedData;
        byte[] responseData = System.Text.Encoding.ASCII.GetBytes(response);
        stream.Write(responseData, 0, responseData.Length);

        // Close the connection
        stream.Close();
        client.Close();
    }
}
  1. 然后,創建一個客戶端:
using System;
using System.Net.Sockets;

class Client
{
    public void Connect(string serverIp, int port)
    {
        TcpClient client = new TcpClient(serverIp, port);
        NetworkStream stream = client.GetStream();

        // Send data to the server
        string message = "Hello, Server!";
        byte[] data = System.Text.Encoding.ASCII.GetBytes(message);
        stream.Write(data, 0, data.Length);

        // Receive response from the server
        byte[] buffer = new byte[256];
        int bytesRead = stream.Read(buffer, 0, buffer.Length);
        string response = System.Text.Encoding.ASCII.GetString(buffer, 0, bytesRead);

        Console.WriteLine("Server response: " + response);

        // Close the connection
        stream.Close();
        client.Close();
    }
}
  1. 最后,在主程序中啟動服務器和客戶端:
using System;
using System.Threading;

class Program
{
    static void Main(string[] args)
    {
        // Start the server
        Server server = new Server();
        Thread serverThread = new Thread(() => server.Start(8000));
        serverThread.Start();

        // Give the server some time to start
        Thread.Sleep(1000);

        // Connect the client
        Client client = new Client();
        client.Connect("127.0.0.1", 8000);

        Console.ReadLine();
    }
}

這個示例中,服務器監聽指定端口上的連接請求,并為每個連接創建一個新線程。客戶端連接到服務器并發送一條消息,然后接收服務器的響應。這種方法可以輕松地擴展到處理多個客戶端連接。

0
太仓市| 安化县| 徐州市| 惠来县| 桃园县| 隆林| 新疆| 涞源县| 古交市| 普洱| 万州区| 长垣县| 盐城市| 阿克陶县| 阿图什市| 上杭县| 原平市| 兰溪市| 武城县| 广宗县| 万安县| 临泽县| 铁岭市| 五莲县| 日喀则市| 汾西县| 寿宁县| 榕江县| 息烽县| 洛川县| 蓬溪县| 华容县| 南岸区| 长岛县| 睢宁县| 靖州| 弥勒县| 泌阳县| 松溪县| 宽甸| 札达县|