package com.oracle.UDPTest;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;public class TestUDP {public static void main(String[] args) {//创建UDPSender发送端多线程对象Thread sender = new Thread(new UDPSender(),"发送端");//创建UDPReveice接收端对象Thread receiver = new Thread(new UDPReceiver(),"接收端");//开启线程
        sender.start();receiver.start();}
}//创建发送端类并实现Runnable接口
class UDPSender implements Runnable{//重写run方法public void run() {//创建DatagramSocket对象DatagramSocket ds = null ;try {//发送端在构造DatagramSocket时不需要传参ds = new DatagramSocket();//利用InetAddress类获取本地InetAddress类对象InetAddress address = InetAddress.getLocalHost();//创建Scanner 对象，用来获取用户输入Scanner sc = new Scanner(System.in);while(true) {System.out.println("<"+Thread.currentThread().getName()+">请输入您要发送的内容：");//获取用户输入String info = sc.next();    //利用用户输入创建byte类型数组byte[] bytes = info.getBytes();//获取数组长度int length = bytes.length;//创建DatagramPacket对象DatagramPacket dp = new DatagramPacket(bytes,length,address,8088);//发送
                ds.send(dp);}} catch ( IOException e) {// TODO Auto-generated catch block
            e.printStackTrace();}finally {//关闭资源
            ds.close();}        }
}
//创建接收端类并实现Runnable接口
class UDPReceiver implements Runnable{public void run() {//创建DatagramSocket对象DatagramSocket ds = null;try {//接收端在构造时必须明确端口ds = new DatagramSocket(8088);//自定义数组byte[] bytes = new byte[1024];//创建DatagramPacket对象DatagramPacket dp = new DatagramPacket(bytes,bytes.length);//循环接收消息while(true) {            //接收消息（没有接受到消息就会一直阻塞）
                ds.receive(dp);//打印消息System.err.println("<"+Thread.currentThread().getName()+">ip："+dp.getAddress()+"端口："+dp.getPort()+"内容："+new String(dp.getData(),0,dp.getLength()));}} catch (IOException e) {// TODO Auto-generated catch block
            e.printStackTrace();}finally {//关闭资源
            ds.close();}}
}