日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關咨詢
選擇下列產品馬上在線溝通
服務時間：8:30-17:00
你可能遇到了下面的問題
關閉右側工具欄

新聞中心

這里有您想知道的互聯(lián)網營銷解決方案
SilverlightSocket通信學習筆記

之前因為項目的關系，涉及到與服務器實時通信，比如通過GPRS將GPS的位置信息等信息發(fā)送到服務器，然后再轉發(fā)給Silverlight應用程序，最后在地圖上標示出實時的地理位置，查了查相關的資料，網上給出的比較好的方法就是利用Socket與服務器通信。于是這兩天看了看Silverlight下的Socket通信，在此將學習的心得和實現(xiàn)過程作一個記錄，以供相互學習和交流。

成都創(chuàng)新互聯(lián)公司主要從事成都網站設計、網站建設、網頁設計、企業(yè)做網站、公司建網站等業(yè)務。立足成都服務資源,十年網站建設經驗,價格優(yōu)惠、服務專業(yè),歡迎來電咨詢建站服務:18980820575

園子里關于這方面的內容已經有很多大神寫過了，這里小小的推薦一下：

http://www.cnblogs.com/webabcd/archive/2008/12/22/1359551.html

因此本文的重點知識說一下具體實現(xiàn)的過程，細節(jié)和原理性的東西不會太多，因為本人也是新手，所以就不賣弄了。之前說到和地圖結合，所以本文的后續(xù)工作將會把Silverlight的Socket通信與ArcGIS 的地圖結合，來實現(xiàn)一個小小的功能，而本篇則主要關于Socket的實現(xiàn)過程。下面就進入正題吧。

一.Silverlight的Socket通信和控制臺、WinForm下的Socket通信有很大的區(qū)別。

對于后兩者的Socket通信，其過程就是開啟端口，綁定端口，監(jiān)聽端口，連接，接收數(shù)據(jù)，發(fā)送數(shù)據(jù)。

而在Silverlight中則不太一樣，在Silverlight中，首先是Silverlight客戶端自動向943端口的服務器端發(fā)送一個“”的語句請求，然后服務器端向客戶端發(fā)送策略文件：

clientaccesspolicy.xml，例如：

 
 
 
 
    
  
  
  
  
  1.  
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.    
    4. 
  
  
  
  
  4.      
    5. 
  
  
  
  
  5.        
    6. 
  
  
  
  
  6.          
    7. 
  
  
  
  
  7.        
    8. 
  
  
  
  
  8.        
    9. 
  
  
  
  
  9.          
    10. 
  
  
  
  
  10.        
    11. 
  
  
  
  
  11.      
    12. 
  
  
  
  
  12.    
    13. 
  
  
  
  
  13.  
    14.

發(fā)送之后，才允許和服務器進行Socket通信，之后的過程則都是一樣。

二、服務器端

2.1、Silverligh中發(fā)送策略文件服務

