當(dāng)前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

oracle队列java_oracle 队列

發(fā)布時(shí)間：2024/8/1 编程问答 26 豆豆

生活随笔收集整理的這篇文章主要介紹了 oracle队列java_oracle 队列小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

Oracle 高級隊(duì)列(AQ)

適用對象：初步了解oracle高級隊(duì)列人群

注意事項(xiàng)：

序號

注意事項(xiàng)

JMS監(jiān)聽部分基本參照以下網(wǎng)站內(nèi)容：

http://blog.csdn.net/scorpio3k/article/details/49406209

本文僅為按作者本身的項(xiàng)目經(jīng)歷編寫，不包含全部oracle高級隊(duì)列功能

Oracle 高級隊(duì)列(AQ). 0

一．前言... 3

二．功能概述... 3

三．創(chuàng)建Oracle高級隊(duì)列... 4

1.Oracle高級隊(duì)列所需權(quán)限... 4

2.創(chuàng)建隊(duì)列結(jié)構(gòu)—TYPE. 4

3.創(chuàng)建隊(duì)列表... 5

4.創(chuàng)建隊(duì)列... 5

5.隊(duì)列管理... 5

6.隊(duì)列創(chuàng)建管理完整步驟... 7

四．JMS監(jiān)聽并處理Oracle 高級隊(duì)列... 10

1. 準(zhǔn)備工作:. 10

2. 創(chuàng)建連接參數(shù)類:. 10

3. 創(chuàng)建消息轉(zhuǎn)換類:. 10

4. 主類進(jìn)行消息處理:. 11

1 前言

一般系統(tǒng)的應(yīng)用可以分為：立即要執(zhí)行和可以延遲要執(zhí)行的事情，區(qū)分這個很重要。為了提高系統(tǒng)的性能，縮短系統(tǒng)等待時(shí)間，引入隊(duì)列技術(shù)。

隊(duì)列是一種能將應(yīng)用程序的處理工作有效地劃分為前臺任務(wù)和后臺任務(wù)的技術(shù)。當(dāng)處理容量允許時(shí)，這種技術(shù)通過存儲消息、確定消息處理的優(yōu)先順序和向應(yīng)用程序提交消息來發(fā)揮作用。它使你能夠平衡本地計(jì)算機(jī)的負(fù)荷，或?qū)⑷蝿?wù)分配到遠(yuǎn)程計(jì)算機(jī)。

為了減少用戶的等待時(shí)間，應(yīng)用程序可以讓說明需要后臺處理的消息排入隊(duì)列。然后就可以從頁面的呈遞過程中去掉該處理任務(wù)。由一個后臺進(jìn)程來讀取并隊(duì)列處理這些消息，或者甚至可以交由一個單獨(dú)的系統(tǒng)來處理它們。

隊(duì)列可以實(shí)現(xiàn)各個系統(tǒng)之間的數(shù)據(jù)共享，消息通信。

2 功能概述

書寫本文的目的：利用Oracle高級隊(duì)列實(shí)現(xiàn)pl/sql代碼，為其它語言實(shí)現(xiàn)高級隊(duì)列的功能作接口。

Oracle高級隊(duì)列有一下好處：

(1)高級隊(duì)列管理是Oracle數(shù)據(jù)庫的一個特性，它提供消息隊(duì)列管理功能。這是一個非常可靠、安全和可伸縮的消息管理系統(tǒng)，因?yàn)樗褂门c其他基于Oracle技術(shù)的應(yīng)用程序相同的數(shù)據(jù)庫特性。

(2)高級隊(duì)列管理的一個很大優(yōu)點(diǎn)是它可以通過pl/sql、java或c來訪問，這樣你就可以把來自一個java servlet的消息入隊(duì)列和使pl/sql存儲過程中的相同消息出隊(duì)列。

(3)高級隊(duì)列管理的另一個優(yōu)點(diǎn)是你可以利用這一軟件通過Oracle net services (sql*net)、http(s)和smtp，在遠(yuǎn)程節(jié)點(diǎn)之間傳播消息。高級隊(duì)列甚至可以通過消息網(wǎng)關(guān)與非Oracle的消息管理系統(tǒng)(如ibm mqseries)相集成。

