4

我在继承的一些代码中有一个奇怪的行为 - 下面的简化示例演示了如果内置到普通控制台应用程序中的问题。

WhoIs 在第 5 次调用时达到其使用限额 - 并返回一条消息 + 关闭套接字。使用 ReadLineAsync 这会产生一个 SocketException 和一些 IOExceptions - 有时这些被捕获在 catch 块中，一切都应该是，大多数时候它们没有被捕获并且程序只是挂起 - 在 VS 调试器中的 Break all 向我展示了其中一个在主线程上调用 Console.WriteLine。直接在调试器外部运行 .exe 文件时，此行为仍然存在。

谁能看到这是什么/为什么会发生？

我实际上可以通过使用 Peek() 来解决我的问题，但我想知道没有被捕获的异常以及“死锁”是怎么回事。大概是某种线程或上下文问题。如果这是我正在做的事情，我想知道是什么，这样我就可以在其他地方避免它！

using System;
using System.IO;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

namespace AsyncIssueConsoleApplication
{
class Program
{
    static void Main(string[] args)
    {
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.WriteLine(Task.Run(() => LookupAsync("elasticsearch.org")).Result);
        Console.ReadLine();
    }

    private static async Task<string> LookupAsync(string domain)
    {
        StringBuilder builder = new StringBuilder();
        TcpClient tcp = new TcpClient();
        await tcp.ConnectAsync("whois.pir.org", 43).ConfigureAwait(false);
        string strDomain = "" + domain + "\r\n";
        byte[] bytDomain = Encoding.ASCII.GetBytes(strDomain.ToCharArray());
        try
        {
            using (Stream s = tcp.GetStream())
            {
                await s.WriteAsync(bytDomain, 0, strDomain.Length).ConfigureAwait(false);
                using (StreamReader sr = new StreamReader(s, Encoding.ASCII))
                {
                    try
                    {
                        //This is fine
                        /*while (sr.Peek() >= 0)
                        {
                            builder.AppendLine(await sr.ReadLineAsync());
                        }*/

                        //This isn't - produces SocketException which usually isn't caught below
                        string strLine = await sr.ReadLineAsync().ConfigureAwait(false);
                        while (null != strLine)
                        {
                            builder.AppendLine(strLine);
                            strLine = await sr.ReadLineAsync().ConfigureAwait(false);
                        }
                    }
                    catch (Exception e)
                    {
                        //Sometimes the SocketException/IOException is caught, sometimes not
                        return builder.ToString();
                    }
                }
            }

        }
        catch (Exception e)
        {
            return builder.ToString();
        }
        return builder.ToString();
    }
}
}

建议的重复问答可能相关，但不能回答我可以看到的这个查询，当然不能完全回答：即我需要对 SynchronizationContext 做什么 - 我已经在使用 ConfigureAwait(false)。

当代码如上所述死锁时，堆栈跟踪是：

mscorlib.dll!System.Threading.Monitor.Wait(object obj, int millisecondsTimeout, bool exitContext)   Unknown
mscorlib.dll!System.Threading.Monitor.Wait(object obj, int millisecondsTimeout) Unknown
mscorlib.dll!System.Threading.ManualResetEventSlim.Wait(int millisecondsTimeout = -1, System.Threading.CancellationToken cancellationToken) Unknown
mscorlib.dll!System.Threading.Tasks.Task.SpinThenBlockingWait(int millisecondsTimeout, System.Threading.CancellationToken cancellationToken)    Unknown
mscorlib.dll!System.Threading.Tasks.Task.InternalWait(int millisecondsTimeout = -1, System.Threading.CancellationToken cancellationToken)   Unknown
mscorlib.dll!System.Threading.Tasks.Task<string>.GetResultCore(bool waitCompletionNotification = true)  Unknown
mscorlib.dll!System.Threading.Tasks.Task<System.__Canon>.Result.get()   Unknown
AsyncIssueConsoleApplication.exe!AsyncIssueConsoleApplication.Program.Main(string[] args = {string[0]}) Line 18 C#

IOException 是：{“无法从传输连接读取数据：现有连接被远程主机强制关闭。”}

SocketException 是：{“已建立的连接被主机中的软件中止”}

4

1 回答 1

1

我现在可以重现它。为了查看它挂在哪里，我切换到同步 IO。异步 IO 的一个常见调试问题是您无法看到当前待处理的 IO。这是您可能不想首先使用异步 IO 的一个关键原因。

在此处输入图像描述

在此处输入图像描述

它挂起是因为远程服务器没有关闭连接。仅当远程端关闭连接时，ReadLine呼叫才会结束。

这可能是速率限制代码中的错误。这也可能是协议的预期行为。也许您打算现在发送下一个请求？或者，也许您应该检测上一行的速率限制并自行关闭。

这不是线程问题。根本没有并发。所有LookupAsync实例都按顺序运行。

我还尝试正确关闭TcpClients 以防远程服务器在面对多个连接时表现不同。没有效果。不过，无论如何，您都应该处置您的资源。这是一个严重的泄漏。

于 2016-04-29T11:06:23.433 回答