Windows Phone 7 下 Socket(TCP) 与 PC 通讯

Windows Phone 7 下 Socket(TCP) 与 PC 通讯，使用 WP7 模拟器与 PC 上的 Simple TCP 服务进行通讯。

TCP 客户端主要实现 Socket 连接的建立、数据的发送与接收和关闭已经建立的 Socket。

  1 using System;  
  2 using System.Net;  
  3 using System.Windows;  
  4 using System.Windows.Controls;  
  5 using System.Windows.Documents;  
  6 using System.Windows.Ink;  
  7 using System.Windows.Input;  
  8 using System.Windows.Media;  
  9 using System.Windows.Media.Animation;  
 10 using System.Windows.Shapes;  
 11   
 12 // 手动增加的  
 13 using System.Net.Sockets;  
 14 using System.Threading;  
 15 using System.Text;  
 16   
 17 namespace SocketClientTest  
 18 {  
 19     public class SocketClient  
 20     {  
 21         Socket socket = null;  
 22   
 23         // 当一个异步操作完成时, 用于通知的事件对象  
 24         static ManualResetEvent socketDone = new ManualResetEvent(false);  
 25   
 26         // 异步操作超过时间定义. 如果在此时间内未接收到回应, 则放弃此操作.  
 27         const int TIMEOUT_MILLISECONDS = 5000;  
 28   
 29         // 最大接收缓冲  
 30         const int MAX_BUFFER_SIZE = 2048;  
 31   
 32         // Socket 连接到指定端口的服务器  
 33         // hostName 服务器名称  
 34         // portNumber 连接端口  
 35         // 返回值: 连接结果返回的字符串  
 36         public string Connect(string hostName, int portNumber)  
 37         {  
 38             string result = string.Empty;  
 39   
 40             // 创建 DnsEndPoint. 服务器的端口传入此方法  
 41             DnsEndPoint hostEntry = new DnsEndPoint(hostName, portNumber);  
 42   
 43             socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  
 44   
 45             // 创建一个 SocketAsyncEventArgs 对象用于连接请求  
 46             SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();  
 47             socketEventArg.RemoteEndPoint = hostEntry;  
 48   
 49             // Inline event handler for the Completed event.  
 50             // Note: This event handler was implemented inline in order to make this method self-contained.  
 51             socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate(object s, SocketAsyncEventArgs e)  
 52                     {  
 53                         result = e.SocketError.ToString();  
 54                         // 标识请求已经完成, 不阻塞 UI 线程  
 55                         socketDone.Set();  
 56                     }  
 57                 );  
 58   
 59             socketDone.Reset();  
 60             socket.ConnectAsync(socketEventArg);  
 61             socketDone.WaitOne(TIMEOUT_MILLISECONDS);  
 62   
 63             return result;  
 64         }  
 65   
 66         public string Send(string data)  
 67         {  
 68             string response = "Operation Timeout";  
 69   
 70             if (socket != null)  
 71             {  
 72                 // 创建 SocketAsyncEventArgs 对象、并设置对象属性  
 73                 SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();  
 74                 socketEventArg.RemoteEndPoint = socket.RemoteEndPoint;  
 75                 socketEventArg.UserToken = null;  
 76   
 77                 socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate(object s, SocketAsyncEventArgs e)  
 78                         {  
 79                             response = e.SocketError.ToString();  
 80                             socketDone.Set();  
 81                         }  
 82                     );  
 83   
 84                 // 将需要发送的数据送入发送缓冲区  
 85                 byte[] payload = Encoding.UTF8.GetBytes(data);  
 86                 socketEventArg.SetBuffer(payload, 0, payload.Length);  
 87   
 88                 socketDone.Reset();  
 89                 socket.SendAsync(socketEventArg);  
 90                 socketDone.WaitOne(TIMEOUT_MILLISECONDS);  
 91             }  
 92             else  
 93             {  
 94                 response = "Socket is not initialized";  
 95             }  
 96   
 97             return response;  
 98         }  
 99   
100         public string Receive()  
101         {  
102             string response = "Operation Timeout";  
103   
104             if (socket != null)  
105             {  
106                 SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();  
107                 socketEventArg.RemoteEndPoint = socket.RemoteEndPoint;  
108                 socketEventArg.SetBuffer(new Byte[MAX_BUFFER_SIZE], 0, MAX_BUFFER_SIZE);  
109   
110                 socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate(object s, SocketAsyncEventArgs e)  
111                         {  
112                             if (e.SocketError == SocketError.Success)  
113                             {  
114                                 // 从接收缓冲区得到数据  
115                                 response = Encoding.UTF8.GetString(e.Buffer, e.Offset, e.BytesTransferred);  
116                                 response = response.Trim('');  
117                             }  
118                             else  
119                             {  
120                                 response = e.SocketError.ToString();  
121                             }  
122   
123                             socketDone.Set();  
124                         }  
125                     );  
126   
127                 socketDone.Reset();  
128                 socket.ReceiveAsync(socketEventArg);  
129                 socketDone.WaitOne(TIMEOUT_MILLISECONDS);  
130             }  
131             else  
132             {  
133                 response = "Socket is not initialized";  
134             }  
135   
136             return response;  
137         }  
138   
139         /// <summary>  
140         /// Closes the Socket connection and releases all associated resources  
141         /// </summary>  
142         public void Close()  
143         {  
144             if (socket != null)  
145             {  
146                 socket.Close();  
147             }  
148         }  
149     }  
150 }

