C#中TCP通信的实现示例

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;

class TcpServer
{
    static void Main()
    {
        // 创建TCP监听器
        TcpListener server = new TcpListener(IPAddress.Any, 12345);
        
        // 启动监听
        server.Start();
        Console.WriteLine("服务器正在监听端口 12345...");

        // 接受客户端连接
        TcpClient client = server.AcceptTcpClient();
        Console.WriteLine("客户端连接成功!");

        // 获取网络流
        NetworkStream stream = client.GetStream();

        // 读取客户端发送的数据
        byte[] buffer = new byte[256];
        int bytesRead;

        while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) != 0)
        {
            string message = Encoding.UTF8.GetString(buffer, 0, bytesRead);
            Console.WriteLine("收到消息: " + message);

            // 向客户端发送回复消息
            byte[] response = Encoding.UTF8.GetBytes("服务器已收到消息");
            stream.Write(response, 0, response.Length);
        }

        // 关闭连接
        client.Close();
        server.Stop();
    }
}

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;

class TcpClientExample
{
    static void Main()
    {
        // 创建TCP客户端
        TcpClient client = new TcpClient();
        
        // 连接到服务端（localhost:12345）
        client.Connect("127.0.0.1", 12345);
        Console.WriteLine("已连接到服务器");

        // 获取网络流
        NetworkStream stream = client.GetStream();

        // 发送消息到服务端
        string message = "你好，服务器!";
        byte[] buffer = Encoding.UTF8.GetBytes(message);
        stream.Write(buffer, 0, buffer.Length);
        Console.WriteLine("已发送消息: " + message);

        // 接收服务端的回复
        buffer = new byte[256];
        int bytesRead = stream.Read(buffer, 0, buffer.Length);
        string response = Encoding.UTF8.GetString(buffer, 0, bytesRead);
        Console.WriteLine("收到回复: " + response);

        // 关闭连接
        client.Close();
    }
}