C#实现基于TCP/IP的聊天室-乐工具技术知识

要在C#中实现一个基于TCP/IP的聊天室，你需要创建一个服务器端和客户端

首先，创建一个新的C#控制台应用程序项目，命名为"ChatServer"。
在项目中添加以下命名空间：

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

在Program类中添加以下代码：

class Program
{
    private static TcpListener _listener;
    private static List _clients = new List();

    static void Main(string[] args)
    {
        StartServer();
    }

    private static void StartServer()
    {
        _listener = new TcpListener(IPAddress.Any, 8000);
        _listener.Start();
        Console.WriteLine("服务器已启动，正在监听端口8000...");

        while (true)
        {
            TcpClient client = _listener.AcceptTcpClient();
            _clients.Add(client);
            Console.WriteLine($"客户端 {client.Client.RemoteEndPoint} 已连接");

            Thread clientThread = new Thread(new ParameterizedThreadStart(HandleClient));
            clientThread.Start(client);
        }
    }

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

        while (true)
        {
            try
            {
                byte[] buffer = new byte[1024];
                int bytesRead = stream.Read(buffer, 0, buffer.Length);
                string message = Encoding.UTF8.GetString(buffer, 0, bytesRead);

                if (message == "exit")
                {
                    _clients.Remove(client);
                    client.Close();
                    Console.WriteLine($"客户端 {client.Client.RemoteEndPoint} 已断开连接");
                    break;
                }

                BroadcastMessage(client, message);
            }
            catch (Exception ex)
            {
                Console.WriteLine($"客户端 {client.Client.RemoteEndPoint} 发生错误: {ex.Message}");
                _clients.Remove(client);
                client.Close();
                break;
            }
        }
    }

    private static void BroadcastMessage(TcpClient sender, string message)
    {
        foreach (TcpClient client in _clients)
        {
            if (client != sender)
            {
                NetworkStream stream = client.GetStream();
                byte[] buffer = Encoding.UTF8.GetBytes(message);
                stream.Write(buffer, 0, buffer.Length);
            }
        }
    }
}

保存并运行ChatServer项目。服务器将开始监听端口8000。
创建一个新的C#控制台应用程序项目，命名为"ChatClient"。
在项目中添加以下命名空间：

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

在Program类中添加以下代码：

class Program
{
    private static TcpClient _client;
    private static NetworkStream _stream;

    static void Main(string[] args)
    {
        ConnectToServer();
    }

    private static void ConnectToServer()
    {
        _client = new TcpClient("127.0.0.1", 8000);
        _stream = _client.GetStream();
        Console.WriteLine("已连接到服务器");

        Thread receiveThread = new Thread(ReceiveMessages);
        receiveThread.Start();

        SendMessages();
    }

    private static void ReceiveMessages()
    {
        while (true)
        {
            try
            {
                byte[] buffer = new byte[1024];
                int bytesRead = _stream.Read(buffer, 0, buffer.Length);
                string message = Encoding.UTF8.GetString(buffer, 0, bytesRead);
                Console.WriteLine(message);
            }
            catch (Exception ex)
            {
                Console.WriteLine($"发生错误: {ex.Message}");
                _client.Close();
                break;
            }
        }
    }

    private static void SendMessages()
    {
        while (true)
        {
            Console.Write("请输入消息: ");
            string message = Console.ReadLine();

            if (message == "exit")
            {
                _client.Close();
                break;
            }

            byte[] buffer = Encoding.UTF8.GetBytes(message);
            _stream.Write(buffer, 0, buffer.Length);
        }
    }
}