<!-- 引入influxdb依賴  --> <dependency>  <groupId>org.influxdb</groupId>  <artifactId>influxdb-java</artifactId>  <version>2.5</version> </dependency>

package com.hontye.parameter.util; import org.influxdb.InfluxDB;import org.influxdb.InfluxDBFactory;import org.influxdb.dto.Point;import org.influxdb.dto.Point.Builder;import org.influxdb.dto.Query;import org.influxdb.dto.QueryResult;import java.util.Map; /** * 時序數據庫 InfluxDB 連接 * @author Dai_LW * */public class InfluxDbUtil {   private static String openurl = "http://127.0.0.1:8086";//連接地址  private static String username = "root";//用戶名  private static String password = "root";//密碼  private static String database = "PARAMTER_DB";//數據庫  private static String measurement = "tw_parameter_tb";//表名   private InfluxDB influxDB;    public InfluxDbUtil(String username, String password, String openurl, String database){    this.username = username;    this.password = password;    this.openurl = openurl;    this.database = database;  }   public static InfluxDbUtil setUp(){    //創建 連接    InfluxDbUtil influxDbUtil = new InfluxDbUtil(username, password, openurl, database);     influxDbUtil.influxDbBuild();     influxDbUtil.createRetentionPolicy(); //   influxDB.deleteDB(database);//   influxDB.createDB(database);    return influxDbUtil;  }   /**連接時序數據庫；獲得InfluxDB**/  public InfluxDB influxDbBuild(){    if(influxDB == null){      influxDB = InfluxDBFactory.connect(openurl, username, password);      influxDB.createDatabase(database);    }    return influxDB;  }   /**   * 設置數據保存策略   * defalut 策略名 /database 數據庫名/ 30d 數據保存時限30天/ 1 副本個數為1/ 結尾DEFAULT 表示 設為默認的策略   */  public void createRetentionPolicy(){    String command = String.format("CREATE RETENTION POLICY /"%s/" ON /"%s/" DURATION %s REPLICATION %s DEFAULT",        "defalut", database, "30d", 1);    this.query(command);  }   /**   * 查詢   * @param command 查詢語句   * @return   */  public QueryResult query(String command){    return influxDB.query(new Query(command, database));  }   /**   * 插入   * @param tags 標簽   * @param fields 字段   */  public void insert(Map<String, String> tags, Map<String, Object> fields){    Builder builder = Point.measurement(measurement);    builder.tag(tags);    builder.fields(fields);     influxDB.write(database, "", builder.build());  }   /**   * 刪除   * @param command 刪除語句   * @return 返回錯誤信息   */  public String deleteMeasurementData(String command){    QueryResult result = influxDB.query(new Query(command, database));    return result.getError();  }   /**   * 創建數據庫   * @param dbName   */  public void createDB(String dbName){    influxDB.createDatabase(dbName);  }   /**   * 刪除數據庫   * @param dbName   */  public void deleteDB(String dbName){    influxDB.deleteDatabase(dbName);  }   public String getUsername() {    return username;  }   public void setUsername(String username) {    this.username = username;  }   public String getPassword() {    return password;  }   public void setPassword(String password) {    this.password = password;  }   public String getOpenurl() {    return openurl;  }   public void setOpenurl(String openurl) {    this.openurl = openurl;  }   public void setDatabase(String database) {    this.database = database;  }}

public class QuatyServiceImpl{private InfluxDbUtil influxDB; public void intoDb() {  influxDB = InfluxDbUtil.setUp();  Map<String, String> tags = new HashMap<>();  Map<String, Object> fields = new HashMap<>();  tags.put("TAG_NAME",info.getKey());  fields.put("TAG_VALUE",code);  fields.put("TIMAMPEST", df.format(new Date()));  influxDB.insert(tags, fields);  }}