修改

whyclj

2020-10-20 40436887f67d5ea4713908ff9dcbd07121b62d86

 EquieDeviceData/src/com/dev/data/Dev_UDPServer_Thread.java

@@ -8,6 +8,7 @@
import java.nio.ByteBuffer;

import java.nio.ByteOrder;

import java.util.Date;

import java.util.Enumeration;

import java.util.List;



import com.base.BaseData;

@@ -52,13 +53,17 @@
                 InetAddress heartgroup = null;

                 DatagramPacket heartpack = null;

                 MulticastSocket socket1 = null;

                 int heart_error_count = 0;               //通讯错误计数

                 while(true) {

                    try {

                     heartgroup = InetAddress.getByName(server_ip);

                     heartpack = new DatagramPacket(new byte[0], 0, heartgroup, port);             // 目的端口和MulticastSocket端口一样！！

                     socket1 = createMulticastGroupAndJoin(heartgroup,port);

                     boolean isNewThread = true;

                     String last = Com.getDateTimeFormat(new Date(2000,1,1), Com.DTF_Y_M_D);         //上一次建表的ymd

                     socket1.setSoTimeout(4000);;

							
                     heart_error_count = 0;

                     //boolean isNewThread = true;

                     //String last = Com.getDateTimeFormat(new Date(2000,1,1), Com.DTF_Y_M_D);         //上一次建表的ymd

                     while(true) {

                        //发送心跳包

                        try {

@@ -79,9 +84,18 @@
                           byte[] buf = BaseData.createHeartData();

                           heartpack.setData(buf);

                           socket1.send(heartpack);

                           //System.err.println(Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));

//                           System.out.println(socket1.getNetworkInterface().getInetAddresses());

//                           Enumeration<InetAddress> ips = socket1.getNetworkInterface().getInetAddresses();

//                           while(ips.hasMoreElements()) {

//                              System.out.println(ips.nextElement().getHostAddress());

//                           }

                           //System.err.println("发送心跳包"+socket1.isConnected()+"==="+socket1.isClosed()+"=="+socket1.isBound()+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));

                           Thread.sleep(5000);

                           if(heart_error_count >10) {

                              break;

                           }

                        } catch (Exception e) {

                           heart_error_count++;

                           try {

                              Thread.sleep(1000);

                           } catch (InterruptedException e1) {

@@ -112,16 +126,18 @@
          }).start(); 

          byte[] data = null;

          DatagramPacket packet= null;

          int conn_error_count = 0;

          while(true) {

            try {

               data = new byte[MAX_DATA_COUNT];

               group = InetAddress.getByName(server_ip);       

               socket = createMulticastGroupAndJoin(group,port);  //加入组播组，设置组播组的监听端口为6556  

               socket.setSoTimeout(5000);

               DatagramPacket outpack = new DatagramPacket(new byte[0], 0, group, port); // 目的端口和MulticastSocket端口一样！！

               packet = new DatagramPacket(data, data.length);  

					
					
               conn_error_count = 0;

               while(true) {                  

                  try {

                  socket.receive(packet);       // 通过MulticastSocket实例端口从组播组接收数据 

                  byte[] headCount = new byte[2];

                  System.arraycopy(data, 0, headCount, 0, headCount.length);

@@ -171,6 +187,13 @@
                        thread_count ++;

                     }

                  }

                  } catch (Exception e) {

                     conn_error_count ++;

                     if(conn_error_count >6) {

                        break;

                     }

                     e.printStackTrace();

                  }

                  //测试程序正常运行异常情况下异常情况

                  //System.out.println(1/0);

                  Thread.sleep(10);