云数据库 GeminiDB-通过Java语言连接GeminiDB Influx实例:使用连接池方式连接实例的Java代码示例

时间：2025-02-12 15:04:14

云数据库 GeminiDB

使用连接池方式连接实例的Java代码示例

package influxdb;import okhttp3.ConnectionPool;import okhttp3.OkHttpClient;import org.influxdb.InfluxDB;import org.influxdb.InfluxDBFactory;import org.influxdb.dto.Point;import org.influxdb.dto.Query;import org.influxdb.dto.QueryResult;import java.util.concurrent.TimeUnit;public class demoConnectionPool {    public static void main(String[] args) {        // 客户端连接池功能基于OkHttpClient实现        OkHttpClient.Builder client = new OkHttpClient().newBuilder();        client.connectTimeout(10, TimeUnit.SECONDS);        client.readTimeout(10, TimeUnit.SECONDS);        client.writeTimeout(10, TimeUnit.SECONDS);        // 建议设为true，屏蔽部分连接错误，并自动进行重试        client.retryOnConnectionFailure(true);        // maxIdleConnections指连接池最多维护的未使用的Idle连接数量，默认值是5        // 超过阈值的idle连接会由连接池关闭，关闭后sockets进入TIME_WAIT状态等待系统回收，该参数需根据实际连接数适当调整        client.connectionPool(new ConnectionPool(5, 30, TimeUnit.SECONDS));        // 认证用的用户名和密码直接写到代码中有很大的安全风险，建议在配置文件或者环境变量中存放(密码应密文存放、使用时解密)，确保安全；        // 本示例以用户名和密码保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量(环境变量名称请根据自身情况进行设置)EXAMPLE_USERNAME_ENV和EXAMPLE_PASSWORD_ENV。        String username = System.getenv("EXAMPLE_USERNAME_ENV");        String password = System.getenv("EXAMPLE_PASSWORD_ENV");        final String serverURL = "http://127.0.0.1:8086", username = username, password = password;        InfluxDB influxdb = InfluxDBFactory.connect(serverURL, username, password, client);        // Create a database...        String databaseName = "foo";        influxdb.query(new Query("CREATE DATABASE " + databaseName, databaseName));        influxdb.setDatabase(databaseName);        // Write points to influxdb.        influxdb.write(Point.measurement("bar")                .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)                .tag("location", "chengdu")                .addField("temperature", 22)                .build());        // Query your data using InfluxQL.        QueryResult queryResult = influxdb.query(new Query("SELECT * FROM bar", databaseName));        // Close it if your application is terminating or you are not using it anymore.        influxdb.close();    }}

上一篇：云数据库 GeminiDB-通过Java语言连接GeminiDB Influx实例:使用非SSL方式连接实例的Java代码示例

下一篇：云数据库 GeminiDB-通过Java语言连接GeminiDB Influx实例:使用非SSL方式连接实例的Java代码示例