C# socket StreamReader.ReadToEnd 永远等待
C# socket StreamReader.ReadToEnd wait forever
在通用 Windows 平台 (UWP) 应用程序中,我尝试使用套接字将对象发送到 Windows 表单程序:
public void CreateListener()
{
TcpListener listener = new TcpListener(IPAddress.Any, port);
listener.Start();
while (true)
{
if (listener.Pending())
{
var childSocketThread = new Thread(() =>
{
string data = null;
var Client = listener.AcceptTcpClient();
using (NetworkStream ns = Client.GetStream())
using (StreamReader sr = new StreamReader(ns))
{
data = sr.ReadToEnd();
var Items = JsonConvert.DeserializeObject<Models.Orders>(data);
Process(Items);
ns.Flush();
ns.Close();
}
});
childSocketThread.IsBackground = true;
childSocketThread.Start();
}
else
{
Thread.Sleep(50); //<--- timeout
}
}
}
但接收对象卡在 ReadToEnd
中,永远不会退出。
我该怎么办?
当您想要发送数据时似乎遇到了问题,刷新您的 StreamWriter 对象后您必须使用 StreamReader 作为响应。
Stream streamIn = socket.InputStream.AsStreamForRead();
StreamReader reader = new StreamReader(streamIn);
string response = await reader.ReadLineAsync();
希望对您有所帮助。
在通用 Windows 平台 (UWP) 应用程序中,我尝试使用套接字将对象发送到 Windows 表单程序:
public void CreateListener()
{
TcpListener listener = new TcpListener(IPAddress.Any, port);
listener.Start();
while (true)
{
if (listener.Pending())
{
var childSocketThread = new Thread(() =>
{
string data = null;
var Client = listener.AcceptTcpClient();
using (NetworkStream ns = Client.GetStream())
using (StreamReader sr = new StreamReader(ns))
{
data = sr.ReadToEnd();
var Items = JsonConvert.DeserializeObject<Models.Orders>(data);
Process(Items);
ns.Flush();
ns.Close();
}
});
childSocketThread.IsBackground = true;
childSocketThread.Start();
}
else
{
Thread.Sleep(50); //<--- timeout
}
}
}
但接收对象卡在 ReadToEnd
中,永远不会退出。
我该怎么办?
当您想要发送数据时似乎遇到了问题,刷新您的 StreamWriter 对象后您必须使用 StreamReader 作为响应。
Stream streamIn = socket.InputStream.AsStreamForRead();
StreamReader reader = new StreamReader(streamIn);
string response = await reader.ReadLineAsync();
希望对您有所帮助。