书到用时方恨少，事非经过不知难。这篇文章主要讲述转载基于阿里云的MQTT远程控制(Android 连接MQTT服务器,ESP8266连接MQTT服务器实现远程通信控制----简单的连接通信)相关的知识，希望能为你提供帮助。
如果不了解MQTT的可以看这篇文章   http://www.cnblogs.com/yangfengwu/p/7764667.html
http://www.cnblogs.com/yangfengwu/p/8026014.html
关于钱的问题,其实自己是花钱买的云服务,虽然自己现在能支付的起,但是呢为了尽量减少支出,自已还有好多好多文章要写,好多好多元器件要买,所以哈会在自己的淘宝上卖源码2元价格,一元捐出,一元自己留着当亲们支付云服务的费用了
如果看不懂也没关系,跟着做就可以了,做完以后您会发现原来MQTT这么好用,也如此简单.
对了我要尽量把程序写的烂一些,界面做的烂一些,因为既然是学习用的应该越直观越好.......说一下,自己的服务器因为公开了稳定性上肯定不好,
数据冲突也是可能的,这是第一篇,下面几篇慢慢的来,咱一块慢慢完善哈
实现的功能--手机和WIFI模块都连接MQTT服务器,手机用按钮实现远程控制一个继电器,然后WIFI模块采集的DHT11的温湿度,远程发给手机
不过自己这批贴片的板子要等到后天才到..........................

文章图片
   
文章图片


文章图片


文章图片

 
 
 
先看一下android 程序怎么写,首先就是下载个MQTT的jar包
链接：https://pan.baidu.com/s/1bpjRzyB 密码：90vv
新建一个Android 工程就不说了吧...............
将下载的jar包放在一个地方

文章图片

 
 
我放在了我的Android的源码的根目录
现在在Android 工程导入下载的那个jar包

文章图片

 
 
文章图片

 
 
文章图片


文章图片

 
 
 
 
文章图片

 
现在把可能用到的一些权限加上 

文章图片

 

文章图片

< !--获取手机信息权限 --> < uses-permission android:name="android.permission.INTERNET"> < /uses-permission> < uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" > < /uses-permission> " < uses-permission android:name="android.permission.CHANGE_NETWORK_STATE"> < /uses-permission> < uses-permission android:name="android.permission.CHANGE_CONFIGURATION" /> < uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" /> < uses-permission android:name="android.permission.READ_PHONE_STATE" /> < uses-permission android:name="android.permission.INTERNET"/> < uses-permission android:name="android.permission.ACCESS_WIFI_STATE"/> < uses-permission android:name="android.permission.WAKE_LOCK"/> < uses-permission android:name="android.permission.CHANGE_WIFI_STATE"/> < uses-permission android:name="android.permission.VIBRATE" /> < uses-permission android:name="android.permission.WRITE_SETTINGS" /> < uses-permission android:name="android.permission.CHANGE_WIFI_MULTICAST_STATE"> < /uses-permission>

文章图片
 
现在呢先写个程序获取手机的IMEI号,因为连接的时候每一个客户端的ClientID要求不能一样,咱就用IMEI号代表ClientID

文章图片

其实就这两句

TelephonyManager mTm = (TelephonyManager)this.getSystemService(TELEPHONY_SERVICE); TelephonyIMEI = mTm.getDeviceId();

 
现在配置咱的MQTT
 

文章图片

public class MainActivity extends Activity {String TelephonyIMEI=""; private MqttClient client; //client private MqttConnectOptions options; //配置@Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); TelephonyManager mTm = (TelephonyManager)this.getSystemService(TELEPHONY_SERVICE); TelephonyIMEI = mTm.getDeviceId(); //Toast.makeText(getApplicationContext(), TelephonyIMEI, 500).show(); MyMqttInit(); }/*初始化配置Mqtt*/ private void MyMqttInit() {try { //(1)主机地址(2)客户端ID,一般以客户端唯一标识符(不能够和其它客户端重名)(3)最后一个参数是指数据保存在内存(具体保存什么数据,以后再说,其实现在我也不是很确定) client = new MqttClient("tcp://47.93.19.134:1883",TelephonyIMEI,new MemoryPersistence()); } catch (MqttException e) { // TODO Auto-generated catch block e.printStackTrace(); }options = new MqttConnectOptions(); //MQTT的连接设置options.setCleanSession(true); //设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接options.setUserName("username"); //设置连接的用户名(自己的服务器没有设置用户名)options.setPassword("password".toCharArray()); //设置连接的密码(自己的服务器没有设置密码)options.setConnectionTimeout(10); // 设置连接超时时间 单位为秒options.setKeepAliveInterval(20); // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制client.setCallback(new MqttCallback() { @Override//获取的消息会执行这里--arg0是主题,arg1是消息 public void messageArrived(String arg0, MqttMessage arg1) throws Exception { // TODO Auto-generated method stub}@Override//订阅主题后会执行到这里 public void deliveryComplete(IMqttDeliveryToken arg0) { // TODO Auto-generated method stub}@Override//连接丢失后，会执行这里 public void connectionLost(Throwable arg0) { // TODO Auto-generated method stub} }); }

文章图片
 
