异步客户端套接字示例


下面的示例程序创建一个连接到服务器的客户端。该客户端是用异步套接字生成的，因此在等待服务器返回响应时不挂起客户端应用程序的执行。该应用程序将字符串发送到服务器，然后在控制台显示该服务器返回的字符串。

C#

1. using System;
   
2. using System.Net;
   
3. using System.Net.Sockets;
   
4. using System.Threading;
   
5. using System.Text;
   
6. // State object for receiving data from remote device.
   
7. public class StateObject {
   
8. // Client socket.
   
9. public Socket workSocket = null;
   
10. // Size of receive buffer.
    
11. public const int BufferSize = 256;
    
12. // Receive buffer.
    
13. public byte[] buffer = new byte[BufferSize];
    
14. // Received data string.
    
15. public StringBuilder sb = new StringBuilder();
    
16. }
    
17. public class AsynchronousClient {
    
18. // The port number for the remote device.
    
19. private const int port = 11000;
    
20. // ManualResetEvent instances signal completion.
    
21. private static ManualResetEvent connectDone =
    
22. new ManualResetEvent(false);
    
23. private static ManualResetEvent sendDone =
    
24. new ManualResetEvent(false);
    
25. private static ManualResetEvent receiveDone =
    
26. new ManualResetEvent(false);
    
27. // The response from the remote device.
    
28. private static String response = String.Empty;
    
29. private static void StartClient() {
    
30. // Connect to a remote device.
    
31. try {
    
32. // Establish the remote endpoint for the socket.
    
33. // The name of the
    
34. // remote device is "host.contoso.com".
    
35. IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
    
36. IPAddress ipAddress = ipHostInfo.AddressList[0];
    
37. IPEndPoint remoteEP = new IPEndPoint(ipAddress, port);
    
38. // Create a TCP/IP socket.
    
39. Socket client = new Socket(AddressFamily.InterNetwork,
    
40. SocketType.Stream, ProtocolType.Tcp);
    
41. // Connect to the remote endpoint.
    
42. client.BeginConnect( remoteEP,
    
43. new AsyncCallback(ConnectCallback), client);
    
44. connectDone.WaitOne();
    
45. // Send test data to the remote device.
    
46. Send(client,"This is a test<EOF>");
    
47. sendDone.WaitOne();
    
48. // Receive the response from the remote device.
    
49. Receive(client);
    
50. receiveDone.WaitOne();
    
51. // Write the response to the console.
    
52. Console.WriteLine("Response received : {0}", response);
    
53. // Release the socket.
    
54. client.Shutdown(SocketShutdown.Both);
    
55. client.Close();
    
56. } catch (Exception e) {
    
57. Console.WriteLine(e.ToString());
    
58. }
    
59. }
    
60. private static void ConnectCallback(IAsyncResult ar) {
    
61. try {
    
62. // Retrieve the socket from the state object.
    
63. Socket client = (Socket) ar.AsyncState;
    
64. // Complete the connection.
    
65. client.EndConnect(ar);
    
66. Console.WriteLine("Socket connected to {0}",
    
67. client.RemoteEndPoint.ToString());
    
68. // Signal that the connection has been made.
    
69. connectDone.Set();
    
70. } catch (Exception e) {
    
71. Console.WriteLine(e.ToString());
    
72. }
    
73. }
    
74. private static void Receive(Socket client) {
    
75. try {
    
76. // Create the state object.
    
77. StateObject state = new StateObject();
    
78. state.workSocket = client;
    
79. // Begin receiving the data from the remote device.
    
80. client.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
    
81. new AsyncCallback(ReceiveCallback), state);
    
82. } catch (Exception e) {
    
83. Console.WriteLine(e.ToString());
    
84. }
    
85. }
    
86. private static void ReceiveCallback( IAsyncResult ar ) {
    
87. try {
    
88. // Retrieve the state object and the client socket
    
89. // from the asynchronous state object.
    
90. StateObject state = (StateObject) ar.AsyncState;
    
91. Socket client = state.workSocket;
    
92. // Read data from the remote device.
    
93. int bytesRead = client.EndReceive(ar);
    
94. if (bytesRead > 0) {
    
95. // There might be more data, so store the data received so far.
    
96. state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead));
    
97. // Get the rest of the data.
    
98. client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,
    
99. new AsyncCallback(ReceiveCallback), state);
    
100. } else {
     
101. // All the data has arrived; put it in response.
     
102. if (state.sb.Length > 1) {
     
103. response = state.sb.ToString();
     
104. }
     
105. // Signal that all bytes have been received.
     
106. receiveDone.Set();
     
107. }
     
