如何使用C＃真正快速地发送大量Web服务请求？

Question

我正在研究一个程序，该程序将从我们的数据库中请求信息，将该信息发送到Web服务，然后将其登录到WebService响应回到数据库。

这是一种调用Web服务的方法，它使用其他一些自定义类，但一切都应该是相当自我解释的。

public void doTransitTimeLoop(string botName)
{
    while (keepProcessingTransitTime)
    // loop until keep processing is set to false from the UI thread
    {
        // send the start query
        DataTable dt = sendSqlQuery($"execute fex.transitStart @Bot='{botName}', @TransitCount={fexTransitInstaces}");

        List<TransitTimePackage> packages = new List<TransitTimePackage>();
        // TransitTimePackage is pretty much just a container class

        string returnQuery = "";
        // loop through rows on datatable 
        foreach (DataRow row in dt.Rows)
        // create a package object from each row
        {
            TransitTimePackage package = TransitTimePackage.createFromDataRow(this, row);

            packages.Add(package);

            ThreadPool.QueueUserWorkItem((object stateInfo) => {
                RestResponse res = package.sendWebserviceRequest();
                package.parseResponse(res);
                returnQuery += package.sqlQuery + "\n";
            });
        }

        // check if all the packages are done, if they aren't, sleep 1 sec
        while (packages.Any(p => p.StatusCode == HttpStatusCode.Created))
            Thread.Sleep(1000);

        DataTable d = sendSqlQuery(returnQuery);

    }
}

目前，我只是将所有网络服务调用推入ThreadPool，以便它们可以同时运行，但这只是让我每分钟大约100个呼叫，因为ThreadPool一次只能处理4个线程。理想情况下，我可以尽快发送我的所有电话，然后等待所有电话完成并继续执行我的代码，但是我不确定是否可能（网络不是我的strongsuit aha）。

任何帮助更快的帮助，都将不胜感激。谢谢！

Answer 1

我不知道为什么您的ThreadPool仅产生4个线程；我什至不知道这是否确实如此。但是，如果是这样，您可以尝试使用threadpool.setminthreads（ https://learn.microsoft.com/en-en-us/dotnet/api/api/api/system.threadpool.threadpool.threadpool.setpool.setpool.setminthreads?views？ ）

您的另一个选项是使用asynchronous套接字（请参阅 https://learn.microsoft.com/en-us/dotnet/api/api/system.sockets.sockets.sockets.socket.beginconnect?view=net-6.0 ）并打开大量异步插座，而无需每个插座一个线。