  现在连接咱的服务器,连接成功后打印一下连接成功,连接是阻塞的,所以放在一个任务里面执行连接
 

文章图片

public class MainActivity extends Activity {String TelephonyIMEI=""; private MqttClient client; //client private MqttConnectOptions options; //配置 MqttConnectThread mqttConnectThread = new MqttConnectThread(); //连接服务器任务 @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); TelephonyManager mTm = (TelephonyManager)this.getSystemService(TELEPHONY_SERVICE); TelephonyIMEI = mTm.getDeviceId(); //Toast.makeText(getApplicationContext(), TelephonyIMEI, 500).show(); MyMqttInit(); //初始化配置MQTT客户端 mqttConnectThread.start(); //执行连接服务器任务 }/*初始化配置Mqtt*/ private void MyMqttInit() { ......... }/*连接服务器任务*/ class MqttConnectThread extends Thread { public void run() { try { client.connect(options); //连接服务器,连接不上会阻塞在这 runOnUiThread(new Runnable() {// public void run() { Toast.makeText(getApplicationContext(), "连接成功", 500).show(); } }); } catch (MqttSecurityException e) { //安全问题连接失败 } catch (MqttException e) { //连接失败原因 } } }

文章图片
 
  现在下载到手机试一试

文章图片

 
  现在呢测试一下通信,测试接收消息,用调试助手发信息,然后手机端接收,然后显示出来
  调试助手链接
链接：https://pan.baidu.com/s/1qYxEeLI 密码：exfj
 
  现在先设置一下APP的订阅的主题,和接收到消息之后就显示出来

文章图片

 
 
文章图片


文章图片

public class MainActivity extends Activity {String TelephonyIMEI=""; private MqttClient client; //client private MqttConnectOptions options; //配置 MqttConnectThread mqttConnectThread = new MqttConnectThread(); //连接服务器任务 @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); TelephonyManager mTm = (TelephonyManager)this.getSystemService(TELEPHONY_SERVICE); TelephonyIMEI = mTm.getDeviceId(); //Toast.makeText(getApplicationContext(), TelephonyIMEI, 500).show(); MyMqttInit(); //初始化配置MQTT客户端 mqttConnectThread.start(); //执行连接服务器任务 }/*初始化配置Mqtt*/ private void MyMqttInit() {try { //(1)主机地址(2)客户端ID,一般以客户端唯一标识符(不能够和其它客户端重名)(3)最后一个参数是指数据保存在内存(具体保存什么数据,以后再说,其实现在我也不是很确定) client = new MqttClient("tcp://47.93.19.134:1883",TelephonyIMEI,new MemoryPersistence()); } catch (MqttException e) { // TODO Auto-generated catch block e.printStackTrace(); }options = new MqttConnectOptions(); //MQTT的连接设置options.setCleanSession(true); //设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接options.setUserName("username"); //设置连接的用户名(自己的服务器没有设置用户名)options.setPassword("password".toCharArray()); //设置连接的密码(自己的服务器没有设置密码)options.setConnectionTimeout(10); // 设置连接超时时间 单位为秒options.setKeepAliveInterval(20); // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制client.setCallback(new MqttCallback() { @Override//获取消息会执行这里--arg0是主题,arg1是消息 public void messageArrived(String arg0, MqttMessage arg1) throws Exception { // TODO Auto-generated method stub final String topic = arg0; //主题 final String msgString = arg1.toString(); //消息runOnUiThread(new Runnable() {// public void run() { Toast.makeText(getApplicationContext(),"主题:"+topic+"消息:"+msgString, 500).show(); } }); }@Override//订阅主题后会执行到这里 public void deliveryComplete(IMqttDeliveryToken arg0) { // TODO Auto-generated method stub}@Override//连接丢失后，会执行这里 public void connectionLost(Throwable arg0) { // TODO Auto-generated method stub} }); }/*连接服务器任务*/ class MqttConnectThread extends Thread { public void run() { try { client.connect(options); //连接服务器,连接不上会阻塞在这client.subscribe("test",0); //设置(订阅)接收的主题,主题的级别是0runOnUiThread(new Runnable() {// public void run() { Toast.makeText(getApplicationContext(), "连接成功", 500).show(); } }); } catch (MqttSecurityException e) { //安全问题连接失败 } catch (MqttException e) { //连接失败原因 } } }

文章图片
下载到手机 
 
