Server

  1. public class UDPServer {
  2. public static void main(String[] args) throws Exception {
  3. // 服务端接受客户端发送的数据报
  4. DatagramSocket socket = new DatagramSocket(65001); //监听的端口号
  5. byte[] buff = new byte[100]; //存储从客户端接受到的内容
  6. DatagramPacket packet = new DatagramPacket(buff, buff.length);
  7. //接受客户端发送过来的内容,并将内容封装进DatagramPacket对象中
  8. socket.receive(packet);
  9. byte[] data = packet.getData(); //从DatagramPacket对象中获取到真正存储的数据
  10. //将数据从二进制转换成字符串形式
  11. String content = new String(data, 0, packet.getLength());
  12. System.out.println(content);
  13. //将要发送给客户端的数据转换成二进制
  14. byte[] sendedContent = String.valueOf(content.length()).getBytes();
  15. // 服务端给客户端发送数据报
  16. //从DatagramPacket对象中获取到数据的来源地址与端口号
  17. DatagramPacket packetToClient = new DatagramPacket(sendedContent,
  18. sendedContent.length, packet.getAddress(), packet.getPort());
  19. socket.send(packetToClient); //发送数据给客户端
  20. }
  21. }

Client

  1. public class UDPClient {
  2. public static void main(String[] args) throws Exception {
  3. // 客户端发数据报给服务端
  4. DatagramSocket socket = new DatagramSocket();
  5. // 要发送给服务端的数据
  6. byte[] buf = "Hello World".getBytes();
  7. // 将IP地址封装成InetAddress对象
  8. InetAddress address = InetAddress.getByName("127.0.0.1");
  9. // 将要发送给服务端的数据封装成DatagramPacket对象 需要填写上ip地址与端口号
  10. DatagramPacket packet = new DatagramPacket(buf, buf.length, address,
  11. 65001);
  12. // 发送数据给服务端
  13. socket.send(packet);
  14. // 客户端接受服务端发送过来的数据报
  15. byte[] data = new byte[100];
  16. // 创建DatagramPacket对象用来存储服务端发送过来的数据
  17. DatagramPacket receivedPacket = new DatagramPacket(data, data.length);
  18. // 将接受到的数据存储到DatagramPacket对象中
  19. socket.receive(receivedPacket);
  20. // 将服务器端发送过来的数据取出来并打印到控制台
  21. String content = new String(receivedPacket.getData(), 0,
  22. receivedPacket.getLength());
  23. System.out.println(content);
  24. }
  25. }