题外话：
三年前，我想录制一套Android入门视频给广大萌新，后来发现录制的速度远远赶不上技术的发展速度，于是就放弃了，一转眼，我也成了萌新，真是，学如逆水行舟，不进则退啊。
这段时间，在换工作，看到不少职位JD都写，有自己的技术博客优先。真是老虎不发威，你当我是病老虎啊。
其实是想，都毕业四年多了，确实该把自己以往经验总结一下，权当是个笔记，如果对别人有所帮助，那就更好了。
因为现在简书注册需要绑定手机号，所以，注册一个新号有些麻烦，只能和游记发在一起试试了，不同的读者朋友暂且点右侧文集分类来看自己感兴趣的文章吧。
MQTT协议以及应用场景:
MQTT (Message Queue Telemetry Transport)，遥测传输协议，其主要提供了订阅/发布两种消息模式，更为简约、轻量，易于使用，是物联网的一个传输协议。
之前使用MQTT协议是因为后端接口开发人手不够，于是就搭了一个MQTT服务器，用来模拟发送数据以及各端的互动，这样，客户端进度就不会受后台开发的限制。
MQTT 服务器:
服务器有windows的，也有linux的，查完资料后我选择了windows下的ActiveMQ.
下载地址:http://activemq.apache.org/
1.下载:
下载最新的
选择windows
2.解压启动服务:
下载完后解压到不带中文的路径下，进入bin目录，按着shitf键，右键单击，选择"在此处打开命令窗口"，执行命令，activemq start。
服务器启动起来之后第一个箭头标记的意思是,连接服务器的端口号是1883
第二个箭头的意思是ActiveMQ的网页控制台可以访问http://127.0.0.1:8161.
3.ActiveMQ网页控制台使用:
登录 http://127.0.0.1:8161,公用账号admin,密码admin
进入控制台后，点击Topics，然后创建一个topic.
创建完后就会显示在topic列表里
点击右侧SendTo，进入发送消息页面
点击send,就完成了一个消息的发送.
Android 客户端实现:
参考项目:https://github.com/eclipse/paho.mqtt.android
gradle依赖:
implementation'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.1.0'
implementation'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
权限:
<uses-permission android:name="android.permission.WAKE_LOCK" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="android.permission.INTERNET"></uses-permission>
一定要添加相关service:
<service android:name="org.eclipse.paho.android.service.MqttService"></service>
连接
配置mqttclient:
mqttAndroidClient =new MqttAndroidClient(MqttManager.mApp.getApplicationContext(),
String.format(URL_FORMAT, MqttManager.ip, MqttManager.port), clientId);
设置回调
mqttAndroidClient.setCallback
相关配置:
MqttConnectOptions mqttConnectOptions =new MqttConnectOptions();
mqttConnectOptions.setAutomaticReconnect(false);
// mqttConnectOptions.setUserName("admin");
// mqttConnectOptions.setPassword("admin".toCharArray());
//设置true,不然重复发送
mqttConnectOptions.setCleanSession(true);
mqttAndroidClient.connect(mqttConnectOptions, null, new IMqttActionListener()
主题订阅
mqttAndroidClient.subscribe(Api.TOPIC, 1);
然后就可以在callback,messageArrived方法里收到服务端发来的消息.
发送消息
MqttMessage mqttMsg =new MqttMessage();
mqttMsg.setPayload(msg.getBytes());
mqttAndroidClient.publish(topic, mqttMsg);
本例只是发送简单的字符串儿,可根据自己项目的需求进行封装,然后进行相应的去重,屏蔽,回调等功能.
模拟超时
本demo未实现,可提供思路,发送消息时,进行相关标记,发送完消息,如果收到回复,就删除其监听,在超时时间到达后,监听还未被删除,说明还未收到回复,就认为是超时了.
Demo地址 AndroidMqttDemo
注意事项:服务启动后,电脑跟手机连同一个WiFi,把ip自己改为自己电脑的ip,就可以用网页发消息给Android设备.也可以用Android发给Android.主题要保持一致
网友评论