IOT开发---Android MQTT使用

这篇具有很好参考价值的文章主要介绍了IOT开发---Android MQTT使用。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

MQTT介绍

MQTT(Message Queuing Telemetry Transport,消息队列遥测传输协议),是一种基于发布/订阅(publish/subscribe)模式的“轻量级”通讯协议。

该协议构建于TCP/IP协议上,它的设计思想是轻巧、开放、 简单、规范,易于实现。这些特点使得它对很多场景来说都是很好的选择,特别是对于受限的环境如机器与机器的通信(M2M)以及物联网环境(IoT)。

MQTT通信模型

MQTT 协议提供一对多的消息发布,可以降低应用程序的耦合性,用户只需要编写极少量的应用代码就能完成一对多的消息发布与订阅,该协议是基于<客户端-服务器>模型,在协议中主要有三种身份:发布者(Publisher)、服务器(Broker)以及订阅者(Subscriber)。

其中,MQTT消息的发布者和订阅者都是客户端,服务器只是作为一个中转的存在,将发布者发布的消息进行转发给所有订阅该主题的订阅者;发布者可以发布在其权限之内的所有主题,并且消息发布者可以同时是订阅者,实现了生产者与消费者的脱耦,发布的消息可以同时被多个订阅者订阅。

MQTT通信模型示意图如下:
android mqtt ssl,Android 进阶,android,物联网,MQTT

MQTT客户端

MQTT 客户端可以向服务端发布信息,也可以从服务端收取信息。我们把客户端发送信息的行为称为 “发布”信息。客户端要想从服务端收取信息,则首先要向服务端“订阅”信息。

客户端具体功能如下:
1.发布消息给其它相关的客户端。
2.订阅主题请求接收相关的应用消息。
3.取消订阅主题请求移除接收应用消息。
4.从服务端终止连接。

MQTT服务端

MQTT 服务端通常是一台服务器(broker),它是 MQTT 信息传输的枢纽,负责将 MQTT 客户端发送来的信息传递给 MQTT 客户端。MQTT 服务端还负责管理 MQTT 客户端,以确保客户端之间的通讯顺畅,保证 MQTT 信息得以正确接收和准确投递。

MQTT 服务器位于消息发布者和订阅者之间,以便用于接收消息并发送到订阅者之中,它的功能有:
1.接受来自客户端的网络连接请求。
2.接受客户端发布的应用消息。
3.处理客户端的订阅和取消订阅请求。
4.转发应用消息给符合条件的已订阅客户端(包括发布者自身)。

Android使用MQTT

集成MQTT库

MQTT有不同语言、不同版本的诸多实现,其中Eclipse Paho只是诸多Java实现中的一个。

我们将使用Eclipse Paho Java Client作为客户端,它是 Java 语言中使用最广泛的 MQTT 客户端库。

集成步骤:

  1. 在Android工程的bulid.gradle(:app) 文件中添加依赖包
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.0'

org.eclipse.paho也实现了一套针对Android端的通讯服务框架https://github.com/eclipse/paho.mqtt.android

不少开发者直接引用这个库:

implementation ‘org.eclipse.paho:org.eclipse.paho.android.service:1.1.1’

在Android 8.0以前这样做是没问题的,8.0以后Android Service行为发生了很大变更,需要进行适配,不然会出现异常。但是这个库的维护人员貌似对Android版本适配不是很积极,鉴于此,我们把库的源码下载下来,对源码进行改造,作为一个库工程使用:

implementation project(':org.eclipse.paho.android.service')
  1. 添加权限
<uses-permission android:name="android.permission.INTERNET" />

<uses-permission android:name="android.permission.WAKE_LOCK" />

<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
  1. 注册Service
<service android:name="org.eclipse.paho.android.service.MqttService" />

定义MQTT管理者

该类设计为单例模式,实现MQTT初始化、连接、订阅消息、发布消息、处理消息、释放连接等操作。

初始化包括创建MqttAndroidClient对象,并设置回调接口,针对连接失败的情况作断线重连的尝试,针对接收的消息进行JSON解析、并重新封装成需要的数据内容,通过EventBus将消息对象抛出去,相关业务模块注册EventBus并接收该对应消息,然后进行处理。

连接主要是设置连接相关参数和针对连接结果的处理,参数有连接认证校验、设置超时时间、设置心跳包发送间隔、设置用户名和密码。文章来源地址https://www.toymoban.com/news/detail-694146.html

/**
 * Created by ZhangJun on 2019/1/3.
 */
class MqttManager private constructor() {

    private var mqttAndroidClient: MqttAndroidClient? = null
    private lateinit var mqttConnectOptions: MqttConnectOptions

    private object MqttManagerHolder {
        val INSTANCE = MqttManager()
    }

