作者:杨大友,余川 测试员:王健
开发工具:Oracle Jdeveloper 10131
软硬件环境:
操作系统linux redhat 3.0 数据库为Oracle 10G 10.0.2
应用服务器为SOA Application Server 10131
开发语言:java
关于体系结构,说多了也让人觉得晕.我直接示例一个做法,至于理解,就慢慢看书吧!
步骤:
1.
创建Oracle AQ
首先以超级用户登陆数据库,修改必要参数,建立AQ用户,并给权限.我是使用sqlplus
Conn sys/******@SID as sysdba
Alter system set AQ_TM_PROCESSES=6
Alter system set JOB_QUEUE_PROCESSES=10
Create user aq identified by aq1234 default tablespace users
temporary tablespace temp quota unlimited on users;
Grant connect,resource to aq;
Grant aq_administrator_role to aq;
Grant execute on dbms_aqadm to aq;
Grant execute on dbms_aq to aq;
Grant create any table to aq;
Grant enqueue any queue,dequeue any queue to aq;
在这插一句,这样创建只是为了便于操作,大家在外面使用应该再创建用户,只需要授予connect,resource,操作dbms_aqadm和
dbms_aq的权限就足够了.如果你想用一个用户操作另外一个用户的queue(比如aq1操作aq创建的queue),那么只需要执行下面的命令:
Conn aq/aq1234@sid
Execute
dbms_aqadm.grant_queue_privilege(‘enqueue’,’aq_queue’,’aq1’,false);
解释:第一个参数是权限,可以有三个值,enqueue,dequeue,all(all就是前面两个都有).第二个参数是queue的名字,第三个参数的把权限给哪个人,第四个的意思,暂不明白,就不说.
下面就是建立queue
tables和queue的时间了.用oem来创建是最简单的,大家自己看一下,我把用命令创建的过程说下:
Conn aq/aq1234@sid
--create a queue table.
BEGIN
dbms_aqadm.create_queue_table(
queue_table=>'JMSTEST_QT',
queue_payload_type=>'SYS.AQ$_JMS
_MESSAGE',
multiple_consumers =>
false,
comment => 'Queue Table For Resource Provider');
END;
/
--create a queue
BEGIN &
