F6 Team

一般利用Sockert都傳送文字字串.

那如果要傳送class or struct的資料怎麼辦呢.

重點就是先將class or struct序列化.

直接看範例吧.

共用Class or Struct

person.cs

using System; using System.Collections.Generic; using System.Text; namespace ClassLibrary2 { [Serializable] public class class_person { public string id; public string name; } [Serializable] public struct struct_person { public string id; public string name; } }

Client端,要using共用的dll

Form1.cs

using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.Net.Sockets; using System.Net; using System.Threading; using ClassLibrary2; using System.Runtime.Serialization.Formatters.Binary; using System.IO; namespace WindowsApplication5 { public partial class Form1 : Form { public Form1() { InitializeComponent(); } private void btnSendClassData_Click(object sender, EventArgs e) { try { IPEndPoint hostEP = new IPEndPoint(IPAddress.Parse(this.tbIp.Text), int.Parse(this.tbPort.Text)); Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); socket.Connect(hostEP); byte[] bytesSend = new byte[1024]; //序列化 BinaryFormatter bf = new BinaryFormatter(); MemoryStream stream = new MemoryStream(); class_person person = new class_person(); person.id = this.tbId.Text; person.name = this.tbName.Text; bf.Serialize(stream, person); bytesSend = stream.ToArray(); socket.SendTo(bytesSend, 0, hostEP); socket.Shutdown(SocketShutdown.Both); socket.Close(); } catch (Exception ex) { MessageBox.Show(ex.ToString()); } } } }

Server端,要using共用的dll

Form1.cs

using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.Net.Sockets; using System.Net; using System.Threading; using ClassLibrary2; using System.Runtime.Serialization.Formatters.Binary; using System.IO; namespace WindowsApplication4 { public partial class Form1 : Form { delegate void SetTextCallback(byte[] data); delegate void GetTextCallback(); Thread startThread; Socket socket; public Form1() { InitializeComponent(); } private void btnOpenListen_Click(object sender, EventArgs e) { startThread = new Thread(new ParameterizedThreadStart(start)); startThread.Start(); this.btnOpenListen.Enabled = false; this.btnCloseListen.Enabled = true; } private void btnCloseListen_Click(object sender, EventArgs e) { socket.Close(); startThread.Abort(); this.btnOpenListen.Enabled = true; this.btnCloseListen.Enabled = false; } private void start(object TransMsg) { IPEndPoint hostEP = new IPEndPoint(IPAddress.Parse(this.tbIp.Text), int.Parse(this.tbPort.Text)); socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); socket.Bind(hostEP); while (true) { try { socket.Listen(50); Socket NewSocket = socket.Accept(); byte[] bytesReceive = new byte[1024]; NewSocket.Receive(bytesReceive); SetText(bytesReceive); NewSocket.Shutdown(SocketShutdown.Both); NewSocket.Close(); } catch (Exception ex) { MessageBox.Show(ex.ToString()); } } } private void SetText(byte[] data) { //反序列化 BinaryFormatter bf = new BinaryFormatter(); MemoryStream stream = new MemoryStream(data); class_person person = (class_person)bf.Deserialize(stream); if (this.tbId.InvokeRequired) { SetTextCallback d = new SetTextCallback(SetText); this.Invoke(d, new object[] { data }); } else { this.tbId.Text = person.id; } if (this.tbName.InvokeRequired) { SetTextCallback d = new SetTextCallback(SetText); this.Invoke(d, new object[] { data }); } else { this.tbName.Text = person.name; } } } }

執行結果：

參考網址：

http://www.blueshop.com.tw/board/show.asp?subcde=BRD20090402141557OY6&fumcde=FUM20050124192253INM
http://topic.csdn.net/t/20031128/10/2504360.html
http://hi.baidu.com/ysdonet/blog/item/2915d2f4ebb2b56bddc47418.html