hivemqtt-client原本是一個java后臺框架，集成到android并沒有android的log打印挽霉，但是我們可以添加防嗡。

由于hivemqtt-client是封裝的netty，所以我們想用netty的loggerHandler打印log侠坎，所以我們也需要修改源碼本鸣。

1.git下載源碼：https://github.com/hivemq/hivemq-mqtt-client.git ，修改源碼如下硅蹦，在MqttChannelInitializer類 添加LoggingHandler。

package com.hivemq.client.internal.mqtt.handler;
...
public class MqttChannelInitializer extends ChannelInboundHandlerAdapter {
...
private void initMqtt(@NotNull Channel channel) {
        channel.pipeline()
        .addLast("log", new LoggingHandler()) //添加netty的log打印
        .addLast("encoder", this.encoder)
        .addLast("auth", this.authHandler)
        .addLast("connect", this.connectHandler)
        .addLast("disconnect", this.disconnectHandler);
    }
}
...

1.2然后重新編譯出：hivemq-mqtt-client-1.3.4.jar即可，這個時候我們就直接依賴jar包了，但是由于hivemqtt-client不僅僅依賴netty還依賴其他的jar供常，所以我們需要添加其他的gradle build的依賴粟矿。

    implementation(name: 'hivemq-mqtt-client-1.3.4', ext: 'jar')
    //其他依賴
    implementation("io.netty:netty-buffer:4.1.99.Final")
    implementation("io.netty:netty-codec:4.1.99.Final")
    implementation("io.netty:netty-common:4.1.99.Final")
    implementation("io.netty:netty-handler:4.1.99.Final")
    implementation("io.netty:netty-transport:4.1.99.Final")

    implementation 'com.google.dagger:dagger:2.27'
    annotationProcessor 'com.google.dagger:dagger-compiler:2.27'

    implementation("org.jctools:jctools-core:2.1.2")
    implementation("org.jetbrains:annotations:16.0.3")

2.android添加方法和log類如下：

//在Application或初始化的時候添加AndroidInternalLogger類。
@Override
public void onCreate() {
      InternalLoggerFactory.setDefaultFactory(new InternalLoggerFactory() {
          @Override
         protected InternalLogger newInstance(String name) {
            return new AndroidInternalLogger(name); //名字即為tag
         }
    });
...
}

添加AndroidInternalLogger類實(shí)現(xiàn)如下：

import android.util.Log;

import java.net.UnknownHostException;

import io.netty.util.internal.logging.InternalLogLevel;
import io.netty.util.internal.logging.InternalLogger;

/**
 * @Author zhikong
 * @Date 17:55
 */
public class AndroidInternalLogger implements InternalLogger {
    private String TAG;

    public AndroidInternalLogger(String name) {
        TAG = name;
    }

    @Override
    public String name() {
        return TAG;
    }

    @Override
    public boolean isTraceEnabled() {
        return true;
    }

    @Override
    public void trace(String msg) {
        Log.v(TAG, msg);
    }

    @Override
    public void trace(String format, Object arg) {
        Log.v(TAG, String.format(format, arg));
    }

    @Override
    public void trace(String format, Object argA, Object argB) {
        Log.v(TAG, String.format(format, argA, argB));
    }

    @Override
    public void trace(String format, Object... arguments) {
        Log.v(TAG, String.format(format, arguments));
    }

    @Override
    public void trace(String msg, Throwable t) {
        Log.v(TAG, msg, t);
    }

    @Override
    public void trace(Throwable t) {
        Log.v(TAG, "trace", t);
    }

    @Override
    public boolean isDebugEnabled() {
        return true;
    }

    @Override
    public void debug(String msg) {
        Log.d(TAG, msg);
    }

    @Override
    public void debug(String format, Object arg) {
        Log.d(TAG, String.format(format, arg));
    }

    @Override
    public void debug(String format, Object argA, Object argB) {
        Log.d(TAG, String.format(format, argA, argB));
    }

    @Override
    public void debug(String format, Object... arguments) {
        Log.d(TAG, String.format(format, arguments));
    }

    @Override
    public void debug(String msg, Throwable t) {
        Log.d(TAG, msg, t);
    }

    @Override
    public void debug(Throwable t) {
        Log.d(TAG, "debug", t);
    }

    @Override
    public boolean isInfoEnabled() {
        return true;
    }

    @Override
    public void info(String msg) {
        Log.i(TAG, msg);
    }

    @Override
    public void info(String format, Object arg) {
        Log.i(TAG, String.format(format, arg));
    }

    @Override
    public void info(String format, Object argA, Object argB) {
        Log.i(TAG, String.format(format, argA, argB));
    }

    @Override
    public void info(String format, Object... arguments) {
        Log.i(TAG, String.format(format, arguments));
    }

    @Override
    public void info(String msg, Throwable t) {
        Log.i(TAG, msg, t);
    }

    @Override
    public void info(Throwable t) {
        Log.i(TAG, "info", t);
    }


    @Override
    public boolean isWarnEnabled() {
        return true;
    }

    @Override
    public void warn(String msg) {
        Log.w(TAG, msg);
    }

