group-four
/
project-car
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Activity

数据处理模块新增

master
刘武 2024-09-28 11:48:28 +08:00
parent 6e70e3f721
commit 35fd16ad12
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java
View File

@ -7,7 +7,7 @@ public class ReceiveTwo {
public static void main(String[] args) {
String topic = "vehicle";
String broker = "tcp://47.101.53.251:1883";
String clientId="lxy";
String clientId="lw";
try {
MqttClient mqttClient= new MqttClient(broker,clientId);
@ -15,12 +15,9 @@ public class ReceiveTwo {
connectOptions.setCleanSession(true);
System.out.println("Connecting to broker：" + broker);
mqttClient.connect(connectOptions);
System.out.println("已连接");
mqttClient.setCallback(new MqttCallback(){
@Override
public void connectionLost(Throwable throwable) {
System.out.println("Connect lost!");