【发布时间】:2015-04-15 01:49:42
【问题描述】:
我正在尝试将自定义 class 从一个 tcp 客户端传递到另一个(使用 TcpListener、TcpClient 和 XmlSerializer)。
我有 1 个问题分成 2 个问题。
当我使用此代码时,客户端在序列化完成时挂起 (我认为对方不知道数据何时完全发送):
public void SendData(myMessage messageClass)
{
NetworkStream serverStream = tcpServer.GetStream();
XmlSerializer xmlSrlz = new XmlSerializer(typeof(myMessage));
xmlSrlz.Serialize(serverStream, messageClass);
serverStream.Flush();
}
public myMessage ReadData()
{
while (true)
{
NetworkStream clientStream = client.GetStream();
XmlSerializer xmlSrlz = new XmlSerializer(typeof(myMessage));
int bytesToread;
byte[] inStream = new byte[10025];
myMessage msg;
do
{
msg = (myMessage)xmlSrlz.Deserialize(clientStream);
clientStream.Flush();
}
while (((bytesToread = clientStream.Read(inStream, 0, (int)client.ReceiveBufferSize)) > 0));
return msg;
}
}
所以,当我四处搜索时,我注意到我可以处理流(或使用using),这样就可以让对方知道数据已完全发送并且没有更多数据要发送:
public void SendData(myMessage messageClass)
{
using (NetworkStream serverStream = tcpServer.GetStream())
{
XmlSerializer xmlSrlz = new XmlSerializer(typeof(myMessage));
xmlSrlz.Serialize(serverStream, messageClass);
serverStream.Flush();
}
}
public myMessage ReadData()
{
while (true)
{
using (NetworkStream clientStream = client.GetStream())
{
XmlSerializer xmlSrlz = new XmlSerializer(typeof(myMessage));
int bytesToread;
byte[] inStream = new byte[10025];
myMessage msg;
do
{
msg = (myMessage)xmlSrlz.Deserialize(clientStream);
clientStream.Flush();
}
while (((bytesToread = clientStream.Read(inStream, 0, (int)client.ReceiveBufferSize)) > 0));
return msg;
}
}
}
但现在我失去了他们 2 个客户端的连接。
当我尝试发送另一条消息时,我得到了异常:
在未连接的套接字上不允许该操作。
那么我怎样才能在不破坏 连接的情况下发送序列化对象?
【问题讨论】:
标签: c# tcpclient xmlserializer tcplistener networkstream