C# socket通信传对象，用xml序列化和反序列化

 

在wince平台下不能BinaryFormatter类来序列化对象，可以用xml来序列化对象，储存在内存流MemoryStream中。要注意MemoryStream的Position属性，在读的时候要设置为0。例子如下：

对象类：

/// <summary>////// </summary>[XmlRoot("GatherData")]public class GatherData{/// <summary>/// 数据/// </summary>[XmlArray("Data")]public string[] Data{get;set;}/// <summary>////// </summary>[XmlElement("ModuleSht")]public string ModuleSht{get;set;}}

客户端：

View Code

public class SocketClient{/// <summary>/// 发送数据线程/// </summary>        Thread mThread;GatherData data;public SocketClient(){mThread = new Thread(new ThreadStart(OnDataSend));mThread.IsBackground = true;mThread.Start();}/// <summary>/// 发送采集数据/// </summary>private void OnDataSend(){try{Socket newclient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);IPEndPoint ie = new IPEndPoint(IPAddress.Parse("172.16.78.112"), 60000);//服务器的IP和端口try{newclient.Connect(ie);}catch (SocketException e){}data= new GatherData() { State = MsgSendState.start, Data = new string[] { "1", "2", "3" }, ModuleSht = "KYPLC" };MemoryStream stream = new MemoryStream();XmlSerializer se = new XmlSerializer(typeof(GatherData));se.Serialize(stream, data);stream.Flush();byte[] buffer = new byte[stream.Length];//一次性发送（如果设定为固定值要循环多次发送）stream.Position = 0;  //将流的当前位置重新归0，否则Read方法将读取不到任何数据\while (stream.Read(buffer, 0, buffer.Length) > 0){newclient.Send(buffer); //从内存中读取二进制流，并发送                }newclient.Shutdown(SocketShutdown.Both);newclient.Close();GC.Collect();}catch (Exception ex){}}}

服务端：

View Code

 public class ClientSocket{const int BufferSize = 1024; static string path = @"E:\";MemoryStream streams = new MemoryStream();public object oSocket;public void myClient(){Socket clientSocket = (Socket)oSocket;string clientName = clientSocket.RemoteEndPoint.ToString();XmlSerializer se = new XmlSerializer(typeof(GatherData));try{while (true){byte[] buffer = new byte[clientSocket.Available];int count = clientSocket.Receive(buffer);if(count==0)break;MemoryStream stream=new MemoryStream(buffer);stream.WriteTo(streams);string str = Encoding.UTF8.GetString(buffer);}streams.Position = 0;//读内存流的起始位置，不为0会出错；GatherData data = se.Deserialize(streams) as GatherData;}catch(Exception ex){Console.WriteLine("客户:" + clientName + "退出");}}}