108. } catch (Exception e) {
     
109. Console.WriteLine(e.ToString());
     
110. }
     
111. }
     
112. private static void Send(Socket client, String data) {
     
113. // Convert the string data to byte data using ASCII encoding.
     
114. byte[] byteData = Encoding.ASCII.GetBytes(data);
     
115. // Begin sending the data to the remote device.
     
116. client.BeginSend(byteData, 0, byteData.Length, 0,
     
117. new AsyncCallback(SendCallback), client);
     
118. }
     
119. private static void SendCallback(IAsyncResult ar) {
     
120. try {
     
121. // Retrieve the socket from the state object.
     
122. Socket client = (Socket) ar.AsyncState;
     
123. // Complete sending the data to the remote device.
     
124. int bytesSent = client.EndSend(ar);
     
125. Console.WriteLine("Sent {0} bytes to server.", bytesSent);
     
126. // Signal that all bytes have been sent.
     
127. sendDone.Set();
     
128. } catch (Exception e) {
     
129. Console.WriteLine(e.ToString());
     
130. }
     
131. }
     
132. public static int Main(String[] args) {
     
133. StartClient();
     
134. return 0;
     
135. }
     
136. }
     

复制代码

异步服务器套接字示例 下面的示例程序创建一个接收来自客户端的连接请求的服务器。该服务器是用异步套接字生成的，
因此在等待来自客户端的连接时不挂起服务器应用程序的执行。该应用程序接收来自客户端的字符串，
在控制台显示该字符串，然后将该字符串回显到客户端。来自客户端的字符串必须包含字符串“<EOF>”，
以发出表示消息结尾的信号。

1. C#
   
2. 复制代码
   
3. 
   
4. using System;
   
5. using System.Net;
   
6. using System.Net.Sockets;
   
7. using System.Text;
   
8. using System.Threading;
   
9. // State object for reading client data asynchronously
   
10. public class StateObject {
    
11. // Client socket.
    
12. public Socket workSocket = null;
    
13. // Size of receive buffer.
    
14. public const int BufferSize = 1024;
    
15. // Receive buffer.
    
16. public byte[] buffer = new byte[BufferSize];
    
17. // Received data string.
    
18. public StringBuilder sb = new StringBuilder();
    
19. }
    
20. public class AsynchronousSocketListener {
    
21. // Thread signal.
    
22. public static ManualResetEvent allDone = new ManualResetEvent(false);
    
23. public AsynchronousSocketListener() {
    
24. }
    
25. public static void StartListening() {
    
26. // Data buffer for incoming data.
    
27. byte[] bytes = new Byte[1024];
    
28. // Establish the local endpoint for the socket.
    
29. // The DNS name of the computer
    
30. // running the listener is "host.contoso.com".
    
31. IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
    
32. IPAddress ipAddress = ipHostInfo.AddressList[0];
    
33. IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);
    
34. // Create a TCP/IP socket.
    
35. Socket listener = new Socket(AddressFamily.InterNetwork,
    
36. SocketType.Stream, ProtocolType.Tcp );
    
37. // Bind the socket to the local endpoint and listen for incoming connections.
    
38. try {
    
39. listener.Bind(localEndPoint);
    
40. listener.Listen(100);
    
41. while (true) {
    
42. // Set the event to nonsignaled state.
    
43. allDone.Reset();
    
44. // Start an asynchronous socket to listen for connections.
    
45. Console.WriteLine("Waiting for a connection...");
    
46. listener.BeginAccept(
    
47. new AsyncCallback(AcceptCallback),
    
48. listener );
    
49. // Wait until a connection is made before continuing.
    
50. allDone.WaitOne();
    
51. }
    
52. } catch (Exception e) {
    
53. Console.WriteLine(e.ToString());
    
54. }
    
55. Console.WriteLine("\nPress ENTER to continue...");
    
56. Console.Read();
    
57. }
    
58. public static void AcceptCallback(IAsyncResult ar) {
    
59. // Signal the main thread to continue.
    
60. allDone.Set();
    
61. // Get the socket that handles the client request.
    
62. Socket listener = (Socket) ar.AsyncState;
    
63. Socket handler = listener.EndAccept(ar);
    
64. // Create the state object.
    
65. StateObject state = new StateObject();
    
66. state.workSocket = handler;
    
67. handler.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
    
68. new AsyncCallback(ReadCallback), state);
    
69. }
    
