使用MQTT协议往Android手机推送消息

  • Article

最近做了一些IoT相关的工作，对于MQTT协议用得比较多。MQTT诞生较早（1999年）但是一直不温不火，直到最近由于物联网的兴起，才由IBM在2013年将其提交到了OASIS规范中，从而在物联网的协议中占得一席之地。这个协议有着如下特点：

轻量化，消息头部采用二进制格式

订阅/发布模式，这样非常适合于服务器推送

可以对不同的话题采用不同的QoS（服务质量），可以在可靠性和复杂度之间取得平衡

介于之前一直想做一个往自己Android手机上推送消息的小应用。但是因为某些网络环境的原因你懂的，Google为Android设计的推送机制在国内并不能很好的使用。如果使用类似于Rest API轮询的方式，对于移动设备来说过于耗费电量以及流量，并不是很好的方法。了解到有了MQTT这种轻量级的协议以后，发现完美契合这个推送消息的需求。于是赶紧试一试！

在整个流程中，需要3个点，分别是MQTT Broker,推送消息的client，以及接收消息的Android client。

1. MQTT Broker
就是一个接受订阅，接受并转发消息的服务器。我选择基于Node的项目mosca，由于我是独立使用，所以特别简单。

 npm install mosca pino -g
mosca -v | pino

简直不要太方便！70

查看一下网络端口

 tcp6       0      0 :::1883                 :::*                    LISTEN

好，已经默认监听在1883端口了。

2. 推送消息的client
就是要推送消息的消息源。这个还是用Node的MQTT项目（Node的库真是好用哭）。
同样是两种用法，第一种独立使用：

 npm install mqtt -g
mqtt sub -t 'topic' -h 'broker_url' -v
mqtt pub -t 'topic' -h 'broker_url' -m 'message'

第二种嵌入code：
[javascript]
var mqtt = require('mqtt')
var client = mqtt.connect('mqtt://test.mosquitto.org')

client.on('connect', function () {
client.subscribe('presence')
client.publish('presence', 'Hello mqtt')
})

client.on('message', function (topic, message) {
// message is Buffer
console.log(message.toString())
client.end()
})
[/javascript]

3. 接收消息的Android client
这个比前两个找起来难度大点。在Play市场上搜索MQTT，试了一些排名靠前的应用，发现对于MQTT的支持都没有什么问题，收发消息也都正常。但是都无法支持后台保持连接以及消息提醒机制。最后找到了这么一个应用，可以实现MQTT消息的后台以及息屏提醒，叫做Linear MQTT Dashboard

打开应用 先进行一下简单的设置
1

返回到主界面，可以看到有两个状态指示灯
2
第二个就表示MQTT Broker的连接状态，如果是绿色的就说明已经成功连接上了。

然后增加一个widget来显示消息，先按一下上图中的暂停按钮，然后按加号添加一个widget，其中主要填好Sub.topic就可以了

我们试着从另一个地方往test话题推送一条消息

 
mqtt pub -t 'test' -h '[MQTT_BROKER_URL]' -m 'hello world'

3
接收成功，那么看看如果app切到后台能不能收到提醒呢
4
可以看到，成功在通知栏提醒了消息，并且有震动。在息屏时也会有震动提醒，完美！

那么到此为止，就利用MQTT协议成功的进行了从任意client往Android手机推送消息的机制，而且非常省电和省流量。其实在这个方案中，Android手机不仅可以作为消息的接收端，也可以作为消息的发送端，那么如果把接收端放在一些嵌入式设备或者小型开发板上（由于MQTT是物联网的标准协议，所以支持较为广泛），那么就可以通过手机来控制这些设备，进而实现智能家居等等任何你能想象的功能！