UDP发送数据、接收数据及UDP通信程序练习

本是古典何须时尚 2024-04-06 09:26 70阅读 0赞

[CSDN话题挑战赛第2期][CSDN_2]  
参赛话题：[学习笔记][Link 1]

**目录**

一、UDP发送数据

二、UDP接收数据

三、UDP通信程序练习

--------------------

## 一、UDP发送数据 ##

Java中的UDP通信：

> ● UDP协议是一种不可靠的网络协议，它在通信的两端各建立一个Socket对象，但是这两个Socket只是发送，接收数据的对象，因此对于基于UDP协议的通信双方而言，没有所谓的客户端和服务端的概念
> 
> ● Java提供了**DatagramSocket**类作为UDP协议的**Socket**

构造方法：

<table> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>DatagramSocket()</td> 
   <td>创建数据报套接字并将其绑定到本机地址上的任何可用接口</td> 
  </tr> 
  <tr> 
   <td>DatagramPacket(byte[] buf,int len,InetAddress add,int port)</td> 
   <td>创建数据包，发送长度为len的数据包到指定主机的指定接口</td> 
  </tr> 
 </tbody> 
</table>

相关方法：

<table> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>void send(DatagramPacket p)</td> 
   <td>发送数据报包</td> 
  </tr> 
  <tr> 
   <td>void close()</td> 
   <td>关闭数据报套接字</td> 
  </tr> 
  <tr> 
   <td>void receive(DatagramPacket p)</td> 
   <td>从此套接字接收数据报包</td> 
  </tr> 
 </tbody> 
</table>

发送数据的步骤：

> ● 创建发送端的Socket对象(DatagramSocket)
> 
> ● 创建数据，并把数据打包
> 
> ● 调用DatagramSocket对象的发送数据
> 
> ● 关闭发送端

代码演示：

public class SendDemo {
        public static void main(String[] args) throws IOException {
            //创建发送端的Socket对象(DatagramSocket) 
            // DatagramSocket() 构造数据报套接字并将其绑定到本地主机上的任何可用端口 
            DatagramSocket ds = new DatagramSocket();
    
            //创建数据，并把数据打包 
            //DatagramPacket(byte[] buf, int length, InetAddress address, int port) 
            //构造一个数据包，发送长度为 length的数据包到指定主机上的指定端口号。 
            byte[] bys = "hello,udp,我来了".getBytes();
    
            DatagramPacket dp = new DatagramPacket(bys,bys.length,InetAddress.getByName("192.168.1.66"),10086);
            //调用DatagramSocket对象的方法发送数据 
            //void send(DatagramPacket p) 从此套接字发送数据报包 
            ds.send(dp);
    
            //关闭发送端 
            //void close() 关闭此数据报套接字 
            ds.close();
        }
    }

## 二、UDP接收数据 ##

接收数据的步骤：

> ● 创建接收端的Socket对象(DatagramSocket)
> 
> ● 创建一个数据包，用于接收数据
> 
> ● 调用DatagramSocket对象的方法接收数据
> 
> ● 关闭接收端

构造方法：

<table> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>DatagramPacket(byte[] buf,int len)</td> 
   <td>创建一个DatagramPacket用于接收长度为len的数据包</td> 
  </tr> 
 </tbody> 
</table>

相关方法：

<table> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>byte[] getData()</td> 
   <td>返回数据缓冲区</td> 
  </tr> 
  <tr> 
   <td>int getLength()</td> 
   <td>返回要发送的数据的长度或接收的数据的长度</td> 
  </tr> 
 </tbody> 
</table>

示例代码：

public class ReceiveDemo {
        public static void main(String[] args) throws IOException {
            //创建接收端的Socket对象(DatagramSocket) 
            DatagramSocket ds = new DatagramSocket(12345);
    
            while (true) {
                //创建一个数据包，用于接收数据 
                byte[] bys = new byte[1024];
                DatagramPacket dp = new DatagramPacket(bys, bys.length);
    
                //调用DatagramSocket对象的方法接收数据 
                ds.receive(dp);
    
                //解析数据包，并把数据在控制台显示 
                System.out.println("数据是：" + new String(dp.getData(), 0, dp.getLength()));
            }
        }
    }

## 三、UDP通信程序练习 ##

需求：

UDP发送数据：数据来自键盘录入，直到输入的数据是886，发送数据结束

UDP接收数据：因为接收端不知道发送端什么时候停止发送，故采用死循环接收

代码实现：

/* 
    UDP发送数据： 
    数据来自于键盘录入，直到输入的数据是886，发送数据结束 
    */
    public class SendDemo {
        public static void main(String[] args) throws IOException {
            //创建发送端的Socket对象(DatagramSocket) 
            DatagramSocket ds = new DatagramSocket();
            //自己封装键盘录入数据 
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            String line;
            while ((line = br.readLine()) != null) {
                //输入的数据是886，发送数据结束 
                if ("886".equals(line)) {
                    break;
                }
                //创建数据，并把数据打包 
                byte[] bys = line.getBytes();
                DatagramPacket dp = new DatagramPacket(bys, bys.length,InetAddress.getByName("192.168.1.66"), 12345);
                //调用DatagramSocket对象的方法发送数据
                ds.send(dp);
            }
            //关闭发送端 
            ds.close();
        }
    }
    /* 
    UDP接收数据： 
    因为接收端不知道发送端什么时候停止发送，故采用死循环接收 
    */
    public class ReceiveDemo {
        public static void main(String[] args) throws IOException {
            //创建接收端的Socket对象(DatagramSocket) 
            DatagramSocket ds = new DatagramSocket(12345);
            while (true) {
                //创建一个数据包，用于接收数据 
                byte[] bys = new byte[1024];
                DatagramPacket dp = new DatagramPacket(bys, bys.length);
                //调用DatagramSocket对象的方法接收数据 
                ds.receive(dp);
                //解析数据包，并把数据在控制台显示 
                System.out.println("数据是：" + new String(dp.getData(), 0,
                        dp.getLength()));
            }
        //关闭接收端 
        // ds.close(); 
        }
    }

[CSDN_2]: https://marketing.csdn.net/p/7b6697fd9dd3795a268d1a6f2fe75012
[Link 1]: https://activity.csdn.net/creatActivity?id=10213