(4)Oracle高級隊(duì)列管理提供了單消費(fèi)者隊(duì)列和多消費(fèi)者隊(duì)列。單消費(fèi)者隊(duì)列只面向單一的接收者。多消費(fèi)者隊(duì)列可以被多個接收者使用。當(dāng)把消息放入多消費(fèi)者隊(duì)列時(shí)，應(yīng)用程序的程序員必須顯式地在消息屬性中指定這些接收者，或者建立決定每條消息的接收者的基于規(guī)則的訂閱過程。

Oracle 高級隊(duì)列具體開發(fā)步驟如下：

(1)首先確定應(yīng)用的需求，是否適合使用高級隊(duì)列？使用高級隊(duì)列預(yù)計(jì)提高性能的預(yù)期值

(2)賦予數(shù)據(jù)庫賬戶相應(yīng)aq權(quán)限。

(3)確定隊(duì)列包體結(jié)構(gòu)，即創(chuàng)建type。

(4)創(chuàng)建隊(duì)列表及隊(duì)列。

(5)隊(duì)列管理

3 創(chuàng)建Oracle高級隊(duì)列

3.1 Oracle高級隊(duì)列所需權(quán)限

賦予權(quán)限和角色：

grant connect, resource to賬戶名;

grant aq_user_role to賬戶名;

grant aq_administrator_role to 賬戶名;

grant execute on sys.dbms_aqadm to賬戶名;

grant execute on sys.dbms_aq to賬戶名;

grant execute on sys.dbms_aqin to賬戶名;

grant execute on sys.dbms_aqjms to賬戶名;

3.2 創(chuàng)建隊(duì)列結(jié)構(gòu)—TYPE

create or replace type 類型名稱 as object

(

字段一???? 字段類型,

字段二???? 字段類型,

字段三???? 字段類型,

字段四???? 字段類型,

…………………………

字段n????? 字段類型

);

3.3 創(chuàng)建隊(duì)列表

begin

sys.dbms_aqadm.create_queue_table

(

queue_table??????? => '隊(duì)列表名',

queue_payload_type => ' type類型',? ??????????--之前定義的type類型

sort_list????????? => 'priority,enq_time',??? --按優(yōu)先級和入列時(shí)間排序

multiple_consumers => false,???????? ?????????--多消費(fèi)者

comment??????????? => '自己加注解',

auto_commit??????? => false?????????????????? --手動控制事務(wù)

);

end;

3.4 創(chuàng)建隊(duì)列

begin

sys.dbms_aqadm.create_queue

(

queue_name???? => '隊(duì)列名',

queue_table??? => '隊(duì)列表名',????????????????????? --之前創(chuàng)建的隊(duì)列表

queue_type???? => sys.dbms_aqadm.normal_queue,

max_retries??? => 3,?????????????????????????????? --取隊(duì)列失敗后重試次數(shù)

retry_delay??? => 1,?????????????????????????????? --重試前等待

retention_time => 0???????????????????????????????? --取隊(duì)列后保持時(shí)間，不保持

);

end;

3.5 隊(duì)列管理

3.5.1 啟動隊(duì)列：

begin

sys.dbms_aqadm.start_queue

(queue_name => '隊(duì)列名',enqueue => true ,dequeue => true );

end;

3.5.2 插入隊(duì)列：

declare

v_message??? 隊(duì)列類型(type);

v_msgid????? raw(16);

v_options??? dbms_aq.enqueue_options_t;

v_properties dbms_aq.message_properties_t;

v_recipients dbms_aq.aq$_recipient_list_t;

begin

v_message := task_c(字段一? => 字符串,

字段二? => 字符串,

字段三? => 字符串,

字段四? => 字符串,

………………………

字段n? => 字符串);

v_properties.priority :=數(shù)字; ??????????????????--該消息的優(yōu)先級別，默認(rèn)為1

v_options.visibility? := dbms_aq.immediate; ????--立即入列

dbms_aq.enqueue(queue_name???????? => '隊(duì)列名',

enqueue_options??? => v_options,

message_properties => v_properties,

payload??????????? => v_message,

msgid????????????? => v_msgid);

end;

3.5.3 暫停隊(duì)列：

begin

sys.dbms_aqadm.stop_queue ( queue_name => '隊(duì)列名');

end;

3.5.4 刪除隊(duì)列：

begin

sys.dbms_aqadm.drop_queue ( queue_name => '隊(duì)列名');

end;

3.5.5 刪除隊(duì)列表：

begin

sys.dbms_aqadm.drop_queue_table (queue_table?? =>? '隊(duì)列表名');

