如何创建Oracle Advance Queue并通过PL/SQL发送XML负载？

没问题！既然你已经会用PL/SQL生成XML负载了，那咱们直接把Oracle AQ的创建和消息发送流程拆成实操步骤，一步一步来：

创建AQ需要三个核心步骤：创建队列表、创建队列、启动队列，全部用PL/SQL就能搞定。

1. 创建队列表（存储消息的底层表） #

队列表是AQ用来存储消息的容器，因为你要发送XML类型的消息，所以指定payload_type为SYS.XMLTYPE：

BEGIN
  DBMS_AQADM.CREATE_QUEUE_TABLE(
    queue_table        => 'XML_MSG_QUEUE_TABLE', -- 自定义队列表名
    queue_payload_type => 'SYS.XMLTYPE',        -- 消息类型为XML
    multiple_consumers => FALSE                 -- 单消费者模式，多消费者设为TRUE
  );
END;
/

2. 创建队列（基于队列表的逻辑队列） #

队列是你实际收发消息的入口，关联刚才创建的队列表：

BEGIN
  DBMS_AQADM.CREATE_QUEUE(
    queue_name  => 'XML_MSG_QUEUE', -- 自定义队列名
    queue_table => 'XML_MSG_QUEUE_TABLE' -- 关联上面的队列表
  );
END;
/

3. 启动队列（必须启动才能收发消息） #

刚创建的队列默认是停止状态，得启动它才能用：

BEGIN
  DBMS_AQADM.START_QUEUE(queue_name => 'XML_MSG_QUEUE');
END;
/

这一步就可以结合你已有的PL/SQL生成XML的逻辑，把XML作为消息发送到队列里：

DECLARE
  v_xml_payload        SYS.XMLTYPE;
  v_enqueue_options    DBMS_AQ.ENQUEUE_OPTIONS_T;
  v_msg_properties     DBMS_AQ.MESSAGE_PROPERTIES_T;
  v_msgid              RAW(16); -- 消息唯一标识
BEGIN
  -- 这里替换成你自己的PL/SQL生成XML的代码
  -- 示例：生成一个订单XML
  v_xml_payload := SYS.XMLTYPE.CREATEXML(
    '<order>
       <order_id>ORD-2024-001</order_id>
       <customer>Alice Smith</customer>
       <items>
         <item>
           <product>Wireless Headphones</product>
           <quantity>1</quantity>
           <price>199.99</price>
         </item>
       </items>
     </order>'
  );

  -- 执行入队操作
  DBMS_AQ.ENQUEUE(
    queue_name         => 'XML_MSG_QUEUE',
    enqueue_options    => v_enqueue_options, -- 默认入队选项即可
    message_properties => v_msg_properties,  -- 默认消息属性即可
    payload            => v_xml_payload,     -- 你的XML负载
    msgid              => v_msgid            -- 返回消息ID
  );

  COMMIT; -- 必须提交，消息才会真正写入队列
  DBMS_OUTPUT.PUT_LINE('XML消息已成功发送，消息ID: ' || RAWTOHEX(v_msgid));
END;
/

确保你的数据库用户拥有以下权限（可以让DBA帮你授予）：

• 授予AQ管理员角色（快捷方式）：

GRANT AQ_ADMINISTRATOR_ROLE TO your_username;

• 或者更细粒度的权限（更安全）：

GRANT EXECUTE ON DBMS_AQ TO your_username;
GRANT EXECUTE ON DBMS_AQADM TO your_username;
GRANT CREATE ANY QUEUE TABLE TO your_username;
GRANT CREATE ANY QUEUE TO your_username;

如果需要验证消息是否成功入队，可以查询队列表：

SELECT qt.user_data.getClobVal() AS xml_message
FROM XML_MSG_QUEUE_TABLE qt;

内容的提问来源于stack exchange，提问作者pratheeba