  现在配置一下软件,对了有些参数现在不明白没关系,后面会介绍一下相关的知识,

文章图片

软件的主题名称要和APP中订阅的主题一样 都是 test
现在连接
 
文章图片

 
  现在点击发布消息
 
文章图片

 
  看手机端

文章图片

 
  说明已经能通信了
  现在说一下关于主题哈,关于/
  现在把手机端的订阅的主题改为"/#"

文章图片

 
  然后下载到手机
 
文章图片


文章图片

你会发现手机也能接收消息
 
文章图片


文章图片

手机都能接收到消息
#  是一个匹配主题中任意层次数的通配符。比如说，如果你订阅了test/device/#，你就可以接收到以下这些主题的消息。

test/device


test/device/后面随便是什么

咱们的设备可以用"/"来进行分类,咱们的APP呢可以指定接收哪一类的产品的数据"XXXX/#"....是不是很方便


对了如果现在接收两个已知主题的设备
假如说是

文章图片

第一种方式

文章图片


文章图片
   
文章图片

 
 

第二种方式

 
文章图片


结果和上面一样

文章图片

 
  现在呢在界面加一个按钮,按下发送消息"1",松开发送消息"0"
然后设置发布的主题是"/test/button"

文章图片

 
 
文章图片


文章图片

 
 

文章图片

public class MainActivity extends Activity {String TelephonyIMEI=""; private MqttClient client; //client private MqttConnectOptions options; //配置 MqttConnectThread mqttConnectThread = new MqttConnectThread(); //连接服务器任务Button button; //发送消息按钮 @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); button = (Button) findViewById(R.id.button1); //获取发送消息按钮 button.setOnTouchListener(buttonTouch); //设置按钮的触摸事件TelephonyManager mTm = (TelephonyManager)this.getSystemService(TELEPHONY_SERVICE); TelephonyIMEI = mTm.getDeviceId(); //Toast.makeText(getApplicationContext(), TelephonyIMEI, 500).show(); MyMqttInit(); //初始化配置MQTT客户端 mqttConnectThread.start(); //执行连接服务器任务 }/*按钮触摸事件*/ private OnTouchListener buttonTouch = new OnTouchListener() {@Override public boolean onTouch(View v, MotionEvent event) { MqttMessage msgMessage = null; //Mqtt消息变量 if (event.getAction() == MotionEvent.ACTION_DOWN) //按下 { msgMessage = new MqttMessage("1".getBytes()); } else if (event.getAction() == MotionEvent.ACTION_UP) //松开 { msgMessage = new MqttMessage("0".getBytes()); }try { client.publish("/test/button",msgMessage); //发送主题为"/test/button"的消息 } catch (MqttPersistenceException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (MqttException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (Exception e) { //其余的状态msgMessage = null; 所以加了这个catch (Exception e) }return false; } };

文章图片
 
  现在下载到手机,
调试助手订阅一下主题  "/test/button"

文章图片

 
  动作一下按钮

文章图片

 
 
文章图片

 
  现在把发过来的数据用文本框显示,不让他提示了
 
文章图片


文章图片

