C#实现的Socket服务器端、客户端代码分享

C#语言中，Socket编程用于实现网络通信，服务器端负责监听端口、接收连接和处理数据请求；客户端则建立连接、发送请求并接收响应。

服务器端代码

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
class Program
{
    static void Main(string[] args)
    {
        // 创建IPEndPoint实例，指定服务器的IP地址和端口号
        IPEndPoint serverEndPoint = new IPEndPoint(IPAddress.Any, 12345);
        // 创建Socket对象
        Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        // 将Socket绑定到指定的IPEndPoint
        serverSocket.Bind(serverEndPoint);
        // 开始监听连接请求
        serverSocket.Listen(10);
        Console.WriteLine("服务器已启动，等待客户端连接...");
        while (true)
        {
            // 接受客户端的连接请求
            Socket clientSocket = serverSocket.Accept();
            Console.WriteLine("客户端已连接：" + clientSocket.RemoteEndPoint.ToString());
            // 从客户端接收数据
            byte[] buffer = new byte[1024];
            int bytesReceived = clientSocket.Receive(buffer, 0, buffer.Length, 0);
            if (bytesReceived > 0)
            {
                string receivedData = Encoding.UTF8.GetString(buffer, 0, bytesReceived);
                Console.WriteLine("收到客户端消息：" + receivedData);
                // 向客户端发送响应数据
                string responseData = "服务器已收到消息：" + receivedData;
                byte[] responseBuffer = Encoding.UTF8.GetBytes(responseData);
                clientSocket.Send(responseBuffer, 0, responseBuffer.Length, 0);
            }
            // 关闭与该客户端的连接
            clientSocket.Close();
        }
    }
}

客户端代码

using System;
using System.Net.Sockets;
using System.Text;
class Program
{
    static void Main(string[] args)
    {
        // 创建IPEndPoint实例，指定服务器的IP地址和端口号
        IPEndPoint serverEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 12345);
        // 创建Socket对象
        Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        // 连接到服务器
        clientSocket.Connect(serverEndPoint);
        Console.WriteLine("已连接到服务器：" + serverEndPoint.ToString());
        // 向服务器发送数据
        string sendData = "Hello, Server!";
        byte[] sendBuffer = Encoding.UTF8.GetBytes(sendData);
        clientSocket.Send(sendBuffer, 0, sendBuffer.Length, 0);
        Console.WriteLine("已发送消息到服务器：" + sendData);
        // 从服务器接收数据
        byte[] receiveBuffer = new byte[1024];
        int bytesReceived = clientSocket.Receive(receiveBuffer, 0, receiveBuffer.Length, 0);
        if (bytesReceived > 0)
        {
            string receivedData = Encoding.UTF8.GetString(receiveBuffer, 0, bytesReceived);
            Console.WriteLine("收到服务器响应：" + receivedData);
        }
        // 关闭与服务器的连接
        clientSocket.Close();
    }
}