概念：
高級隊列（Advanced Queue，簡稱AQ）:
高級隊列是oracle的一種高級應(yīng)用,它主要是表和觸發(fā)器之間的組合而成的一種應(yīng)用。其主要作用是在各應(yīng)用系統(tǒng)中進(jìn)行消息傳遞。
目的：
利用高級隊列來實現(xiàn)消息在兩個不同數(shù)據(jù)庫之間的異步傳輸，滿足業(yè)務(wù)系統(tǒng)的改造需求。
基本環(huán)境：
DB1：Oracle 10g Version 10.2.0.4.0
DB2：Oracle 10g Version 10.2.0.4.0
基本組成：
發(fā)送方（DB1）：
Queue type：決定發(fā)送消息的類型
Queue table：消息發(fā)送的載體
Queue：隊列
Subscriber：訂購者，同一個隊列可以有n個訂購者
Propagation：傳播進(jìn)程
接收方（DB2）：
Queue type：決定接收消息的類型
Queue table：消息接收的載體
Queue：隊列
發(fā)送方（DB1）代碼：
1.創(chuàng)建aq用戶并賦權(quán)
--sys用戶操作，其他操作為aq用戶
create user aq identified by aq;
grant connect,resource,aq_administrator_role,unlimited tablespace to aq;
grant create database link to aq;
grant execute on dbms_aq to aq;
grant execute on dbms_aqadm to aq;

begin
dbms_aqadm.grant_system_privilege('ENQUEUE_ANY', 'aq', FALSE);
dbms_aqadm.grant_system_privilege('DEQUEUE_ANY', 'aq', FALSE);
end;
2.創(chuàng)建db link
create database link db2.LK connect to AQ using db2;
確認(rèn)dblink有效。
3.創(chuàng)建type
CREATE type aq.Message_typ as object (
subject????? VARCHAR2(30),
text???????? VARCHAR2(80));
可根據(jù)自己的需求決定具體字段。
4.創(chuàng)建queue
DECLARE
?? subscriber sys.aq$_agent;
BEGIN
?? --根據(jù)type創(chuàng)建queue table
?? DBMS_AQADM.CREATE_QUEUE_TABLE(queue_table???????? => 'aq.que_shenshou_tab',
???????????????????????????????? multiple_consumers => TRUE,
???????????????????????????????? queue_payload_type => 'aq.Message_typ');
?? --根據(jù)queue table創(chuàng)建queue
?? DBMS_AQADM.CREATE_QUEUE(queue_name?? => 'aq.que_shenshou',
?????????????????????????? queue_table => 'aq.que_shenshou_tab');
?? --開始這個queue
?? DBMS_AQADM.START_QUEUE(queue_name => 'aq.que_shenshou');
?? --添加一個subscriber
?? --這里可以添加n個subscriber，每個subscriber相當(dāng)于一個獨立的通道
?? --這里shenshou1為consumer name，接收端要根據(jù)這個名字來決定出隊
?? --aq.que_shenshou@db2.Lk 為接收端（db2）上的queue名和dblink的組合
?? subscriber := sys.aq$_agent('shenshou1', 'aq.que_shenshou@db2.lk' , NULL);
?? DBMS_AQADM.ADD_SUBSCRIBER(queue_name => 'que_shenshou',
???????????????????????????? subscriber => subscriber);
?? --創(chuàng)建propagation
?? DBMS_AQADM.SCHEDULE_PROPAGATION(queue_name?? => 'que_shenshou',
?????????????????????????????????? destination => 'db2.lk');
END;
至此，發(fā)送端隊列創(chuàng)建完畢。
可通過以下視圖查看：
select * from user_queue_tables;
select * from user_queues;
select * from user_queue_subscribers;
select * from user_queue_schedules;

oracle隊列