    fun init(node: String, port: Int, clientId: String) {
        try {
            if (mqttAndroidClient == null) {
                mqttAndroidClient = MqttAndroidClient(XxApplication.instance, "ssl://$node:$port", clientId)
            } else {
                mqttAndroidClient!!.setCallback(object : MqttCallbackExtended {
                    override fun connectComplete(reconnect: Boolean, serverURI: String?) {
                        LogUtils.d(TAG, "mqtt connectComplete reconnect = $reconnect")
                    }

                    override fun connectionLost(cause: Throwable?) {
                        if (cause != null) {
                            LogUtils.d(TAG, "mqtt connectionLost cause = " + cause.message)
                        }
                        connect()
                    }

                    @Throws(Exception::class)
                    override fun messageArrived(topic: String, message: MqttMessage) {
                        val str = String(message.payload)
                        LogUtils.d(TAG, "messageArrived str = $str")
                        val jsonObject = JSONObject(str)
                        val event = jsonObject.optJSONObject("event")
                        val header = event.optJSONObject("header")
                        val namespace = header.optString("namespace")
                        val name = header.optString("name")
                        val payload = event.optJSONObject("payload")
                        val message1 = MqttMessageBean()
                        message1.messageId = namespace.plus(name)
                        message1.messageContent = payload
                        EventBus.getDefault().post(ServerEvent.MqttMessageEvent(message1))
                    }

                    override fun deliveryComplete(token: IMqttDeliveryToken) {
                        //do nothing
                    }
                })

                mqttConnectOptions = MqttConnectOptions()
                mqttConnectOptions.socketFactory = sslSocketFactory

                mqttConnectOptions.isAutomaticReconnect = true
                mqttConnectOptions.isCleanSession = false
                // 设置超时时间,单位:秒
                mqttConnectOptions.connectionTimeout = 10
                // 心跳包发送间隔,单位:秒
                mqttConnectOptions.keepAliveInterval = 20
                // 用户名
                mqttConnectOptions.userName = CommonUtils.decryptToken()
                // 密码
                mqttConnectOptions.password = XxApplication.instance.packageName.toCharArray()
                connect()
            }
        } catch (ex: Exception) {
            ex.printStackTrace()
        }
    }

    private fun connect() {
        if (mqttAndroidClient != null && !mqttAndroidClient!!.isConnected) {
            mqttAndroidClient!!.connect(mqttConnectOptions, null, object : IMqttActionListener {
                override fun onSuccess(asyncActionToken: IMqttToken) {
                    val disconnectedBufferOptions = DisconnectedBufferOptions()
                    disconnectedBufferOptions.bufferSize = 100
                    disconnectedBufferOptions.isBufferEnabled = true
                    disconnectedBufferOptions.isPersistBuffer = false
                    disconnectedBufferOptions.isDeleteOldestMessages = false
                    mqttAndroidClient!!.setBufferOpts(disconnectedBufferOptions)
                }

                override fun onFailure(asyncActionToken: IMqttToken, exception: Throwable) {
                    LogUtils.d(TAG, " mqtt connect fail exception = " + exception.message)
                }
            })
        }
    }

    private val sslSocketFactory: SSLSocketFactory
        get() {
            try {
                val sslContext = SSLContext.getInstance("SSL")
                sslContext.init(null, trustManager, SecureRandom())
                return sslContext.socketFactory
            } catch (e: Exception) {
                throw RuntimeException(e)
            }

        }

    private val trustManager: Array<TrustManager>
        get() = arrayOf(object : X509TrustManager {
            override fun checkClientTrusted(chain: Array<X509Certificate>, authType: String) {
                //do nothing
            }

            override fun checkServerTrusted(chain: Array<X509Certificate>, authType: String) {
                //do nothing
            }

            override fun getAcceptedIssuers(): Array<X509Certificate> {
                return arrayOf()
            }
        })

    /**
     * 订阅消息
     */
    fun subscribeTopic(subTopic: String, qos: Int) {
        try {
            if (mqttAndroidClient != null && mqttAndroidClient!!.isConnected) {
                mqttAndroidClient!!.subscribe(subTopic, qos)
            }
        } catch (ex: MqttException) {
            System.err.println("Exception while subscribing")
            ex.printStackTrace()
        }

    }

    /**
     * 发布消息
     */
    fun publishMessage(pubTopic: String, qos: Int, content: String) {
        try {
            if (mqttAndroidClient != null && mqttAndroidClient!!.isConnected) {
                mqttAndroidClient!!.publish(pubTopic, content.toByteArray(), qos, false)
            }
        } catch (e: MqttException) {
            System.err.println("Error Publishing: " + e.message)
            e.printStackTrace()
        }

    }

    fun release() {
        try {
            if (mqttAndroidClient != null) {
                mqttAndroidClient!!.unregisterResources()
                if (mqttAndroidClient!!.isConnected) {
                    mqttAndroidClient!!.disconnect()
                }
                mqttAndroidClient!!.close()
                mqttAndroidClient = null
            }
        } catch (e: Exception) {
            e.printStackTrace()
        }
    }

    companion object {
        private val TAG = MqttManager::class.java.simpleName

        val instance: MqttManager
            get() = MqttManagerHolder.INSTANCE
    }
}

定义消息实体

/**
 * Created by ZhangJun on 2019/1/5.
 */
class MqttMessageBean {
    var messageId: String = ""
    var messageContent: JSONObject = JSONObject()
}

