如何在Spring Boot中實現Oracle AQ隊列？

Question

我已經找到了如何使用AQ（Streams？）包創建Oracle數據庫。我還在Oracle中創建了一些隊列（手工）。 （使用PL/SQL和SQL）。

但是，我很難與Spring建立正確的連接。

下工作（使用oracle.AQ Java包）：

private final String aqUrl = "jdbc:oracle:thin:@localhost:1521:orcl"; 
private final String aqUser = "queue_mut"; 
private final String aqPassword = "******"; 
private final String aqSchema = "queue_mut"; 
private final String aqTable = "aq_table1"; 
private final String aqQueue = "aq_queue1"; 


@Test 
public void testManualAQ() throws ClassNotFoundException, SQLException, AQException { 

    Class.forName("oracle.jdbc.driver.OracleDriver"); 
    Connection connection = DriverManager.getConnection(aqUrl, aqUser, aqPassword); 
    connection.setAutoCommit(false); 

    Class.forName("oracle.AQ.AQOracleDriver"); 
    AQSession aqSession = AQDriverManager.createAQSession(connection); 
    AQQueueTable q_table = aqSession.createQueueTable(aqSchema, aqTable, new AQQueueTableProperty("RAW")); 
    aqSession.createQueue(q_table, aqQueue, new AQQueueProperty()); 

} 

（基於https://docs.oracle.com/cd/B10501_01/appdev.920/a96587/apexampl.htm）

這讓我發現，我可以連接到Oracle和達到AQ功能。

現在，我正在嘗試創建Java配置的Bean以便使用JmsTemplate。

@Resource 
private JmsTemplate jmsTemplate; 

@Test 
public void testJmsTemplate() { 
    String xmlval = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" + 
      "<product id=\"10\">\n" + 
      " <description>Foo</description>\n" + 
      " <price>2.05</price>\n" + 
      "</product>"; 

    jmsTemplate.convertAndSend(aqSchema + ".jms_ws_incoming_queue", xmlval); 
} 

（是的，隊列已經存在;-)）

用下面的配置類：

import oracle.jms.AQjmsFactory; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 
import org.springframework.jdbc.datasource.DataSourceTransactionManager; 
import org.springframework.jms.core.JmsTemplate; 

import javax.jms.ConnectionFactory; 
import javax.jms.JMSException; 
import javax.sql.DataSource; 

@Configuration 
public class OracleAQConfiguration { 

    @Bean 
    public DataSourceTransactionManager transactionManager(DataSource dataSource) { 
     DataSourceTransactionManager manager = new DataSourceTransactionManager(); 
     manager.setDataSource(dataSource); 
     return manager; 
    } 

    @Bean 
    public ConnectionFactory connectionFactory(DataSource dataSource) throws JMSException { 
     return AQjmsFactory.getQueueConnectionFactory(dataSource); 
    } 

    @Bean 
    public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory) { 
     JmsTemplate jmsTemplate = new JmsTemplate(); 
     jmsTemplate.setSessionTransacted(true); 
     jmsTemplate.setConnectionFactory(connectionFactory); 
     return jmsTemplate; 
    } 
} 

而且具有屬性陽明：

spring: 
    datasource: 
    url: jdbc:oracle:thin:@localhost:1521:orcl 
    username: queue_mut 
    password: ****** 
    driverClassName: oracle.jdbc.driver.OracleDriver 

但與此我收到我無法理解的錯誤：

2017-04-19 12:11:17,151 INFO my.project.QueueTest: Started QueueTest in 5.305 seconds (JVM running for 6.588) 

