<!-- InfluxDB 3.x Java 客戶端 -->
<dependency>
    <groupId>com.influxdb</groupId>
    <artifactId>influxdb3-java</artifactId>
    <version>6.8.0</version> <!-- 推薦使用最新穩(wěn)定版 -->
</dependency>
<!-- Spring Boot 核心依賴（已存在可忽略） -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>

dependencies {
    implementation 'com.influxdb:influxdb3-java:6.8.0'
    implementation 'org.springframework.boot:spring-boot-starter'
}

spring:
  influxdb3:
    url: http://localhost:8086 # InfluxDB 3.x 連接地址
    token: your-influxdb3-auth-token # 認(rèn)證令牌
    bucket: your-bucket-name # 存儲(chǔ)桶名稱（對(duì)應(yīng)數(shù)據(jù)庫）
    org: your-organization-id # 組織ID
    timeout: 30000 # 連接超時(shí)時(shí)間（可選，默認(rèn)30秒）

spring.influxdb3.url=http://localhost:8086
spring.influxdb3.token=your-influxdb3-auth-token
spring.influxdb3.bucket=your-bucket-name
spring.influxdb3.org=your-organization-id
spring.influxdb3.timeout=30000

import com.influxdb.v3.client.InfluxDBClient3;
import com.influxdb.v3.client.InfluxDBClient3Factory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
 * InfluxDB 3.x 客戶端配置類
 */
@Configuration
public class InfluxDB3Config {
    @Value("${spring.influxdb3.url}")
    private String influxDbUrl;
    @Value("${spring.influxdb3.token}")
    private String influxDbToken;
    @Value("${spring.influxdb3.bucket}")
    private String influxDbBucket;
    @Value("${spring.influxdb3.org}")
    private String influxDbOrg;
    @Value("${spring.influxdb3.timeout:30000}")
    private int influxDbTimeout;
    /**
     * 創(chuàng)建 InfluxDBClient3 單例 Bean
     * @return InfluxDBClient3 客戶端實(shí)例
     */
    @Bean(destroyMethod = "close") // 容器銷毀時(shí)自動(dòng)關(guān)閉客戶端連接
    public InfluxDBClient3 influxDBClient3() {
        return InfluxDBClient3Factory.create(
                influxDbUrl,
                influxDbToken.toCharArray(),
                influxDbOrg,
                influxDbBucket
        );
    }
}

import com.influxdb.v3.client.InfluxDBClient3;
import org.springframework.stereotype.Service;
import java.time.Instant;
/**
 * InfluxDB 3.x 數(shù)據(jù)操作服務(wù)
 */
@Service
public class InfluxDB3Service {
    private final InfluxDBClient3 influxDBClient3;
    // 構(gòu)造函數(shù)注入客戶端
    public InfluxDB3Service(InfluxDBClient3 influxDBClient3) {
        this.influxDBClient3 = influxDBClient3;
    }
    /**
     * 寫入監(jiān)控?cái)?shù)據(jù)（Line Protocol 格式）
     * @param measurement 測(cè)量值名稱（表名）
     * @param deviceId 設(shè)備ID（標(biāo)簽）
     * @param temperature 溫度（字段）
     * @param humidity 濕度（字段）
     */
    public void writeMonitorData(String measurement, String deviceId, double temperature, double humidity) {
        // 構(gòu)建 Line Protocol 字符串：measurement tagKey=tagValue fieldKey=fieldValue timestamp
        String lineProtocol = String.format(
                "%s,device_id=%s temperature=%.2f,humidity=%.2f %d",
                measurement,
                deviceId,
                temperature,
                humidity,
                Instant.now().toEpochMilli() * 1_000_000 // 時(shí)間戳（納秒級(jí)）
        );
        // 寫入數(shù)據(jù)
        influxDBClient3.writeRecord(lineProtocol);
        System.out.println("數(shù)據(jù)寫入成功：" + lineProtocol);
    }
}

import com.influxdb.v3.client.QueryResult;
import com.influxdb.v3.client.exceptions.InfluxException;
import java.util.List;
import java.util.Map;
/**
 * 擴(kuò)展查詢方法
 */
public class InfluxDB3Service {
    // 省略已有代碼...
    /**
     * 查詢指定設(shè)備的最新監(jiān)控?cái)?shù)據(jù)
     * @param deviceId 設(shè)備ID
     * @return 查詢結(jié)果列表
     */
    public List<Map<String, Object>> queryLatestMonitorData(String deviceId) {
        // SQL 查詢語句（InfluxDB 3.x 兼容 SQL 語法）
        String sql = String.format(
                "SELECT * FROM monitor_data WHERE device_id = '%s' ORDER BY time DESC LIMIT 10",
                deviceId
        );
        try {
            // 執(zhí)行查詢
            QueryResult queryResult = influxDBClient3.query(sql);
            // 轉(zhuǎn)換為 Map 列表（便于后續(xù)處理）
            return queryResult.getRecords();
        } catch (InfluxException e) {
            System.err.println("查詢失?。? + e.getMessage());
            throw new RuntimeException("InfluxDB 查詢異常", e);
        }
    }
}

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("/influxdb3")
public class InfluxDB3Controller {
    private final InfluxDB3Service influxDB3Service;
    public InfluxDB3Controller(InfluxDB3Service influxDB3Service) {
        this.influxDB3Service = influxDB3Service;
    }
    /**
     * 寫入數(shù)據(jù)接口
     */
    @PostMapping("/write")
    public String writeData(
            @RequestParam String deviceId,
            @RequestParam double temperature,
            @RequestParam double humidity
    ) {
        influxDB3Service.writeMonitorData("monitor_data", deviceId, temperature, humidity);
        return "數(shù)據(jù)寫入成功";
    }
    /**
     * 查詢數(shù)據(jù)接口
     */
    @GetMapping("/query")
    public List<Map<String, Object>> queryData(@RequestParam String deviceId) {
        return influxDB3Service.queryLatestMonitorData(deviceId);
    }
}