From 35fd16ad1274b38f3c8108ceb70ceea2b6f83bcf Mon Sep 17 00:00:00 2001 From: Liu Wu <2780205363@qq.com> Date: Sat, 28 Sep 2024 11:48:28 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=A4=84=E7=90=86=E6=A8=A1?= =?UTF-8?q?=E5=9D=97=E6=96=B0=E5=A2=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/muyu/data/util/ReceiveTwo.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java index d7d89bf..6895c7c 100644 --- a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java +++ b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java @@ -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!");