上面說到，Silverlight中，服務器端會向客戶端發(fā)送策略文件，然后才能開始Socket通信，下面給出服務器端的發(fā)送策略文件服務的代碼，該代碼是在網上找的，是別人已經寫好的一個類，所以在編寫Silverlight 的Socket通信程序時，只要添加這個類就好了，代碼如下：

 
 
 
 
    
  
  
  
  
  1. using System;  
    2. 
  
  
  
  
  2. using System.Net.Sockets;  
    3. 
  
  
  
  
  3. using System.Net;  
    4. 
  
  
  
  
  4. using System.Threading;  
    5. 
  
  
  
  
  5. using System.IO;  
    6. 
  
  
  
  
  6. using System.Windows.Forms;  
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8. namespace WindowsServer  
    9. 
  
  
  
  
  9. {  
    10. 
  
  
  
  
  10.     class PolicySocketServer  
    11. 
  
  
  
  
  11.     {  
    12. 
  
  
  
  
  12.         TcpListener _Listener = null;  
    13. 
  
  
  
  
  13.         TcpClient _Client = null;  
    14. 
  
  
  
  
  14.         static ManualResetEvent _TcpClientConnected = new ManualResetEvent(false);  
    15. 
  
  
  
  
  15.         const string _PolicyRequestString = "";  
    16. 
  
  
  
  
  16.         int _ReceivedLength = 0;  
    17. 
  
  
  
  
  17.         byte[] _Policy = null;  
    18. 
  
  
  
  
  18.         byte[] _ReceiveBuffer = null;  
    19. 
  
  
  
  
  19.  
    20. 
  
  
  
  
  20.         private void InitializeData()  
    21. 
  
  
  
  
  21.         {  
    22. 
  
  
  
  
  22.             string policyFile = Path.Combine(Application.StartupPath, "clientaccesspolicy.xml");  
    23. 
  
  
  
  
  23.             using (FileStream fs = new FileStream(policyFile, FileMode.Open))  
    24. 
  
  
  
  
  24.             {  
    25. 
  
  
  
  
  25.                 _Policy = new byte[fs.Length];  
    26. 
  
  
  
  
  26.                 fs.Read(_Policy, 0, _Policy.Length);  
    27. 
  
  
  
  
  27.             }  
    28. 
  
  
  
  
  28.             _ReceiveBuffer = new byte[_PolicyRequestString.Length];  
    29. 
  
  
  
  
  29.         }  
    30. 
  
  
  
  
  30.         public void StartSocketServer()  
    31. 
  
  
  
  
  31.         {  
    32. 
  
  
  
  
  32.             InitializeData();  
    33. 
  
  
  
  
  33.  
    34. 
  
  
  
  
  34.             try  
    35. 
  
  
  
  
  35.             {  
    36. 
  
  
  
  
  36.                 _Listener = new TcpListener(IPAddress.Any, 943);  
    37. 
  
  
  
  
  37.                 _Listener.Start();  
    38. 
  
  
  
  
  38.                 while (true)  
    39. 
  
  
  
  
  39.                 {  
    40. 
  
  
  
  
  40.                     _TcpClientConnected.Reset();  
    41. 
  
  
  
  
  41.                     _Listener.BeginAcceptTcpClient(new AsyncCallback(OnBeginAccept), null);  
    42. 
  
  
  
  
  42.                     _TcpClientConnected.WaitOne();  
    43. 
  
  
  
  
  43.                 }  
    44. 
  
  
  
  
  44.             }  
    45. 
  
  
  
  
  45.             catch (Exception)  
    46. 
  
  
  
  
  46.             {  
    47. 
  
  
  
  
  47.             }  
    48. 
  
  
  
  
  48.         }  
    49. 
  
  
  
  
  49.  
    50. 
  
  
  
  
  50.         private void OnBeginAccept(IAsyncResult ar)  
    51. 
  
  
  
  
  51.         {  
    52. 
  
  
  
  
  52.             _Client = _Listener.EndAcceptTcpClient(ar);  
    53. 
  
  
  
  
  53.             _Client.Client.BeginReceive(_ReceiveBuffer, 0, _PolicyRequestString.Length, SocketFlags.None,  
    54. 
  
  
  
  
  54.                 new AsyncCallback(OnReceiveComplete), null);  
    55. 
  
  
  
  
  55.         }  
    56. 
  
  
  
  
  56.  
    57. 
  
  
  
  
  57.         private void OnReceiveComplete(IAsyncResult ar)  
    58. 
  
  
  
  
  58.         {  
    59. 
  
  
  
  
  59.             try  
    60. 
  
  
  
  
  60.             {  
    61. 
  
  
  
  
  61.                 _ReceivedLength += _Client.Client.EndReceive(ar);  
    62. 
  
  
  
  
  62.                 if (_ReceivedLength < _PolicyRequestString.Length)  
    63. 
  
  
  
  
  63.                 {  
    64. 
  
  
  
  
  64.                     _Client.Client.BeginReceive(_ReceiveBuffer, _ReceivedLength,  
    65. 
  
  
  
  
  65.                         _PolicyRequestString.Length - _ReceivedLength,  
    66. 
  
  
  
  
  66.                         SocketFlags.None, new AsyncCallback(OnReceiveComplete), null);  
    67. 
  
  
  
  
  67.                     return;  
    68. 
  
  
  
  
  68.                 }  
    69. 
  
  
  
  
  69.                 string request = System.Text.Encoding.UTF8.GetString(_ReceiveBuffer, 0, _ReceivedLength);  
    70. 
  
  
  
  
  70.                 if (StringComparer.InvariantCultureIgnoreCase.Compare(request, _PolicyRequestString) != 0)  
    71. 
  
  
  
  
  71.                 {  
    72. 
  
  
  
  
  72.                     _Client.Client.Close();  
    73. 
  
  
  
  
  73.                     return;  
    74. 
  
  
  
  
  74.                 }  
    75. 
  
  
  
  
  75.                 _Client.Client.BeginSend(_Policy, 0, _Policy.Length, SocketFlags.None,  
    76. 
  
  
  
  
  76.                     new AsyncCallback(OnSendComplete), null);  
    77. 
  
  
  
  
  77.             }  
    78. 
  
  
  
  
  78.             catch (Exception)  
    79. 
  
  
  
  
  79.             {  
    80. 
  
  
  
  
  80.                 _Client.Client.Close();  
    81. 
  
  
  
  
  81.             }  
    82. 
  
  
  
  
  82.             _ReceivedLength = 0;  
    83. 
  
  
  
  
  83.             _TcpClientConnected.Set(); //Allow waiting thread to proceed   
    84. 
  
  
  
  
  84.         }  
    85. 
  
  
  
  
  85.  
    86. 
  
  
  
  
  86.         private void OnSendComplete(IAsyncResult ar)  
    87. 
  
  
  
  
  87.         {  
    88. 
  
  
  
  
  88.             try  
    89. 
  
  
  
  
  89.             {  
    90. 
  
  
  
  
  90.                 _Client.Client.EndSendFile(ar);  
    91. 
  
  
  
  
  91.             }  
    92. 
  
  
  
  
  92.             catch (Exception)  
    93. 
  
  
  
  
  93.             {  
    94. 
  
  
  
  
  94.             }  
    95. 
  
  
  
  
  95.             finally  
    96. 
  
  
  
  
  96.             {  
    97. 
  
  
  
  
  97.                 _Client.Client.Close();  
    98. 
  
  
  
  
  98.             }  
    99. 
  
  
  
  
  99.         }   
    100. 
  
  
  
  
  100.     }  
    101. 
  
  
  
  
  101. } 
    102.

