Camel mongo组件不支持多个mongo DB连接

Question

我们的Camel Mongo DB组件不支持多个Mongo DB连接。默认情况下，它在所有mongoendpoint中使用单个Mongodb bean

问题：

我为两个数据库创建了两个不同的mongo bean实例，并分别进行了身份验证。在Spring创建了两个MongoDBeans实例

使用DB初始化/创建mongoendpoint（具有不同DB的多个endpoint）时，它将第一个mongoendpointdb连接到所有endpoint。所以所有的mongoendpoint都指向同一个数据库，这个数据库是在创建第一个mongoendpoint时首先添加的。

代码如下：

<bean id="DbLocal" name="DbLocal" class="com.mongodb.MongoClient">
    <constructor-arg index="0">
        <bean class="com.mongodb.MongoClientURI">
            <constructor-arg index="0" value="mongodb://<user1>:<pwd1>@<host>:<port>/DB1" />
        </bean>
    </constructor-arg>
</bean>                    

<bean id="appDb" name="appDb" class="com.mongodb.MongoClient">
    <constructor-arg index="0">
        <bean class="com.mongodb.MongoClientURI">
            <constructor-arg index="0" value="mongodb://<host>:<port>/DB2" />
        </bean>
    </constructor-arg>
</bean>

<route id="jobStart" startupOrder="1">
    <from uri="direct:jobStart" />
    <to uri="bean:jobMonitorInsertQueryBuilder" />
    <to uri="mongodb:appDb?database={{requestDb}}&amp;collection={{jobmonitorCollection}}&amp;operation=insert"/>
</route                             
<route id="jobEnd" startupOrder="2">
    <from uri="direct:jobEnd" />
    <to uri="bean:jobMonitorUpdateQueryBuilder" />
    <to uri="mongodb:DbLocal?database={{requestDb}}&amp;collection={{jobmonitorCollection}}&amp;operation=update" />
</route>

我试着注释掉camel mongo组件中的if检查，从而允许mongo连接查找在MongoDbComponent中创建的每个mongoendpoint。JAVA这样，它可以用于多个DB连接

你知道为什么mongo组件在camel中只允许一个mongoDB连接吗，是因为存在任何问题吗

受保护的endpointcreateEndpoint（字符串uri、剩余字符串、映射参数）抛出异常{
//TODO:这只支持一个mongodb
//如果（db==null）{
db=CamelContextHelper.mandatoryLookup（getCamelContext（），remaining，Mongo.class）；
LOG.debug（“解析了名为{}的连接，剩余，db）
/}

https://github.com/apache/camel/blob/master/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
感谢您在这方面的帮助

骆驼论坛链接：http://camel.465427.n5.nabble.com/Camel-mongo-db-does-not-support-multiple-mongo-DB-tp5765468.html

-斯里

Answer 1

此功能已在camel 2.18.2和2.19.0中实现。请使用这些版本在您的项目中实现多个DB。

仅供参考：

https://issues.jboss.org/browse/ENTESB-5884

吉拉机票链接-https://issues.apache.org/jira/browse/CAMEL-10644

谢谢，
潘尼尔