Skip to content

Commit 061cc10

Browse files
author
xiaonan
committed
添加设备
0 parents  commit 061cc10

22 files changed

+1094
-0
lines changed

‎pom.xml

+66
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,66 @@
1+
<project xmlns="http://maven.apache.org/POM/4.0.0"
2+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4+
<modelVersion>4.0.0</modelVersion>
5+
<groupId>cn.cuiot.dmp</groupId>
6+
<artifactId>mqtt-sample</artifactId>
7+
<version>1.0-SNAPSHOT</version>
8+
<name>DMP MQTT DEMO</name>
9+
<description>DMP MQTT DEMO</description>
10+
11+
<properties>
12+
<java.version>1.8</java.version>
13+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
14+
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
15+
</properties>
16+
17+
<dependencies>
18+
19+
<dependency>
20+
<groupId>org.eclipse.paho</groupId>
21+
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
22+
<version>1.2.0</version>
23+
</dependency>
24+
25+
<!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
26+
<dependency>
27+
<groupId>com.alibaba</groupId>
28+
<artifactId>fastjson</artifactId>
29+
<version>1.2.75</version>
30+
</dependency>
31+
32+
<dependency>
33+
<groupId>org.projectlombok</groupId>
34+
<artifactId>lombok</artifactId>
35+
<version>1.18.16</version>
36+
</dependency>
37+
38+
<dependency>
39+
<groupId>org.slf4j</groupId>
40+
<artifactId>slf4j-api</artifactId>
41+
<version>1.7.25</version>
42+
</dependency>
43+
44+
<dependency>
45+
<groupId>ch.qos.logback</groupId>
46+
<artifactId>logback-classic</artifactId>
47+
<version>1.2.3</version>
48+
</dependency>
49+
50+
</dependencies>
51+
52+
<build>
53+
<plugins>
54+
<plugin>
55+
<groupId>org.apache.maven.plugins</groupId>
56+
<artifactId>maven-compiler-plugin</artifactId>
57+
<version>3.8.1</version>
58+
<configuration>
59+
<source>1.8</source>
60+
<target>1.8</target>
61+
<encoding>UTF-8</encoding>
62+
</configuration>
63+
</plugin>
64+
</plugins>
65+
</build>
66+
</project>

‎src/main/java/cn/cuiot/dmp/device/bussiness/AuthAutoRegister.java

+50
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,50 @@
1+
package cn.cuiot.dmp.device.bussiness;
2+
3+
import cn.cuiot.dmp.device.util.MqttUtil;
4+
import lombok.extern.slf4j.Slf4j;
5+
import org.eclipse.paho.client.mqttv3.MqttException;
6+
7+
/**
8+
* 本接口用于一型一密设备获取token
9+
*/
10+
@Slf4j
11+
public class AuthAutoRegister {
12+
public static void main(String[] args) {
13+
//用户填写，10-48位字母数字"-"
14+
String deviceId = "12369874512369874510";
15+
//平台新建设备后生成
16+
String deviceKey = "20210609deviceKey01";
17+
//平台新建产品后生成
18+
String productSecret = "4b4a9838959b9c7db319e1467dd2a633";
19+
//平台新建产品时生成
20+
String productKey = "cu559dtdb0tuk4BC";
21+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"
22+
// String host = "dmp-mqtt.cuiot.cn:1883";
23+
String host = "tcp://dmp-mqtt.cuiot.cn:1883";
24+
//工具类
25+
MqttUtil mqttUtil = new MqttUtil();
26+
try {
27+
//初始化
28+
mqttUtil.connectClient(host, deviceId + "|" + productKey + "|0|2|1", deviceKey + "|" + productKey,
29+
mqttUtil.generatePassword(deviceId, deviceKey, productKey, productSecret));
30+
//订阅
31+
mqttUtil.sub(productKey, deviceKey);
32+
//等待一段时间
33+
Thread.sleep(10 * 1000);
34+
//断开连接
35+
mqttUtil.disconnectClient();
36+
} catch (MqttException e) {
37+
log.info("!!! Reason Code is: " + e.getReasonCode());
38+
log.info("!!! Message is: " + e.getMessage());
39+
log.info("!!! Exception is: " + e);
40+
e.printStackTrace();
41+
} catch (Exception e) {
42+
e.printStackTrace();
43+
} finally {
44+
//关闭客户端
45+
mqttUtil.closeClient();
46+
//退出代码
47+
System.exit(0);
48+
}
49+
}
50+
}