2.2、啟動策略文件服務，聲明Socket，監(jiān)聽端口，接收數(shù)據(jù)，發(fā)送數(shù)據(jù)。

啟動策略文件服務

 
 
 
 
    
  
  
  
  
  1. #region Start The Policy Server 驗證策略文件  
    2. 
  
  
  
  
  2.             PolicySocketServer StartPolicyServer = new PolicySocketServer();  
    3. 
  
  
  
  
  3.             Thread th = new Thread(new ThreadStart(StartPolicyServer.StartSocketServer));  
    4. 
  
  
  
  
  4.             th.IsBackground = true;  
    5. 
  
  
  
  
  5.             th.Start();  
    6. 
  
  
  
  
  6.             #endregion 
    7.

聲明Socket，綁定端口，開始監(jiān)聽

 
 
 
 
    
  
  
  
  
  1. private void StartButton_Click(object sender, EventArgs e)  
    2. 
  
  
  
  
  2.         {//創(chuàng)建Socket  
    3. 
  
  
  
  
  3.             listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  
    4. 
  
  
  
  
  4.             //獲取主機信息  
    5. 
  
  
  
  
  5.             IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());  
    6. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  7.             //把IP和端口轉換化為IPEndPoint實例,端口號取4530  
    8. 
  
  
  
  
  8.             //Win7 中開啟了IPV6的地址，因此0,1對應的是IPV6的地址，2，3對應IPV4地址，3對應本機的IP地址  
    9. 
  
  
  
  
  9.             //XP中沒有開啟IPV6  
    10. 
  
  
  
  
  10.             HostIPTextBox.Text = ipHostInfo.AddressList[3].ToString();  
    11. 
  
  
  
  
  11.  
    12. 
  
  
  
  
  12.             if (!string.IsNullOrEmpty(PortTextBox.Text))  
    13. 
  
  
  
  
  13.             {  
    14. 
  
  
  
  
  14.                 //獲取端口號  
    15. 
  
  
  
  
  15.                 int port = Convert.ToInt32(PortTextBox.Text.Trim());  
    16. 
  
  
  
  
  16.                 //獲得本機的IP地址  
    17. 
  
  
  
  
  17.                 localEP = new IPEndPoint(ipHostInfo.AddressList[3], port);  
    18. 
  
  
  
  
  18.             }  
    19. 
  
  
  
  
  19.             else  
    20. 
  
  
  
  
  20.             {  
    21. 
  
  
  
  
  21.                //默認4530端口  
    22. 
  
  
  
  
  22.                 ipAddress = IPAddress.Parse("127.0.0.1");  
    23. 
  
  
  
  
  23.                 localEP = new IPEndPoint(ipHostInfo.AddressList[3], 4530);  
    24. 
  
  
  
  
  24.             }  
    25. 
  
  
  
  
  25.  
    26. 
  
  
  
  
  26.             try  
    27. 
  
  
  
  
  27.             {  
    28. 
  
  
  
  
  28.                 //綁定指定的終結點  
    29. 
  
  
  
  
  29.                 listener.Bind(localEP);  
    30. 
  
  
  
  
  30.                 //開始監(jiān)聽  
    31. 
  
  
  
  
  31.                 listener.Listen(10);  
    32. 
  
  
  
  
  32.                 //一直循環(huán)接收客戶端的消息，開啟監(jiān)聽端口線程  
    33. 
  
  
  
  
  33.                 ThreadStart threadwatchStart = new ThreadStart(WatchConnecting);  
    34. 
  
  
  
  
  34.                 threadWatch = new Thread(threadwatchStart);  
    35. 
  
  
  
  
  35.                 threadWatch.IsBackground = true;  
    36. 
  
  
  
  
  36.                 threadWatch.Start();  
    37. 
  
  
  
  
  37.             }  
    38. 
  
  
  
  
  38.             catch (Exception ex)  
    39. 
  
  
  
  
  39.             {  
    40. 
  
  
  
  
  40.                 MessageBox.Show(ex.Data.ToString());  
    41. 
  
  
  
  
  41.             }  
    42. 
  
  
  
  
  42.         } 
    43.