70. public static void ReadCallback(IAsyncResult ar) {
    
71. String content = String.Empty;
    
72. // Retrieve the state object and the handler socket
    
73. // from the asynchronous state object.
    
74. StateObject state = (StateObject) ar.AsyncState;
    
75. Socket handler = state.workSocket;
    
76. // Read data from the client socket.
    
77. int bytesRead = handler.EndReceive(ar);
    
78. if (bytesRead > 0) {
    
79. // There might be more data, so store the data received so far.
    
80. state.sb.Append(Encoding.ASCII.GetString(
    
81. state.buffer,0,bytesRead));
    
82. // Check for end-of-file tag. If it is not there, read
    
83. // more data.
    
84. content = state.sb.ToString();
    
85. if (content.IndexOf("<EOF>") > -1) {
    
86. // All the data has been read from the
    
87. // client. Display it on the console.
    
88. Console.WriteLine("Read {0} bytes from socket. \n Data : {1}",
    
89. content.Length, content );
    
90. // Echo the data back to the client.
    
91. Send(handler, content);
    
92. } else {
    
93. // Not all data received. Get more.
    
94. handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
    
95. new AsyncCallback(ReadCallback), state);
    
96. }
    
97. }
    
98. }
    
99. private static void Send(Socket handler, String data) {
    
100. // Convert the string data to byte data using ASCII encoding.
     
101. byte[] byteData = Encoding.ASCII.GetBytes(data);
     
102. // Begin sending the data to the remote device.
     
103. handler.BeginSend(byteData, 0, byteData.Length, 0,
     
104. new AsyncCallback(SendCallback), handler);
     
105. }
     
106. private static void SendCallback(IAsyncResult ar) {
     
107. try {
     
108. // Retrieve the socket from the state object.
     
109. Socket handler = (Socket) ar.AsyncState;
     
110. // Complete sending the data to the remote device.
     
111. int bytesSent = handler.EndSend(ar);
     
112. Console.WriteLine("Sent {0} bytes to client.", bytesSent);
     
113. handler.Shutdown(SocketShutdown.Both);
     
114. handler.Close();
     
115. } catch (Exception e) {
     
116. Console.WriteLine(e.ToString());
     
117. }
     
118. }
     
119. public static int Main(String[] args) {
     
120. StartListening();
     
121. return 0;
     
122. }
     
123. }
     

复制代码

异步客户端套接字示例


下面的示例程序创建一个连接到服务器的客户端。该客户端是用异步套接字生成的，因此在等待服务器返回响应时不挂起客户端应用程序的执行。该应用程序将字符串发送到服务器，然后在控制台显示该服务器返回的字符串。

C#

1. using System;
   
2. using System.Net;
   
3. using System.Net.Sockets;
   
4. using System.Threading;
   
5. using System.Text;
   
6. // State object for receiving data from remote device.
   
7. public class StateObject {
   
8. // Client socket.
   
9. public Socket workSocket = null;
   
10. // Size of receive buffer.
    
11. public const int BufferSize = 256;
    
12. // Receive buffer.
    
13. public byte[] buffer = new byte[BufferSize];
    
14. // Received data string.
    
15. public StringBuilder sb = new StringBuilder();
    
16. }
    
