From 291d27a34b52911dbcfd8232f0685d34b0fc96a8 Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期五, 23 十月 2020 10:30:59 +0800
Subject: [PATCH] 代码优化
---
EquieDeviceData/src/com/dev/data/Dev_UDPServer_Thread.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/EquieDeviceData/src/com/dev/data/Dev_UDPServer_Thread.java b/EquieDeviceData/src/com/dev/data/Dev_UDPServer_Thread.java
index 5ac2c43..6a67669 100644
--- a/EquieDeviceData/src/com/dev/data/Dev_UDPServer_Thread.java
+++ b/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;
--
Gitblit v1.9.1