連接端口，接收數(shù)據(jù)

 
 
 
 
    
  
  
  
  
  1. private void WatchConnecting()  
    2. 
  
  
  
  
  2.         {  
    3. 
  
  
  
  
  3.             ChangeStatue("等待Silverlight客戶端連接.....");  
    4. 
  
  
  
  
  4.             while (true)  //持續(xù)不斷監(jiān)聽客戶端發(fā)來的請求    
    5. 
  
  
  
  
  5.             {  
    6. 
  
  
  
  
  6.                 listener.BeginAccept(AcceptCallBack, listener);  
    7. 
  
  
  
  
  7.                 _flipFlop.WaitOne();  
    8. 
  
  
  
  
  8.             }  
    9. 
  
  
  
  
  9.         } 
    10. 
 
 
 
 
 
 
 
 
    
  
  
  
  
  1. private  void AcceptCallBack(IAsyncResult asyresult)  
    2. 
  
  
  
  
  2.         {  
    3. 
  
  
  
  
  3.             Socket listener = (Socket)asyresult.AsyncState;  
    4. 
  
  
  
  
  4.             Socket socket = listener.EndAccept(asyresult);  
    5. 
  
  
  
  
  5.             ChangeStatue("連接到Silverlight客戶端....");  
    6. 
  
  
  
  
  6.             _flipFlop.Set();  
    7. 
  
  
  
  
  7.             var state = new StateObject();  
    8. 
  
  
  
  
  8.             state.Socket = socket;  
    9. 
  
  
  
  
  9.             socket.BeginReceive(state.Buffer, 0, StateObject.BufferSize, 0, ReciverCallBack, state);  
    10. 
  
  
  
  
  10.         } 
    11. 
 
 
 
 
 
 
 
 
    
  
  
  
  
  1. private void ReciverCallBack(IAsyncResult asyResult)  
    2. 
  
  
  
  
  2.         {  
    3. 
  
  
  
  
  3.             StateObject state = (StateObject)asyResult.AsyncState;  
    4. 
  
  
  
  
  4.             Socket socket = state.Socket;  
    5. 
  
  
  
  
  5.             int read = socket.EndReceive(asyResult);  
    6. 
  
  
  
  
  6.             if (read > 0)  
    7. 
  
  
  
  
  7.             {  
    8. 
  
  
  
  
  8.                 string chunk = Encoding.UTF8.GetString(state.Buffer, 0, read);  
    9. 
  
  
  
  
  9.                 state.StringBuilder.Append(chunk);  
    10. 
  
  
  
  
  10.                 if (state.StringBuilder.Length > 0)  
    11. 
  
  
  
  
  11.                 {  
    12. 
  
  
  
  
  12.                     string result = state.StringBuilder.ToString();  
    13. 
  
  
  
  
  13.                     ChangeStatue("成功接收到消息："+result);  
    14. 
  
  
  
  
  14.                     ChangeReciveText(result);  
    15. 
  
  
  
  
  15.                     Send(socket, SendTextBox.Text);  
    16. 
  
  
  
  
  16.                     AddListItems("接收消息："+result+"\n");  
    17. 
  
  
  
  
  17.                     AddListItems("發(fā)送消息：" + SendTextBox.Text + "\n");  
    18. 
  
  
  
  
  18.                 }  
    19. 
  
  
  
  
  19.             }  
    20. 
  
  
  
  
  20.         } 
    21.

