javaUDP协议DatagramPacket、DatagramSocket

/**
* UDP协议，TCP/IP协议族中的协议，面向无连接，通信不需要建立连接（三次握手四次挥手），可能发生丢包乱序错包重复包，效率高于TCP，常用于游戏和视频通话
*/
public class DatagramPacket1 {
   public static void main(String[] args) {
       //UDP同样需要先创建服务端/接收方
       DatagramSocket ds = null;
       try {
           DatagramPacket dp = new DatagramPacket(new byte[1024],1024);
           //datagram数据报packet包，UDP使用数据报包封装数据，发送方发送数据报包，接收方接收数据报包
           //服务端/接收方的数据报包对象的构造器需要：用于存放接收到的数据的字节数组byte[]、字节数组的可用长度（还可以指定存放的起始位置offset，不写默认从0位开始）
           ds = new DatagramSocket(9999);
           //通过DatagramSocket类发送/接收数据报包，需要指定端口用于发送/接收
           ds.receive(dp);
           //.receive(DatagramPacket)阻塞，等待接收数据，将收到的数据放入准备好的接收用数据报包中
           System.out.println(new String(dp.getData(),dp.getOffset(),dp.getLength()));
           //.getData()返回数据报包中的字节数据，new String(byte[])将数据转为字符串，因为数组可能没有放满，所以需要指定长度
           //.getOffset()返回数据开始位置 .getLength()返回数据实际长度
       } catch (IOException e) {
           throw new RuntimeException(e);
       } finally {
           if (ds != null) {
               ds.close();
               //DatagramSocket使用端口，用完需要关闭通道
           }
       }
   }
}

class UDPClient{
   public static void main(String[] args) {
       //通过客户端/发送方发送数据
       byte[] data = "将需要发送的数据转换为字节数组".getBytes();
       DatagramPacket dp = null;
       try {
           dp = new DatagramPacket(data,0,data.length,InetAddress.getLocalHost(),9999);
           //客户端/发送方构造器需要：存放了要发送的数据的字节数组、数据起始位置offset（不写默认从0位开始）、数据实际长度、用于指定发送地址IP:port的SocketAddress抽象类（子类为InetSocketAddress）（也可以用InetAddress指定ip，再加int port指定端口）
           //接收方不需要指定地址，发送方需要指定地址
           try(DatagramSocket ds = new DatagramSocket(8888)) {
               //与TCP不同的是，UDP发送方和接收方使用同一个类DatagramSocket，因为不需要建立连接，所以从一开始双方即为平等的，既可以发也可以接，也可以通过数据报包指定不同的地址群发
               //这里是客户端/发送方使用8888端口向 本机地址:9999端口发送数据报包
               ds.send(dp);

               /*
               ByteArrayOutputStream baos = new ByteArrayOutputStream();
               DataOutputStream dos = new DataOutputStream(baos);
                 发送基本数据类型，先将基本数据写入数组，再将数组封包，发送
               dos.writeLong(1000L);
               dos.writeChar('a');
               dos.writeUTF("接收方也需要按写入的顺序读取各个数据类型");
               dos.flush();
               byte[] data2 = baos.toByteArray();
               ds.send(new DatagramPacket(data2,data2.length,new InetSocketAddress("127.0.0.1",9999)));
               */

           } catch (IOException e) {
               throw new RuntimeException(e);
           }
       } catch (UnknownHostException e) {
           throw new RuntimeException(e);
       }
   }
}

class Person implements Serializable{
   //使用UDP发送对象，要发送的对象必须实现Serializable接口
   String name;
   int age;

   public Person(String name, int age) {
       this.name = name;
       this.age = age;
   }
   @Override
   public String toString() {
       return "Person{" +
               "name='" + name + '\'' +
               ", age=" + age +
               '}';
   }
}
class SendObject{
   public static void main(String[] args) {
       Person p = new Person("qian",20);
       byte[] obj = null;
       try(ByteArrayOutputStream baos = new ByteArrayOutputStream();
           ObjectOutputStream oos = new ObjectOutputStream(baos)) {
           oos.writeObject(p);
           oos.flush();
           obj = baos.toByteArray();
       } catch (IOException e) {
           throw new RuntimeException(e);
       }
       DatagramPacket dp = new DatagramPacket(obj,obj.length,new InetSocketAddress("127.0.0.1",9999));
       try(DatagramSocket ds = new DatagramSocket(8888)) {
           ds.send(dp);
       } catch (IOException e) {
           throw new RuntimeException(e);
       }
       //接收方也需要有这个类才能使用ObjectInputStream正确读取
   }
}