end;

3.6 隊(duì)列創(chuàng)建管理完整步驟

在aquser賬戶中創(chuàng)建高級隊(duì)列,高級隊(duì)列結(jié)構(gòu)為callid,msg_id,report_time,sms_report,respurl,send_times，隊(duì)列名稱為sms_queue。

開發(fā)步驟：

(1)賦予權(quán)限：

grant connect, resource to aquser;

grant aq_user_role to aquser;

grant aq_administrator_role to aquser;

grant execute on sys.dbms_aqadm to aquser;

grant execute on sys.dbms_aq to aquser;

grant execute on sys.dbms_aqin to aquser;

grant execute on sys.dbms_aqjms to aquser;

(2)創(chuàng)建隊(duì)列結(jié)構(gòu)(type)：

create or replace type sms_queue_type as object

(

callid????? varchar2(1024),

msg_id????? varchar2(1024),

report_time varchar2(1024),

sms_report? varchar2(1024),

respurl???? varchar2(1024),

send_times? varchar2(1024)

);

(3)創(chuàng)建隊(duì)列表：

begin

sys.dbms_aqadm.create_queue_table

(

queue_table??????? => 'sms_queue_table',

queue_payload_type => 'sms_queue_type',

sort_list????????? => 'priority,enq_time',

multiple_consumers => false,

comment??????????? => 'queue for test',

auto_commit??????? => false

);

end;

(4)創(chuàng)建隊(duì)列：

begin

sys.dbms_aqadm.create_queue

(

queue_name???? => 'sms_queue',

queue_table??? => 'sms_queue_table',

queue_type???? => sys.dbms_aqadm.normal_queue,

max_retries??? => 3,

retry_delay??? => 1,

retention_time => 0

);

end;

(5)啟動隊(duì)列：

begin

sys.dbms_aqadm.start_queue

(queue_name => 'sms_queue',enqueue => true ,dequeue => true );

end;

(6)建立入隊(duì)存儲：

CREATE OR REPLACE procedure sms_enqueue(in_callid????? varchar2,

in_msg_id????? varchar2,

in_report_time varchar2,

in_sms_report? varchar2,

in_respurl???? varchar2,

in_send_times? number,

out_result???? out varchar2,

out_sqlerrm??? out varchar2) as

/*聲明變量*/

v_Message??? SMS_QUEUE_TYPE;

v_MsgId????? RAW(16);

v_options??? DBMS_AQ.ENQUEUE_OPTIONS_T;

v_properties DBMS_AQ.MESSAGE_PROPERTIES_T;

v_Recipients DBMS_AQ.AQ$_RECIPIENT_LIST_T;

v_sqlerrm??? varchar2(512);

begin

/*對列字段賦值*/

v_Message := SMS_QUEUE_TYPE(callid????? => in_callid,

msg_id????? => in_msg_id,

report_time => in_report_time,

sms_report? => in_sms_report,

respurl???? => in_respurl,

send_times? => in_send_times);

/*讓消息立即進(jìn)入隊(duì)列*/

v_options.visibility := DBMS_AQ.IMMEDIATE;

/*入隊(duì)操作*/

dbms_aq.enqueue(queue_name???????? => 'sms_queue',

enqueue_options??? => v_options,

message_properties => v_properties,

payload??????????? => v_Message,

msgid????????????? => v_MsgId);

/*異常處理*/

exception

WHEN OTHERS THEN

v_sqlerrm?? := SQLERRM;

out_result? := '-1';

out_sqlerrm := v_sqlerrm;

end;

(6)刪除隊(duì)列：

begin

sys.dbms_aqadm.stop_queue ( queue_name => 'sms_queue');

end;

begin

sys.dbms_aqadm.drop_queue ( queue_name => 'sms_queue');

end;

begin

sys.dbms_aqadm.drop_queue_table (queue_table?? =>? 'sms_queue_table');

end;

drop type voicechange.sms_queue_type;

4 JMS監(jiān)聽并處理Oracle 高級隊(duì)列

4.1 準(zhǔn)備工作:

Java使用JMS進(jìn)行相應(yīng)的處理，需要使用Oracle提供的jar，在Oracle安裝目錄可以找到：在linux中可以使用find命令進(jìn)行查找，例如:find `pwd` -name 'jmscommon.jar'

需要的jar為：

