UDP聊天实现

• 循环发送消息

  public static void main(String[] args) throws Exception{
      DatagramSocket socket = new DatagramSocket(8888);
      //准备数据，控制台读取  system.in
      BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
      while (true) {
          String data = reader.readLine();
          byte[] datas = data.getBytes();
          DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress("localhost", 6666));
          socket.send(packet);
          if(data.equals("bye")){
              break;
          }
      }
      socket.close();
  }
  

• 循环接收消息

  public static void main(String[] args) throws Exception {
      DatagramSocket socket = new DatagramSocket(6666);
      while (true) {
          //准备接收包裹
          byte[] container = new byte[1024];
          DatagramPacket packet = new DatagramPacket(container, 0, container.length);
          socket.receive(packet);//阻塞式接收包裹
          //断开连接  bye
          byte[] data=packet.getData();
          String receiveData=new String(data,0,data.length);
          System.out.println(receiveData);
          if (receiveData.equals("bye")){
              break;
          }
      }
      socket.close();
  }