C#基于Socket实现简单聊天室功能攻略

简介

本攻略旨在介绍如何使用C#语言基于Socket实现一个简单聊天室的功能。在本攻略中，我们将使用Socket API来创建网络连接，使用TCP协议进行数据传输。

需要注意的是，本攻略主要面向有一定C#编程基础的读者，对Socket编程有一定了解。

步骤

以下是基于Socket实现简单聊天室功能的步骤：

第一步：创建服务端

首先，我们需要创建一个服务端来接受客户端的连接请求。在C#中，可以使用Socket类来创建一个TCP服务端。代码如下：

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

namespace SocketChatRoom
{
    class Server
    {
        private Socket serverSocket;
        private List<Socket> clientList;

        public Server()
        {
            // 创建一个IPv4 TCP Socket
            serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            // 绑定IP地址和端口号
            IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 1234);
            serverSocket.Bind(endPoint);

            // 开始监听连接
            serverSocket.Listen(10);
            Console.WriteLine("Server started.");

            // 创建客户端Socket列表
            clientList = new List<Socket>();

            // 开始等待连接请求
            while (true)
            {
                Socket clientSocket = serverSocket.Accept();
                Console.WriteLine("Accepted a client.");

                // 将客户端Socket加入列表
                clientList.Add(clientSocket);

                // 新开一个线程处理客户端消息
                Task.Factory.StartNew(() =>
                {
                    ReceiveMessage(clientSocket);
                });
            }
        }

        private void ReceiveMessage(Socket clientSocket)
        {
            // 创建缓存区
            const int bufferSize = 1024;
            byte[] buffer = new byte[bufferSize];

            while (true)
            {
                try
                {
                    // 接收客户端数据
                    int receiveSize = clientSocket.Receive(buffer);
                    string message = Encoding.UTF8.GetString(buffer, 0, receiveSize);
                    Console.WriteLine(message);

                    // 将消息转发给所有客户端
                    SendMessageToAllClients(message, clientSocket);
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                    clientList.Remove(clientSocket);
                    break;
                }
            }
        }

        private void SendMessageToAllClients(string message, Socket excludeClient)
        {
            // 将消息转发给所有客户端
            foreach (Socket client in clientList)
            {
                if (client != excludeClient)
                {
                    client.Send(Encoding.UTF8.GetBytes(message));
                }
            }
        }
    }
}

在上述代码中，我们创建了一个名为Server的类来表示服务端。在构造函数中，我们首先创建了一个IPv4 TCP Socket，并绑定了IP地址和端口号，然后开始监听连接。当一个客户端连接进来后，我们将其Socket加入到客户端列表中，并开启一个新的线程用于处理客户端的消息。在ReceiveMessage方法中，我们使用一个while循环不断接收客户端的数据，并将其转发给所有客户端。

需要注意的是，在每次接收完客户端的数据后，我们都需要将其转发给所有客户端。在SendMessageToAllClients方法中，我们遍历客户端列表，将消息发送给所有客户端（除了源客户端）。

第二步：创建客户端

接下来，我们需要创建一个客户端来连接服务端，并发送消息到服务端。在C#中，也可以使用Socket类来创建一个TCP客户端。代码如下：

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

namespace SocketChatRoom
{
    class Client
    {
        private Socket clientSocket;

        public Client()
        {
            // 创建一个IPv4 TCP Socket
            clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            // 连接服务端
            IPEndPoint remoteEP = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 1234);
            clientSocket.Connect(remoteEP);

            // 开始接收服务端消息
            Task.Factory.StartNew(() =>
            {
                ReceiveMessage();
            });

            // 不断从控制台读取用户输入，发送到服务端
            while (true)
            {
                string message = Console.ReadLine();

                // 发送消息到服务端
                clientSocket.Send(Encoding.UTF8.GetBytes(message));
            }
        }

        private void ReceiveMessage()
        {
            // 创建缓存区
            const int bufferSize = 1024;
            byte[] buffer = new byte[bufferSize];

            while (true)
            {
                try
                {
                    // 接收服务端数据
                    int receiveSize = clientSocket.Receive(buffer);
                    string message = Encoding.UTF8.GetString(buffer, 0, receiveSize);
                    Console.WriteLine(message);
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                    break;
                }
            }
        }
    }
}

在上述代码中，我们创建了一个名为Client的类来表示客户端。在构造函数中，我们首先连接服务端，然后开启一个新的线程用于接收服务端的消息。在ReceiveMessage方法中，我们使用一个while循环不断接收服务端的数据，并将其输出到控制台。在循环外部，我们不断从控制台读取用户输入，并将其发送到服务端。

第三步：测试聊天室

现在我们已经完成了服务端和客户端的创建。我们可以先启动一个服务端，并等待1个或多个客户端连接。接着，我们启动一个或多个客户端，并输入消息。在服务端和所有客户端中，我们都可以看到所有的消息。

示例

以下是两个示例：

示例一

在本示例中，我们将启动一个服务端和两个客户端，并观察他们之间的通信。

步骤

启动服务端；
启动客户端1；
启动客户端2；
在客户端1中输入消息“Hello, client2!”，并按回车键；
在客户端2中输入消息“Hi, client1! How are you?”，并按回车键；
观察服务端和所有客户端中的信息输出。

输出

服务端：

Server started.
Accepted a client.
Hello, client2!
Accepted a client.
Hi, client1! How are you?

客户端1：

Hello, client2!

客户端2：

Hi, client1! How are you?

示例二

在本示例中，我们将启动一个服务端和三个客户端，并观察他们之间的通信。

步骤

启动服务端；
启动客户端1；
启动客户端2；
启动客户端3；
在客户端1中输入消息“Hello, all!”，并按回车键；
观察服务端和所有客户端中的信息输出。

输出

服务端：

Server started.
Accepted a client.
Accepted a client.
Accepted a client.
Hello, all!

客户端1：

Hello, all!

客户端2：

客户端3：

从输出中我们可以看到，在服务端和客户端1中都能看到消息“Hello, all!”，而客户端2和客户端3没有任何输出。这是因为在本示例中，我们只是在客户端1中发送了消息，而在服务端中将消息转发给了所有客户端，因此只有服务端和客户端1中能够看到消息。

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：C#基于Socket实现简单聊天室功能 - Python技术站

C#基于Socket实现简单聊天室功能

C#基于Socket实现简单聊天室功能攻略

简介

步骤

第一步：创建服务端

第二步：创建客户端

第三步：测试聊天室

示例

示例一

步骤

输出

示例二

步骤

输出

相关文章