發(fā)送數(shù)據(jù)

 
 
 
 
    
  
  
  
  
  1. private void Send(Socket handler, String data)  
    2. 
  
  
  
  
  2.         {  
    3. 
  
  
  
  
  3.             byte[] byteData = Encoding.UTF8.GetBytes(data);  
    4. 
  
  
  
  
  4.             handler.BeginSend(byteData, 0, byteData.Length, 0, new AsyncCallback(SendCallBack), handler);  
    5. 
  
  
  
  
  5.         }  
    6. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  7.         private void SendCallBack(IAsyncResult asyResult)  
    8. 
  
  
  
  
  8.         {  
    9. 
  
  
  
  
  9.             try  
    10. 
  
  
  
  
  10.             {  
    11. 
  
  
  
  
  11.                 Socket handler = (Socket)asyResult.AsyncState;  
    12. 
  
  
  
  
  12.                 int byteSent = handler.EndSend(asyResult);  
    13. 
  
  
  
  
  13.                 if (byteSent > 0)  
    14. 
  
  
  
  
  14.                 {  
    15. 
  
  
  
  
  15.                     ChangeStatue("發(fā)送數(shù)據(jù)成功！");  
    16. 
  
  
  
  
  16.                 }  
    17. 
  
  
  
  
  17.             }  
    18. 
  
  
  
  
  18.             catch (Exception ex)  
    19. 
  
  
  
  
  19.             {  
    20. 
  
  
  
  
  20.                 MessageBox.Show(ex.Data.ToString());  
    21. 
  
  
  
  
  21.             }  
    22. 
  
  
  
  
  22.         } 
    23.

StateObject類：

 
 
 
 
    
  
  
  
  
  1. public class StateObject  
    2. 
  
  
  
  
  2.     {  
    3. 
  
  
  
  
  3.         public Socket Socket;  
    4. 
  
  
  
  
  4.         public StringBuilder StringBuilder = new StringBuilder();  
    5. 
  
  
  
  
  5.         public const int BufferSize = 1024;  
    6. 
  
  
  
  
  6.         public byte[] Buffer = new byte[BufferSize];  
    7. 
  
  
  
  
  7.         public int TotalSize;  
    8. 
  
  
  
  
  8.     } 
    9.

客戶端：

和服務器端類似，客戶端的操作包括：聲明Socket，指定服務器地址和端口，連接到指定的服務器端口，發(fā)送數(shù)據(jù)，接收數(shù)據(jù)。

下面是具體的實現(xiàn)代碼：

聲明Socket

 
 
 
 
    
  
  
  
  
  1. private Socket socket; 
    2.

