在出队过程中会话终止后 Oracle AQ 消息丢失

Question

我在 Oracle 11g R2 Windows 2008 R2 数据库上遇到 DBMS_AQ.deQueue 问题。当会话出队并在之后（提交或回滚之前）被终止时，特定消息将从队列中永久删除。我希望它仍然在队列中，或者至少在异常队列中。我执行以下步骤进行测试：

1. 从会话 1 入队，然后提交。 （参见下面的代码）
2. 从会话 2 出列。（参​​见下面的代码）
3. 会话 1: select * from MY_Q_T ->我的消息在这里仍然可见。
4. 会话 2：从 MY_Q_T 选择 * ->我的消息不再可见。
5. 终止会话 2（出队）会话。
6. 会话 1：从 MY_Q_T 选择 * ->我的消息不再可见。消息丢失。

这是一个错误吗？由于出队（/可见性）未设置为自主，所以当会话 2 被终止时，我希望消息仍然在队列中。有解决方法的想法吗？

用于入队和出队的代码：

ENQUEUE：

declare
    queue_options      DBMS_AQ.ENQUEUE_OPTIONS_T;
    message_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
    message_id         raw(16);
    pl                 MY_PAYLPOAD_T;
begin
    DBMS_AQ.enQueue(queue_name         => 'MY_Q',
                    enqueue_options    => queue_options,
                    message_properties => message_properties,
                    payload            => pl,
                    msgid              => message_id);
end;

DEQUEUE：

declare
    queue_options      DBMS_AQ.DEQUEUE_OPTIONS_T;
    message_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
    message_id         raw(2000);
    pl               MY_PAYLPOAD_T;
begin
    DBMS_AQ.DEQUEUE(queue_name         => 'MY_Q',
                  dequeue_options    => queue_options,
                  message_properties => message_properties,
                  payload            => pl,
                  msgid              => message_id);
end;

Answer 1

你如何终止会话？看起来您刚刚从会话注销，默认情况下会在客户端程序的会话中提交任何打开的事务。
由于出队事务已提交，因此该消息已从队列中消失。

您可以通过在表中插入一行、终止/关闭会话并检查是否添加了该行来验证这一点。