我有一个为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);
}
}
}
}
也就是说,服务器将数据流式传输到客户端,有时带有元标记,并且可以随时断开连接。我遇到的问题是我不知道如何检测服务器何时断开连接。
另一端可以将"优雅"套接字闭合检测为 0 长度读取。也就是说,它就像一个常规的流结束。
"中止"套接字闭合更棘手。您必须发送数据以检测另一端是否已关闭,一旦写入失败,任何其他读取或写入都应失败(例外)。如果您的协议不允许您发送数据,那么您必须假设超时到期后连接错误并关闭它。:(
根据应用程序的不同,"中止"套接字关闭可能是正常的 - 特别是,可以编写非常繁忙的服务器来夹紧关闭其连接,因为它允许它们更快地回收资源(避免四步套接字关闭握手)。
StreamSocket 类(无论是其输入或输出流)上似乎没有任何事件或属性,还是与连接状态相关的 DataReader/DataWriter 类。
DataReader
/DataWriter
不关心"连接"。他们真的只是BitConverter
,只是这次设计得更好。
我猜StreamSocket
没有"连接"属性的原因是因为Socket.Connected
几乎无用且绝对具有误导性。
我会尝试直接使用 StreamSocket.InputStream.ReadAsync
而不是使用 DataReader
,因为无论如何您只是在读取字节。听起来您可能在 DataReader
中发现了一个错误,如果InputStream.ReadAsync
按预期工作,您应该在 Microsoft Connect 上报告该错误。另请参阅此相关论坛帖子。