【TDengine 使用环境】
【TDengine 版本】
【操作系统以及版本】
【部署方式】容器/非容器部署
【集群节点数】
【集群副本数】
【描述业务影响】
【问题复现路径/shan】做过哪些操作出现的问题
【遇到的问题：问题现象及影响】
使用websocket连接方式的场合：测试程序运行不久就会报连接失败的错误，之后即使停止测试程序，数据库也无法再次连接（停止测试程序很长时间后），必须重启才能恢复使用。
使用rest连接方式的场合：测试程序可以长时间运行，资源占用率也很低，大概cpu:50%, mem:800MB左右.
测试代码如下：
package avicit.tsd.test;
import cn.hutool.core.date.DateUtil;
import com.taosdata.jdbc.TSDBDriver;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.time.LocalDateTime;
import java.util.Properties;
public class WsTest {
public static void main(String[] args) throws Exception {
Properties properties = new Properties();
properties.setProperty(TSDBDriver.PROPERTY_KEY_ASYNC_WRITE, "stmt");
properties.setProperty(TSDBDriver.PROPERTY_KEY_BATCH_SIZE_BY_ROW, "10000");
properties.setProperty(TSDBDriver.PROPERTY_KEY_CACHE_SIZE_BY_ROW, "100000");
properties.setProperty(TSDBDriver.PROPERTY_KEY_BACKEND_WRITE_THREAD_NUM, "5");
properties.setProperty(TSDBDriver.PROPERTY_KEY_ENABLE_AUTO_RECONNECT, "true");
properties.setProperty(TSDBDriver.PROPERTY_KEY_MESSAGE_WAIT_TIMEOUT, "5000");
properties.setProperty(TSDBDriver.PROPERTY_KEY_COPY_DATA, "false");
properties.setProperty(TSDBDriver.PROPERTY_KEY_STRICT_CHECK, "false");
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:TAOS-WS://10.216.36.62:6041/iot_platform?characterEncoding=UTF-8&useUnicode=true&useSSL=false&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghai&useInformationSchema=true");
config.setUsername("root");
config.setPassword("taosdata");
config.setMinimumIdle(10);
config.setMaximumPoolSize(20);
config.setConnectionTimeout(30000);
config.setMaxLifetime(0);
config.setIdleTimeout(0);
config.setConnectionTestQuery("SELECT 1");
config.setDataSourceProperties(properties);
HikariDataSource dataSource = new HikariDataSource(config);
for (int i = 0 ; i < 30 ; i++) {
new Thread(() -> {
write(dataSource);
}).start();
}
}
private static void write(DataSource dataSource) {
for (;;) {
try (Connection connection = dataSource.getConnection()) {
String sql = "INSERT INTO iot_platform.? using iot_platform.equipment TAGS ('test') VALUES (now(),?,?,?)";
try (PreparedStatement pstmt = connection.prepareStatement(sql)) {
for (int i = 0; i < 100; i++) {
pstmt.setString(1, "test_" + i);
pstmt.setString(2, "test_" + i);
pstmt.setString(3, String.valueOf(i));
pstmt.setString(4, DateUtil.format(LocalDateTime.now(), "yyyy-MM-dd HH:mm:ss.SSS"));
pstmt.addBatch();
}
pstmt.executeBatch();
Thread.sleep(500);
}
} catch (Exception e) {
System.out.printf("Failed to insert to table meters using efficient writing, %sErrMessage: %s%n",
e instanceof SQLException ? "ErrCode: " + ((SQLException) e).getErrorCode() + ", " : "",
e.getMessage());
e.printStackTrace();
}
}
}
}
【资源配置】
【报错完整截图】
数据库报错信息
是否用了多副本？需要查看taosdlog日志中的ERROR信息进一步判断
单节点部署，没启用多副本，taosd日志如下：09/03 17:49:47.217019 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:49:47.218022 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:49:53.113935 00000102 C UTL INFO report client cont with QID:0x1000000062d610009/03 17:50:17.234499 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:50:17.235806 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:50:23.113917 00000102 C UTL INFO report client cont with QID:0x1000000062d950009/03 17:50:47.251655 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:50:47.251697 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:50:53.114061 00000102 C UTL INFO report client cont with QID:0x1000000062dc90009/03 17:51:17.265378 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:51:17.266066 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there09/03 17:51:23.113878 00000102 C UTL INFO report client cont with QID:0x1000000062dfd0009/03 17:51:23.115251 00000404 C RPC WARN http-report failed to acquire recv buf since Ref is not there
我现在的遇到问题就是，使用ws连接器的时候，只要调用PreparedStatement.executeBatch()或者方法PreparedStatement.execute()一次，数据库就会变得无法使用，拒绝连接，只有重启才能继续使用。使用Statement就可以正常插入数据。假如是我的代码写的有问题，但是只调用一次PreparedStatement.execute()方法也不应该使得数据库无法使用呀。
tdentine版本：3.3.7.0
jdbc版本：taos-jdbcdriver:3.7.2(taos-jdbcdriver:3.7.0也一样)
错误日志如下：
09/03 18:18:32.486224 00000321 DB ERROR QID:0x4000000000000063 latency:3.684571093s, sql:insert into km_iot_tsdb_6043 using keeper_monitor tags (‘iot-tsdb:6043’) values ( now, 0.016667, 0.100702, 0), err:Post “http://127.0.0.1:6041/rest/sql/log?req_id=4697554515144998993”: read tcp 127.0.0.1:36528->127.0.0.1:6041: read: connection reset by peerhttp://127.0.0.1:6041/rest/sql/log?req_id=4697554515144998993”: read tcp 127.0.0.1:36528->127.0.0.1:6041: read: connection reset by peerhttp://127.0.0.1:6041/rest/sql/log?req_id=4697554515205816402”: dial tcp 127.0.0.1:6041: connect: connection refusedhttp://127.0.0.1:6041/rest/sql/log?req_id=4697554515205816402”: dial tcp 127.0.0.1:6041: connect: connection refusedhttp://127.0.0.1:6041/rest/sql/log?req_id=4697554515246710867”: dial tcp 127.0.0.1:6041: connect: connection refusedhttp://127.0.0.1:6041/rest/sql/log?req_id=4697554515246710867”: dial tcp 127.0.0.1:6041: connect: connection refused
system
2026 年1 月 10 日 01:49
8
此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。
