C#构建高性能TCP服务器：详解Socket编程及客户端管理

这篇文章将详细介绍如何使用C#以及Socket编程构建一个高性能的TCP服务器。我们将涵盖以下内容：

监听特定端口的连接请求* 创建新的线程处理每个客户端连接* 接收和解析客户端消息* 向客户端发送响应* 管理多个客户端连接

代码示例csharpusing System;using System.Collections.Generic;using System.IO;using System.Linq;using System.Net.Sockets;using System.Net;using System.Text;using System.Threading.Tasks;

namespace UdpClientDemo_Server{ internal class Server { TcpListener server; Action ShowMsg; IPEndPoint localEp; List userList = new List(); TcpClient remote_client;

    public Server(Action<String> ShowMsg, String localIp, int port)        {            this.ShowMsg = ShowMsg;            this.localEp = new IPEndPoint(IPAddress.Parse(localIp), port);            server = new TcpListener(localEp);            server.Start();            Task.Run(() =>            {                StartJS();            });        }        private void StartJS()        {            while (true)            {                remote_client = server.AcceptTcpClient();                SUser newUser = new SUser(ShowMsg, remote_client);



            userList.Add(newUser);                String remoteEp = remote_client.Client.RemoteEndPoint.ToString();                                ShowMsg(remoteEp + '上线了');                NetworkStream ns = remote_client.GetStream();

            BinaryReader br = new BinaryReader(ns);                Task.Run(() =>                {                    while (true)                    {

                    try                        {                            String sss = br.ReadString();                            ShowMsg(remoteEp + '>'+ sss);                        }                        catch                        {                            ShowMsg('客户端掉线了！');                            break;                        }

                }                });            }        }        public void Send(String str, int userIndex)        {            SUser findUser = null;            int i = 1;            foreach (SUser u in userList)            {                if (userIndex == i)                {                    findUser = u;                    break;                }                i++;            }            findUser.Send(str);        }    }}

代码解释

创建Server类: Server 类用于管理服务器的操作, 包括监听连接、处理消息和管理客户端。2. 初始化Server: 构造函数接收一个用于显示消息的委托 ShowMsg、本地IP地址和端口号。它创建了一个 TcpListener 对象并开始监听指定端口的连接请求。3. StartJS方法: 该方法在一个循环中不断接受客户端连接。 * 每当有新的客户端连接, 它会创建一个新的 SUser 对象来表示该客户端，并将该对象添加到 userList 中。 * 同时，它会启动一个新的线程来处理该客户端的消息。4. 消息处理: 在每个客户端的线程中, 服务器会不断地从网络流中读取数据。 * 如果读取到数据，它会调用 ShowMsg 委托将消息显示在界面上。 * 如果读取过程中出现异常，则认为客户端断开连接，并结束该线程。5. 发送消息: Send 方法用于向指定的客户端发送消息。

总结

通过以上步骤，我们使用C#和Socket编程实现了一个简单的TCP服务器。该服务器能够监听连接请求、处理来自多个客户端的消息，并向指定客户端发送响应。这为构建更复杂的网络应用程序奠定了基础。