17. public class AsynchronousClient {
    
18. // The port number for the remote device.
    
19. private const int port = 11000;
    
20. // ManualResetEvent instances signal completion.
    
21. private static ManualResetEvent connectDone =
    
22. new ManualResetEvent(false);
    
23. private static ManualResetEvent sendDone =
    
24. new ManualResetEvent(false);
    
25. private static ManualResetEvent receiveDone =
    
26. new ManualResetEvent(false);
    
27. // The response from the remote device.
    
28. private static String response = String.Empty;
    
29. private static void StartClient() {
    
30. // Connect to a remote device.
    
31. try {
    
32. // Establish the remote endpoint for the socket.
    
33. // The name of the
    
34. // remote device is "host.contoso.com".
    
35. IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
    
36. IPAddress ipAddress = ipHostInfo.AddressList[0];
    
37. IPEndPoint remoteEP = new IPEndPoint(ipAddress, port);
    
38. // Create a TCP/IP socket.
    
39. Socket client = new Socket(AddressFamily.InterNetwork,
    
40. SocketType.Stream, ProtocolType.Tcp);
    
41. // Connect to the remote endpoint.
    
42. client.BeginConnect( remoteEP,
    
43. new AsyncCallback(ConnectCallback), client);
    
44. connectDone.WaitOne();
    
45. // Send test data to the remote device.
    
46. Send(client,"This is a test<EOF>");
    
47. sendDone.WaitOne();
    
48. // Receive the response from the remote device.
    
49. Receive(client);
    
50. receiveDone.WaitOne();
    
51. // Write the response to the console.
    
52. Console.WriteLine("Response received : {0}", response);
    
53. // Release the socket.
    
54. client.Shutdown(SocketShutdown.Both);
    
55. client.Close();
    
56. } catch (Exception e) {
    
57. Console.WriteLine(e.ToString());
    
58. }
    
59. }
    
60. private static void ConnectCallback(IAsyncResult ar) {
    
61. try {
    
62. // Retrieve the socket from the state object.
    
63. Socket client = (Socket) ar.AsyncState;
    
64. // Complete the connection.
    
65. client.EndConnect(ar);
    
66. Console.WriteLine("Socket connected to {0}",
    
67. client.RemoteEndPoint.ToString());
    
68. // Signal that the connection has been made.
    
69. connectDone.Set();
    
70. } catch (Exception e) {
    
71. Console.WriteLine(e.ToString());
    
72. }
    
73. }
    
74. private static void Receive(Socket client) {
    
75. try {
    
76. // Create the state object.
    
77. StateObject state = new StateObject();
    
78. state.workSocket = client;
    
79. // Begin receiving the data from the remote device.
    
80. client.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
    
81. new AsyncCallback(ReceiveCallback), state);
    
82. } catch (Exception e) {
    
83. Console.WriteLine(e.ToString());
    
84. }
    
85. }
    
86. private static void ReceiveCallback( IAsyncResult ar ) {
    
87. try {
    
88. // Retrieve the state object and the client socket
    
89. // from the asynchronous state object.
    
90. StateObject state = (StateObject) ar.AsyncState;
    
91. Socket client = state.workSocket;
    
92. // Read data from the remote device.
    
93. int bytesRead = client.EndReceive(ar);
    
94. if (bytesRead > 0) {
    
95. // There might be more data, so store the data received so far.
    
96. state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead));
    
97. // Get the rest of the data.
    
98. client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,
    
99. new AsyncCallback(ReceiveCallback), state);
    
100. } else {
     
101. // All the data has arrived; put it in response.
     
102. if (state.sb.Length > 1) {
     
103. response = state.sb.ToString();
     
104. }
     
105. // Signal that all bytes have been received.
     
106. receiveDone.Set();
     
107. }
     
108. } catch (Exception e) {
     
109. Console.WriteLine(e.ToString());
     
110. }
     
111. }
     
112. private static void Send(Socket client, String data) {
     
113. // Convert the string data to byte data using ASCII encoding.
     
114. byte[] byteData = Encoding.ASCII.GetBytes(data);
     
115. // Begin sending the data to the remote device.
     
116. client.BeginSend(byteData, 0, byteData.Length, 0,
     
117. new AsyncCallback(SendCallback), client);
     
118. }
     
119. private static void SendCallback(IAsyncResult ar) {
     
120. try {
     
121. // Retrieve the socket from the state object.
     
122. Socket client = (Socket) ar.AsyncState;
     
123. // Complete sending the data to the remote device.
     
124. int bytesSent = client.EndSend(ar);
     
125. Console.WriteLine("Sent {0} bytes to server.", bytesSent);
     
126. // Signal that all bytes have been sent.
     
127. sendDone.Set();
     
128. } catch (Exception e) {
     
129. Console.WriteLine(e.ToString());
     
130. }
     
131. }
     
132. public static int Main(String[] args) {
     
133. StartClient();
     
134. return 0;
     
135. }
     
136. }
     

复制代码

异步服务器套接字示例 下面的示例程序创建一个接收来自客户端的连接请求的服务器。该服务器是用异步套接字生成的，
因此在等待来自客户端的连接时不挂起服务器应用程序的执行。该应用程序接收来自客户端的字符串，
在控制台显示该字符串，然后将该字符串回显到客户端。来自客户端的字符串必须包含字符串“<EOF>”，
以发出表示消息结尾的信号。

1. C#
   
2. 复制代码
   
3. 
   
4. using System;
   
5. using System.Net;
   
6. using System.Net.Sockets;
   
7. using System.Text;
   
8. using System.Threading;
   
9. // State object for reading client data asynchronously
   
10. public class StateObject {
    
11. // Client socket.
    
12. public Socket workSocket = null;
    
13. // Size of receive buffer.
    
14. public const int BufferSize = 1024;
    
15. // Receive buffer.
    
16. public byte[] buffer = new byte[BufferSize];
    
17. // Received data string.
    
18. public StringBuilder sb = new StringBuilder();
    
19. }
    
