springboot使用rocketmq RocketMQMessageListener參數


參數 version 4.6

1. consumerGroup 消費者分組

2. topic 主題

3. selectorType 消息選擇器類型

  1. 默認值 SelectorType.TAG 根據TAG選擇
    僅支持表達式格式如:“tag1 || tag2 || tag3”,如果表達式為null或者“*”標識訂閱所有消息
  2. SelectorType.SQL92 根據SQL92表達式選擇
  • 關鍵字:
    AND, OR, NOT, BETWEEN, IN, TRUE, FALSE, IS, NULL
  • 數據類型:
    Boolean, like: TRUE, FALSE
    String, like: ‘abc’
    Decimal, like: 123
    Float number, like: 3.1415
  • 語法:
AND, OR
>, >=, <, <=, =
BETWEEN A AND B, equals to >=A AND <=B
NOT BETWEEN A AND B, equals to >B OR <A
IN ('a', 'b'), equals to ='a' OR ='b', this operation only support String type.
IS NULL, IS NOT NULL, check parameter whether is null, or not.
=TRUE, =FALSE, check parameter whether is true, or false.
  • 樣例:
(a > 10 AND a < 100) OR (b IS NOT NULL AND b=TRUE)

4. selectorExpression 選擇器表達式

默認值 ”*“

5. consumeMode 消費模式

  1. 默認值 ConsumeMode.CONCURRENTLY 並行處理
  2. ConsumeMode.ORDERLY 按順序處理

6. messageModel 消息模型

  1. 默認值 MessageModel.CLUSTERING 集群
  2. MessageModel.BROADCASTING 廣播

7. consumeThreadMax 最大線程數

默認值 64

8. consumeTimeout 超時時間

默認值 30000ms

9. accessKey

默認值 ${rocketmq.consumer.access-key:}

10. secretKey

默認值 ${rocketmq.consumer.secret-key:}

11. enableMsgTrace 啟用消息軌跡

默認值 true

12. customizedTraceTopic 自定義的消息軌跡主題

默認值 ${rocketmq.consumer.customized-trace-topic:}
沒有配置此配置項則使用默認的主題

13. nameServer 命名服務器地址

默認值 ${rocketmq.name-server:}

14. accessChannel

默認值 ${rocketmq.access-channel:}


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM