Oracle AQ能否用多个JMS监听器分类型出队特定自定义消息？

完全可以将A、B类型消息放入单个Oracle AQ队列，通过自定义属性区分类型，配合JMS消息选择器实现分类型消费。针对你遇到的选择器失效问题，下面给出具体的排查和解决方法：

一、入队时正确设置JMS属性的方式 #

你之前的错误在于混淆了消息体属性和JMS消息属性：消息选择器只能过滤JMS层面的属性（标准属性/自定义属性），无法识别消息体内部的字段。正确的设置方式分两种场景：

1. Java代码入队（使用Oracle AQ JMS API） #

直接通过JMS消息对象设置自定义属性，而非操作消息体：

// 初始化AQ会话、生产者等逻辑省略
AQjmsTextMessage msg = (AQjmsTextMessage) session.createTextMessage("你的业务 payload");
// 设置自定义JMS属性，用于选择器过滤
msg.setStringProperty("MSG_TYPE", "A"); 
producer.send(msg);

2. PL/SQL入队 #

通过DBMS_AQ.MESSAGE_PROPERTIES_T的user_property设置属性，确保属性名能被JMS监听器识别：

DECLARE
  enq_msgid RAW(16);
  enq_prop DBMS_AQ.ENQUEUE_PROPERTIES_T;
  msg_payload YOUR_BUSINESS_PAYLOAD_TYPE; -- 替换为你的消息体类型
  msg_prop DBMS_AQ.MESSAGE_PROPERTIES_T;
BEGIN
  msg_payload := YOUR_BUSINESS_PAYLOAD_TYPE('业务内容');
  -- 设置自定义属性
  msg_prop.user_property('MSG_TYPE') := 'B';
  DBMS_AQ.ENQUEUE(
    queue_name => 'YOUR_QUEUE_NAME',
    enqueue_properties => enq_prop,
    message_properties => msg_prop,
    payload => msg_payload,
    msgid => enq_msgid
  );
  COMMIT;
END;
/

二、监听器端消息选择器的正确配置 #

确保选择器语法符合JMS规范，且属性名、值与入队时完全匹配（值大小写敏感，属性名Oracle默认不敏感，但建议保持一致）：

1. Spring Boot JMS监听器示例 #

// 监听A类型消息
@JmsListener(destination = "YOUR_QUEUE_NAME", selector = "MSG_TYPE = 'A'")
public void handleTypeAMessage(Message message) {
    // 转换消息、调用第三方A系统API逻辑
}

// 监听B类型消息
@JmsListener(destination = "YOUR_QUEUE_NAME", selector = "MSG_TYPE = 'B'")
public void handleTypeBMessage(Message message) {
    // 转换消息、调用第三方B系统API逻辑
}

2. 原生JMS监听器示例 #

// 创建针对A类型的消费者
MessageConsumer consumerA = session.createConsumer(queue, "MSG_TYPE = 'A'");
consumerA.setMessageListener(new MessageListener() {
    @Override
    public void onMessage(Message message) {
        // 处理A类型消息
    }
});

三、排查问题的关键步骤 #

如果还是失效，按以下步骤验证：

1. 检查属性是否正确传递：临时去掉选择器，消费消息后打印所有JMS属性，确认MSG_TYPE是否存在，值是否正确。
2. 核对选择器语法：确保没有拼写错误，比如引号使用正确（必须是单引号）、属性名和入队时一致。
3. 确认队列类型：Oracle AQ队列需是JMS兼容的队列（比如SYS.AQ$_JMS_TEXT_MESSAGE类型），而非原生AQ队列。

四、顺序性保障说明 #

你提到的同一类型消息顺序性需求，只要单个类型对应一个单线程监听器（默认JMS监听器都是单线程），Oracle AQ的FIFO特性就能保证消息顺序，无需额外配置。

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