20. public class AsynchronousSocketListener {
    
21. // Thread signal.
    
22. public static ManualResetEvent allDone = new ManualResetEvent(false);
    
23. public AsynchronousSocketListener() {
    
24. }
    
25. public static void StartListening() {
    
26. // Data buffer for incoming data.
    
27. byte[] bytes = new Byte[1024];
    
28. // Establish the local endpoint for the socket.
    
29. // The DNS name of the computer
    
30. // running the listener is "host.contoso.com".
    
31. IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
    
32. IPAddress ipAddress = ipHostInfo.AddressList[0];
    
33. IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);
    
34. // Create a TCP/IP socket.
    
35. Socket listener = new Socket(AddressFamily.InterNetwork,
    
36. SocketType.Stream, ProtocolType.Tcp );
    
37. // Bind the socket to the local endpoint and listen for incoming connections.
    
38. try {
    
39. listener.Bind(localEndPoint);
    
40. listener.Listen(100);
    
41. while (true) {
    
42. // Set the event to nonsignaled state.
    
43. allDone.Reset();
    
44. // Start an asynchronous socket to listen for connections.
    
45. Console.WriteLine("Waiting for a connection...");
    
46. listener.BeginAccept(
    
47. new AsyncCallback(AcceptCallback),
    
48. listener );
    
49. // Wait until a connection is made before continuing.
    
50. allDone.WaitOne();
    
51. }
    
52. } catch (Exception e) {
    
53. Console.WriteLine(e.ToString());
    
54. }
    
55. Console.WriteLine("\nPress ENTER to continue...");
    
56. Console.Read();
    
57. }
    
58. public static void AcceptCallback(IAsyncResult ar) {
    
59. // Signal the main thread to continue.
    
60. allDone.Set();
    
61. // Get the socket that handles the client request.
    
62. Socket listener = (Socket) ar.AsyncState;
    
63. Socket handler = listener.EndAccept(ar);
    
64. // Create the state object.
    
65. StateObject state = new StateObject();
    
66. state.workSocket = handler;
    
67. handler.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
    
68. new AsyncCallback(ReadCallback), state);
    
69. }
    
70. public static void ReadCallback(IAsyncResult ar) {
    
71. String content = String.Empty;
    
72. // Retrieve the state object and the handler socket
    
73. // from the asynchronous state object.
    
74. StateObject state = (StateObject) ar.AsyncState;
    
75. Socket handler = state.workSocket;
    
76. // Read data from the client socket.
    
77. int bytesRead = handler.EndReceive(ar);
    
78. if (bytesRead > 0) {
    
79. // There might be more data, so store the data received so far.
    
80. state.sb.Append(Encoding.ASCII.GetString(
    
81. state.buffer,0,bytesRead));
    
82. // Check for end-of-file tag. If it is not there, read
    
83. // more data.
    
84. content = state.sb.ToString();
    
85. if (content.IndexOf("<EOF>") > -1) {
    
86. // All the data has been read from the
    
87. // client. Display it on the console.
    
88. Console.WriteLine("Read {0} bytes from socket. \n Data : {1}",
    
89. content.Length, content );
    
90. // Echo the data back to the client.
    
91. Send(handler, content);
    
92. } else {
    
93. // Not all data received. Get more.
    
94. handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
    
95. new AsyncCallback(ReadCallback), state);
    
96. }
    
97. }
    
98. }
    
99. private static void Send(Socket handler, String data) {
    
100. // Convert the string data to byte data using ASCII encoding.
     
101. byte[] byteData = Encoding.ASCII.GetBytes(data);
     
102. // Begin sending the data to the remote device.
     
103. handler.BeginSend(byteData, 0, byteData.Length, 0,
     
104. new AsyncCallback(SendCallback), handler);
     
105. }
     
106. private static void SendCallback(IAsyncResult ar) {
     
107. try {
     
108. // Retrieve the socket from the state object.
     
109. Socket handler = (Socket) ar.AsyncState;
     
110. // Complete sending the data to the remote device.
     
111. int bytesSent = handler.EndSend(ar);
     
112. Console.WriteLine("Sent {0} bytes to client.", bytesSent);
     
113. handler.Shutdown(SocketShutdown.Both);
     
114. handler.Close();
     
115. } catch (Exception e) {
     
116. Console.WriteLine(e.ToString());
     
117. }
     
118. }
     
119. public static int Main(String[] args) {
     
120. StartListening();
     
121. return 0;
     
122. }
     
123. }
     

复制代码