1038      iPhone_iPad_Mac_apple

狀態不一致___異常類別_產品使用問題_消息隊列 MQ-阿裏雲

1. 消息不合法

可能產生的原因

一般是消息屬性、消息內容不合法，不合法的情況有：

• 消息為空
• 消息內容為空
• 消息內容長度為0
• 消息內容超過限定長度

建議解決方案

請確保消息沒有以上的不合法情況，並根據異常提示進行解決。

2. 參數不合法

可能產生的原因

參數不合法的情況有以下幾種：

建議解決方案

按照如下步驟操作：

1. 按照異常提示修改客戶端對應參數的配置，確保其在合理範圍內；
2. 重啟應用。

3. 客戶端狀態異常

可能產生的原因

1. 創建 Consumer、Producer 之後未顯示調用 start() 方法來啟動客戶端；
2. 創建 Consumer、Producer 之後 start() 過程有異常導致客戶端啟動失敗；
3. 創建 Consumer、Producer 並成功調用 start() 方法後，顯示調用了 shutdown() 方法關閉了客戶端；

建議解決方案

按如下步驟操作：

1. 確保創建 Consumer、Producer 之後調用 start() 保證客戶端處於啟動狀態；
2. 查看 ons.log 判斷在客戶端在啟動過程中是否有異常。

4. 訂閱關係不一致

問題描述

在不同的 JVM 中啟動了多個 Consumer，並且給相同的 Consumer ID 配置了不同的 Topic，或者是相同的 Topic 但 Tag 不同，最終導致訂閱關係不一致，消息不符合預期。

錯誤代碼示例

錯誤示例一：同一個訂閱組（CID-MQ-FAQ）訂閱的 Topic 不同（分別是 MQ-FAQ-TOPIC-1、MQ-FAQ-TOPIC-2）。

JVM-1上的代碼:

    Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-1", "NM-MQ-FAQ", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();

     Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-2", "NM-MQ-FAQ", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();

    Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-1", "NM-MQ-FAQ-1", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();

     Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-1", "NM-MQ-FAQ-2", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();