dbms_aq 是 oracle 原生支持触发器与消息队列集成的唯一可靠路径，需显式授权、使用 object 类型 payload、autonomous_transaction 入队，并配 jndi 数据源供 java 消费端读取。
dbms_aq 是 oracle 原生支持触发器与消息队列集成的唯一可靠路径。用外部中间件（如 rabbitmq、msmq）或 xp_cmdshell 调用系统命令的方式，要么受限于 oracle 版本（如 11g 不支持高版本 jdk），要么存在严重安全风险，实际生产环境基本不可行。
必须先授权并启用 AQ 功能
Oracle 默认不开放高级队列权限，未授权就调用 DBMS_AQ 会直接报 ORA-01031: insufficient privileges。管理员需执行：
GRANT EXECUTE ON SYS.DBMS_AQ TO your_user;GRANT EXECUTE ON SYS.DBMS_AQADM TO your_user;- 如果涉及 JMS 消息格式，还需
GRANT EXECUTE ON SYS.DBMS_AQ_BQVIEW TO your_user;
注意：不能只给 EXECUTE_CATALOG_ROLE —— 这个角色不包含 AQ 包权限，必须显式授权。
payload 类型必须是 OBJECT 或 SYS.AQ$_JMS_MESSAGE
自定义消息结构必须用 CREATE OR REPLACE TYPE 定义为 SQL OBJECT，不能用 PL/SQL RECORD。例如：
CREATE OR REPLACE TYPE order_event_payload AS OBJECT ( order_id NUMBER, status VARCHAR2(20), updated_at DATE );
常见错误是试图在触发器里直接构造 JSON 字符串或用 VARCHAR2 存消息体——DBMS_AQ.ENQUEUE 会拒绝非合法 payload 类型，报 ORA-24033: invalid queue payload type。
若需兼容 Java 消费端，建议直接用 SYS.AQ$_JMS_MESSAGE，避免自定义类型跨 schema 解析失败。
触发器中调用 ENQUEUE 必须用 AUTONOMOUS_TRANSACTION
否则队列入列操作会绑定到原 DML 事务中：一旦主事务回滚，消息也会消失，失去“事件已发生”的语义保障。
正确写法：
CREATE OR REPLACE TRIGGER tr_order_insert
AFTER INSERT ON orders
FOR EACH ROW
DECLARE
PRAGMA AUTONOMOUS_TRANSACTION;
l_enqueue_options DBMS_AQ.ENQUEUE_OPTIONS_T;
l_message_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
l_msgid RAW(16);
l_payload order_event_payload;
BEGIN
l_payload := order_event_payload(:NEW.order_id, 'CREATED', SYSDATE);
DBMS_AQ.ENQUEUE(
queue_name => 'order_events_q',
enqueue_options => l_enqueue_options,
message_properties => l_message_properties,
payload => l_payload,
msgid => l_msgid
);
COMMIT; -- autonomous transaction 必须显式提交
END;
漏掉 COMMIT 会导致入列消息被静默丢弃；用 DBMS_OUTPUT.PUT_LINE 调试时也看不到输出——autonomous transaction 独立于父会话输出缓冲区。
Java 消费端读取 AQ 队列要配对使用 JNDI 数据源
Oracle AQ 不是标准 JMS Broker，Java 端不能用通用 ConnectionFactory。必须通过 Oracle 提供的 oracle.jms.AQjmsFactory 获取连接：
QueueConnectionFactory qcf = AQjmsFactory.getConnectionFactory("jdbc:oracle:thin:@//host:1521/orcl");
QueueConnection qc = qcf.createQueueConnection("user", "pwd");
QueueSession qs = qc.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue q = ((AQjmsSession)qs).getQueue("YOUR_SCHEMA", "order_events_q");
QueueReceiver qr = qs.createReceiver(q);
关键点：getQueue() 第一个参数必须是 schema 名（大写），不是当前连接用户名；若用连接池（如 HikariCP），需确保数据源配置中 connectionInitSql 包含 ALTER SESSION SET CURRENT_SCHEMA=YOUR_SCHEMA，否则 ORA-00942: table or view does not exist。
真正容易被忽略的是：AQ 队列本身不自动清理已消费消息。默认 retention_time 是 0（即立即删除），但如果消费端异常中断、消息未被 ACK，它会滞留在队列中，且无法被重复消费——这和 Kafka/RabbitMQ 的“重试+死信”逻辑完全不同。上线前务必确认业务能否容忍这种一次性语义。
