package com.himi.updDemo1;

 import java.io.IOException;

 import java.net.DatagramPacket;

 import java.net.DatagramSocket;

 import java.net.InetAddress;

 import java.util.Scanner;

 /**

  *

  * 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 的包发送到指定主机上的指定端口号。

         */

         while(true) {

         Scanner  sc = new Scanner(System.in);

         String data = sc.nextLine();

         if(data.equals("886")){

             break;

         }

         byte[] bytes = data.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.updDemo1;

 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);

         while (true) {

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

             // 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();

     }

 }