‎src/main/java/cn/cuiot/dmp/device/bussiness/AuthCommon.java

+49
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
package cn.cuiot.dmp.device.bussiness;
2+
3+
import cn.cuiot.dmp.device.util.MqttUtil;
4+
import lombok.extern.slf4j.Slf4j;
5+
import org.eclipse.paho.client.mqttv3.MqttException;
6+
7+
/**
8+
* 该接口用于mqtt设备使用一机一密方式注册上线
9+
*/
10+
@Slf4j
11+
public class AuthCommon {
12+
public static void main(String[] args) {
13+
//用户填写，10-48位字母数字"-"
14+
String deviceId = "zhiyangji01";
15+
//平台新建设备后生成
16+
String deviceKey = "SFIefovTnfRPiV6";
17+
//平台新建设备后生成
18+
String deviceSecret = "D3DE73DA544E82753C034D22B7CACAE4";
19+
//平台新建产品时生成
20+
String productKey = "cu59flm720qarrke";
21+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"
22+
String host = "tcp://dmp-mqtt.cuiot.cn:1883";
23+
//工具类
24+
MqttUtil mqttUtil = new MqttUtil();
25+
try {
26+
//初始化
27+
mqttUtil.connectClient(host, deviceId + "|" + productKey + "|0|0|1", deviceKey + "|" + productKey,
28+
mqttUtil.generatePassword(deviceId, deviceKey, productKey, deviceSecret));
29+
//订阅
30+
mqttUtil.sub(productKey, deviceKey);
31+
//等待一段时间
32+
Thread.sleep(10 * 1000);
33+
//断开连接
34+
mqttUtil.disconnectClient();
35+
} catch (MqttException e) {
36+
log.warn("!!! Reason Code is: " + e.getReasonCode());
37+
log.warn("!!! Message is: " + e.getMessage());
38+
log.warn("!!! Exception is: " + e);
39+
e.printStackTrace();
40+
} catch (Exception e) {
41+
e.printStackTrace();
42+
} finally {
43+
//关闭客户端
44+
mqttUtil.closeClient();
45+
//退出代码
46+
System.exit(0);
47+
}
48+
}
49+
}

‎src/main/java/cn/cuiot/dmp/device/bussiness/AuthCommonTest.java

