influxdb-java-2.14的query报连接重置

Question

服务器连接influxDB报 Connection reset 但是curl是可以返回数据的

报错信息：org.influxdb.InfluxDBIOException: java.net.SocketException: Connection reset

这个如何解决啊？

Answer 1

引自微信小程序：皆我百晓生：

首先，"Connection reset" 错误通常意味着服务器端在处理请求时意外中断了连接。这可能是由于网络问题、防火墙配置或服务器端出现故障引起的。

要解决这个问题，你可以尝试以下解决方案：

1. 确定你使用的 InfluxDB 版本和 InfluxDB-Java 版本相匹配。确保你正在使用最新的稳定版本。

2. 检查服务器网络连接是否正常。你可以尝试在同一网络环境中使用 curl 命令进行查询，确认服务器是否能正确响应。

3. 检查服务器的防火墙配置。确保端口号（默认为 8086）没有被阻止，并且可以从客户端访问该端口。

4. 配置 InfluxDB 连接时使用适当的超时设置。你可以通过设置 InfluxDB.setConnectTimeout() 和 InfluxDB.setReadTimeout() 来增加连接和读取超时时间。

下面是一个使用 InfluxDB-Java 进行查询时设置连接超时的示例：

import org.influxdb.InfluxDB;
import org.influxdb.InfluxDBFactory;
import org.influxdb.dto.Query;
import org.influxdb.dto.QueryResult;

public class InfluxDBExample {
    public static void main(String[] args) {
        String username = "your_username";
        String password = "your_password";
        String database = "your_database";
        String retentionPolicy = "your_retention_policy";
        String queryStr = "SELECT * FROM your_measurement";

        // 创建 InfluxDB 实例
        InfluxDB influxDB = InfluxDBFactory.connect("http://your_influxdb_host:8086", username, password);

        // 设置连接和读取超时时间（单位：毫秒）
        influxDB.setConnectTimeout(5000);
        influxDB.setReadTimeout(5000);

        // 查询数据
        Query query = new Query(queryStr, database);
        QueryResult queryResult = influxDB.query(query);

        // 处理查询结果
        // ...

        // 关闭 InfluxDB 连接
        influxDB.close();
    }
}

请根据你的实际情况替换示例代码中的用户名、密码、数据库、保留策略、测量值和 InfluxDB 主机信息。

如果以上解决方案都没有解决问题，你可能需要进一步检查服务器端的日志文件以查找更多关于连接中断的信息。