Android 中使用MQTT(第一篇)

Posted 2023-04-24

参考技术A

MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议。它是一种发布/订阅，极其简单和轻量级的消息传递协议，专为受限设备和低带宽，高延迟或不可靠的网络而设计。它的设计思想是轻巧、开放、简单、规范，易于实现。这些特点使得它对很多场景来说都是很好的选择，特别是对于受限的环境如机器与机器的通信（M2M）以及物联网环境。相对于XMPP，MQTT更加轻量级，并且占用的宽带低。

MQTT协议有以下特点：

那么问题来了？重连连接成功后重复接收到最后一条消息
MQTT推送消息订阅端重复接收问题。
（背景）订阅端断开的时候，发布端多次推送消息。
（现象）订阅端启动时，接收到最后一条推送消息有两次；即使Qos设置为2；依然是两次。
经排查是因为
MqttMessage的Retained设置为了true;
该值很多文章上只说了是 消息保留机制，若设置为true，mqtt服务器会保留每次发布的消息；较少提到 若订阅某主题的客户端重启，则会把此主题之前发布的消息重新推送到客户端。该值默认为false;去掉修改该值即可
那么问题来了？重连连接后手动那么多遗漏的消息，怎么选择只接收最新的一条消息呢？
MQTT推送消息订阅端重复接收问题。
（背景）订阅端断开的时候，发布端多次推送消息。
（现象）订阅端启动时，接收到msg1，msg2，msg3 （这三个消息都是同一个类型消息，只需要处理最新的msg3就好，不然界面会刷新三次）这个谁有什么好办法没呢？

GitHub地址： https://github.com/eclipse/paho.mqtt.android
mqtt的官方文档： http://mqtt.org/documentation
Github上有中文翻译： https://github.com/mcxiaoke/mqtt

在module的build.gradle文件中添加依赖

在 AndroidManifest.xml 添加限权

在 AndroidManifest.xml 注册Service （MyMqttService为自己写的服务，下文会讲到）

Android中调用so库-第一篇

前言

公司是做人脸识别的，最近主管叫我了解一下车牌识别的sdk，里面就涉及so库的调用。想认真了解一下ndk和so库的使用，查了一下资料，然后总结一下自己的心得，理解的不对的地方请留言指教。

大纲

1.Android Studio 中怎么引用so库；

2.so库适配的问题，以及常见错误总结；

Android Studio 中怎么引用so库

1.首先创建libs文件夹或者jniLibs文件夹，如果放到 libs文件夹里面，要在build.gradle配置环境里面，加上这个配置。查了一下，是将libs目录指定为jniLibs的意思，这样免得再建jniLibs目录了。

    sourceSets 
        main 
            jniLibs.srcDirs = ['libs']
        
    

2. 默认会在 jniLibs，里面再创建armeabi-v7a文件夹，然后把so放到里面。

3. 代码中创建一个类，然后在类里面加载so 库，System.loadLibrary("AiwinnCarBrandDect"); 并且暴露要调用so库的方法。

class PlateRecognition 
    static 
        System.loadLibrary("AiwinnCarBrandDect");
    

    static native long InitRecognizer(String casacde_detection,
                                      String ssddetect_param, String ssddetect_bin,
                                      String finemapping_param, String finemapping_bin,
                                      String segmentation_prototxt, String segmentation_caffemodel,
                                      String charRecognization_proto, String charRecognization_caffemodel,
                                      String SegmentationFree_proto, String SegmentationFree_caffemodel);

    static native long ReleaseRecognizer(long object);

    static native String Recognization(long inputMat, long object, float ThreadValue);

想调so里面什么方法，在PlateRecognition类暴露即可。

2. so库适配的问题

大家可能有点疑惑，jniLibs里面为什么是armeabi-v7a，其实这个跟设备的cpu类型有关，下面是主流cpu版本：

armeabi/armeabi-v7a：这个架构是arm类型的，主要用于Android4.0之后的，cpu值32位的

x86/x86_64：这个架构是x86类型的，有32位和64位，占用的设备比例比较小

arm64-v8：这个架构是arm类型，主要用于Android5.0之后，cpu是64位的

跟大家分享一篇博客，这篇博客写的很详细，还分析so库使用的源码原理，常见错误以及释放so库使用的注意事项：

Android 调用so库全过程

备注，加载so库还有其他方法，这种方法只适合：1. SO是不是JNI规范的SO，比如有没有返回JNI不直接支持的类型。也就是说这个SO是可以直接当作JNI来调用；2. 希望这个SO的库直接暴露给JAVA层。

暂时写到这里，有新的体会和理解继续更新内容。。。