| | |
| | | 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;
|
| | |
| | | }
|
| | | } 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);
|
| | |
| | | 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;
|