处理 WinRT StreamSocket 断开连接(服务器端和客户端)

本文关键字:服务器端 客户端 连接 WinRT StreamSocket 断开 处理 | 更新日期: 2023-09-27 18:30:51

我有一个为Windows 8/WinRT编写的应用程序,它使用StreamSocket API与服务器建立流连接。也就是说,服务器将数据流式传输到客户端,有时带有元标记,并且可以随时断开连接。

我遇到的问题是我不知道如何检测服务器何时断开连接。StreamSocket 类(无论是其输入或输出流)上似乎没有任何事件或属性,还是与连接状态相关的 DataReader/DataWriter 类。

最重要的是,在服务器端与客户端断开连接后,DataReader 方法 ReadAsync 不会失败。相反,据我所知,该操作成功了,并且它填充到其缓冲区中的数据只是服务器发送给它的最后一件事(即它没有清除其内部缓冲区,即使我可以看到它已经"消耗"了缓冲区每次我调用 ReadByte)。它对每次后续调用 ReadAsync 都会执行此操作 - 使用服务器在断开连接之前最后发送的内容重新填充缓冲区。下面是代码的简化版本:

    public async Task TestSocketConnectionAsync()
    {
        var socket = new StreamSocket();
        await socket.ConnectAsync(new HostName(Host), Port.ToString(),
            SocketProtectionLevel.PlainSocket);
        var dr = new DataReader(socket.InputStream);
        dr.InputStreamOptions = InputStreamOptions.Partial;
        this.cts = new CancellationTokenSource();
        this.listenerOperation = StartListeningAsync(dr, cts);
    }
    public async Task StartListeningAsync(DataReader dr, CancellationTokenSource cts)
    {
        var token = cts.Token;
        while (true)
        {
            token.ThrowIfCancellationRequested();
            var readOperation = dr.LoadAsync(1024);
            var result = await readOperation;
            if (result <= 0 || readOperation.Status != Windows.Foundation.AsyncStatus.Completed)
            {
                cts.Cancel(); // never gets called, status is always Completed, result always > 0
            }
            else
            {
                while (dr.UnconsumedBufferLength > 0)
                {
                    byte nextByte = dr.ReadByte();
                    // DriveStateMachine(nextByte);
                }
            }
        }
    }

处理 WinRT StreamSocket 断开连接(服务器端和客户端)

也就是说,服务器将数据流式传输到客户端,有时带有元标记,并且可以随时断开连接。我遇到的问题是我不知道如何检测服务器何时断开连接。

另一端可以将"优雅"套接字闭合检测为 0 长度读取。也就是说,它就像一个常规的流结束。

"中止"套接字闭合更棘手。您必须发送数据以检测另一端是否已关闭,一旦写入失败,任何其他读取或写入都应失败(例外)。如果您的协议不允许您发送数据,那么您必须假设超时到期后连接错误并关闭它。:(

根据应用程序的不同,"中止"套接字关闭可能是正常的 - 特别是,可以编写非常繁忙的服务器来夹紧关闭其连接,因为它允许它们更快地回收资源(避免步套接字关闭握手)。

StreamSocket 类(无论是其输入或输出流)上似乎没有任何事件或属性,还是与连接状态相关的 DataReader/DataWriter 类。

DataReader/DataWriter不关心"连接"。他们真的只是BitConverter,只是这次设计得更好。

我猜StreamSocket没有"连接"属性的原因是因为Socket.Connected几乎无用且绝对具有误导性。


我会尝试直接使用 StreamSocket.InputStream.ReadAsync 而不是使用 DataReader ,因为无论如何您只是在读取字节。听起来您可能在 DataReader 中发现了一个错误,如果InputStream.ReadAsync按预期工作,您应该在 Microsoft Connect 上报告该错误。另请参阅此相关论坛帖子。