1. package net.program;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. 
   
8. public class UdpSendDemo {
   
9. 
   
10.         /**
    
11.          *         192.168.11.248
    
12.                 255.255.255.0
    
13.                 192.168.11.1
    
14.          * UDP数据报协议发送数据流程：
    
15.          *         1 创建发送端的Socket对象，DatagramSocket
    
16.          *  2 创建数据，并将数据封包，底层为IO数据流
    
17.          *  3 调用DatagramSocket对象的发送方法，将数据发送
    
18.          *  4 释放资源
    
19.          * @throws IOException
    
20.          */
    
21.         public static void main(String[] args) throws IOException {
    
22.                 //DatagramSocket()
    
23. //        构造数据报套接字并将其绑定到本地主机上任何可用的端口。
    
24.                 DatagramSocket ds = new DatagramSocket();
    
25.                 //创建数据
    
26.                 byte[] bys = "This is UDP demo".getBytes();
    
27.                 int length = bys.length;
    
28.                 //数据封装DatagramPacket
    
29.                 //DatagramPacket(byte[] buf, int length, InetAddress address, int port)
    
30.                 InetAddress address = InetAddress.getByName("192.168.11.248");
    
31. //                System.out.println(address.getHostAddress()+"..."+address.getHostName());
    
32.                 DatagramPacket dp = new DatagramPacket(bys, length, address,10086);
    
33.                 ds.send(dp);
    
34.                 //释放资源
    
35.                 ds.close();
    
36.         }
    
37. 
    
38. }
    

复制代码

1. package net.program;
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. 
   
8. public class UdpReceiveDemo {
   
9. 
   
10.         /**
    
11.          * UDP接收程序：
    
12.          *  1 创建UDP套接字对象，DatagramSocket,并指定接收端口
    
13.          *  2 创建接收数据包DatagramPacket
    
14.          *  3 调用DatagramSocket的接收方法，接收数据，放入DatagramPacket
    
15.          *  4 解析数据包并输出到控制台
    
16.          *  5 释放资源
    
17.          * @throws IOException
    
18.          */
    
19.         public static void main(String[] args) throws IOException {
    
20.                 //创建套接字
    
21.                 DatagramSocket ds = new DatagramSocket(10086);
    
22.                 //创建接收容器，数据报包
    
23.                 byte[] buf = new byte[1024];
    
24.                 DatagramPacket dp = new DatagramPacket(buf, 1024);
    
25.                 //接收数据报包
    
26.                 ds.receive(dp);//该方法在接收到数据报之前一直阻塞
    
27.                 //获取ip地址
    
28.                 InetAddress address = dp.getAddress();
    
29.                 System.out.println(address.getHostName()+"..."+address.getHostAddress()+" 发来消息:");
    
30.                 //解析数据包内容，数据+长度
    
31.                 byte[] datas = dp.getData();
    
32.                 int length = dp.getLength();
    
33.                 String message = new String(datas,0,length);
    
34.                 System.out.println(message);
    
35.                 //释放资源
    
36.                 ds.close();
    
37.         }
    
38. 
    
39. }
    

复制代码