Настройка источников данных во время выполнения с помощью Camel

Я настроил очень простой маршрут в Apache Camel, где запрос отправляется компоненту JDBC для выполнения. Я запустил проект Camel. Я пытаюсь отправить параметры подключения к базе данных dataSource1 в заголовке сообщения RabbitMQ. Под параметрами подключения я подразумеваю driverClassName, url, имя пользователя, пароль. Клиент моего приложения должен ввести все эти параметры, чтобы решить, к какой базе данных подключаться. Я, вероятно, буду использовать промах маршрутизации в зависимости от того, что указал пользователь driverClassName, но это другое дело.

Обратите внимание, что в этом примере я поместил оператор SQL в файл, чтобы сделать его проще. Как я могу это сделать?

Вот мой верблюжий контекст:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:camel="http://camel.apache.org/schema/spring"
       xmlns:jdbc="http://www.springframework.org/schema/jdbc"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
       http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd">

  <camel:camelContext xmlns="http://camel.apache.org/schema/spring">
    <camel:route>
      <camel:from uri="file:src/data?noop=true"/>
      <camel:to uri="jdbc:dataSource1"/>
      <camel:convertBodyTo type="java.lang.String"/>
      <camel:log message="${body}"/>
    </camel:route>
  </camel:camelContext>

  <bean id="dataSource1"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="url" value="jdbc:mysql://localhost:3306/employees"/>
    <property name="username" value="root"/>
    <property name="password" value=""/>
  </bean>
</beans>

И проект Maven:

<?xml version="1.0" encoding="UTF-8"?>
<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>

  <groupId>group1</groupId>
  <artifactId>com.mycompany</artifactId>
  <packaging>jar</packaging>
  <version>1.0-SNAPSHOT</version>

  <name>A Camel Spring Route</name>
  <url>http://www.myorganization.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.apache.camel</groupId>
      <artifactId>camel-core</artifactId>
      <version>2.12.2</version>
    </dependency>
    <dependency>
      <groupId>org.apache.camel</groupId>
      <artifactId>camel-spring</artifactId>
      <version>2.12.2</version>
    </dependency>

    <!-- logging -->
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-api</artifactId>
      <version>1.7.5</version>
    </dependency>
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-log4j12</artifactId>
      <version>1.7.5</version>
    </dependency>
    <dependency>
      <groupId>log4j</groupId>
      <artifactId>log4j</artifactId>
      <version>1.2.17</version>
    </dependency>

    <!-- testing -->
    <dependency>
      <groupId>org.apache.camel</groupId>
      <artifactId>camel-test-spring</artifactId>
      <version>2.12.2</version>
      <scope>test</scope>
    </dependency>

      <dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
          <version>5.1.26</version>
      </dependency>

      <!-- Jdbc -->
      <dependency>
          <groupId>org.apache.camel</groupId>
          <artifactId>camel-jdbc</artifactId>
          <version>2.12.2</version>
      </dependency>

      <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-jdbc</artifactId>
          <version>4.0.0.RELEASE</version>
      </dependency>
  </dependencies>

  <build>
    <defaultGoal>install</defaultGoal>

    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>2.5.1</version>
        <configuration>
          <source>1.6</source>
          <target>1.6</target>
        </configuration>
      </plugin>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-resources-plugin</artifactId>
        <version>2.6</version>
        <configuration>
          <encoding>UTF-8</encoding>
        </configuration>
      </plugin>

      <!-- allows the route to be ran via 'mvn camel:run' -->
      <plugin>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-maven-plugin</artifactId>
        <version>2.12.2</version>
      </plugin>
    </plugins>
  </build>
</project>

person Ali B    schedule 23.01.2014    source источник
comment
Под параметрами подключения вы имеете в виду имя пользователя и пароль?   -  person Ralf    schedule 23.01.2014
comment
Спасибо за просмотр моего вопроса Ральф. Под параметрами подключения я подразумеваю driverClassName, url, имя пользователя, пароль. Я обновил вопрос с дополнительной информацией.   -  person Ali B    schedule 23.01.2014


Ответы (2)


Источником данных является bean-компонент Spring. Создайте свой собственный bean-компонент и попросите Spring внедрить источник данных. Затем вы можете подключить этот bean-компонент к вашему маршруту до шага JDBC и использовать заголовки обмена, которые должны содержат заголовки JMS для обновления свойств источника данных.

Тем не менее, я думаю, что этот подход к дизайну напрашивается на неприятности:

  • Если вы когда-либо хотели использовать объединенный источник данных (и вы должны это сделать), вам нужно сбросить пул соединений, что дорого.
  • Вам необходимо синхронизировать изменения состояния (одноэлементного) источника данных, поскольку в этом отношении он не является потокобезопасным, а с Camel вы работаете в многопоточной среде.
  • Вы отправляете имена пользователей и пароли для своих БД повсюду, и вы должны защищать эту информацию, пока она находится в пути.

Наверняка есть еще...

person Ralf    schedule 23.01.2014
comment
Видите ли, то, что я прошу выше, является очень упрощенной версией того, что я пытаюсь создать. Таким образом решая первую проблему и переходя к следующей. В конце концов, я имею в виду отправку ключа в пути к значению строки подключения, которое определено в базе данных. Затем я сохраню набор с этими ключами, извлеченными в памяти. Как я уже сказал, первая проблема заключается в том, как определить источник данных для первой загрузки и внедрить его в компонент camel-jdbc. Теперь стало понятнее? - person Ali B; 24.01.2014

Может быть, через несколько лет. Купить Я достиг этого с помощью AbstractRoutingDataSource, который позволяет динамически изменять источник данных (вам не нужно сбрасывать пул соединений или маршрут)

Справочная ссылка: https://spring.io/blog/2007/01/23/dynamic-datasource-routing/

person jpincz    schedule 14.09.2019