org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is oracle.jms.AQjmsException: Error creating the db_connection; nested exception is java.lang.ClassCastException: com.sun.proxy.$Proxy102 cannot be cast to oracle.jdbc.internal.OracleConnection 

    at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316) 
    at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:169) 
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:487) 
    at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:570) 
    at org.springframework.jms.core.JmsTemplate.convertAndSend(JmsTemplate.java:658) 
    at my.project.QueueTest.testJmsTemplate(QueueTest.java:51) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:498) 
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) 
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) 
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) 
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) 
    at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75) 
    at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86) 
    at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84) 
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325) 
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:252) 
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94) 
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) 
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) 
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) 
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) 
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) 
    at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61) 
    at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70) 
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363) 
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191) 
    at org.junit.runner.JUnitCore.run(JUnitCore.java:137) 
    at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68) 
    at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:51) 
    at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:237) 
    at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:498) 
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147) 
Caused by: oracle.jms.AQjmsException: Error creating the db_connection 
    at oracle.jms.AQjmsDBConnMgr.getConnection(AQjmsDBConnMgr.java:625) 
    at oracle.jms.AQjmsDBConnMgr.<init>(AQjmsDBConnMgr.java:399) 
    at oracle.jms.AQjmsConnection.<init>(AQjmsConnection.java:249) 
    at oracle.jms.AQjmsConnectionFactory.createConnection(AQjmsConnectionFactory.java:513) 
    at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:180) 
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:474) 
    ... 36 more 
Caused by: java.lang.ClassCastException: com.sun.proxy.$Proxy102 cannot be cast to oracle.jdbc.internal.OracleConnection 
    at oracle.jms.AQjmsGeneralDBConnection.getProviderKey(AQjmsGeneralDBConnection.java:98) 
    at oracle.jms.AQjmsGeneralDBConnection.<init>(AQjmsGeneralDBConnection.java:67) 
    at oracle.jms.AQjmsDBConnMgr.getConnection(AQjmsDBConnMgr.java:566) 
    ... 41 more 

我相信演員例外的發生是因爲它是ProxyConnection[PooledConnection[oracle.jdbc.driver.T4CConnection@40016ce1]]。但我不知道如何解決這個問題。

Answer 1

我們在嘗試從Spring引導訪問Oracle AQ時遇到過相同的異常。研究表明，由於數據庫連接池庫不允許訪問oracle AQ庫所需的底層連接，所以拋出了這個異常（dbcp和tomcat連接池庫都拋出異常，不相同但相似）

當我們從依賴關係中刪除了數據庫連接池庫時，這個異常消失了，這導致了整個應用程序沒有數據庫連接池的不良狀態。

我們注意到，如果我們使用以下方法沒有拋出異常 AQjmsFactory.getQueueConnectionFactory(url, info);

也許連接池與解決方案還缺少的，但僅限於從AQ讀取組件。在應用程序中其他組件將彙集

這裏連接的好處是bean定義了Java的配置：

@Bean 
public QueueConnectionFactory connectionFactory() throws Exception { 
    OracleServiceInfo serviceInfo = (OracleServiceInfo) this.cloud().getServiceInfo(NAME_PRIMARY_DS); 
    Properties info = new Properties(); 
    String url = serviceInfo.getJdbcUrl(); 
    info.put("driver-name", "oracle.jdbc.OracleDriver"); 
    info.put("user", serviceInfo.getUserName()); 
    info.put("password", serviceInfo.getPassword()); 
    return oracle.jms.AQjmsFactory.getQueueConnectionFactory(url, info); 
} 

@Bean 
public JmsTemplate jmsTemplate() throws Exception { 
    JmsTemplate jmsTemplate = new JmsTemplate(); 
    jmsTemplate.setConnectionFactory(connectionFactory()); 
    return jmsTemplate; 
} 

我不知道但如果這是一個很好的解決方案。但這絕對是擺脫問題中討論的例外的一種方式。

Answer 2

更改jdbc庫，在我的情況下，這個固定的（如果不這樣做，試圖用其它版本）：

<dependency> 
    <groupId>com.oracle</groupId> 
    <artifactId>ojdbc7</artifactId> 
    <version>12.1.0.2.0</version> 
</dependency>