需求
相信我们所有人都使用过或正在使用扣扣和微信。QQ是一款基于互联网的即时通信软件。我们在享受即时通讯的便捷和智能时，是否也想过，QQ、微信的聊天功能是怎么实现的？

功能
我们首先需要知道我们和对方的网络地址，现在主流的ip地址是IPV4和IPV6。
之后我们就可以通过这些地址进行双向通信，实现聊天室的功能。
实现
查看本机IP
打开windows的控制面板（按win +R ）
watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjI5MTA5,size_16,color_FFFFFF,t_70#pic_center.jpg
输入cmd
输入ipconfig查看本机IP
20210604105632817.jpg
发送端
  1.         //获取当前IPv4地址
  2.         private string GetIpAddress()
  3.         {
  4.             string hostName = Dns.GetHostName();   //获取本机名
  5.             IPHostEntry localhost = Dns.GetHostByName(hostName);    //方法已过期，可以获取IPv4的地址
  6.                                                                     //IPHostEntry localhost = Dns.GetHostEntry(hostName);   //获取IPv6地址
  7.             IPAddress localaddr = localhost.AddressList[0];
  9.             return localaddr.ToString();
  10.         }
  11.         public void UdpSend()
  12.         {
  13.             //Parse()把十进制iP转化成IPAddress类，绑定IP地址和端口
  14.             remoteIPEp = new IPEndPoint(IPAddress.Parse("IP地址"), CLIENT_UDP_PORT);
  15.             //创建发送数据 Socket 对象与数据缓冲区
  16.             udpSendDataBuf = new byte[1024];
  17.             skUdpSend = new Socket(AddressFamily.InterNetwork,
  18.             SocketType.Dgram, ProtocolType.Udp);
  19.             //为false，等待执行
  20.             mreUdpShutDown = new ManualResetEvent(false);
  21.             mreUdpSend = new ManualResetEvent(false);
  22.             whUdp = new WaitHandle[2];
  23.             whUdp[0] = mreUdpShutDown;//UDP结束命令
  24.             whUdp[1] = mreUdpSend; //UDP服务结束命令
  25.             int iWaitRetCode;
  26.             iWaitRetCode = WaitHandle.WaitAny(whUdp, 1000);   //等待指定数组中的任意元素接收信号，同时使用 TimeSpan 指定时间间隔
  27.             byte[] b_txt;
  28.             int iByteLen;
  30.             //满足条件
  31.             while (iWaitRetCode != 0)
  32.             {
  33.                 switch (iWaitRetCode)
  34.                 {
  35.                     case 1://发送数据
  36.                         b_txt = Encoding.UTF8.GetBytes(strSendTxt);
  37.                         iByteLen = b_txt.Length;
  38.                         //初始化缓存数据
  39.                         Array.Clear(udpSendDataBuf, iWaitRetCode, iByteLen);
  40.                         //复制数组
  41.                         Array.Copy(b_txt, udpSendDataBuf, iByteLen);
  42.                         //发送到指定IP
  43.                         skUdpSend.SendTo(udpSendDataBuf, remoteIPEp);
  44.                         //消费掉一次事件
  45.                         mreUdpSend.Reset();
  46.                         break;
  47.                     case WaitHandle.WaitTimeout://超时
  48.                         break;
  49.                 }
  50.                 //继续下次事件检测
  51.                 iWaitRetCode = WaitHandle.WaitAny(whUdp, 1000);
  52.             }
  53.             skUdpSend.Close();
  54.             skUdpSend = null;
  55.         }
  56.         #endregion    UDP发送线程线程
  57.         public static string strSendTxt;
  58.         private void button1_Click(object sender, EventArgs e)
  59.         {
  60.             mreUdpShutDown.Set();
  61.         }
  63.         private void button2_Click(object sender, EventArgs e)
  64.         {
  65.             strSendTxt = GetIpAddress() +"："+ textBox1.Text + "\r\n";
  66.             mreUdpSend.Set();
  67.         }
  69.         private void liaotian_Load(object sender, EventArgs e)
  70.         {
  71.             //线程开始
  72.             ThreadStart theStart = new ThreadStart(UdpSend);
  73.             Thread theThr = new Thread(theStart);
  74.             theThr.Start();
  75.         }
  77.         private void liaotian_FormClosing(object sender, FormClosingEventArgs e)
  78.         {
  79.             mreUdpShutDown.Set();
  80.         }
