Socket创建简单服务器和客户端程序，互相发送一条消息

https://blog.csdn.net/weixin_42464466/article/details/84782870

  • AddressFamily.Internet表示IPV4地址

  • AddressFamily.InternetV6表示IPV6地址

  • SocketType.Stream-数据流 对应TCP协议传输数据

  • SocketType.gram-数据报 对应UDP协议传输数据

  • ProtocolType.TCP

  • ProtocolType.UDP

  • 节点，标明了IP地址和端口号，由于 套接字（Socket） 需要绑定在一个进程上面，通过节点（IP: port）来确定

  • 对于TCP/IP协议而言，一台计算机有 0~66535个端口（有的已被占用，自定义申请时多使用靠后的端口号）

参考：https://blog.csdn.net/tianlansedeshijie/article/details/95357734

  • IPEndPoint继承于EndPoint。IPEndPoint引用的时候参数为IP和端口。IPEndPoint iep = new IPEndPoint(IPAddress.Any, 9050);

  • .net中 Bind(EndPoint localEP);方法参数是EndPoint，填入IPEndPoint会按照EndPoint参数执行。

EndPoint是IPEndPoint的基类，IPEndPoint可以强转为EndPoint。EndPoint ep = (EndPoint)iep;

  • 主要原因是IPEndPoint可以自己写入IP地址和端口。

https://www.cnblogs.com/pctzhang/archive/2012/02/02/2335324.html

  • new Socket(…).Accept()

  • new Socket(…).AcceptAsync(SocketAsyncEventArgs e)

  • new Socket(…).BeginAccept()

归并折叠其中的代码块

功能

  • 互相发送一条消息并接收

  • 暂无用户自定义消息内容功能—— Console.ReadLine()

  • 暂无多次通讯功能——线程中添加while循环或其他（异步接收方法等）

  1. // 服务器端
  2. using System;
  3. using System.Net;
  4. using System.Net.Sockets;
  5. using System.Text;
  6. using System.Threading;
  8. namespace Demo01_SocketTest_Sever
  9. {
  10.     class SeverEnd
  11.     {
  12.         private static Socket severSocket;
  13.         static void Main(string[] args)
  14.         {
  15.             // 1. 建立服务器
  16.             severSocket = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
  17.             // 2. 绑定进程
  18.             severSocket.Bind(new IPEndPoint(IPAddress.Parse("192.168.0.105"),6666));
  19.             // 3. 规定同时连接客户端数量
  20.             severSocket.Listen(10);
  21.             // 4. 提示服务器启动成功
  22.             Console.WriteLine("服务器启动成功");
  23.             // 5. 建立Accept等待连接线程（Accpet方法如果没有连接则会挂起，这里使用线程来处理）
  24.             Thread severAcceptThread = new Thread(SeverAccept);// new Thread（委托）
  25.             severAcceptThread.Start();
  26.             // 6. 暂停主线程
  27.             Console.ReadKey();
  28.         }
  30.         // 线程委托方法——Accept
  31.         private static void SeverAccept()
  32.         {
  33.             // 1. 建立客户端实例
  34.             Socket clientInstance = severSocket.Accept();
  35.             // 2. 向客户端发送消息肯定连接成功
  36.             clientInstance.Send(Encoding.Default.GetBytes("服务器发来消息：连接成功"));
  37.             // 3. 建立Receive接收消息线程（Receive方法如果没有连接则会挂起，这里使用线程来处理）
  38.             Thread severReceiveThread = new Thread(SeverReceive);
  39.             severReceiveThread.Start(clientInstance);
  40.         }
  41.         // 线程委托方法——Receive
  42.         private static void SeverReceive(Object clientSocket)
  43.         {
  44.             // 1. 构建byte数组（充当缓冲区用于存储客户端发来的消息）
  45.             byte[] data = new byte[1024];
  46.             // 2. 接收客户端clientSocket发来的消息，并存储至data缓冲区，且返回数据字节长度
  47.             int length = (clientSocket as Socket).Receive(data);
  48.             // 3. 打印输出接收到的消息（相当于处理数据）
  49.             Console.WriteLine(Encoding.UTF8.GetString(data,0,length));
  50.         }
  51.     }
  52. }
  54. // 客户端
  55. using System;
  56. using System.Net;
  57. using System.Net.Sockets;
  58. using System.Text;
  59. using System.Threading;
  61. namespace Demo01_SocketTest_Client
  62. {
  63.     class Program
  64.     {
  65.         private static Socket clientSocket;
  66.         static void Main(string[] args)
  67.         {
  68.             // 1. 创建客户端Socket
  69.             clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  70.             // 2. 建立连接（请求，对应SeverEnd中第五步）
  71.             clientSocket.Connect(new IPEndPoint(IPAddress.Parse("192.168.0.105"),6666));
  72.             // 3. 提示连接成功
  73.             Console.WriteLine("连接成功");
  74.             // 4. 向服务器发送消息
  75.             clientSocket.Send(Encoding.UTF8.GetBytes("来自客户端：你好呀服务器！"));
  76.             // 5. 建立Receive接收消息线程（接收来自服务器端的消息），Receive方法如果没有连接则会挂起，这里使用线程来处理
  77.             Thread clientReceiveThread = new Thread(ClientReceive);
  78.             // 6. 暂停主线程
  79.             Console.ReadKey();
  80.         }
  82.         // 线程委托方法
  83.         private static void ClientReceive()
  84.         {
  85.             // 1. 构建byte数组（充当缓冲区用于存储服务器端发来的消息）
  86.             byte[] data = new byte[1024];
  87.             // 2. 接收由服务器端发来的消息，并存储至data缓冲区，且返回消息字节长
  88.             int length = clientSocket.Receive(data);
  89.             // 3. 打印输出接收到的消息（相当于处理数据）
  90.             Console.WriteLine(Encoding.UTF8.GetString(data,0,length));
  91.         }
  92.     }
  93. }

 

版权声明：本文为YuanShiRenY原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/YuanShiRenY/p/Socket_Server_Client.html