+109
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,109 @@
1+
package cn.cuiot.dmp.device.bussiness;
2+
3+
import cn.cuiot.dmp.device.util.MqttUtil;
4+
import lombok.extern.slf4j.Slf4j;
5+
import org.eclipse.paho.client.mqttv3.MqttException;
6+
7+
public class AuthCommonTest {
8+
public static void main(String[] args) {
9+
// 设备1
10+
//用户填写，10-48位字母数字"-"
11+
/* String deviceId1 = "zhiyangji01";
12+
//平台新建设备后生成
13+
String deviceKey1 = "SFIefovTnfRPiV6";
14+
//平台新建设备后生成
15+
String deviceSecret1 = "D3DE73DA544E82753C034D22B7CACAE4";
16+
//平台新建产品时生成
17+
String productKey1 = "cu59flm720qarrke";
18+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"
19+
20+
// 设备2
21+
//用户填写，10-48位字母数字"-"
22+
String deviceId2 = "xuetangyi01";
23+
//平台新建设备后生成
24+
String deviceKey2 = "P8948q8ma0kPY5r";
25+
//平台新建设备后生成
26+
String deviceSecret2 = "9217E1574B1F8AC82BC45147E629217D";
27+
//平台新建产品时生成
28+
String productKey2 = "cu697dfal4iwbzND";
29+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"*/
30+
31+
// 设备3
32+
//用户填写，10-48位字母数字"-"
33+
String deviceId3 = "xueyayi01";
34+
//平台新建设备后生成
35+
String deviceKey3 = "mMKjziAOo1q3ehQ";
36+
//平台新建设备后生成
37+
String deviceSecret3 = "A7810D47B3E985ACFEE50B097FE1FD29";
38+
//平台新建产品时生成
39+
String productKey3 = "cu1gqwdbkr9mqxz3";
40+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"
41+
42+
/* // 设备4
43+
//用户填写，10-48位字母数字"-"
44+
String deviceId4 = "huxiji01";
45+
//平台新建设备后生成
46+
String deviceKey4 = "Jw7Zwy7ifUAwG9U";
47+
//平台新建设备后生成
48+
String deviceSecret4 = "947B4C03228AF433352E8EB87E3D3831";
49+
//平台新建产品时生成
50+
String productKey4 = "cu1caux4y0ynyavT";
51+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"*/
52+
53+
// 设备5
54+
//用户填写，10-48位字母数字"-"
55+
String deviceId5 = "xueyangyi01";
56+
//平台新建设备后生成
57+
String deviceKey5 = "YPBQ5eOpi5pvwTs";
58+
//平台新建设备后生成
59+
String deviceSecret5 = "7D9FBDEF9AFDF087E5836C2EB2C0FAC7";
60+
//平台新建产品时生成
61+
String productKey5 = "cu1gwpy8r7t14vbo";
62+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"
63+
64+
String host = "tcp://dmp-mqtt.cuiot.cn:1883";
65+
//工具类
66+
MqttUtil mqttUtil = new MqttUtil();
67+
try {
68+
/* //初始化
69+
mqttUtil.connectClient(host, deviceId1 + "|" + productKey1 + "|0|0|0", deviceKey1 + "|" + productKey1,
70+
mqttUtil.generatePassword(deviceId1, deviceKey1, productKey1, deviceSecret1));
71+
//订阅
72+
mqttUtil.sub(productKey1,deviceKey1);
73+
74+
//初始化
75+
mqttUtil.connectClient(host, deviceId2 + "|" + productKey2 + "|0|0|0", deviceKey2 + "|" + productKey2,
76+
mqttUtil.generatePassword(deviceId2, deviceKey2, productKey2, deviceSecret2));
77+
//订阅
78+
mqttUtil.sub(productKey2,deviceKey2);*/
79+
80+
81+
//初始化
82+
mqttUtil.connectClient(host, deviceId3 + "|" + productKey3 + "|0|0|0", deviceKey3 + "|" + productKey3,
83+
mqttUtil.generatePassword(deviceId3, deviceKey3, productKey3, deviceSecret3));
84+
//订阅
85+
mqttUtil.sub(productKey3, deviceKey3);
86+
87+
88+
/* //初始化
89+
mqttUtil.connectClient(host, deviceId4 + "|" + productKey4 + "|0|0|0", deviceKey4 + "|" + productKey4,
90+
mqttUtil.generatePassword(deviceId4, deviceKey4, productKey4, deviceSecret4));
91+
//订阅
92+
mqttUtil.sub(productKey4,deviceKey4);*/
93+
94+
95+
/* //初始化
96+
mqttUtil.connectClient(host, deviceId5 + "|" + productKey5 + "|0|0|0", deviceKey5 + "|" + productKey5,
97+
mqttUtil.generatePassword(deviceId5, deviceKey5, productKey5, deviceSecret5));
98+
//订阅
99+
mqttUtil.sub(productKey5,deviceKey5);*/
100+
101+
102+
} catch (MqttException e) {
103+
System.out.println("!!! Reason Code is: " + e.getReasonCode());
104+
System.out.println("!!! Message is: " + e.getMessage());
105+
System.out.println("!!! Exception is: " + e);
106+
e.printStackTrace();
107+
}
108+
}
109+
}

‎src/main/java/cn/cuiot/dmp/device/bussiness/AuthCommonTestSelf.java

