проблема подключения к базе данных потребителя camel-sql - PullRequest
Новая
       22

проблема подключения к базе данных потребителя camel-sql

0 голосов
/ 15 марта 2019

Я использую Apache Camel с загрузкой Spring. Я использую мое весеннее загрузочное приложение в качестве jar без какого-либо сервера.

В приложении у меня есть потребительский маршрут Camel-SQL с задержкой 1000. Затем этот потребитель далее вызывает другой маршрут, который использует сплиттер и параллельную обработку.

Через Jprofiler я заметил, что мои соединения с БД не закрываются, которые открываются через потребителя.

У меня также есть настройки dbcp2 в application.properties и в базе данных Oracle. Я наблюдаю за этой проблемой связи впервые. Кто-нибудь тоже сталкивался с такой же проблемой в любое время? Или мне нужно добавить любую другую конфигурацию.

Любая помощь будет оценена.

1 Ответ

0 голосов
/ 17 марта 2019

Вот одна из моих конфигураций Oracle: 

<cm:property-placeholder id="server.placeholder" persistent-id="name.of.company.datasource">
    <cm:default-properties>
        <cm:property name="db.host" value="host"/>
        <cm:property name="db.port" value="1521"/>
        <cm:property name="db.instance" value="dbname"/>
        <cm:property name="db.user" value="user"/>
        <cm:property name="db.password" value="password"/>
        <cm:property name="driverClassName" value="oracle.jdbc.pool.OracleDataSource" />
        <cm:property name="validationQuery" value="SELECT 1 FROM DUAL" />
        <cm:property name="defaultReadOnly" value="false" />
        <cm:property name="defaultAutoCommit" value="true" />
        <cm:property name="maxActive" value="100" />
        <cm:property name="whenExhaustedAction" value="2" />
        <cm:property name="maxWait" value="-1" />
        <cm:property name="maxIdle" value="8" />
        <cm:property name="minIdle" value="1" />
        <cm:property name="testOnBorrow" value="true" />
        <cm:property name="testOnReturn" value="true" />
        <cm:property name="timeBetweenEvictionRunsMillis" value="-1" />
        <cm:property name="numTestsPerEvictionRun" value="3" />
        <cm:property name="minEvictableIdleTimeMillis" value="1800000" />
        <cm:property name="testWhileIdle" value="false" />
        <cm:property name="softMinEvictableIdleTimeMillis" value="-1" />
        <cm:property name="lifo" value="true" />
    </cm:default-properties>
</cm:property-placeholder>

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  <property name="driverClassName" value= "${driverClassName}" />
  <property name="url" value="jdbc:oracle:thin:@${db.host}:${db.port}:${db.instance}" />
  <property name="username" value="${db.user}" />
  <property name="password" value="${db.password}" />
  <property name="maxIdle" value="1" />
</bean>

<bean id="connectionFactory" class="org.apache.commons.dbcp.DataSourceConnectionFactory">
  <argument ref="dataSource" />
</bean>

<bean id="connectionPool" class="org.apache.commons.pool.impl.GenericObjectPool" >
  <argument><null/></argument>
  <argument value="${maxActive}" />
  <argument value="${whenExhaustedAction}" />
  <argument value="${maxWait}" />
  <argument value="${maxIdle}" />
  <argument value="${minIdle}" />
  <argument value="${testOnBorrow}" />
  <argument value="${testOnReturn}" />
  <argument value="${timeBetweenEvictionRunsMillis}" />
  <argument value="${numTestsPerEvictionRun}" />
  <argument value="${minEvictableIdleTimeMillis}" />
  <argument value="${testWhileIdle}" />
  <argument value="${softMinEvictableIdleTimeMillis}" />
  <argument value="${lifo}" />
</bean>

<bean id="pooledConnectionFactory" class="org.apache.commons.dbcp.PoolableConnectionFactory" >
  <argument ref="connectionFactory" />
  <argument ref="connectionPool" />
  <argument><null/></argument>
  <argument value="${validationQuery}" />
  <argument value="${defaultReadOnly}" />
  <argument value="${defaultAutoCommit}" />
</bean>

<bean id="poolingDataSource" class="org.apache.commons.dbcp.PoolingDataSource" depends-on="pooledConnectionFactory">
  <argument ref="connectionPool" />
</bean>

<service interface="javax.sql.DataSource" ref="poolingDataSource"> 
    <service-properties>
        <entry key="osgi.jndi.service.name" value="jdbc/oracle/db"/>
        <entry key="datasource.name" value="jdbc/oracle/db" />
    </service-properties>
</service>

Возможно, это поможет вам.Я думаю, что соединение с БД просто не успевает вернуться в пул между запросами.Необходимо настроить время ожидания подключения и аналогичные параметры (параметры простоя, minEvictableIdleTimeMillis , timeBetweenEvictionRunsMillis , numTestsPerEvictionRun ).

.
...