hivemqtt-client添加android log打印

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类实现如下：

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); // 默认情况下，如果没有匹配的级别，可以使用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)); // 默认情况下，如果没有匹配的级别，可以使用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)); // 默认情况下，如果没有匹配的级别，可以使用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)); // 默认情况下，如果没有匹配的级别，可以使用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); // 默认情况下，如果没有匹配的级别，可以使用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); // 默认情况下，如果没有匹配的级别，可以使用VERBOSE级别
        }
    }

}

最后，送上我编译好的jar，包括重连，过滤tag：cong。添加androidlog版的hivemq-mqtt-client.jar资源-CSDN文库

最后编辑于：2024.11.06 16:27:08

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 215,539评论 6赞 497
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 91,911评论 3赞 391
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 161,337评论 0赞 351
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 57,723评论 1赞 290
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 66,795评论 6赞 388
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,762评论 1赞 294
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,742评论 3赞 416
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 38,508评论 0赞 271
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,954评论 1赞 308
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,247评论 2赞 331
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,404评论 1赞 345
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,104评论 5赞 340
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,736评论 3赞 324
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,352评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,557评论 1赞 268
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 47,371评论 2赞 368
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,292评论 2赞 352

hivemqtt-client添加android log打印

hivemqtt-client原本是一个java后台框架，集成到android并没有android的log打印，但是我们可以添加。

由于hivemqtt-client是封装的netty，所以我们想用netty的loggerHandler打印log，所以我们也需要修改源码。

1.git下载源码：https://github.com/hivemq/hivemq-mqtt-client.git ，修改源码如下，在MqttChannelInitializer类 添加LoggingHandler。

1.2然后重新编译出：hivemq-mqtt-client-1.3.4.jar即可，这个时候我们就直接依赖jar包了，但是由于hivemqtt-client不仅仅依赖netty还依赖其他的jar，所以我们需要添加其他的gradle build的依赖。

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

最后，送上我编译好的jar，包括重连，过滤tag：cong。添加androidlog版的hivemq-mqtt-client.jar资源-CSDN文库

推荐阅读更多精彩内容

1.git下载源码：https://github.com/hivemq/hivemq-mqtt-client.git ，修改源码如下，在MqttChannelInitializer类添加LoggingHandler。