接收端
  1. namespace FormUdpSend
  2. {
  3.     public partial class send : Form
  4.     {
  5.         public send()
  6.         {
  7.             InitializeComponent();
  8.         }
  9.         #region  UDP发送线程
  10.         public static int iUdpRecvPkgLen;
  11.         public static Socket skUdpSend;
  12.         public static byte[] udpSendDataBuf;
  13.         public static IPEndPoint remoteIPEp;  //IP地址和端口的绑定
  14.         public static int CLIENT_UDP_PORT = 0x5555;  //分配给 Port属性,例子用ipv4
  16.         public static ManualResetEvent mreUdpShutDown;//UDP结束命令
  17.         public static ManualResetEvent mreUdpSend;//UDP发送命令
  18.         public static WaitHandle[] whUdp;  //UDP相关句柄
  19.         //获取当前IPv4地址
  20.         private string GetIpAddress()
  21.         {
  22.             string hostName = Dns.GetHostName();   //获取本机名
  23.             IPHostEntry localhost = Dns.GetHostByName(hostName);    //方法已过期，可以获取IPv4的地址
  24.                                                                     //IPHostEntry localhost = Dns.GetHostEntry(hostName);   //获取IPv6地址
  25.             IPAddress localaddr = localhost.AddressList[0];
  27.             return localaddr.ToString();
  28.         }
  30.         public void UdpSend()
  31.         {
  32.             //Parse()把十进制iP转化成IPAddress类，绑定IP地址和端口
  33.             remoteIPEp = new IPEndPoint(IPAddress.Parse("169.254.7.216"), CLIENT_UDP_PORT);
  34.             //创建发送数据 Socket 对象与数据缓冲区
  35.             udpSendDataBuf = new byte[1024];
  36.             skUdpSend = new Socket(AddressFamily.InterNetwork,
  37.             SocketType.Dgram, ProtocolType.Udp);
  39.             //为false，等待执行
  40.             mreUdpShutDown = new ManualResetEvent(false);
  41.             mreUdpSend = new ManualResetEvent(false);
  42.             whUdp = new WaitHandle[2];
  43.             whUdp[0] = mreUdpShutDown;//UDP结束命令
  44.             whUdp[1] = mreUdpSend; //UDP服务结束命令
  46.             int iWaitRetCode;
  47.             iWaitRetCode = WaitHandle.WaitAny(whUdp, 1000);   //等待指定数组中的任意元素接收信号，同时使用 TimeSpan 指定时间间隔
  48.             byte[] b_txt;
  49.             int iByteLen;
  51.             //满足条件
  52.             while (iWaitRetCode != 0)
  53.             {
  54.                 switch (iWaitRetCode)
  55.                 {
  56.                     case 1://发送数据
  57.                         b_txt = Encoding.UTF8.GetBytes(strSendTxt);
  58.                         iByteLen = b_txt.Length;
  59.                         //初始化缓存数据
  60.                         Array.Clear(udpSendDataBuf, iWaitRetCode, iByteLen);
  61.                         //复制数组
  62.                         Array.Copy(b_txt, udpSendDataBuf, iByteLen);
  63.                         //发送到指定IP
  64.                         skUdpSend.SendTo(udpSendDataBuf, remoteIPEp);
  65.                         //消费掉一次事件
  66.                         mreUdpSend.Reset();
  67.                         break;
  68.                     case WaitHandle.WaitTimeout://超时
  69.                         break;
  70.                 }
  71.                 //继续下次事件检测
  72.                 iWaitRetCode = WaitHandle.WaitAny(whUdp, 1000);
  73.             }
  74.             skUdpSend.Close();
  75.             skUdpSend = null;
  76.         }
  77.         #endregion    UDP发送线程线程
  78.         public static string strSendTxt;
  79.         private void button1_Click(object sender, EventArgs e)
  80.         {
  81.             mreUdpShutDown.Set();
  82.         }
  84.         private void button2_Click(object sender, EventArgs e)
  85.         {
  86.             strSendTxt = GetIpAddress() +"："+ textBox1.Text + "\r\n";
  87.             mreUdpSend.Set();
  88.         }
  90.         private void Form1_Load(object sender, EventArgs e)
  91.         {
  92.             //线程开始
  93.             ThreadStart theStart = new ThreadStart(UdpSend);
  94.             Thread theThr = new Thread(theStart);
  95.             theThr.Start();
  96.         }
  98.         private void Form1_FormClosing(object sender, FormClosingEventArgs e)
  99.         {
  100.             mreUdpShutDown.Set();
  101.         }
  102.     }
  103. }
使用流程

  • 在发送端程序中输入IP地址
  • 运行发送端程序，在输入框中输入要发送的消息
  • 运行接收端信息
  • 输入IP地址
  • 查看消息框
运行结果

watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0NjI5MTA5,size_16,color_FFFFFF,t_70#pic_center.jpg
程序