C#Socket异步通讯实现详解

C# Socket异步通讯客户端实现源码

达拉特网站制作公司哪家好，找创新互联公司！从网页设计、网站建设、微信开发、APP开发、响应式网站等网站项目制作，到程序开发，运营维护。创新互联公司于2013年创立到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选创新互联公司。

C# Socket异步通讯客户端之主程序：

 
 
 
    
  
  
  
  1. using System;
    2. 
  
  
  
  2. using System.Net;
    3. 
  
  
  
  3. using System.Net.Sockets;
    4. 
  
  
  
  4. using System.Threading;
    5. 
  
  
  
  5. using System.Text;
    6. 
  
  
  
  6. // State object for receiving data from remote device.
    7. 
  
  
  
  7. public class StateObject {
    8. 
  
  
  
  8. // Client socket.
    9. 
  
  
  
  9. public Socket workSocket = null;
    10. 
  
  
  
  10. // Size of receive buffer.
    11. 
  
  
  
  11. public const int BufferSize = 256;
    12. 
  
  
  
  12. // Receive buffer.
    13. 
  
  
  
  13. public byte[] buffer = new byte[BufferSize];
    14. 
  
  
  
  14. // Received data string.
    15. 
  
  
  
  15. public StringBuilder sb = new StringBuilder();
    16. 
  
  
  
  16. }
    17. 
  
  
  
  17. public class AsynchronousClient {
    18. 
  
  
  
  18. // The port number for the remote device.
    19. 
  
  
  
  19. private const int port = 11000;
    20. 
  
  
  
  20. // ManualResetEvent instances signal completion.
    21. 
  
  
  
  21. private static ManualResetEvent connectDone =
    22. 
  
  
  
  22. new ManualResetEvent(false);
    23. 
  
  
  
  23. private static ManualResetEvent sendDone = 
    24. 
  
  
  
  24. new ManualResetEvent(false);
    25. 
  
  
  
  25. private static ManualResetEvent receiveDone =
    26. 
  
  
  
  26. new ManualResetEvent(false);
    27. 
  
  
  
  27. // The response from the remote device.
    28. 
  
  
  
  28. private static String response = String.Empty;
    29. 
  
  
  
  29. private static void StartClient() {
    // Connect to a remote device.
    30. 
  
  
  
  30. 
  
  
  
  31. try {// Establish the remote endpoint for the socket.
    // The name of the 
    // remote device is "host.contoso.com".
    IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
    IPAddress ipAddress = ipHostInfo.AddressList[0];
    IPEndPoint remoteEP = new IPEndPoint(ipAddress, port);
    32. 
  
  
  
  32. // 生成一个TCP/IP socket. 
    33. 
  
  
  
  33. Socket client = new Socket(AddressFamily.InterNetwork, 
    34. 
  
  
  
  34. SocketType.Stream, ProtocolType.Tcp); 
    35. 
  
  
  
  35. 
  
  
  
  36. // 与目标终端连接. 
    37. 
  
  
  
  37. client.BeginConnect(remoteEP, 
    38. 
  
  
  
  38. new AsyncCallback(ConnectCallback), client); 
    39. 
  
  
  
  39. //等待，直到连接程序完成。在ConnectCallback中适当位置有connecDone.Set()语句 
    40. 
  
  
  
  40. connectDone.WaitOne(); 
    41. 
  
  
  
  41. 
  
  
  
  42. // 发送数据到远程终端. 
    43. 
  
  
  
  43. Send(client, "This is a test"); 
    44. 
  
  
  
  44. sendDone.WaitOne(); 
    45. 
  
  
  
  45. 
  
  
  
  46. // 接收返回数据. 
    47. 
  
  
  
  47. Receive(client); 
    48. 
  
  
  
  48. receiveDone.WaitOne(); 
    49. 
  
  
  
  49. 
  
  
  
  50. // Write the response to the console. 
    51. 
  
  
  
  51. Console.WriteLine("Response received : {0}", response); 
    52. 
  
  
  
  52. 
  
  
  
  53. // Release the socket. 
    54. 
  
  
  
  54. client.Shutdown(SocketShutdown.Both); 
    55. 
  
  
  
  55. client.Close(); 
    56. 
  
  
  
  56. return 0; 
    57. 
  
  
  
  57. }
    58.

C# Socket异步通讯客户端之连接部分Callback:

 
 
 
    
  
  
  
  1. private static void ConnectCallback(IAsyncResult ar) 
    2. 
  
  
  
  2. { 
    3. 
  
  
  
  3. 
  
  
  
  4. // 从state对象获取socket. 
    5. 
  
  
  
  5. Socket client = (Socket)ar.AsyncState; 
    6. 
  
  
  
  6. 
  
  
  
  7. // 完成连接. 
    8. 
  
  
  
  8. client.EndConnect(ar); 
    9. 
  
  
  
  9. 
  
  
  
  10. Console.WriteLine("Socket connected to {0}", 
    11. 
  
  
  
  11. client.RemoteEndPoint.ToString()); 
    12. 
  
  
  
  12. 
  
  
  
  13. // 连接已完成，主线程继续. 
    14. 
  
  
  
  14. connectDone.Set();
    15. 
  
  
  
  15. } catch (Exception e) {
    16. 
  
  
  
  16. Console.WriteLine(e.ToString());
    17. 
  
  
  
  17. }
    18. 
  
  
  
  18. }
    19.

C# Socket异步通讯客户端之数据接收：

 
 
 
    
  
  
  
  1.    private static void Receive(Socket client) 
    2. 
  
  
  
  2. try {{ 
    3. 
  
  
  
  3. 
  
  
  
  4. // 构造容器state. 
    5. 
  
  
  
  5. StateObject state = new StateObject(); 
    6. 
  
  
  
  6. state.workSocket = client; 
    7. 
  
  
  
  7. 
  
  
  
  8. // 从远程目标接收数据. 
    9. 
  
  
  
  9. client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, 
    10. 
  
  
  
  10. new AsyncCallback(ReceiveCallback), state); 
    11. 
  
  
  
  11. } catch (Exception e) {
    12. 
  
  
  
  12. Console.WriteLine(e.ToString());
    13. 
  
  
  
  13. }
    }
    14. 
  
  
  
  14. 
  
  
  
  15. private static void ReceiveCallback(IAsyncResult ar) 
    16. 
  
  
  
  16. { 
    17. 
  
  
  
  17. 
  
  
  
  18. // 从输入参数异步state对象中获取state和socket对象 
    19. 
  
  
  
  19. StateObject state = (StateObject)ar.AsyncState; 
    20. 
  
  
  
  20. Socket client = state.workSocket; 
    21. 
  
  
  
  21. 
  
  
  
  22. //从远程设备读取数据 
    23. 
  
  
  
  23. int bytesRead = client.EndReceive(ar); 
    24. 
  
  
  
  24. 
  
  
  
  25. if (bytesRead > 0) 
    26. 
  
  
  
  26. { 
    27. 
  
  
  
  27. // 有数据，存储. 
    28. 
  
  
  
  28. state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead)); 
    29. 
  
  
  
  29. 
  
  
  
  30. // 继续读取. 
    31. 
  
  
  
  31. client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, 
    32. 
  
  
  
  32. new AsyncCallback(ReceiveCallback), state); 
    33. 
  
  
  
  33. } 
    34. 
  
  
  
  34. else
    35. 
  
  
  
  35. { 
    36. 
  
  
  
  36. // 所有数据读取完毕. 
    37. 
  
  
  
  37. if (state.sb.Length > 1) 
    38. 
  
  
  
  38. { 
    39. 
  
  
  
  39. response = state.sb.ToString(); 
    40. 
  
  
  
  40. } 
    41. 
  
  
  
  41. // 所有数据读取完毕的指示信号. 
    42. 
  
  
  
  42. receiveDone.Set(); 
    43. 
  
  
  
  43. } 
    44. 
  
  
  
  44. } catch (Exception e) {
    45. 
  
  
  
  45. Console.WriteLine(e.ToString());
    46. 
  
  
  
  46. }
    47. 
  
  
  
  47. }
    48.

