Spring загрузка с Oracle AQ и универсальным пулом подключенийJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Spring загрузка с Oracle AQ и универсальным пулом подключений

Сообщение Anonymous »

Я использую Oracle AQ с весенней загрузкой следующим образом:
Зависимость Gradle:

Код: Выделить всё

implementation "com.oracle.database.spring:oracle-spring-boot-starter-aqjms:23.4.0"
JmsConfiguration:

Код: Выделить всё

    @Configuration
@EnableJms
public class JmsConfiguration {

@Bean
public ConnectionFactory connectionFactory(DataSource dataSource) {
return AQjmsFactory.getQueueConnectionFactory(dataSource);
}
Теперь я пытаюсь настроить некоторые свойства для универсального пула соединений Oracle через application.yaml на основе этой документации Oracle, но свойства не применяются :

Код: Выделить всё

spring:
datasource:
url: jdbc:oracle:thin:@localhost:1521/ORCLPDB1
username: AQ_USER
password: your_password
oracleucp:
initial-pool-size: 5
min-pool-size: 10
max-pool-size: 30
connection-wait-timeout: 2
connection-factory-class-name: oracle.jdbc.pool.OracleDataSource
connection-pool-name: some_pool_name
type: oracle.ucp.jdbc.PoolDataSource
А если я устанавливаю их с помощью кода, то это работает:

Код: Выделить всё

import jakarta.jms.ConnectionFactory;
import jakarta.jms.JMSException;
import oracle.jakarta.jms.AQjmsFactory;
import oracle.ucp.jdbc.PoolDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.annotation.EnableJms;

import java.sql.SQLException;

@Configuration
@EnableJms
public class JmsConfiguration {

@Bean
public ConnectionFactory connectionFactory(PoolDataSource poolDataSource) throws JMSException, SQLException {
poolDataSource.setInitialPoolSize(5);
poolDataSource.setMinPoolSize(10);
poolDataSource.setMaxPoolSize(30);
poolDataSource.setConnectionWaitTimeout(3000);

return AQjmsFactory.getQueueConnectionFactory(poolDataSource);
}
Чтобы узнать, применились настройки или нет, я использую это:

Код: Выделить всё

import oracle.ucp.jdbc.PoolDataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
import org.springframework.context.event.EventListener;

import java.sql.SQLException;
import java.util.List;

@SpringBootApplication
@ConfigurationPropertiesScan
public class RequestBufferingServiceApplication {

@Autowired
PoolDataSource poolDataSource;

public static void main(String[] args) {
SpringApplication.run(RequestBufferingServiceApplication.class, args);
}

@EventListener(ApplicationReadyEvent.class)
public void foo() throws SQLException {
System.out.println("------");
System.out.println("Init pool size: " + poolDataSource.getInitialPoolSize());
System.out.println("Min pool size: " + poolDataSource.getMinPoolSize());
System.out.println("Max pool size: " + poolDataSource.getMaxPoolSize());
System.out.println("ConnectionWaitTimeout: " + poolDataSource.getConnectionWaitTimeout());
System.out.println("------");
}
}
Как правильно применить свойства Oracle UCP через application.yaml?
РЕДАКТИРОВАТЬ:
Вывод без влияния application.yaml:

Код: Выделить всё

------
Init pool size: 0
Min pool size: 0
Max pool size: 2147483647
ConnectionWaitTimeout: 3
------
Вывод с учетом конфигурации Java (желательно):

Код: Выделить всё

------
Init pool size: 5
Min pool size: 10
Max pool size: 30
ConnectionWaitTimeout: 2
------
build.gradle:

Код: Выделить всё

plugins {
id 'java'
id 'org.springframework.boot' version '3.3.3'
id 'io.spring.dependency-management' version '1.1.6'
id 'io.freefair.lombok' version '8.11'
id "io.qameta.allure-report"  version "2.11.2"
id 'org.sonarqube' version '5.0.0.4638'
id 'jacoco'
}

group = 'de.telekom.mff'

java {
toolchain {
languageVersion = JavaLanguageVersion.of(21)
}
}

bootJar {
archiveFileName = "request-buffering-service.${archiveExtension.get()}"
}

jar {
enabled = true
}

configurations {
compileOnly {
extendsFrom annotationProcessor
}
}

repositories {
mavenCentral()
}

ext {
versions = [
oracleSpringBootStarterAqjms: "23.4.0",
allureCucumber7Jvm          : "2.27.0",
testcontainers              : "1.20.1",
springCloud                 : "2023.0.3",
awaitility                  : "4.2.2",
xmlUnit                     : "2.10.0",
jsonUnitAssertj             : "3.2.2",
wiremock                    : "4.1.4"
]
}

dependencyManagement {
imports {
mavenBom "org.springframework.cloud:spring-cloud-dependencies:${versions.springCloud}"
}
}

dependencies {
implementation "org.springframework.boot:spring-boot-starter-web"
implementation "org.springframework.boot:spring-boot-starter-webflux"
implementation "org.springframework.boot:spring-boot-starter-log4j2"
implementation "org.springframework.boot:spring-boot-starter-actuator"
implementation "org.springframework:spring-aspects"
implementation "org.springframework.cloud:spring-cloud-starter-kubernetes-fabric8-config"
implementation "org.springframework.cloud:spring-cloud-kubernetes-fabric8-leader"
implementation "com.oracle.database.spring:oracle-spring-boot-starter-aqjms:${versions.oracleSpringBootStarterAqjms}"
testImplementation "org.springframework.boot:spring-boot-starter-test"
testImplementation "io.fabric8:kubernetes-server-mock"
testImplementation "org.springframework.cloud:spring-cloud-contract-wiremock:${versions.wiremock}"
testImplementation "org.testcontainers:oracle-free:${versions.testcontainers}"
testImplementation "org.testcontainers:junit-jupiter:${versions.testcontainers}"
testImplementation "org.awaitility:awaitility:${versions.awaitility}"
testImplementation "org.xmlunit:xmlunit-core:${versions.xmlUnit}"
testImplementation "io.qameta.allure:allure-cucumber7-jvm:${versions.allureCucumber7Jvm}"
testImplementation "net.javacrumbs.json-unit:json-unit-assertj:${versions.jsonUnitAssertj}"
testRuntimeOnly "org.junit.platform:junit-platform-launcher"
}
Журнал отладки запуска Spring (с использованием стартера aqjms 23.4.0, где URL-адрес, пользователь и пароль для базы данных автоматически настраиваются через application.yaml):

Отрицательные совпадения:
DataSourceAutoConfiguration:
Не соответствует:
- @ConditionalOnClass не нашел требуемый класс 'org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType'
(OnClassCondition)
DataSourceInitializationConfiguration:
Не соответствует:
- @ConditionalOnClass не соответствует найдите необходимый класс «org.springframework.jdbc.datasource.init.DatabasePopulator»
(OnClassCondition)
DataSourceTransactionManagerAutoConfiguration:
Не соответствует:
- @ConditionalOnClass не нашел требуемый класс «org.springframework.jdbc.core.JdbcTemplate» ( OnClassCondition)


Подробнее здесь: https://stackoverflow.com/questions/793 ... ction-pool
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»