From 7f00c32dc75f3e3f959806e78692176dbf0bedbd Mon Sep 17 00:00:00 2001
From: Liu Wu <2780205363@qq.com>
Date: Sat, 28 Sep 2024 12:28:18 +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
---
cloud-modules/cloud-data/pom.xml | 11 +++-
.../main/java/com/muyu/data/util/Iotdb.java | 29 ++++++++
.../main/java/com/muyu/data/util/Receive.java | 66 +++++++++++--------
.../java/com/muyu/data/util/ReceiveTwo.java | 53 ---------------
cloud-modules/pom.xml | 3 +-
5 files changed, 79 insertions(+), 83 deletions(-)
create mode 100644 cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Iotdb.java
delete mode 100644 cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java
diff --git a/cloud-modules/cloud-data/pom.xml b/cloud-modules/cloud-data/pom.xml
index 83b9abc..0cbaa8f 100644
--- a/cloud-modules/cloud-data/pom.xml
+++ b/cloud-modules/cloud-data/pom.xml
@@ -105,7 +105,16 @@
-
+
+ org.apache.iotdb
+ iotdb-session
+ 1.3.2
+
+
+ org.apache.iotdb
+ node-commons
+ 1.3.2
+
diff --git a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Iotdb.java b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Iotdb.java
new file mode 100644
index 0000000..4048e76
--- /dev/null
+++ b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Iotdb.java
@@ -0,0 +1,29 @@
+package com.muyu.data.util;
+
+import org.apache.iotdb.isession.util.Version;
+import org.apache.iotdb.rpc.IoTDBConnectionException;
+import org.apache.iotdb.session.Session;
+
+public class Iotdb {
+ public static void main(String[] args) throws IoTDBConnectionException {
+
+ System.out.println("测试数据库开始~~~~~");
+
+ // 初始化与连接
+ Session session = new Session.Builder()
+ .host("47.101.53.251")
+ .port(6667)
+ .username("root")
+ .password("root")
+ .version(Version.V_1_0)
+ .build();
+
+ // 开启session Rpc不压缩
+ session.open(false);
+
+ //
+
+
+ }
+
+}
diff --git a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Receive.java b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Receive.java
index 69e01cf..f7cec3d 100644
--- a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Receive.java
+++ b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/Receive.java
@@ -1,43 +1,53 @@
package com.muyu.data.util;
-
-import org.eclipse.paho.client.mqttv3.MqttClient;
-import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
-import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+import org.eclipse.paho.client.mqttv3.*;
public class Receive {
- public static MqttClient mqttClient= null;
- private static MemoryPersistence memoryPersistence=null;
- private static MqttConnectOptions mqttConnectOptions=null;
-
- private static String ClientName="";
-
- private static String IP="";
-
public static void main(String[] args) {
+ String topic = "vehicle";
+ String broker = "tcp://47.101.53.251:1883";
+ String clientId="lw";
- }
+ try {
+ MqttClient mqttClient= new MqttClient(broker,clientId);
+ MqttConnectOptions connectOptions=new MqttConnectOptions();
+ connectOptions.setCleanSession(true);
+ System.out.println("Connecting to broker：" + broker);
+ mqttClient.connect(connectOptions);
+ System.out.println("已连接");
+ mqttClient.setCallback(new MqttCallback(){
- public static void start(String clientId){
- //初始化连接设置对象
- mqttConnectOptions = new MqttConnectOptions();
- //设置是否情
+ @Override
+ public void connectionLost(Throwable throwable) {
+ System.out.println("Connect lost!");
+ }
+
+ @Override
+ public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
+ System.out.println("Message arrived. topic:"+topic);
+ }
+
+ @Override
+ public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
+
+ }
+ });
+
+ mqttClient.subscribe(topic);
+ System.out.println("Subscribed to topic " + topic);
+ } catch (MqttException e) {
+ System.out.println("reason "+e.getReasonCode());
+ System.out.println("msg " +e.getMessage());
+ System.out.println("loc " +e.getLocalizedMessage());
+ System.out.println("cause "+e.getCause());
+ System.out.println("excep "+e);
+ e.printStackTrace();
+ }
}
-
-
-
-
-
-
-
-
-
-
-
}
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
deleted file mode 100644
index 6895c7c..0000000
--- a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java
+++ /dev/null
@@ -1,53 +0,0 @@
-package com.muyu.data.util;
-
-import org.eclipse.paho.client.mqttv3.*;
-
-public class ReceiveTwo {
-
- public static void main(String[] args) {
- String topic = "vehicle";
- String broker = "tcp://47.101.53.251:1883";
- String clientId="lw";
-
- try {
- MqttClient mqttClient= new MqttClient(broker,clientId);
- MqttConnectOptions connectOptions=new MqttConnectOptions();
- 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!");
- }
-
- @Override
- public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
- System.out.println("Message arrived. topic:"+topic);
- }
-
- @Override
- public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
-
- }
- });
-
- mqttClient.subscribe(topic);
- System.out.println("Subscribed to topic " + topic);
- } catch (MqttException e) {
- System.out.println("reason "+e.getReasonCode());
- System.out.println("msg " +e.getMessage());
- System.out.println("loc " +e.getLocalizedMessage());
- System.out.println("cause "+e.getCause());
- System.out.println("excep "+e);
- e.printStackTrace();
- }
-
-
- }
-
-
-
-}
diff --git a/cloud-modules/pom.xml b/cloud-modules/pom.xml
index d0e5426..2f9b690 100644
--- a/cloud-modules/pom.xml
+++ b/cloud-modules/pom.xml
@@ -18,7 +18,8 @@
cloud-modules-wechat
cloud-modules-breakdown
cloud-modules-warn
- cloud-data
+ cloud-data
+
cloud-modules