tcp发送之前判断是否连接

562935844@qq.com

2022-09-23 830e47a67026205b75f69e061d81783aa606a237

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

@@ -17,6 +17,7 @@
import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.InetSocketAddress;

import java.net.SocketAddress;

import java.util.concurrent.atomic.AtomicBoolean;





@@ -86,7 +87,7 @@
     * @return

     */

    public static UdpSocketBoot init(int port, UdpSocketOptions options) {

        return init(null, port, options);

        return init("0.0.0.0", port, options);

    }





@@ -98,10 +99,12 @@
                return;

            }

            if (TextUtils.isEmpty(ipAddress)) {

                mSocket = SocketPool.getInstance().getUdpSocket1(new InetSocketAddress(port));

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

            }else {

                mSocket = SocketPool.getInstance().getUdpSocket(new InetSocketAddress(ipAddress,port));

            }

            mSocket.setBroadcast(true);

            mSocket.setReuseAddress(true);

//            mSocket.setReuseAddress(true);



        } catch (Exception e) {

            LogUtils.e("初始化Socket 失败：" + e.getMessage());

@@ -122,15 +125,16 @@


    @Override

    public UdpSocketOptions getOptions() {

        return null;

        return this.socketOptions;

    }



    @Override

    public void onHandleResponse() throws Exception {

        if (mSocket == null) {

            return;

        }

        try {

           mSocket.receive(receivePacket);

            mSocket.receive(receivePacket);

        } catch (IOException e) {

            e.printStackTrace();

        }

@@ -139,33 +143,34 @@
        }

        //排除自己发出去的

        try {

            if (IpUtils.isLocalIpAddress( receivePacket.getAddress().getHostAddress()))

            if (IpUtils.isLocalIpAddress(receivePacket.getAddress().getHostAddress()))

                return;

        } catch (Exception ignored) {



        }



        try {

            LogUtils.i( "接收到Udp数据包，网络地址：" + receivePacket.getAddress().getHostAddress() + ":" + receivePacket.getPort());

            LogUtils.i("接收到Udp数据包，网络地址：" + receivePacket.getAddress().getHostAddress() + ":" + receivePacket.getPort());



            IHandleMessage handleMessage = getOptions().getHandleMessage();

            if (handleMessage != null) {

                byte[] data = new byte[receivePacket.getLength()];

                System.arraycopy(receivePacket.getData(), 0, data, 0, data.length);

                handleMessage.read(data);

                handleMessage.read(data,receivePacket.getAddress().getHostAddress());

            }



        }catch (Exception e){

        } catch (Exception e) {



        }

    }





    @Override

    public void sendMsg(InetSocketAddress inetSocketAddress, byte[] msg) throws Exception {

    public void sendMsg(String ipAddress,int port, byte[] msg) throws Exception {

        if (msg == null) {

            return;

        }

        final DatagramPacket sendPacket = new DatagramPacket(msg, msg.length, inetSocketAddress);

        final DatagramPacket sendPacket = new DatagramPacket(msg, msg.length, InetAddress.getByName(ipAddress), port);

        mSocket.send(sendPacket);

    }

}