到了这里,关于IOT开发---Android MQTT使用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Modbus TCP/BACnet IP/MQTT物联网网关IOT-810介绍及其典型应用

    伴随着计算机技术以及互联网的发展,物联网这个概念已经逐渐进入我们的日常生活,例如智能泊车,智能家居,智能照明,智能楼宇等。智能楼宇是将传统的楼宇自控系统与物联网技术相融合,把系统中常见的传感器、设备、嵌入式计算机接入到网络,在云端统一进行管理

    2024年02月17日
    浏览(58)
  • 【IoT网络层】STM32 + ESP8266 +MQTT + 阿里云物联网平台 |开源,附资料|

    🌟博主领域:嵌入式领域人工智能软件开发 本节目标: 通过MQTT.fx模拟连接或通过串口连接ESP8266发送AT命令,实现阿里云物联网平台发送数据同时接收数据,IOT studio界面显示数据。具体来说:使用ESP8266 ESP-01来连接网络,获取设备数据发送到阿里云物联网平台并显示且oled显

    2024年02月04日
    浏览(57)
  • 使用4G通信模块和MQTT协议,完成物联网设备开发。

    (1)安装并使用4G模块通信模块,建立microPython开发环境; (2)使用提供的Demo开发例程,使用MQTT传输协议连接阿里或腾讯网站,完成物联网设备开发。 (3)将温湿度信息上传到网站; (4)手机APP查看数 这是第一步,在阿里云平台创建产品和设备,用来将实际的设备数据

    2024年02月04日
    浏览(59)
  • 物联网协议NB-IoT,LORA,wifi,蓝牙,zigbee,MQTT,COAP之间的关系

    NB-IoT,LORA,WIFI,蓝牙,zigbee,4G都是物理层的,这几个都需要芯片模组支持(硬件支持) 而MQTT,COAP,HTTP都是应用层协议,这些需要开发服务器,或者对接云平台厂商(软件支持) 所以(MQTT,COAP,HTTP)是居于(NB-IoT,LORA,WIFI,蓝牙,zigbee,4G)的上层协议 不需要网关:

    2024年02月15日
    浏览(54)
  • Mainflux IoT:Go语言轻量级开源物联网平台,支持HTTP、MQTT、WebSocket、CoAP协议

    Mainflux是一个由法国的创业公司开发并维护的 安全、可扩展 的开源物联网平台,使用 Go语言开发、采用微服务的框架。Mainflux支持多种接入设备,包括设备、用户、APP;支持多种协议,包括HTTP、MQTT、WebSocket、CoAP,并支持他们之间的协议互转。 Mainflux的南向接口连接设备,北

    2024年02月01日
    浏览(110)
  • Android MQTT连接阿里云使用Json解析数据

    这里有两种方法: 这里先介绍第一种方法: 切换到Android 目录: 按照如下图,添加依赖即可: 第二种方法: 打开Android Studio 然后切换到Android 目录找到Lib文件夹,将MQTT的JAR包复制进去即可。 然后点击project目录然后将MQTT JAR包导进去 添加完成之后作为库导入工程中 在MainA

    2024年02月03日
    浏览(43)
  • 【001_IoT/物联网通信协议基础: HTTP、Websocket、MQTT、AMQP、COAP、LWM2M一文搞懂】

    学历代表过去、能力代表现在、学习力代表将来。 一个良好的学习方法是通过输出来倒逼自己输入。写博客既是对过去零散知识点的总结和复盘,也是参加了 零声教育 写博客活动。 零声教育体验课:https://xxetb.xetslk.com/s/3fbO81 本文是开发过程中的知识点总结,供大家学习交

    2024年04月22日
    浏览(35)
  • Android+MQTT(Android APP 连接至MQTT服务器)

    这段时间因为毕设的需求,接触学习了一下用Android app连接MQTT服务器,然后对下位机(STM32/ESP8266)进行数据通讯的一个小设计,本篇文章介绍app+MQTT服务器这一段。 实现原理: 这里设计的是一个监测控制智能风扇的APP,可以实时监测当前温度、湿度及下位机的传感器、控制

    2024年02月02日
    浏览(48)
  • android studio 使用MQTT协议连接onenet 注意事项和相关函数

    一、注意事项: 1.添加依赖: 2.在注册表允许打开网络 3.在application     /application之间添加用于支持 MQTT(Message Queuing Telemetry Transport)通信协议的 Eclipse Paho Android 服务。 4.打开项目中的 gradle.properties 文件,并确保以下属性设置为true------更新所有的支持库到AndroidX中。 二、

    2024年04月26日
    浏览(46)
  • 用java开发MQTT(SSL连接)

    近期又接触到了新的一个东西MQTT,用本地环境模拟一下吧。 主要是用EMQ作为服务器,首先当然是去官网下载一个EMQ  下载 EMQX 我本地用的是windows版本,下载完后进去bin目录后有个emqx文件 用命令窗口输入emqx start 就启动了 这里主要是用mysql来鉴权,设置一下就好了,当然建

    2024年02月07日
    浏览(42)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包