java实现udp通讯的代码

 更新时间:2018年09月22日 10:59:27   作者:rising1234  
这篇文章主要为大家详细介绍了java实现udp通讯的代码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

需求:应用A(通常有多个)和应用B(1个)进行 socket通讯,应用A必须知道应用B的ip地址(在应用A的配置文件中写死的),这个时候就必须把应用B的ip设成固定ip(但是某些时候如更换路由后要重新设置网络,但是操作人员不知道这个规则),就有可能造成应用A和应用B无法进行正常通讯,所以要改成应用A动态获取应用B的ip地址。

经过讨论决定采用udp协议实现,upd是一种无连接的传输层协议。应用A在不知道应用B的 ip情况下 可以使用广播地址255.255.255.255,将消息发送到在同一广播网络上的B。从而获取B的ip。

实现代码:

B应用为服务端:将udp监听放到一个线程中,当有客户端请求时就会进行响应

/**
 * udp连接,用于动态ip, pos向255.255.255.255:5060发送请求即可
 * **/
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("接收数据包" + 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线程出现异常:" + 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服务端已经启动!");
    } catch (Exception e) {
      datagramSocket = null;
      System.out.println("udp服务端启动失败!");
      e.printStackTrace();
    }
  }
}

客户端:本来客户端是使用pb来实现的,但是这里使用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());
      
       //获取服务端ip
      String serverIp = recePacket.getAdress();
    } catch (SocketException e) {
      e.printStackTrace();
    } catch (UnknownHostException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      // 关闭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();
    }
  }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • SPRING FRAMEWORK BEAN作用域和生命周期原理解析

    SPRING FRAMEWORK BEAN作用域和生命周期原理解析

    这篇文章主要介绍了SPRING FRAMEWORK BEAN作用域和生命周期原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-01-01
  • Java设计模式之观察者模式observer pattern详解

    Java设计模式之观察者模式observer pattern详解

    这篇文章主要介绍了Java设计模式之观察者模式observer pattern详解,当一个对象发生数据变化时,通知其他相关的一系列对象,接受到通知的对象根据该对象的变化进行相应处理以响应变化的过程,需要的朋友可以参考下
    2023-12-12
  • Java基于栈方式解决汉诺塔问题实例【递归与非递归算法】

    Java基于栈方式解决汉诺塔问题实例【递归与非递归算法】

    这篇文章主要介绍了Java基于栈方式解决汉诺塔问题的方法,结合实例形式分析了java栈方式采用递归与非递归算法解决汉诺塔问题的相关操作技巧,需要的朋友可以参考下
    2017-11-11
  • 详解Java设计模式之备忘录模式的使用

    详解Java设计模式之备忘录模式的使用

    这篇文章主要介绍了Java设计模式之备忘录模式的使用,备忘录模式中的发起者和管需要的朋友可以参考下
    2016-02-02
  • Spring Boot实现动态更新任务的方法

    Spring Boot实现动态更新任务的方法

    这篇文章主要介绍了Spring Boot实现动态更新任务的方法,文中给出了详细的示例代码供大家参考学习,对大家学习使用Spring Boot动态更新任务具有一定的参考价值,需要的朋友们来一起看看吧。
    2017-04-04
  • Java运算符从见过到掌握下

    Java运算符从见过到掌握下

    计算机的最基本用途之一就是执行数学运算,作为一门计算机语言,Java也提供了一套丰富的运算符来操纵变量,本篇对大家的学习或工作具有一定的价值,紧接上篇,需要的朋友可以参考下
    2021-09-09
  • JavaWeb实现多文件上传及zip打包下载

    JavaWeb实现多文件上传及zip打包下载

    这篇文章主要为大家详细介绍了JavaWeb实现多文件上传及zip打包下载,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-07-07
  • Java concurrency线程池之Callable和Future_动力节点Java学院整理

    Java concurrency线程池之Callable和Future_动力节点Java学院整理

    这篇文章主要为大家详细介绍了Java concurrency线程池之Callable和Future,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-06-06
  • Java并发 线程间的等待与通知

    Java并发 线程间的等待与通知

    这篇文章主要介绍了Java并发 线程间的等待与通知,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-10-10
  • Java实现的AES256加密解密功能示例

    Java实现的AES256加密解密功能示例

    这篇文章主要介绍了Java实现的AES256加密解密功能,结合完整实例形式分析了Java实现AES256加密解密功能的步骤与相关操作技巧,需要的朋友可以参考下
    2017-02-02

最新评论