Java使用UDP协议发送和接收数据

 import java.io.BufferedReader;

    
 import java.io.IOException;
    
 import java.io.InputStreamReader;
    
 import java.net.DatagramPacket;
    
 import java.net.DatagramSocket;
    
 import java.net.InetAddress;
    
 import java.net.SocketException;
    
  
    
 public class UDPSendTest {
    
     public static void main(String[] args) throws IOException {
    
     // 创建发送端Socket对象
    
     DatagramSocket ds = new DatagramSocket();
    
     // 自己封装键盘录入数据
    
     BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    
     String line;
    
     while((line=br.readLine())!=null){
    
         if(line.equals("ending")){
    
             break;
    
         }
    
         // 数据打包
    
         byte[] b = line.getBytes();
    
         DatagramPacket dp = new DatagramPacket(b, b.length, InetAddress.getByName("uos-pc"),10086);
    
         // 调用DatagramSocket对象方法发送数据
    
         ds.send(dp);
    
     }
    
     // 释放资源
    
     ds.close();
    
  
    
     }
    
 }

 import java.io.IOException;

    
 import java.net.DatagramPacket;
    
 import java.net.DatagramSocket;
    
 import java.net.SocketException;
    
  
    
 public class UDPReceiveTest {
    
     public static void main(String[] args) throws IOException {
    
     // 创建Socket对象接受数据，需指定端口
    
     DatagramSocket ds = new DatagramSocket(10086);
    
     while(true) {// 发送端一直发送，故用循环接收
    
         // 创建数据包，接收数据
    
         byte[] b = new byte[1024];
    
         DatagramPacket dp = new DatagramPacket(b, b.length);
    
         // 调用DatagramSocket对象方法接收数据
    
         ds.receive(dp);
    
         // 解析数据
    
         System.out.println(new String(dp.getData(), 0, dp.getLength()));
    
     }
    
     // 关闭接收端
    
     // ds.close();
    
     }
    
 }