指定服務器地址和端口，開始連接

 
 
 
 
    
  
  
  
  
  1. private void SendButton_Click(object sender, RoutedEventArgs e)  
    2. 
  
  
  
  
  2.         {  
    3. 
  
  
  
  
  3.             if(string.IsNullOrEmpty(IPTextBox.Text)||string.IsNullOrEmpty(PortTextBox.Text))  
    4. 
  
  
  
  
  4.             {  
    5. 
  
  
  
  
  5.                 MessageBox.Show ("請輸入主機IP地址和端口號！");  
    6. 
  
  
  
  
  6.                 return;  
    7. 
  
  
  
  
  7.             }  
    8. 
  
  
  
  
  8.             //ip地址  
    9. 
  
  
  
  
  9.             string host=IPTextBox.Text.Trim();  
    10. 
  
  
  
  
  10.             //端口號  
    11. 
  
  
  
  
  11.             int port=Convert.ToInt32(PortTextBox.Text.Trim());  
    12. 
  
  
  
  
  12.             //建立終結點對象  
    13. 
  
  
  
  
  13.             DnsEndPoint hostEntry=new DnsEndPoint(host,port);  
    14. 
  
  
  
  
  14.             //創(chuàng)建一個Socket對象  
    15. 
  
  
  
  
  15.             socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);  
    16. 
  
  
  
  
  16.             //創(chuàng)建Socket異步事件參數(shù)  
    17. 
  
  
  
  
  17.             SocketAsyncEventArgs socketEventArg=new SocketAsyncEventArgs ();  
    18. 
  
  
  
  
  18.             //將消息轉化為發(fā)送的byte[]格式  
    19. 
  
  
  
  
  19.             byte[]buffer=Encoding.UTF8.GetBytes(MessageTextBox.Text);  
    20. 
  
  
  
  
  20.             //注冊Socket完成事件  
    21. 
  
  
  
  
  21.             socketEventArg.Completed+=new EventHandler(socketEventArg_Completed);  
    22. 
  
  
  
  
  22.             //設置Socket異步事件遠程終結點  
    23. 
  
  
  
  
  23.             socketEventArg.RemoteEndPoint=hostEntry;  
    24. 
  
  
  
  
  24.             //將定義好的Socket對象賦值給Socket異步事件參數(shù)的運行實例屬性  
    25. 
  
  
  
  
  25.             socketEventArg.UserToken = buffer;  
    26. 
  
  
  
  
  26.             try  
    27. 
  
  
  
  
  27.             {  
    28. 
  
  
  
  
  28.                 socket.ConnectAsync(socketEventArg);  
    29. 
  
  
  
  
  29.             }  
    30. 
  
  
  
  
  30.             catch(SocketException ex)  
    31. 
  
  
  
  
  31.             {  
    32. 
  
  
  
  
  32.                 throw new SocketException((int)ex.ErrorCode);  
    33. 
  
  
  
  
  33.             }  
    34. 
  
  
  
  
  34.         } 
    35.

向服務器發(fā)送數(shù)據(jù)，并接受服務器回復的消息。

 
 
 
 
    
  
  
  
  
  1. private void socketEventArg_Completed(object sender, SocketAsyncEventArgs e)  
    2. 
  
  
  
  
  2.         {  
    3. 
  
  
  
  
  3.            //檢查是否發(fā)送出錯  
    4. 
  
  
  
  
  4.             if (e.SocketError != SocketError.Success)  
    5. 
  
  
  
  
  5.             {  
    6. 
  
  
  
  
  6.                 if (e.SocketError == SocketError.ConnectionAborted)  
    7. 
  
  
  
  
  7.                 {  
    8. 
  
  
  
  
  8.                     Dispatcher.BeginInvoke(() => MessageBox.Show("連接超時....請重試！"));  
    9. 
  
  
  
  
  9.                 }  
    10. 
  
  
  
  
  10.                 else if (e.SocketError == SocketError.ConnectionRefused)  
    11. 
  
  
  
  
  11.                 {  
    12. 
  
  
  
  
  12.                     Dispatcher.BeginInvoke(() => MessageBox.Show("無法連接到服務器端："+e.SocketError));  
    13. 
  
  
  
  
  13.                 }else  
    14. 
  
  
  
  
  14.                 {  
    15. 
  
  
  
  
  15.                     Dispatcher.BeginInvoke(() => MessageBox.Show("出錯了！"+e.SocketError));  
    16. 
  
  
  
  
  16.                 }  
    17. 
  
  
  
  
  17.                 return;  
    18. 
  
  
  
  
  18.             }  
    19. 
  
  
  
  
  19.            //如果連接上，則發(fā)送數(shù)據(jù)  
    20. 
  
  
  
  
  20.             if (e.LastOperation == SocketAsyncOperation.Connect)  
    21. 
  
  
  
  
  21.             {  
    22. 
  
  
  
  
  22.                     byte[] userbytes = (byte[])e.UserToken;  
    23. 
  
  
  
  
  23.                     e.SetBuffer(userbytes, 0, userbytes.Length);  
    24. 
  
  
  
  
  24.                     socket.SendAsync(e);  
    25. 
  
  
  
  
  25.                       
    26. 
  
  
  
  
  26.             }//如果已發(fā)送數(shù)據(jù)，則開始接收服務器回復的消息  
    27. 
  
  
  
  
  27.             else if (e.LastOperation == SocketAsyncOperation.Send)  
    28. 
  
  
  
  
  28.             {  
    29. 
  
  
  
  
  29.                 Dispatcher.BeginInvoke(() => 
    30. 
  
  
  
  
  30.                 {  
    31. 
  
  
  
  
  31.                     listBox1.Items.Add("客戶端在" + DateTime.Now.ToShortTimeString() + "，發(fā)送消息：" + MessageTextBox.Text);  
    32. 
  
  
  
  
  32.                 });  
    33. 
  
  
  
  
  33.                 byte[] userbytes = new byte[1024];  
    34. 
  
  
  
  
  34.                 e.SetBuffer(userbytes, 0, userbytes.Length);  
    35. 
  
  
  
  
  35.                 socket.ReceiveAsync(e);  
    36. 
  
  
  
  
  36.             }//接收服務器數(shù)據(jù)  
    37. 
  
  
  
  
  37.             else if (e.LastOperation == SocketAsyncOperation.Receive)  
    38. 
  
  
  
  
  38.             {  
    39. 
  
  
  
  
  39.                 string RecevieStr = Encoding.UTF8.GetString(e.Buffer, 0, e.Buffer.Length).Replace("\0", "");  
    40. 
  
  
  
  
  40.                 Dispatcher.BeginInvoke(() => 
    41. 
  
  
  
  
  41.                 {  
    42. 
  
  
  
  
  42.                     listBox1.Items.Add("服務器在" + DateTime.Now.ToShortTimeString() + "，回復消息：" + RecevieStr);  
    43. 
  
  
  
  
  43.                 });  
    44. 
  
  
  
  
  44.                 socket.Close();  
    45. 
  
  
  
  
  45.             }  
    46. 
  
  
  
  
  46.         } 
    47.

