将Apache Camel与InfluxDB 2.x集成：构建自定义组件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <!-- 建议替换为自己的父POM，此处为示例 -->
    <parent>
        <groupId>org.apache.camel</groupId>
        <artifactId>components</artifactId>
        <version>3.19.0</version> <!-- 根据你使用的Camel版本调整 -->
    </parent>

    <groupId>my.custom.components</groupId>
    <artifactId>camel-influxdb2x</artifactId>
    <version>3.19.0</version>
    <packaging>jar</packaging>
    <name>Camel :: InfluxDB 2.x Client Component</name>
    <description>A custom Camel component for InfluxDB 2.x</description>
    <url>https://example.com/camel-influxdb2x</url>

    <properties>
        <version.influx-java-driver>2.7.0</version.influx-java-driver> <!-- InfluxDB 2.x Java客户端版本 -->
        <camel.version>3.19.0</camel.version> <!-- 保持与父POM一致或自行管理 -->
        <junit.jupiter.version>5.9.1</junit.jupiter.version>
        <mockito.version>4.8.0</mockito.version>
        <log4j.version>2.19.0</log4j.version>
    </properties>

    <dependencies>
        <!-- Apache Camel 支持库 -->
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-support</artifactId>
            <version>${camel.version}</version>
        </dependency>

        <!-- InfluxDB 2.x Java 客户端驱动 -->
        <dependency>
            <groupId>com.influxdb</groupId>
            <artifactId>influxdb-client-java</artifactId>
            <version>${version.influx-java-driver}</version>
            <exclusions>
                <!-- 排除可能引起冲突或不必要的依赖 -->
                <exclusion>
                    <groupId>com.squareup.okhttp3</groupId>
                    <artifactId>logging-interceptor</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <!-- 测试依赖 -->
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-test-junit5</artifactId>
            <version>${camel.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.mockito</groupId>
            <artifactId>mockito-core</artifactId>
            <version>${mockito.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-slf4j-impl</artifactId>
            <version>${log4j.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter-api</artifactId>
            <version>${junit.jupiter.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter-engine</artifactId>
            <version>${junit.jupiter.version}</version>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

// my.custom.components.influxdb2x.Influx2DbComponent.java
package my.custom.components.influxdb2x;

import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.support.DefaultComponent;

import java.util.Map;

@org.apache.camel.spi.Metadata(label = "database,iot,influxdb",
                                description = "Component for InfluxDB 2.x database",
                                producerOnly = true)
public class Influx2DbComponent extends DefaultComponent {

    private InfluxDBClient influxDBClient;
    private String url;
    private String token;
    private String org; // InfluxDB 2.x specific

    public Influx2DbComponent() {
    }

    public Influx2DbComponent(CamelContext context) {
        super(context);
    }

    @Override
    protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
        Influx2DbEndpoint endpoint = new Influx2DbEndpoint(uri, this);
        endpoint.setBucket(remaining); // remaining might be the bucket name
        setProperties(endpoint, parameters);
        return endpoint;
    }

    @Override
    protected void doStart() throws Exception {
        super.doStart();
        if (influxDBClient == null) {
            // Initialize InfluxDB 2.x client
            if (url == null || token == null || org == null) {
                throw new IllegalArgumentException("InfluxDB 2.x URL, Token, and Org must be configured.");
            }
            this.influxDBClient = InfluxDBClientFactory.create(url, token.toCharArray(), org);
        }
    }

    @Override
    protected void doStop() throws Exception {
        if (influxDBClient != null) {
            influxDBClient.close();
        }
        super.doStop();
    }

    // Getters and Setters for url, token, org, influxDBClient
    public InfluxDBClient getInfluxDBClient() {
        return influxDBClient;
    }

    public void setInfluxDBClient(InfluxDBClient influxDBClient) {
        this.influxDBClient = influxDBClient;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public String getToken() {
        return token;
    }

    public void setToken(String token) {
        this.token = token;
    }

    public String getOrg() {
        return org;
    }

    public void setOrg(String org) {
        this.org = org;
    }
}