阅读量:0
要在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<TcpClient> _clients = new List<TcpClient>(); 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); } } } - 保存并运行ChatClient项目。多个客户端可以同时连接到服务器并发送消息。
这个示例展示了如何使用C#创建一个基本的TCP/IP聊天室。你可以根据需要对其进行扩展和优化。
