2021-11-16 1.更新

JLChen

2021-11-16 a4246a571c78ac6c46e7bf7dbfc123b7148caed8

 HDLSDK/hdl-socket/src/main/java/com/hdl/sdk/socket/client/UdpClient.java

@@ -5,9 +5,11 @@


import com.hdl.sdk.common.HDLSdk;

import com.hdl.sdk.common.utils.IpUtils;

import com.hdl.sdk.common.utils.LogUtils;

import com.hdl.sdk.common.utils.ThreadToolUtils;

import com.hdl.sdk.socket.SocketBoot;

import com.hdl.sdk.socket.SocketOptions;

import com.hdl.sdk.socket.SocketPool;

import com.hdl.sdk.socket.annotation.ConnectStatus;

import com.hdl.sdk.socket.codec.IHandleMessage;

import com.hdl.sdk.socket.listener.ConnectStatusListener;

@@ -16,6 +18,7 @@
import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.InetSocketAddress;

import java.util.List;

import java.util.concurrent.atomic.AtomicBoolean;



@@ -78,12 +81,11 @@


    @Override

    public void connect() throws Exception {



        try {

            mSocket = ClientPool.getInstance().getUdpSocket(ip, monitorPort);

            mSocket = SocketPool.getInstance().getUdpSocket(new InetSocketAddress(monitorPort));



            mSocket.setBroadcast(true);

            mSocket.setReuseAddress(true);



            isConnect.set(true);

            if (receivePacket == null) {

                receivePacket = new DatagramPacket(receiveByte, BUFFER);

@@ -147,7 +149,7 @@
        }

        final String receive = new String(receivePacket.getData(), 0, receivePacket.getLength());



        Log.d("---->", receive + " from " + receivePacket.getAddress().getHostAddress() + ":" + receivePacket.getPort());

        LogUtils.d("---->", receive + " from " + receivePacket.getAddress().getHostAddress() + ":" + receivePacket.getPort());



        //重置长度

        if (receivePacket != null) {