我正在创建一个 Win 8 商店应用程序,在其中使用 StreamSocket 连接到用 Java 编写的服务器。当我在调试中运行应用程序时,在 StreamSocket.ConnectAsync(...)、DataWriter.StoreAsync() 和 DataReader.LoadAsync(...) 上设置断点,它会连接、发送消息并接收返回的消息。然而,一旦我删除任何一个断点,该方法就不起作用了。我该如何解决这个问题?这是我的代码:
public async void Connect()
{
try
{
await socket.ConnectAsync(new Windows.Networking.HostName(ip),
"50000", SocketProtectionLevel.PlainSocket);
Connected = true;
}
catch (Exception e)
{
if (SocketError.GetStatus(e.HResult) == SocketErrorStatus.Unknown)
{
throw;
}
Windows.UI.Popups.MessageDialog md =
new Windows.UI.Popups.MessageDialog("Error: " + e.Message);
return;
}
return;
}
public async void HandShake()
{
try
{
//output
writer = new DataWriter(socket.OutputStream);
writer.UnicodeEncoding =
Windows.Storage.Streams.UnicodeEncoding.Utf8;
byte[] nameBytes = Encoding.UTF8.GetBytes(Name.ToCharArray());
writer.WriteBytes(nameBytes);
await writer.StoreAsync();
await writer.FlushAsync();
writer.DetachStream();
writer.Dispose();
//input
reader = new DataReader(socket.InputStream);
reader.InputStreamOptions = InputStreamOptions.Partial;
reader.UnicodeEncoding = Windows.Storage.Streams.UnicodeEncoding.Utf8;
uint bytesAvailable = await reader.LoadAsync(4096);
byte[] byArray = new byte[bytesAvailable];
reader.ReadBytes(byArray);
string temp = Encoding.UTF8.GetString(byArray, 0,
Convert.ToInt32(bytesAvailable));
temp = temp.Substring(0, temp.Length - 1);
if (temp == "NAME OK")
{
GoodName = true;
}
reader.DetachStream();
reader.Dispose();
}
catch (Exception e)
{
//await Task.WhenAll(tasks.ToArray());
if (SocketError.GetStatus(e.HResult) == SocketErrorStatus.Unknown)
{
throw;
}
Windows.UI.Popups.MessageDialog md =
new Windows.UI.Popups.MessageDialog("Error: " + e.Message);
md.ShowAsync();
}
}
最佳答案
默认情况下,
LoadAsync
在读取所有请求的字节之前不会阻塞。您可能收到部分消息。
您需要实现任何类型的 message framing正如我在博客中所描述的那样,您的协议(protocol)使用。
附注避免async void
。它确实使您的错误处理变得复杂。
关于c# - StreamSocket、DataWriter.StoreAsync()、DataReader.LoadAsync() -- 异步问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21359004/