app/oracle/product/12.1.0/dbhome_1/rdbms/jlib/jmscommon.jar

app/oracle/product/12.1.0/dbhome_1/jdbc/lib/ojdbc7.jar

app/oracle/product/12.1.0/dbhome_1/jlib/orai18n.jar

app/oracle/product/12.1.0/dbhome_1/jlib/jta.jar

app/oracle/product/12.1.0/dbhome_1/rdbms/jlib/aqapi_g.jar

4.2 創(chuàng)建連接參數(shù)類:

實(shí)際使用時(shí)可以把參數(shù)信息配置在properties文件中，使用spring進(jìn)行注入。

package org.kevin.jms;

c class JmsConfig

{

public String username = "數(shù)據(jù)庫賬戶名";

public String password = "數(shù)據(jù)庫賬戶密碼";

public String jdbcUrl = "jdbc:oracle:thin:@數(shù)據(jù)庫TNS:端口號:名稱";

public String queueName = "監(jiān)聽的隊(duì)列名稱";

}

4.3 創(chuàng)建消息轉(zhuǎn)換類:

package org.kevin.jms;

import java.sql.SQLException;

import oracle.jdbc.driver.OracleConnection;

import oracle.jdbc.internal.OracleTypes;

import oracle.jpub.runtime.MutableStruct;

import oracle.sql.CustomDatum;

import oracle.sql.CustomDatumFactory;

import oracle.sql.Datum;

import oracle.sql.STRUCT;

@SuppressWarnings("deprecation")

public class QUEUE_MESSAGE_TYPE implements CustomDatum, CustomDatumFactory {

public static final String _SQL_NAME = "QUEUE_MESSAGE_TYPE";

public static final int _SQL_TYPECODE = OracleTypes.STRUCT;

MutableStruct _struct;

// 12表示字符串

static int[] _sqlType = { 12 };

static CustomDatumFactory[] _factory = new CustomDatumFactory[1];

static final QUEUE_MESSAGE_TYPE _MessageFactory = new QUEUE_MESSAGE_TYPE();

public static CustomDatumFactory getFactory() {

return _MessageFactory;

}

public QUEUE_MESSAGE_TYPE() {

_struct = new MutableStruct(new Object[1], _sqlType, _factory);

}

public Datum toDatum(OracleConnection c) throws SQLException {

return _struct.toDatum(c, _SQL_NAME);

}

public CustomDatum create(Datum d, int sqlType) throws SQLException {

if (d == null)

return null;

QUEUE_MESSAGE_TYPE o = new QUEUE_MESSAGE_TYPE();

o._struct = new MutableStruct((STRUCT) d, _sqlType, _factory);

return o;

}

public String getContent() throws SQLException {

return (String) _struct.getAttribute(0);

}

4.4 主類進(jìn)行消息處理:

package org.kevin.jms;

import java.util.Properties;

import javax.jms.Message;

import javax.jms.MessageConsumer;

import javax.jms.MessageListener;

import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueConnectionFactory;

import javax.jms.Session;

import oracle.jms.AQjmsAdtMessage;

import oracle.jms.AQjmsDestination;

import oracle.jms.AQjmsFactory;

import oracle.jms.AQjmsSession;

public class Main {

public static void main(String[] args) throws Exception {

JmsConfig config = new JmsConfig();

QueueConnectionFactory queueConnectionFactory = AQjmsFactory.getQueueConnectionFactory(config.jdbcUrl,

new Properties());

QueueConnection conn = queueConnectionFactory.createQueueConnection(config.username, config.password);

AQjmsSession session = (AQjmsSession) conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

conn.start();

Queue queue = (AQjmsDestination) session.getQueue(config.username, config.queueName);

MessageConsumer consumer = session.createConsumer(queue, null, QUEUE_MESSAGE_TYPE.getFactory(), null, false);

consumer.setMessageListener(new MessageListener() {

@Override

public void onMessage(Message message) {

System.out.println("ok");

AQjmsAdtMessage adtMessage = (AQjmsAdtMessage) message;

try {

QUEUE_MESSAGE_TYPE payload = (QUEUE_MESSAGE_TYPE) adtMessage.getAdtPayload();

System.out.println(payload.getContent());

} catch (Exception e) {

e.printStackTrace();

}

});

Thread.sleep(1000000);

}

總結(jié)

以上是生活随笔為你收集整理的oracle队列java_oracle 队列的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。