Java 中使用Oracle Native AQ

在前面的例子里我们为队列消息创建了一个Oracle Object type "queue_message_type",在java语言中我们不能使用Oracle的数据类型，因此我们要创建一个和"queue_message_type"对应的java类。我们可以使用Oracle Jpublisher,通过它，我们可以创建一个和Oracle Object type对应的java类。(这里就不具体讨论JPublisher用法)

这里我们用JPubisher创建一个和Oracle Object type "queue_message_type"对应java class "QUEUE_MESSAGE_TYPE "

在使用Oracle Native AQ对java的interface之前，我们必须通过jdbc连接到数据库，代码如下

//loads the Oracle JDBC driver

Class.forName("oracle.jdbc.driver.OracleDriver");

NativeAQ aq = new NativeAQ();

//DB connection, HOST --- 数据库所在的机器domian id SID----数据的service name

aq.connection = DriverManager.getConnection("jdbc:oracle:thin:@HOST:1521:SID","aquser","aquesr");

//

aq.connection.setAutoCommit(false);

然后我们通过传入AQ connection来获取AQ session对象

//loads the Oracle AQ driver

Class.forName("oracle.AQ.AQOracleDriver");

aq.session = AQDriverManager.createAQSession(aq.connection);

上述工作做好后，我们可以获取我们需要的queue对象了,进行出列的操作。

AQQueue queue = aq.session.getQueue("aqadm","MESSAGE_QUEUE");

AQDequeueOption dequeueOption = new AQDequeueOption();

System.out.println("Waiting for message to dequeue……...");

AQMessage message =

((AQOracleQueue)queue).dequeue(dequeueOption,QUEUE_MESSAGE_TYPE.getFactory());

把raw payload 转换成我们消息类型

AQObjectPayload payload = message.getObjectPayload();

QUEUE_MESSAGE_TYPE messageData = (QUEUE_MESSAGE_TYPE) payload.getPayloadData();

http://www.doczj.com/doc/75f0f07df46527d3240ce020.htmlmit();

System.out.println("Dequeued no: " + messageData.getNo());

System.out.println("Dequeued title: " + messageData.getTitle);

System.out.pritnln("Dequeued text: " + messageData.getText());

小结：Oracle Advanced Queuing是一个功能强大并且使用起来相对简单的产品。它提供的java包使我们不用编写太多的java代码就可以实现enqueue和dequeue操作。