whyclj
2020-10-23 291d27a34b52911dbcfd8232f0685d34b0fc96a8
代码优化
2个文件已修改
10 ■■■■ 已修改文件
EquieDeviceData/src/com/dev/data/Dev_UDPServer_Thread.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
EquieDeviceData/src/com/dev/data/InverterPowerUDPServer_Thread.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
EquieDeviceData/src/com/dev/data/Dev_UDPServer_Thread.java
@@ -4,7 +4,9 @@
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.MulticastSocket;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.util.Date;
@@ -189,10 +191,10 @@
                            }
                        } catch (Exception e) {
                            conn_error_count ++;
                            if(conn_error_count >6) {
                            if(conn_error_count >=6) {
                                break;
                            }
                            e.printStackTrace();
                            //e.printStackTrace();
                        }
                        //测试程序正常运行异常情况下异常情况
                        //System.out.println(1/0);
@@ -240,6 +242,8 @@
    private MulticastSocket createMulticastGroupAndJoin(InetAddress group,int port) {
        try {  
            MulticastSocket socket = new MulticastSocket(port); // 初始化MulticastSocket类并将端口号与之关联  
            //InetAddress bind = new InetSocketAddress("192.0.0.74", port);
            //MulticastSocket socket = new MulticastSocket(bind); // 初始化MulticastSocket类并将端口号与之关联
            socket.setLoopbackMode(false);
            socket.joinGroup(group); // 加入此组播组  
            return socket;  
EquieDeviceData/src/com/dev/data/InverterPowerUDPServer_Thread.java
@@ -86,7 +86,7 @@
                            if(conn_error_count >=6) {
                                break;
                            }
                            e.printStackTrace();
                            //e.printStackTrace();
                        }
                        //测试程序异常情况下,程序能否继续运行
                        //System.out.println(1/0);