1

我创建了简单的 tcp 服务器 - 它运行良好。

当我们切换到压力测试时，问题就开始了——因为我们的服务器应该处理许多并发打开的套接字——我们创建了一个压力测试来检查这一点。不幸的是，当并发打开的套接字数量在 100 左右时，看起来服务器阻塞并且无法及时响应新的连接请求。

我们已经尝试了几种类型的服务器 - 并且都产生相同的行为。

服务器：可以类似于这篇文章中的示例（都产生相同的行为）

如何编写可扩展的基于 Tcp/Ip 的服务器

这是我们正在使用的代码 - 当客户端连接时 - 服务器将挂起以保持套接字处于活动状态。

enter code here

公共类服务器

{
    private static readonly TcpListener listener = new TcpListener(IPAddress.Any, 2060);

    public Server()
    {
        listener.Start();
        Console.WriteLine("Started.");

        while (true)
        {
            Console.WriteLine("Waiting for connection...");
            var client = listener.AcceptTcpClient();
            Console.WriteLine("Connected!");
            // each connection has its own thread
            new Thread(ServeData).Start(client);
        }
    }

    private static void ServeData(object clientSocket)
    {
        Console.WriteLine("Started thread " + Thread.CurrentThread.ManagedThreadId);

        var rnd = new Random();
        try
        {
            var client = (TcpClient)clientSocket;
            var stream = client.GetStream();
            byte[] arr = new byte[1024];
            stream.Read(arr, 0, 1024);
            Thread.Sleep(int.MaxValue);

        }
        catch (SocketException e)
        {
            Console.WriteLine("Socket exception in thread {0}: {1}", Thread.CurrentThread.ManagedThreadId, e);
        }
    }
}

压力测试客户端：是一个简单的 tcp 客户端，一个接一个地循环和打开套接字

class Program
    {
        static List<Socket> sockets;
        static private void go(){
            Socket newsock = new Socket(AddressFamily.InterNetwork,
                                  SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint iep = new IPEndPoint(IPAddress.Parse("11.11.11.11"), 2060);
            try
            {
                newsock.Connect(iep);
            }
            catch (SocketException ex)
            {
                Console.WriteLine(ex.Message );
            }
            lock (sockets)
            {
                sockets.Add(newsock);
            }

        }
        static void Main(string[] args)
        {
            sockets = new List<Socket>();
            //int start = 1;// Int32.Parse(Console.ReadLine());
            for (int i = 1; i < 1000; i++)
            {   
                go();
                Thread.Sleep(200);
            }
            Console.WriteLine("press a key");
            Console.ReadKey();




        }
    }
}

有没有简单的方法来解释这种行为？如果 TCP 服务器会产生更好的结果，也许 c++ 实现？也许这实际上是一个客户端问题？

欢迎任何评论！

提供

4

2 回答 2

0

首先，每个连接设计的线程不太可能特别具有可扩展性，您最好将您的设计基于异步服务器模型，该模型在后台使用 IO 完成端口。但是，在这种情况下，这不太可能成为问题，因为您并没有真正对服务器施加太大压力。

其次，听积压是一个红鲱鱼。侦听积压用于为等待接受的连接提供队列。在此示例中，您的客户端使用同步连接调用，这意味着客户端在任何时候都不会有超过 1 次未完成的连接尝试。如果您在客户端中使用异步连接尝试，那么您可能会考虑调整监听积压。

第三，鉴于客户端代码没有显示它发送任何数据，您可以简单地发出读取调用并移除其后的睡眠，读取调用将阻塞。睡眠只会使事情变得混乱。

您是否在同一台机器上运行客户端和服务器？

这是客户端和服务器中的所有代码吗？

您可以尝试使用我的免费 TCP 测试客户端从问题空间中消除客户端，该客户端可在此处获得：http: //www.lenholgate.com/blog/2005/11/windows-tcpip-server-performance.html

同样，您可以针对我的一台简单的免费服务器测试您的测试客户端，例如：http: //www.lenholgate.com/blog/2005/11/simple-echo-servers.html

我看不出代码有任何明显错误（除了整体设计）。

于 2010-12-29T20:06:11.023 回答
0

指定一个巨大的侦听器积压：http: //msdn.microsoft.com/en-us/library/5kh8wf6s.aspx

于 2010-12-29T14:59:08.113 回答