+43
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
package cn.cuiot.dmp.device.bussiness;
2+
3+
import cn.cuiot.dmp.device.util.MqttUtil;
4+
import org.eclipse.paho.client.mqttv3.MqttException;
5+
6+
public class AuthCommonTestSelf {
7+
public static void main(String[] args) {
8+
/*//用户填写，10-48位字母数字"-"
9+
String deviceId = "zhiyangji1";
10+
//平台新建设备后生成
11+
String deviceKey = "4wf35tv4gDaomfR";
12+
//平台新建设备后生成
13+
String deviceSecret = "B867B2C9D385B685E44A40C13F509455";
14+
//平台新建产品时生成
15+
String productKey = "cu1txpab9hycjgfX";*/
16+
17+
//用户填写，10-48位字母数字"-"
18+
String deviceId = "huiyiji01";
19+
//平台新建设备后生成
20+
String deviceKey = "3Xhi8Cmd7OMQLW3";
21+
//平台新建设备后生成
22+
String deviceSecret = "91B882F3BC8C5F9819D02AD830FF54D4";
23+
//平台新建产品时生成
24+
String productKey = "cu1gge9qa8x7y6vo";
25+
26+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"
27+
String host = "tcp://dmp-mqtt.cuiot.cn:1883";
28+
//工具类
29+
MqttUtil mqttUtil = new MqttUtil();
30+
try {
31+
//初始化
32+
mqttUtil.connectClient(host, deviceId + "|" + productKey + "|0|0|0", deviceKey + "|" + productKey,
33+
mqttUtil.generatePassword(deviceId, deviceKey, productKey, deviceSecret));
34+
//订阅
35+
mqttUtil.sub(productKey, deviceKey);
36+
} catch (MqttException e) {
37+
System.out.println("!!! Reason Code is: " + e.getReasonCode());
38+
System.out.println("!!! Message is: " + e.getMessage());
39+
System.out.println("!!! Exception is: " + e);
40+
e.printStackTrace();
41+
}
42+
}
43+
}

‎src/main/java/cn/cuiot/dmp/device/bussiness/AuthPreRegister.java

+50
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,50 @@
1+
package cn.cuiot.dmp.device.bussiness;
2+
3+
import cn.cuiot.dmp.device.util.MqttUtil;
4+
import lombok.extern.slf4j.Slf4j;
5+
import org.eclipse.paho.client.mqttv3.MqttException;
6+
7+
/**
8+
* 本接口用于一型一密预注册设备获取deviceSecret
9+
*/
10+
@Slf4j
11+
public class AuthPreRegister {
12+
public static void main(String[] args) {
13+
//用户填写，10-48位字母数字"-"
14+
String deviceId = "qqwert9874563212";
15+
//平台新建设备后生成
16+
String deviceKey = "tkVHBuJq5Z5ilRA";
17+
//平台新建产品后生成
18+
String productSecret = "9124adc1d1b9559c2ed69297f8211316";
19+
//平台新建产品时生成
20+
String productKey = "cu55fttq15e2aczA";
21+
//平台服务地址 格式： "dmp-mqtt.cuiot.cn:1883"
22+
String host = "tcp://dmp-mqtt.cuiot.cn:1883";
23+
//工具类
24+
MqttUtil mqttUtil = new MqttUtil();
25+
try {
26+
//初始化
27+
mqttUtil.connectClient(host, deviceId + "|" + productKey + "|0|1|0", deviceKey + "|" + productKey,
28+
mqttUtil.generatePassword(deviceId, deviceKey, productKey, productSecret));
29+
//订阅
30+
mqttUtil.sub(productKey, deviceKey);
31+
//等待一段时间
32+
Thread.sleep(10 * 1000);
33+
//断开连接
34+
mqttUtil.disconnectClient();
35+
} catch (MqttException e) {
36+
log.info("!!! Reason Code is: " + e.getReasonCode());
37+
log.info("!!! Message is: " + e.getMessage());
38+
log.info("!!! Exception is: " + e);
39+
e.printStackTrace();
40+
;
41+
} catch (Exception e) {
42+
e.printStackTrace();
43+
} finally {
44+
//关闭客户端
45+
mqttUtil.closeClient();
46+
//退出代码
47+
System.exit(0);
48+
}
49+
}
50+
}

0 commit comments

Comments
 (0)