package com.himi.udpDemo;

 import java.io.IOException;

 import java.net.DatagramPacket;

 import java.net.DatagramSocket;

 import java.net.InetAddress;

 import java.net.SocketException;

 import java.net.UnknownHostException;

 /**

  *

  * UDP协议发送数据:

  * 1. 创建发送端的Socket对象

  * 2. 创建数据，并把数据打包

  * 3. 调用Socket对象的发送方法,发送数据包

  * 4. 释放资源

  *

  */

 public class UdpSendDemo {

     public static void main(String[] args) throws IOException {

         //创建发送端的Socket对象,这里使用的UDP使用的客户端的Socket对象类是DatagramSocket.

         //DatagramSocket：DatagramSocket()

         DatagramSocket ds = new DatagramSocket();

         //创建数据，并把数据打包

         //DatagramPacket：此类表示数据报包

         /**DatagramPacket(byte[] buf, int length, InetAddress address, int port)

         **         构造数据报包，用来将长度为 length 的包发送到指定主机上的指定端口号。

         */

         //创建数据

         byte[] bytes = "风云雄霸天下,风云必胜. 风云合璧,摩柯无量. 圣心诀,玄武真功".getBytes();

         //IP地址对象

         InetAddress address = InetAddress.getByName("49.123.72.145");

         //端口号

         int port = 10086;

         //数据打包

         DatagramPacket dp = new DatagramPacket(bytes, bytes.length, address, port);

         //调用Socket对象的发送方法,发送数据包

         //public void send(DatagramPacket p)

         ds.send(dp);

         //释放资源

         ds.close();

     }

 }

 package com.himi.udpDemo;

 import java.io.IOException;

 import java.net.DatagramPacket;

 import java.net.DatagramSocket;

 import java.net.InetAddress;

 /**

  *

  * UDP协议接收数据:

  * 1. 创建接收端的Socket对象

  * 2. 创建数据包，接收数据(接收容器)

  * 3. 调用Socket对象的接收方法,接收数据包

  * 4. 解析数据包，并显示在控制台

  * 5. 释放资源

  *

  */

 public class UdpReceiveDemo {

     public static void main(String[] args) throws IOException {

         // 创建接收端的Socket对象

         //DatagramSocket(int port):创建数据报套接字并将其绑定到本地主机上的指定端口

         DatagramSocket ds = new DatagramSocket(10086);

         //创建数据包，接收数据(接收容器)

         //DatagramPacket(byte[] buf, int length)

         byte[] bytes = new byte[1024];

         int length  = bytes.length;

         DatagramPacket dp = new DatagramPacket(bytes, length);

         //调用Socket对象的接收方法,接收数据包

         // public void receive(DatagramPacket p)

         ds.receive(dp);//阻塞式方法

         //解析数据包，并显示在控制台

         //获取对方的IP

         //public InetAddress getAddress()

         InetAddress address = dp.getAddress();

         String IP = address.getHostAddress();

         //public byte[] getData():获取数据的缓冲区

         //public int getLength():获取数据的实际长度

         byte[] bys = dp.getData();

         int len = dp.getLength();

         String s = new String(bys,0,len);

         System.out.println("发送端"+IP+"的数据："+s);

         //释放资源

         ds.close();

     }

 }