快捷導(dǎo)航

java實(shí)現(xiàn)udp通訊的代碼

更新時間：2018年09月22日 10:59:27 作者：rising1234

這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)udp通訊的代碼，具有一定的參考價值，感興趣的小伙伴們可以參考一下

需求：應(yīng)用A（通常有多個）和應(yīng)用B（1個）進(jìn)行 socket通訊，應(yīng)用A必須知道應(yīng)用B的ip地址（在應(yīng)用A的配置文件中寫死的），這個時候就必須把應(yīng)用B的ip設(shè)成固定ip（但是某些時候如更換路由后要重新設(shè)置網(wǎng)絡(luò)，但是操作人員不知道這個規(guī)則），就有可能造成應(yīng)用A和應(yīng)用B無法進(jìn)行正常通訊，所以要改成應(yīng)用A動態(tài)獲取應(yīng)用B的ip地址。

經(jīng)過討論決定采用udp協(xié)議實(shí)現(xiàn)，upd是一種無連接的傳輸層協(xié)議。應(yīng)用A在不知道應(yīng)用B的 ip情況下可以使用廣播地址255.255.255.255，將消息發(fā)送到在同一廣播網(wǎng)絡(luò)上的B。從而獲取B的ip。

實(shí)現(xiàn)代碼：

B應(yīng)用為服務(wù)端：將udp監(jiān)聽放到一個線程中，當(dāng)有客戶端請求時就會進(jìn)行響應(yīng)

/**
 * udp連接，用于動態(tài)ip, pos向255.255.255.255：5060發(fā)送請求即可
 * **/
public class UdpServer extends Thread implements Runnable {
  private final int MAX_LENGTH = 1024;
  private final int PORT = 5060;
  private DatagramSocket datagramSocket;
  
  public void run() {
    try {
      init();
      while(true){
        try {
          byte[] buffer = new byte[MAX_LENGTH];
          DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
          receive(packet);
          String receStr = new String(packet.getData(), 0 , packet.getLength());
          System.out.println("接收數(shù)據(jù)包" + receStr);
          byte[] bt = new byte[packet.getLength()];
          
          System.arraycopy(packet.getData(), 0, bt, 0, packet.getLength());
          System.out.println(packet.getAddress().getHostAddress() + "：" + packet.getPort() + "：" + Arrays.toString(bt));
          packet.setData(bt);
          response(packet);
          
        } catch (Exception e) {
          e.printStackTrace();
          LoggerUtil.error("udp線程出現(xiàn)異常：" + e.toString());
        }
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  public void receive(DatagramPacket packet) throws Exception {
    datagramSocket.receive(packet);
  }

  public void response(DatagramPacket packet) throws Exception {
    datagramSocket.send(packet);
  }
  
  /**
   * 初始化連接
   */
  public void init(){
    try {
      datagramSocket = new DatagramSocket(PORT);
      System.out.println("udp服務(wù)端已經(jīng)啟動！");
    } catch (Exception e) {
      datagramSocket = null;
      System.out.println("udp服務(wù)端啟動失??！");
      e.printStackTrace();
    }
  }
}

客戶端：本來客戶端是使用pb來實(shí)現(xiàn)的，但是這里使用java來模擬

/***
 * UDP Client端
 ***/
public class UdpClient {
  
  private String sendStr = "hello";
  private String netAddress = "255.255.255.255";
  private final int PORT = 5060;
  
  private DatagramSocket datagramSocket;
  private DatagramPacket datagramPacket;
  
  public UdpClient(){
    try { 
      datagramSocket = new DatagramSocket();
      byte[] buf = sendStr.getBytes();
      InetAddress address = InetAddress.getByName(netAddress);
      datagramPacket = new DatagramPacket(buf, buf.length, address, PORT);
      datagramSocket.send(datagramPacket);
      
      byte[] receBuf = new byte[1024];
      DatagramPacket recePacket = new DatagramPacket(receBuf, receBuf.length);
      datagramSocket.receive(recePacket);
      
      String receStr = new String(recePacket.getData(), 0 , recePacket.getLength());
      
　　　　　　　//獲取服務(wù)端ip
      String serverIp = recePacket.getAdress();
    } catch (SocketException e) {
      e.printStackTrace();
    } catch (UnknownHostException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      // 關(guān)閉socket
      if(datagramSocket != null){
        datagramSocket.close();
      }
    }
  }
  
  public static void main(String[] args) {
    for (int i = 0; i < 100; i++) {
      new Thread(new Runnable() {
        @Override
        public void run() {
          UdpClient udpClient = new UdpClient();
        }
      }).start();
    }
  }
}

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: