【转载】(一)基于阿里云的MQTT远程控制(Android连接MQTT服务器,ESP8266连接MQTT服务器实现远程通信控制简单的连接通信)

"android.permission.INTERNET">
"android.permission.WRITE_EXTERNAL_STORAGE" >"
"android.permission.CHANGE_NETWORK_STATE">
"android.permission.CHANGE_CONFIGURATION" />
"android.permission.ACCESS_NETWORK_STATE" />
"android.permission.READ_PHONE_STATE" />
"android.permission.INTERNET"/>
"android.permission.ACCESS_WIFI_STATE"/>
"android.permission.WAKE_LOCK"/>
"android.permission.CHANGE_WIFI_STATE"/>
"android.permission.VIBRATE" />
"android.permission.WRITE_SETTINGS" />
"android.permission.CHANGE_WIFI_MULTICAST_STATE">

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

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)
{
//连接失败原因
}
}
}

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);//设置(订阅)接收的主题,主题的级别是0

runOnUiThread(new Runnable() {//
public void run() {
Toast.makeText(getApplicationContext(), "连接成功", 500).show();
}
});
}
catch (MqttSecurityException e)
{
//安全问题连接失败
}
catch (MqttException e)
{
//连接失败原因
}
}
}

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;
}
};

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

wifi.setmode(wifi.STATION)
RelayPin = 2;--RelayPin
gpio.mode(RelayPin,gpio.OUTPUT)--RelayPin
gpio.write(RelayPin,0)--RelayPin
LedPin = 4;--LedPin
gpio.mode(LedPin,gpio.OUTPUT)--LedPin
gpio.write(LedPin,0)--LedPin
DHT11pin = 5--DHT11 GPIO
Temperature = "0";--Storage temperature
Humidity = "0";--Store humidity
apcfg={}
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)
if string.find(data,"1") ~= nil then
gpio.write(RelayPin,1)
end
if string.find(data,"0") ~= nil then
gpio.write(RelayPin,0)
end
end)
--[[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)