如何在 Apache Camel 中正确绑定并使用自定义 DataSource-java教程-PHP中文网

如何在 Apache Camel 中正确绑定并使用自定义 DataSource

本文详解在 Camel 3.20.5 独立 Java 应用中，通过 SimpleRegistry 或路由构造器方式将 DataSource 注入 SQL 组件的完整实践，避免 “camel data source not available” 错误。

本文详解在 camel 3.20.5 独立 java 应用中，通过 `simpleregistry` 或路由构造器方式将 `datasource` 注入 sql 组件的完整实践，避免 “camel data source not available” 错误。

在 Apache Camel 中使用 sql: 组件执行数据库查询时，必须确保目标 DataSource 已在 Camel 上下文的注册表（Registry）中正确定义，并且其名称与 URI 中 dataSource= 参数值严格匹配。常见错误如 Error binding property (dataSource=ds)，本质是 Camel 在解析 sql://...?dataSource=ds 时，未能在当前 CamelContext 的 Registry 中查找到名为 "ds" 的 DataSource 实例。

关键问题分析

你原始代码中存在两个关键疏漏：

Registry 未关联到 CamelContext：虽然创建了 SimpleRegistry reg 并绑定了 "ds"，但并未将其注入 DefaultCamelContext；
注册时机过晚：即使注册成功，若在 camelContext.addRoutes(...) 之后才绑定，路由构建阶段（URI 解析）已无法感知该 Bean。

正确实现方式（推荐：路由类内绑定）

最可靠、可维护的方式是在 RouteBuilder 子类中完成注册，并确保在 configure() 方法执行前 DataSource 已就绪：

Apache 2.4.62

PHP中文网提供Apache 2.4.62 官方 tar.gz 源码包下载，通过源码编译安装，开发者能够灵活定制模块、优化性能并精准控制安装路径，满足多样化的业务需求。

下载

public class MyRoute extends RouteBuilder {
    private final DataSource dataSource;

    public MyRoute(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    @Override
    public void configure() throws Exception {
        // ✅ 确保在路由定义前，将数据源绑定到当前 CamelContext 的 Registry
        getCamelContext().getRegistry().bind("ds", dataSource);

        from("timer:demo?period=5000")
            .routeId("sql-test-route")
            .to("sql:SELECT 1 FROM DUAL?dataSource=ds&outputType=SelectList");
    }
}

主程序启动逻辑

public class StandaloneCamelApp {
    private static DataSource setupDataSource() {
        BasicDataSource ds = new BasicDataSource();
        ds.setDriverClassName("oracle.jdbc.driver.OracleDriver");
        ds.setUsername("xcccc");
        ds.setPassword("xxxxx");
        ds.setUrl("jdbc:oracle:thin:@xxxxx:1521:xxxxx");
        // ⚠️ 建议设置连接池参数（可选但强烈推荐）
        ds.setInitialSize(1);
        ds.setMaxIdle(5);
        ds.setMinIdle(1);
        ds.setMaxOpenPreparedStatements(20);
        return ds;
    }

    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();

        // ✅ 创建路由实例并传入数据源
        MyRoute route = new MyRoute(setupDataSource());

        // ✅ 添加路由（此时 configure() 内部会完成注册）
        context.addRoutes(route);

        // ✅ 启动上下文
        context.start();

        // 保持运行（测试用）
        Thread.sleep(30000);
        context.stop();
    }
}

替代方案：使用 SimpleRegistry（需显式注入）

若坚持使用 SimpleRegistry，必须在创建 CamelContext 时传入：

SimpleRegistry registry = new SimpleRegistry();
registry.bind("ds", setupDataSource());

CamelContext context = new DefaultCamelContext(registry); // ✅ 关键：传入定制 Registry
context.addRoutes(new MyRoute()); // 此处 MyRoute 不再负责绑定，仅定义路由逻辑