panlili2024
2025-03-05 134209ad70f82051da3ce63471df0cc8f778e57d
HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/socket/udp/UdpSocketBoot.java
@@ -35,6 +35,7 @@
    /**
     * 绑定 socket
     *
     * @throws Exception 可能端口冲突
     */
    public void bind() throws Exception {
@@ -46,7 +47,7 @@
     * 初始化接收线程
     */
    private void initReceiveThread() {
        if(null!=receiveThread){
        if (null != receiveThread) {
            return;
        }
        receiveThread = ThreadToolUtils.getInstance().newFixedThreadPool(1);
@@ -57,7 +58,7 @@
                    try {
                        client.onHandleResponse();
                    } catch (Exception e) {
                       LogUtils.i("接收线程异常:"+e.getMessage());
                        LogUtils.i("接收线程异常:" + e.getMessage());
                    }
                }
            }
@@ -67,34 +68,37 @@
    /**
     * 发送数据
     *
     * @param ipAddress 目的的IP地址
     * @param port 端口
     * @param msg 发送数据
     * @param listener 发送回调
     * @param port      端口
     * @param msg       发送数据
     * @param listener  发送回调
     */
    public void sendMsg(String ipAddress,int port,byte[] msg, SendListener listener) {
        sendMsg(ipAddress,port, msg, true, listener);
    public void sendMsg(String ipAddress, int port, byte[] msg, SendListener listener) {
        sendMsg(ipAddress, port, msg, true, listener);
    }
    /**
     * 发送数据
     *
     * @param ipAddress 目的的IP地址
     * @param port 端口
     * @param msg 发送数据
     * @param port      端口
     * @param msg       发送数据
     */
    public void sendMsg(String ipAddress,int port,byte[] msg) {
        sendMsg(ipAddress,port, msg, true, null);
    public void sendMsg(String ipAddress, int port, byte[] msg) {
        sendMsg(ipAddress, port, msg, true, null);
    }
    /**
     * 发送数据
     * @param ipAddress 目的IP地址
     * @param port 端口
     * @param msg 发送的数据
     *
     * @param ipAddress      目的IP地址
     * @param port           端口
     * @param msg            发送的数据
     * @param isRefreshRetry 是否要重发
     * @param listener 发送回调
     * @param listener       发送回调
     */
    public void sendMsg(String ipAddress,int port, byte[] msg, boolean isRefreshRetry, SendListener listener) {
    public void sendMsg(String ipAddress, int port, byte[] msg, boolean isRefreshRetry, SendListener listener) {
        if (isRefreshRetry) {
            //重置连接次数
            resendCount.set(0);
@@ -118,7 +122,7 @@
        isOpenRetry.set(false);
        sendMap.clear();
        receiveThread.shutdown();
        receiveThread=null;
        receiveThread = null;
        client.close();
    }
}