Skip to content

T
TDengine

qq_50753323 / TDengine
与 Fork 源项目一致

Fork自 taosdata / TDengine

通知 1
Star 0
Fork 0
T
TDengine

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 cef379d9 编写于 作者: B Bomin Zhang
浏览文件
操作

update java document for subscription

上级 321aa289
隐藏空白更改
内联 并排
Showing with 39 addition and 50 deletion
documentation20/webdocs/markdowndocs/advanced features-ch.md
浏览文件 @ cef379d9
...@@ -295,27 +295,30 @@ $ taos ...@@ -295,27 +295,30 @@ $ taos
这时，因为电流超过了10A，您应该可以看到示例程序将它输出到了屏幕上。 这时，因为电流超过了10A，您应该可以看到示例程序将它输出到了屏幕上。
您可以继续插入一些数据观察示例程序的输出。 您可以继续插入一些数据观察示例程序的输出。
### jdbc使用数据订阅功能 ### Java 使用数据订阅功能
（1）使用订阅功能前的数据准备 订阅功能也提供了 Java 开发接口，相关说明请见 [Java Connector](https://www.taosdata.com/cn/documentation20/connector/)。需要注意的是，目前 Java 接口没有提供异步订阅模式，但用户程序可以通过创建 `TimerTask` 等方式达到同样的效果。
```shell 下面以一个示例程序介绍其具体使用方法。它所完成的功能与前面介绍的 C 语言示例基本相同，也是订阅数据库中所有电流超过 10A 的记录。
# 创建power库
#### 准备数据
```sql
# 创建 power 库
taos> create database power; taos> create database power;
# 切换库 # 切换库
taos> use power; taos> use power;
# 创建超级表 # 创建超级表
taos> create table meters(ts timestamp, current float, voltage int, phase int) tags(location binary(64), groupI taos> create table meters(ts timestamp, current float, voltage int, phase int) tags(location binary(64), groupId int);
d int);
# 创建表 # 创建表
taos> create table d1001 using meters tags ("Beijing.Chaoyang",2); taos> create table d1001 using meters tags ("Beijing.Chaoyang", 2);
taos> create table d1002 using meters tags ("Beijing.Haidian",2); taos> create table d1002 using meters tags ("Beijing.Haidian", 2);
# 插入测试数据 # 插入测试数据
taos> insert into d1001 values("2020-08-15 12:00:00.000", 12, 220, 1),("2020-08-15 12:10:00.000", 12.3, 220, 2),("2020-08-15 12:20:00.000", 12.2, 220, 1); taos> insert into d1001 values("2020-08-15 12:00:00.000", 12, 220, 1),("2020-08-15 12:10:00.000", 12.3, 220, 2),("2020-08-15 12:20:00.000", 12.2, 220, 1);
taos> insert into d1002 values("2020-08-15 12:00:00.000", 9.9, 220, 1),("2020-08-15 12:10:00.000", 10.3, 220, 1),("2020-08-15 12:20:00.000", 11.2, 220, 1); taos> insert into d1002 values("2020-08-15 12:00:00.000", 9.9, 220, 1),("2020-08-15 12:10:00.000", 10.3, 220, 1),("2020-08-15 12:20:00.000", 11.2, 220, 1);
# 从超级表meters查询current大于10的数据 # 从超级表 meters 查询电流大于 10A 的记录
taos> select * from meters where current > 10; taos> select * from meters where current > 10;
ts | current | voltage | phase| location | groupid | ts | current | voltage | phase | location | groupid |
=========================================================================================================== ===========================================================================================================
2020-08-15 12:10:00.000 | 10.30000 | 220 | 1 | Beijing.Haidian | 2 | 2020-08-15 12:10:00.000 | 10.30000 | 220 | 1 | Beijing.Haidian | 2 |
2020-08-15 12:20:00.000 | 11.20000 | 220 | 1 | Beijing.Haidian | 2 | 2020-08-15 12:20:00.000 | 11.20000 | 220 | 1 | Beijing.Haidian | 2 |
...@@ -325,7 +328,7 @@ taos> select * from meters where current > 10; ...@@ -325,7 +328,7 @@ taos> select * from meters where current > 10;
Query OK, 5 row(s) in set (0.004896s) Query OK, 5 row(s) in set (0.004896s)
``` ```
（2）使用jdbc提供的订阅功能 #### 示例程序
```java ```java
public class SubscribeDemo { public class SubscribeDemo {
...@@ -337,42 +340,36 @@ public class SubscribeDemo { ...@@ -337,42 +340,36 @@ public class SubscribeDemo {
TSDBSubscribe subscribe = null; TSDBSubscribe subscribe = null;
try { try {
// 加载驱动
Class.forName("com.taosdata.jdbc.TSDBDriver"); Class.forName("com.taosdata.jdbc.TSDBDriver");
// 获取Connectin
Properties properties = new Properties(); Properties properties = new Properties();
properties.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8"); properties.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
properties.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8"); properties.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
String jdbcUrl = "jdbc:TAOS://127.0.0.1:6030/power?user=root&password=taosdata"; String jdbcUrl = "jdbc:TAOS://127.0.0.1:6030/power?user=root&password=taosdata";
connection = DriverManager.getConnection(jdbcUrl, properties); connection = DriverManager.getConnection(jdbcUrl, properties);
// 创建Subscribe，topic为主题名称，sql为查询语句，restar为true代表每次订阅消费历史数据 subscribe = ((TSDBConnection) connection).subscribe(topic, sql, true); // 创建订阅
subscribe = ((TSDBConnection) connection).subscribe(topic, sql, true);
int count = 0; int count = 0;
while (true) { while (count < 10) {
// 消费数据 TimeUnit.SECONDS.sleep(1); // 等待1秒，避免频繁调用 consume，给服务端造成压力
TSDBResultSet resultSet = subscribe.consume(); TSDBResultSet resultSet = subscribe.consume(); // 消费数据
// 打印结果集 if (resultSet == null) {
if (resultSet != null) { continue;
ResultSetMetaData metaData = resultSet.getMetaData(); }
while (resultSet.next()) { ResultSetMetaData metaData = resultSet.getMetaData();
int columnCount = metaData.getColumnCount(); while (resultSet.next()) {
for (int i = 1; i <= columnCount; i++) { int columnCount = metaData.getColumnCount();
System.out.print(metaData.getColumnLabel(i) + " : " + resultSet.getString(i) + "\t"); for (int i = 1; i <= columnCount; i++) {
} System.out.print(metaData.getColumnLabel(i) + ": " + resultSet.getString(i) + "\t");
System.out.println("\n====================");
count++;
} }
System.out.println();
count++;
} }
if (count > 10)
break;
TimeUnit.SECONDS.sleep(1);
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} finally { } finally {
try { try {
if (null != subscribe) if (null != subscribe)
subscribe.close(true); subscribe.close(true); // 关闭订阅
if (connection != null) if (connection != null)
connection.close(); connection.close();
} catch (SQLException throwables) { } catch (SQLException throwables) {
...@@ -383,38 +380,30 @@ public class SubscribeDemo { ...@@ -383,38 +380,30 @@ public class SubscribeDemo {
} }
``` ```
（3）订阅功能演示 运行示例程序，首先，它会消费符合查询条件的所有历史数据：
运行demo，首先，subscribe会将满足情况的历史数据消费
```shell ```shell
# java -jar subscribe.jar # java -jar subscribe.jar
ts : 1597464000000 current : 12.0 voltage : 220 phase : 1 location : Beijing.Chaoyang groupid : 2 ts: 1597464000000 current: 12.0 voltage: 220 phase: 1 location: Beijing.Chaoyang groupid : 2
==================== ts: 1597464600000 current: 12.3 voltage: 220 phase: 2 location: Beijing.Chaoyang groupid : 2
ts : 1597464600000 current : 12.3 voltage : 220 phase : 2 location : Beijing.Chaoyang groupid : 2 ts: 1597465200000 current: 12.2 voltage: 220 phase: 1 location: Beijing.Chaoyang groupid : 2
==================== ts: 1597464600000 current: 10.3 voltage: 220 phase: 1 location: Beijing.Haidian groupid : 2
ts : 1597465200000 current : 12.2 voltage : 220 phase : 1 location : Beijing.Chaoyang groupid : 2 ts: 1597465200000 current: 11.2 voltage: 220 phase: 1 location: Beijing.Haidian groupid : 2
====================
ts : 1597464600000 current : 10.3 voltage : 220 phase : 1 location : Beijing.Haidian groupid : 2
====================
ts : 1597465200000 current : 11.2 voltage : 220 phase : 1 location : Beijing.Haidian groupid : 2
====================
``` ```
接着，使用taos客户端向表中新增数据 接着，使用 taos 客户端向表中新增一条数据：
```shell ```sql
# taos # taos
taos> use power； taos> use power；
taos> insert into d1001 values("2020-08-15 12:40:00.000", 12.4, 220, 1); taos> insert into d1001 values("2020-08-15 12:40:00.000", 12.4, 220, 1);
``` ```
查看数据消费情况 因为这条数据的电流大于10A，示例程序会将其消费：
```shell ```shell
ts : 1597466400000 current : 12.4 voltage : 220 phase : 1 location : Beijing.Chaoyang groupid : 2 ts: 1597466400000 current: 12.4 voltage: 220 phase: 1 location: Beijing.Chaoyang groupid: 2
====================
``` ```
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或