经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » Java相关 » Java » 查看文章
java实现udp通讯的代码
来源:jb51  时间:2018/9/25 19:01:55  对本文有异议

需求:应用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监听放到一个线程中,当有客户端请求时就会进行响应

  1. /**
  2. * udp连接,用于动态ip, pos向255.255.255.255:5060发送请求即可
  3. * **/
  4. public class UdpServer extends Thread implements Runnable {
  5. private final int MAX_LENGTH = 1024;
  6. private final int PORT = 5060;
  7. private DatagramSocket datagramSocket;
  8. public void run() {
  9. try {
  10. init();
  11. while(true){
  12. try {
  13. byte[] buffer = new byte[MAX_LENGTH];
  14. DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
  15. receive(packet);
  16. String receStr = new String(packet.getData(), 0 , packet.getLength());
  17. System.out.println("接收数据包" + receStr);
  18. byte[] bt = new byte[packet.getLength()];
  19. System.arraycopy(packet.getData(), 0, bt, 0, packet.getLength());
  20. System.out.println(packet.getAddress().getHostAddress() + ":" + packet.getPort() + ":" + Arrays.toString(bt));
  21. packet.setData(bt);
  22. response(packet);
  23. } catch (Exception e) {
  24. e.printStackTrace();
  25. LoggerUtil.error("udp线程出现异常:" + e.toString());
  26. }
  27. }
  28. } catch (Exception e) {
  29. e.printStackTrace();
  30. }
  31. }
  32.  
  33. public void receive(DatagramPacket packet) throws Exception {
  34. datagramSocket.receive(packet);
  35. }
  36.  
  37. public void response(DatagramPacket packet) throws Exception {
  38. datagramSocket.send(packet);
  39. }
  40. /**
  41. * 初始化连接
  42. */
  43. public void init(){
  44. try {
  45. datagramSocket = new DatagramSocket(PORT);
  46. System.out.println("udp服务端已经启动!");
  47. } catch (Exception e) {
  48. datagramSocket = null;
  49. System.out.println("udp服务端启动失败!");
  50. e.printStackTrace();
  51. }
  52. }
  53. }
  54.  

客户端:本来客户端是使用pb来实现的,但是这里使用java来模拟

  1. /***
  2. * UDP Client端
  3. ***/
  4. public class UdpClient {
  5. private String sendStr = "hello";
  6. private String netAddress = "255.255.255.255";
  7. private final int PORT = 5060;
  8. private DatagramSocket datagramSocket;
  9. private DatagramPacket datagramPacket;
  10. public UdpClient(){
  11. try {
  12. datagramSocket = new DatagramSocket();
  13. byte[] buf = sendStr.getBytes();
  14. InetAddress address = InetAddress.getByName(netAddress);
  15. datagramPacket = new DatagramPacket(buf, buf.length, address, PORT);
  16. datagramSocket.send(datagramPacket);
  17. byte[] receBuf = new byte[1024];
  18. DatagramPacket recePacket = new DatagramPacket(receBuf, receBuf.length);
  19. datagramSocket.receive(recePacket);
  20. String receStr = new String(recePacket.getData(), 0 , recePacket.getLength());
  21.        //获取服务端ip
  22. String serverIp = recePacket.getAdress();
  23. } catch (SocketException e) {
  24. e.printStackTrace();
  25. } catch (UnknownHostException e) {
  26. e.printStackTrace();
  27. } catch (IOException e) {
  28. e.printStackTrace();
  29. } finally {
  30. // 关闭socket
  31. if(datagramSocket != null){
  32. datagramSocket.close();
  33. }
  34. }
  35. }
  36. public static void main(String[] args) {
  37. for (int i = 0; i < 100; i++) {
  38. new Thread(new Runnable() {
  39. @Override
  40. public void run() {
  41. UdpClient udpClient = new UdpClient();
  42. }
  43. }).start();
  44. }
  45. }
  46. }

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

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号