    @Override
    public void warn(String format, Object arg) {
        Log.w(TAG, String.format(format, arg));
    }

    @Override
    public void warn(String format, Object argA, Object argB) {
        Log.w(TAG, String.format(format, argA, argB));
    }

    @Override
    public void warn(String format, Object... arguments) {
        Log.w(TAG, String.format(format, arguments));
    }

    @Override
    public void warn(String msg, Throwable t) {
        Log.w(TAG, msg, t);
    }

    @Override
    public void warn(Throwable t) {
        Log.w(TAG, "warn", t);
    }


    @Override
    public boolean isErrorEnabled() {
        return true;
    }

    @Override
    public void error(String msg) {
        Log.e(TAG, msg);
    }

    @Override
    public void error(String format, Object arg) {
        Log.e(TAG, String.format(format, arg));
    }

    @Override
    public void error(String format, Object argA, Object argB) {
        Log.e(TAG, String.format(format, argA, argB));
    }

    @Override
    public void error(String format, Object... arguments) {
        Log.e(TAG, String.format(format, arguments));
    }

    @Override
    public void error(String msg, Throwable t) {
        if (t instanceof UnknownHostException) {
            Log.e(TAG, msg + ":" + t.getMessage());
        } else {
            Log.e(TAG, msg, t);
        }
    }

    @Override
    public void error(Throwable t) {
        Log.e(TAG, "error", t);
    }


    @Override
    public boolean isEnabled(InternalLogLevel level) {
        return true;
    }

    @Override
    public void log(InternalLogLevel level, String msg) {
        switch (level) {
            case DEBUG:
                Log.d(TAG, msg);
                break;
            case INFO:
                Log.i(TAG, msg);
                break;
            case WARN:
                Log.w(TAG, msg);
                break;
            case ERROR:
                Log.e(TAG, msg);
                break;
            default:
                Log.v(TAG, msg); // 默認(rèn)情況下涩金，如果沒有匹配的級別，可以使用VERBOSE級別
        }
    }

    @Override
    public void log(InternalLogLevel level, String format, Object arg) {
        switch (level) {
            case DEBUG:
                Log.d(TAG, String.format(format, arg));
                break;
            case INFO:
                Log.i(TAG, String.format(format, arg));
                break;
            case WARN:
                Log.w(TAG, String.format(format, arg));
                break;
            case ERROR:
                Log.e(TAG, String.format(format, arg));
                break;
            default:
                Log.v(TAG, String.format(format, arg)); // 默認(rèn)情況下，如果沒有匹配的級別生音，可以使用VERBOSE級別
        }
    }

    @Override
    public void log(InternalLogLevel level, String format, Object argA, Object argB) {
        switch (level) {
            case DEBUG:
                Log.d(TAG, String.format(format, argA, argB));
                break;
            case INFO:
                Log.i(TAG, String.format(format, argA, argB));
                break;
            case WARN:
                Log.w(TAG, String.format(format, argA, argB));
                break;
            case ERROR:
                Log.e(TAG, String.format(format, argA, argB));
                break;
            default:
                Log.v(TAG, String.format(format, argA, argB)); // 默認(rèn)情況下，如果沒有匹配的級別窒升，可以使用VERBOSE級別
        }
    }

    @Override
    public void log(InternalLogLevel level, String format, Object... arguments) {
        switch (level) {
            case DEBUG:
                Log.d(TAG, String.format(format, arguments));
                break;
            case INFO:
                Log.i(TAG, String.format(format, arguments));
                break;
            case WARN:
                Log.w(TAG, String.format(format, arguments));
                break;
            case ERROR:
                Log.e(TAG, String.format(format, arguments));
                break;
            default:
                Log.v(TAG, String.format(format, arguments)); // 默認(rèn)情況下缀遍，如果沒有匹配的級別，可以使用VERBOSE級別
        }
    }

    @Override
    public void log(InternalLogLevel level, String msg, Throwable t) {
        switch (level) {
            case DEBUG:
                Log.d(TAG, msg, t);
                break;
            case INFO:
                Log.i(TAG, msg, t);
                break;
            case WARN:
                Log.w(TAG, msg, t);
                break;
            case ERROR:
                Log.e(TAG, msg, t);
                break;
            default:
                Log.v(TAG, msg, t); // 默認(rèn)情況下饱须，如果沒有匹配的級別域醇，可以使用VERBOSE級別
        }
    }

    @Override
    public void log(InternalLogLevel level, Throwable t) {
        switch (level) {
            case DEBUG:
                Log.d(TAG, "Exception", t);
                break;
            case INFO:
                Log.i(TAG, "Exception", t);
                break;
            case WARN:
                Log.w(TAG, "Exception", t);
                break;
            case ERROR:
                Log.e(TAG, "Exception", t);
                break;
            default:
                Log.v(TAG, "Exception", t); // 默認(rèn)情況下，如果沒有匹配的級別，可以使用VERBOSE級別
        }
    }

}

最后譬挚，送上我編譯好的jar锅铅，包括重連，過濾tag：cong减宣。添加androidlog版的hivemq-mqtt-client.jar資源-CSDN文庫