stm32 app 连上阿里云_stm32与云平台或者app之间的通信方法

stm32 app 连上阿里云

阿里云篇

1.首先得先注册账号，注册账号后选择物联网平台
2.点击公共实例

3.创建产品产品（我以智能窗户为例）

4添加设备
我们需要添三个设备 app pc stm32(由于我以前产品有 为避免重复 我改成software stm32 computer) 我以stm32为例

5.回到产品定义既可以发布又能订阅的topic，这个topic如同单向路一样，可以允许不同的车通过，但是反向却不能反向。我们要用app给32收发消息，所以我们要建立两个topic（data1 和 data2 同样以一个为例）。
首先回到产品，选择对应产品，点击Topic类列表。点击自定义Topic 点击定义Topic
6.创建云产品流转规则并设定规则（数据由谁给谁）显然我们也要建两个，同样一个为例

7.启动云产品流转规则

我们使用mqtt测试一下能不能连上。我们得用技小新 MQTT编程工具，自动生成连接Aliyun信息

链接：[https://pan.baidu.com/s/14C55cnRO3C0G5gnN95JKWw] 提取码：o24i （链接来自 蓝色のLED）
首先去复制三元组，在设备页面选择一个设备

点进去 一键复制
打开技小新 （千万注意不要大括号）
打开mqtt.fx将刚刚生成的粘贴过去


粘贴好了点ok或者apply
再点击 Conect

再打开阿里云的设备会看到我的software在线

APP篇

1.新建工程

工程建立完 我们只需要看三个文件

2.网络权限

3.界面设置
在此之前先得把你手机开发者模式打开并授权传输文件 配置好后
软件会识别到你的手机

界面设置我建议你看正哥的（反正我看的就是他的）
（阿正啷个哩个啷）他有个专题（7天Java0基础速成安卓开发），可以看到第四天的，后面联网，正哥有服务器，（你要是有的话，就跟这那个走就完事了）

不同的手机型号不同，排版还得改一下。
4.app联上阿里云
新建工程就生成的

先把java库加入工程，直接复制文件，将其粘贴在图片目录下。然后右击文件 选择add as库就OK了。

（链接：https://pan.baidu.com/s/1uZKdYVxq7DftTXAPWMgWzA
提取码：irct ）

mqtt协议那边（不会 做好cv工程师该做的）
只需要将第一行留下（自己新建的工程）把我的从第二行复制过去，在改成自己阿里云的四元组，就能连上自己设备（与正哥不一样的地方就是四元组 一定得仿照这个格式填入）
链接成功

细心的我把代码留下
package com.example.smart_window;

import android.annotation.SuppressLint;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.widget.Toast;

import androidx.appcompat.app.AppCompatActivity;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

//MainActivity依赖AppCompatActivity
public class MainActivity extends AppCompatActivity {

private String host = "tcp://a1IGfJFIYk1.iot-as-mqtt.cn-shanghai.aliyuncs.com:1883";
private String mqtt_id = "software|securemode=3,signmethod=hmacsha1,timestamp=789|"; 
private String userName = "software&a1IGfJFIYk1";
private String passWord = "b400896f719f6c3794dd9ba8e798d6de72ac7ac3";

private String mqtt_sub_topic = "/a1mFXDKSRyr/my_app/user/ad"; //本次只连 未验证  收发
private String mqtt_pub_topic = "/a1mFXDKSRyr/my_app/user/data"; 

private MqttClient client;
private MqttConnectOptions options;
private Handler handler;
private ScheduledExecutorService scheduler;




@SuppressLint("HandlerLeak")
@Override
protected void onCreate(Bundle savedInstanceState) {
    //这里是界面打开后 最先运行的地方
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main); //对应界面UI


    Mqtt_init();
    startReconnect();

    handler = new Handler() {
        @SuppressLint("SetTextI18n")
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            switch (msg.what){
                case 1: //开机校验更新回传
                    break;
                case 2:  // 反馈回传

                    break;
                case 3:  //MQTT 收到消息回传   UTF8Buffer msg=new UTF8Buffer(object.toString());


                    break;
                case 30:  //连接失败
                    Toast.makeText(MainActivity.this,"连接失败" ,Toast.LENGTH_SHORT).show();
                    break;
                case 31:   //连接成功
                    Toast.makeText(MainActivity.this,"连接成功" ,Toast.LENGTH_SHORT).show();
                    try {
                        client.subscribe(mqtt_sub_topic,1);
                    } catch (MqttException e) {
                        e.printStackTrace();
                    }
                    break;
                default:
                    break;
            }
        }
    };
}



private void parseJSONWithJSONObject(String JsonData) { //解析json数据
    try
    {
      
    }
    catch (Exception e)
    {
        e.printStackTrace();
    }
}


private void Mqtt_init()
{
    try {
        //host为主机名，test为clientid即连接MQTT的客户端ID，一般以客户端唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
        client = new MqttClient(host, mqtt_id,
                new MemoryPersistence());
        //MQTT的连接设置
        options = new MqttConnectOptions();
        //设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
        options.setCleanSession(false);
        //设置连接的用户名
        options.setUserName(userName);
        //设置连接的密码
        options.setPassword(passWord.toCharArray());
        // 设置超时时间 单位为秒
        options.setConnectionTimeout(30);
        // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制
        options.setKeepAliveInterval(100);
        //设置回调
        client.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable cause) {
                //连接丢失后，一般在这里面进行重连
                System.out.println("connectionLost----------");
                //startReconnect();
            }
            @Override
            public void deliveryComplete(IMqttDeliveryToken token) {
                //publish后会执行到这里
                System.out.println("deliveryComplete---------"
                        + token.isComplete());
            }
            @Override
            public void messageArrived(String topicName, MqttMessage message)
                    throws Exception {
                //subscribe后得到的消息会执行到这里面
                System.out.println("messageArrived----------");
                Message msg = new Message();
                msg.what = 3;   //收到消息标志位
                msg.obj = topicName + "---" + message.toString();
                handler.sendMessage(msg);    // hander 回传
            }
        });
    } catch (Exception e) {
        e.printStackTrace();
    }
}
private void Mqtt_connect() {
    new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                if(!(client.isConnected()) )  //如果还未连接
                {
                    client.connect(options);
                    Message msg = new Message();
                    msg.what = 31;
                    handler.sendMessage(msg);
                }
            } catch (Exception e) {
                e.printStackTrace();
                Message msg = new Message();
                msg.what = 30;
                handler.sendMessage(msg);
            }
        }
    }).start();
}
private void startReconnect() {
    scheduler = Executors.newSingleThreadScheduledExecutor();
    scheduler.scheduleAtFixedRate(new Runnable() {
        @Override
        public void run() {
            if (!client.isConnected()) {
                Mqtt_connect();
            }
        }
    }, 0 * 1000, 10 * 1000, TimeUnit.MILLISECONDS);
}
private void publishmessageplus(String topic,String message2)
{
    if (client == null || !client.isConnected()) {
        return;
    }
    MqttMessage message = new MqttMessage();
    message.setPayload(message2.getBytes());
    try {
        client.publish(topic,message);
    } catch (MqttException e) {

        e.printStackTrace();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166

}

stm32篇

同样直接改成自己阿里云的四元组，直接给工程
用的串口2与8266通信，使用串口打印信息，查看链接状态。
链接成功 串口显示

阿里云也显示上，（有时候连不上 可能是网络不好，多按复位多连几次就好了）
工程
链接：https://pan.baidu.com/s/1qvMQ0WeR0QpD9icpxYDQkw
提取码：o724