【发布时间】:2011-02-13 22:37:18
【问题描述】:
我正在尝试通过网络流发送 XML 可序列化对象。
我已经在 UDP 广播服务器上使用过它,它从本地网络接收 UDP 消息。这里是服务端的sn-p:
while (mServiceStopFlag == false) {
if (mSocket.Available > 0) {
IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Any, DiscoveryPort); byte[] bData;
// Receive discovery message
bData = mSocket.Receive(ref ipEndPoint);
// Handle discovery message
HandleDiscoveryMessage(ipEndPoint.Address, bData);
...
这是客户端:
IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Broadcast, DiscoveryPort);
MemoryStream mStream = new MemoryStream();
byte[] bData;
// Create broadcast UDP server
mSocket = new UdpClient();
mSocket.EnableBroadcast = true;
// Create datagram data
foreach (NetService s in ctx.Services)
XmlHelper.SerializeClass<NetService>(mStream, s);
bData = mStream.GetBuffer();
// Notify the services
while (mServiceStopFlag == false) {
mSocket.Send(bData, (int)mStream.Length, ipEndPoint);
Thread.Sleep(DefaultServiceLatency);
}
它工作得很好。
但现在我试图获得相同的结果,但在 TcpClient 套接字上,但直接使用 XMLSerializer 实例:
在服务器端:
TcpClient sSocket = k.Key;
ServiceContext sContext = k.Value;
Message msg = new Message();
while (sSocket.Connected == true) {
if (sSocket.Available > 0) {
StreamReader tr = new StreamReader(sSocket.GetStream());
msg = (Message)mXmlSerialize.Deserialize(tr);
// Handle message
msg = sContext.Handler(msg);
// Reply with another message
if (msg != null)
mXmlSerialize.Serialize(sSocket.GetStream(), msg);
} else
Thread.Sleep(40);
}
在客户端:
NetworkStream mSocketStream;
Message rMessage;
// Network stream
mSocketStream = mSocket.GetStream();
// Send the message
mXmlSerialize.Serialize(mSocketStream, msg);
// Receive the answer
rMessage = (Message)mXmlSerialize.Deserialize(mSocketStream);
return (rMessage);
数据已发送(Available 属性大于 0),但方法 XmlSerialize.Deserialize(应反序列化 Message 类)阻塞。
我错过了什么?
【问题讨论】:
标签: c# xml-serialization network-protocols