对 TCP 客户端的使用如下：

  1 using System;  
  2 using System.Collections.Generic;  
  3 using System.Linq;  
  4 using System.Net;  
  5 using System.Windows;  
  6 using System.Windows.Controls;  
  7 using System.Windows.Documents;  
  8 using System.Windows.Input;  
  9 using System.Windows.Media;  
 10 using System.Windows.Media.Animation;  
 11 using System.Windows.Shapes;  
 12 using Microsoft.Phone.Controls;  
 13   
 14 /* 
 15  * 可以运行在 Windows Phone 7 模拟器上与 PC 进行 Socket 通讯。从 Simple TCP 服务获取相应的回应。 
 16 */  
 17   
 18 namespace SocketClientTest  
 19 {  
 20     public partial class MainPage : PhoneApplicationPage  
 21     {  
 22         const int ECHO_PORT = 7;  // 回应端口: 配合 PC 系统的 Simple TCP 服务使用，回应接收到的字符串  
 23         const int QOTD_PORT = 17; // 当日语录端口:  配合 PC 系统的 Simple TCP 服务使用  
 24   
 25         // 构造函数  
 26         public MainPage()  
 27         {  
 28             InitializeComponent();  
 29   
 30             txtRemoteHost.Text = "yonghang-pc";       // 计算机名：可以从 桌面->计算名->属性中查看到  
 31             txtInput.Text = "Test socket 测试";       // 发送的字符串  
 32         }  
 33   
 34         private void btnEcho_Click(object sender, RoutedEventArgs e)  
 35         {  
 36             // 清空 log   
 37             ClearLog();  
 38   
 39             // 确认输入是否有效  
 40             if (ValidateRemoteHostInput() && ValidateEditEchoInput())  
 41             {  
 42                 // 初始化 SocketClient 实例  
 43                 SocketClient client = new SocketClient();  
 44   
 45                 // 开始连接 Echo Server  
 46                 Log(String.Format("Connecting to server '{0}' over port {1} (echo) ...", txtRemoteHost.Text, ECHO_PORT), true);  
 47                 string result = client.Connect(txtRemoteHost.Text, ECHO_PORT);  
 48                 Log(result, false);  
 49   
 50                 // 发送字符串到 Echo Server  
 51                 Log(String.Format("Sending '{0}' to server ...", txtInput.Text), true);  
 52                 result = client.Send(txtInput.Text);  
 53                 Log(result, false);  
 54   
 55                 // 接收来自 Echo Server 的回应  
 56                 Log("Requesting Receive ...", true);  
 57                 result = client.Receive();  
 58                 Log(result, false);  
 59   
 60                 // 关闭 Socket 连接  
 61                 client.Close();  
 62             }  
 63   
 64         }  
 65   
 66         // 获取当日语录  
 67         private void btnGetQuote_Click(object sender, RoutedEventArgs e)  
 68         {  
 69             ClearLog();  
 70   
 71             if (ValidateRemoteHostInput())  
 72             {  
 73                 SocketClient client = new SocketClient();  
 74   
 75                 Log(String.Format("Connecting to server '{0}' over port {1} (Quote of the Day) ...", txtRemoteHost.Text, QOTD_PORT), true);  
 76                 string result = client.Connect(txtRemoteHost.Text, QOTD_PORT);  
 77                 Log(result, false);  
 78   
 79                 Log("Requesting Receive ...", true);  
 80                 result = client.Receive();  
 81                 Log(result, false);  
 82   
 83                 client.Close();  
 84             }  
 85         }  
 86   
 87         // 判断是否有输入  
 88         private bool ValidateEditEchoInput()  
 89         {  
 90             if (String.IsNullOrWhiteSpace(txtInput.Text))  
 91             {  
 92                 MessageBox.Show("Please enter string to send.");  
 93                 return false;  
 94             }  
 95   
 96             return true;  
 97         }  
 98   
 99         // 判断是否有输入  
100         private bool ValidateRemoteHostInput()  
101         {  
102             if (String.IsNullOrWhiteSpace(txtRemoteHost.Text))  
103             {  
104                 MessageBox.Show("Please enter host name!");  
105                 return false;  
106             }  
107   
108             return true;  
109         }  
110   
111        // 在 TextBox 中输出测试信息  
112         private void Log(string message, bool isOutgoing)  
113         {  
114             string direction = (isOutgoing) ? ">> " : "<< ";  
115             txtOutput.Text += Environment.NewLine + direction + message;  
116         }  
117   
118         // 清空测试信息  
119         private void ClearLog()  
120         {  
121             txtOutput.Text = String.Empty;  
122         }  
123     }  
124 }