xaml代碼：

 
 
 
 
    
  
  
  
  
  1. 
  
  
  
  
  2.     xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation" 
    3. 
  
  
  
  
  3.     xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" 
    4. 
  
  
  
  
  4.     xmlns:d="http://schemas.microsoft.com/expression/blend/2008" 
    5. 
  
  
  
  
  5.     xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006" 
    6. 
  
  
  
  
  6.     xmlns:esri="http://schemas.esri.com/arcgis/client/2009" x:Class="SilverlightSocket.MainPage" 
    7. 
  
  
  
  
  7.     mc:Ignorable="d" 
    8. 
  
  
  
  
  8.     d:DesignHeight="417" d:DesignWidth="530"> 
    9. 
  
  
  
  
  9.  
    10. 
  
  
  
  
  10.      
    11. 
  
  
  
  
  11.          
    12. 
  
  
  
  
  12.              
    13. 
  
  
  
  
  13.              
    14. 
  
  
  
  
  14.          
    15. 
  
  
  
  
  15.          
    16. 
  
  
  
  
  16.              
    17. 
  
  
  
  
  17.          
    18. 
  
  
  
  
  18.          
    19. 
  
  
  
  
  19.              
    20. 
  
  
  
  
  20.          
    21. 
  
  
  
  
  21.          
    22. 
  
  
  
  
  22.              
    23. 
  
  
  
  
  23.                  
    24. 
  
  
  
  
  24.              
    25. 
  
  
  
  
  25.              
    26. 
  
  
  
  
  26.              
    27. 
  
  
  
  
  27.              
    28. 
  
  
  
  
  28.              
    29. 
  
  
  
  
  29.              
    30. 
  
  
  
  
  30.              
    31. 
  
  
  
  
  31.              
    32. 
  
  
  
  
  32.              
    33. 
  
  
  
  
  33.              
    34. 
  
  
  
  
  34.              
    35. 
  
  
  
  
  35.          
    36. 
  
  
  
  
  36.      
    37. 
  
  
  
  
  37.  
    38.

最后效果示意圖：

服務器端：

Silverlight客戶端：

后續(xù)工作中將結合地圖來實現(xiàn)模擬實時位置的顯示功能。


分享文章：SilverlightSocket通信學習筆記
本文來源：http://m.5511xx.com/article/cddocdc.html