      接收显示的换一下

文章图片

 
 

文章图片

runOnUiThread(new Runnable() {//因为操作的是主界面的控件所以用刷新UI的线程,最好用handle哈,我这里怎么简单怎么写 public void run() { //Toast.makeText(getApplicationContext(),"主题:"+topic+"消息:"+msgString, 500).show(); textView.setText("主题:"+topic+"\\n消息:"+msgString); } });

文章图片
 
  现在试一下

文章图片

 

文章图片

 
 
好了,现在咱开始控制咱的WIFI模块了....用咱的手机控制WIFI板子上的继电器,WIFI模块呢采集温湿度,然后显示在手机的文本框中
自己更倾向于用lua开发,所以要刷入lua的固件哈
关于刷固件可以参考
http://www.cnblogs.com/yangfengwu/p/7514336.html
自己已经下载好的固件
【转载基于阿里云的MQTT远程控制(Android 连接MQTT服务器,ESP8266连接MQTT服务器实现远程通信控制----简单的连接通信)】链接：https://pan.baidu.com/s/1o8pAISy 密码：9zns
 
如果亲们自己下载的话别忘了,把mqtt和dht选择上哈

文章图片

 
 
程序--init.lua

文章图片

wifi.setmode(wifi.STATION)RelayPin = 2; --RelayPin gpio.mode(RelayPin,gpio.OUTPUT)--RelayPin gpio.write(RelayPin,0)--RelayPinLedPin = 4; --LedPin gpio.mode(LedPin,gpio.OUTPUT)--LedPin gpio.write(LedPin,0)--LedPinDHT11pin = 5--DHT11 GPIOTemperature = "0"; --Storage temperature Humidity = "0"; --Store humidityapcfg={} apcfg.ssid="qqqqq" apcfg.pwd="11223344" wifi.sta.config(apcfg) --wifi.sta.connect() wifi.sta.autoconnect(1)clientid = wifi.sta.getmac() mqttClient=nil mqttConnectedFlage = 0; Mymqtt = mqtt.Client(clientid, 120,"user", "password"); --[[The connection serve]] tmr.alarm(0, 1000, 1, function() Mymqtt:connect("47.93.19.134", 1883, 0,ConnectSuccess,ConnectFailed) end)--[[The connection Success]] function ConnectSuccess(client) client:subscribe("/test/button", 0, subscribeSuccess)print("connected") mqttClient = client; tmr.stop(0); mqttConnectedFlage = 1; end--[[The connection fails]] function mqttConnectFailed(client,reason) mqttConnectedFlage = 0; print("failed reason: " .. reason) tmr.start(0); end--[[The subscribe Success]] function subscribeSuccess(client) print("subscribe success") end--[[The Receive Msg]] Mymqtt:on("message", function(client, topic, data) ifstring.find(data,"1") ~= nil then gpio.write(RelayPin,1) endifstring.find(data,"0") ~= nil then gpio.write(RelayPin,0) endend)--[[The Send Msg]] tmr.alarm(1, 1000, 1, function()if mqttClient ~= nil and mqttConnectedFlage == 1 then mqttClient:publish("/test/yang","Temperature="..Temperature.."; ".."Humidity="..Humidity, 0, 0, function(client) gpio.write(4,1-gpio.read(4)) end) end end)--[[The gather humiture data]] tmr.alarm(5, 2000, 1, function()--Every other 1S local status, temp, humi, temp_dec, humi_dec = dht.read11(DHT11pin)--Gathering temperature and humidity if status == dht.OK or status == dht.ERROR_CHECKSUM then Temperature = temp; Humidity = humi; --print("DHT Temperature:"..temp.."; ".."Humidity:"..humi) end end)printip = 0 wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T) printip = 0 end)wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T) if printip == 0 then ip,netmask,gateway = wifi.sta.getip() print(gateway) end printip = 1 end)

文章图片
 
现在说一下个个部分的功能,对了关于语法问题和其余的问题就请大家参考我的,其实上面的代码就是参考的官方给的API函数,
我希望亲们最重要的是有自学的能力,而不是需要别人灌输东西的机器.

文章图片

 
 
文章图片


文章图片

 
 
文章图片


文章图片


文章图片


文章图片


文章图片


文章图片

 
  好了亲们可以自己去测试了
源码链接
https://item.taobao.com/item.htm?spm=a1z38n.10677092.0.0.7a8f8764Ey3xGc& id=563674399702
wifi的就是上面的,直接复制粘贴过去就好啦
APP源码链接：https://pan.baidu.com/s/1pLKGLrt

自己淘宝店的链接呢在最上面

推荐阅读

• 

  美播直播怎么放音乐？美播直播放音乐方法教程
• 

  大货车查违章哪个软件最准确 查违章哪个好
• 

  治安调解的原则有哪一些
• 

  财富贷是真的吗 财富贷可靠吗
• 

  招财猫怎么放，招财猫怎么放置
• 

  梦幻西游不pk有必要带龟速吗 梦幻西游龟速和配速哪个好
• 

  跨境电商行业报告 面试为什么选择跨境电商这个行业，跨境电商行业的发展趋势
• 

  edius怎么添加特效素材 edius给立体素材加特效的图文操作方法
• 

  游子吟中运用对偶的手法的诗句是
• 

  大卷烫发怎么打理好看 大脸如何打理头发，大卷头发怎么打理视频
• 

  取名诺诺的寓意是什么
• 

  一个刚入职的公务员一年能收入多少？
• 

  抖音蘑菇头我要送你99朵玫瑰花动态表情包分享
• 

  齐河物流园分拣员怎么样,快递从早上6点到晚上9点每天派送千余件
• 

  赫曼陆龟能长多大 小于多少很容易生命危险
• 

  皮沙发长霉斑可以用什么洗掉，真皮沙发有霉斑怎么清洗
• 

  初中总分多少分上a班 初中最多多少分
• 

  终其一生
• 

  箭牌洁具的价格表 箭牌单功能卫浴单价
• 

  知柏地黄丸有4大妙用 知柏地黄丸的作用与功效！

• WIN10网狐开发环境搭建与Android客户端编译
• MappedByteBuffer 存储long
• TCP_Wrappers 基于TCP的安全控制
• Android WebView 文明踩坑之路
• Android+ESP8266+路由器实现远程控制(基于花生壳域名方式访问)
• 2Django实战第2天（app设计）
• 360儿童卫士哪里买？怎样买？360儿童卫士购买办法
• 360儿童卫士手环购买图文详细教程 360儿童卫士手环怎样买流程
• 附360儿童卫士2申请官网 360儿童卫士2手环申请图文详细教程