C# Socket异步通讯客户端之发送数据：

 
 
 
    
  
  
  
  1. private static void Send(Socket client, String data) 
    2. 
  
  
  
  2. { 
    3. 
  
  
  
  3. // 格式转换. 
    4. 
  
  
  
  4. byte[] byteData = Encoding.ASCII.GetBytes(data); 
    5. 
  
  
  
  5. 
  
  
  
  6. // 开始发送数据到远程设备. 
    7. 
  
  
  
  7. client.BeginSend(byteData, 0, byteData.Length, 0, 
    8. 
  
  
  
  8. new AsyncCallback(SendCallback), client); 
    9. 
  
  
  
  9. }  
    10. 
  
  
  
  10. private static void SendCallback(IAsyncResult ar) 
    11. 
  
  
  
  11. { 
    12. 
  
  
  
  12. 
  
  
  
  13. // 从state对象中获取socket 
    14. 
  
  
  
  14. Socket client = (Socket)ar.AsyncState; 
    15. 
  
  
  
  15. 
  
  
  
  16. // 完成数据发送. 
    17. 
  
  
  
  17. int bytesSent = client.EndSend(ar); 
    18. 
  
  
  
  18. Console.WriteLine("Sent {0} bytes to server.", bytesSent); 
    19. 
  
  
  
  19. 
  
  
  
  20. // 指示数据已经发送完成，主线程继续. 
    21. 
  
  
  
  21. sendDone.Set(); 
    22. 
  
  
  
  22. }
    23. 
  
  
  
  23. } catch (Exception e) {
    24. 
  
  
  
  24. Console.WriteLine(e.ToString());
    25. 
  
  
  
  25. } 
    26. 
  
  
  

    27. 
  
  
  
  27. }
    28. 
  
  
  
  28. public static int Main(String[] args) {
    29. 
  
  
  
  29. StartClient();
    30. 
  
  
  
  30. return 0;
    31. 
  
  
  
  31. }
    32. 
  
  
  
  32. }
    33.

C# Socket异步通讯客户端的实现源码内容就基本向你介绍到这里，希望对你了解和学习C# Socket异步通讯有所帮助。

文章名称：C#Socket异步通讯实现详解
标题来源：http://www.shufengxianlan.com/qtweb/news10/60960.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

微信小程序知识

同城分类信息

奢侈品网站建设方案　　 　虚拟主机　　 　网站SEO优化　　 　全网营销推广　　 　成都主机租用　　 　定制网站建设多少钱　　 　全网整合营销　　 　大英网站建设　　 　企业网站设计　　 　微信小程序开发　　 　成都富士康招工　　 　成都定制网站　　 　成都网站设计　　 　成都路面机械设备　　 　网站建设公司　　 　重庆托管服务器　　 　小谭建站工作室　　 　成都网站设计　　 　成都免费网站建设公司　　 　成都保温材料