Android如何实现MQTT消息推送？

说实话，MQTT是一种非常轻量级的消息传输协议，咱就是说非常适合用于移动端推送场景。

一提到MQTT大部分介绍dou会先说MQTT是一种轻量级的消息传输协议，那为什么是轻量级的呢，一起kan下：

协议头部开销小：

发布/订阅模式：

QoS等级控制：

二进制协议：

为了方便使用，把MQTT相关的方法dou写在了一个Service中，启动后先初始化MqttAndroidClient，然后设置一些回调监听，Ke以kan到回调了3个方法：

messageArrived: 收到Yi订阅主题的消息

connectionLost: MQTT断开连接，可在此增加一些重连的逻辑

deliveryComplete: 向特定主题发送消息成功

class MQTTService : Service {
    // ...
}

对外暴露一些方法，MQTT连接、MQTT断开连接、订阅主题、取消订阅主题、发布消息。

fun connect {
    // ...
}
fun disconnect {
    // ...
}
fun subscribe {
    // ...
}
fun unsubscribe {
    // ...
}
fun publish {
    // ...
}

完整的MainActivity逻辑如下

class MainActivity : AppCompatActivity {
    private lateinit var binding: ActivityMainBinding
    private var mqttService: MQTTService? = null
    override fun onCreate {
        super.onCreate
        binding = ActivityMainBinding.inflate
        setContentView
        init
    }
    private fun init {
        // 绑定MQTT服务
        val intent = Intent
        bindService
        binding.btnConnect.setOnClickListener { connectMQTT }
        binding.btnDisconnect.setOnClickListener { disconnectMQTT }
        binding.btnSubscribe.setOnClickListener { subscribeTopic }
        binding.btnUnsubscribe.setOnClickListener { unsubscribeTopic }
        binding.btnPublish.setOnClickListener { publishMessage }
    }
    private fun connectMQTT {
        // ...
    }
    private fun disconnectMQTT {
        // ...
    }
    private fun subscribeTopic {
        // ...
    }
    private fun unsubscribeTopic {
        // ...
    }
    private fun publishMessage {
        // ...
    }
}

使用Eclipse MosquittoZuo为Broker进行测试，安装完成后切换到安装目录，打开命令行窗口，执行下面的指令生成密码文件：

// username修改为你的用户名，执行后会提示输入两遍密码
mosquitto_passwd -c passwd_file username

然后执行：

mosquitto -v -c mosquitto.conf

到这里Broker就运行起来了先启动一个订阅者，来接收客户端发送的消息：

.\mosquitto_sub -h 你的电脑IP -p 1883 -t android/mqtt/demo -u admin -P 123456

其中android/mqtt/demo是你要订阅的主题，admin和123456换成你修改的用户名和密码，在客户端发送一条消息，Ke以kan到Yi经收到了：

然后再执行发布消息，Ke以kan到客户端也接收到了消息：

到这里Android消息推送MQTT方案就介绍完了如有问题Ke以给我留言评论或者在GitHub中提交Issues，谢谢！