關于springboot使用rocketmq?RocketMQMessageListener參數(shù)問題
參數(shù) version 4.6
1. consumerGroup 消費者分組
2. topic 主題
3. selectorType 消息選擇器類型
默認值 SelectorType.TAG 根據(jù)TAG選擇
僅支持表達式格式如:“tag1 || tag2 || tag3”,如果表達式為null或者“*”標識訂閱所有消息
SelectorType.SQL92 根據(jù)SQL92表達式選擇
- 關鍵字:
AND, OR, NOT, BETWEEN, IN, TRUE, FALSE, IS, NULL
- 數(shù)據(jù)類型:
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 消費模式
- 默認值 ConsumeMode.CONCURRENTLY 并行處理
- ConsumeMode.ORDERLY 按順序處理
6. messageModel 消息模型
- 默認值 MessageModel.CLUSTERING 集群
- MessageModel.BROADCASTING 廣播
7. consumeThreadMax 最大線程數(shù)
默認值 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:}
到此這篇關于springboot使用rocketmq RocketMQMessageListener參數(shù)的文章就介紹到這了,更多相關springboot使用rocketmq內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Java多線程使用阻塞隊列實現(xiàn)生產(chǎn)者消費者模型詳解
這篇文章主要介紹了Java多線程使用阻塞隊列實現(xiàn)生產(chǎn)者消費者模型詳解,主要講解阻塞隊列的特性、實際開發(fā)中常用的到的生產(chǎn)者消費者模型,以及生產(chǎn)者消費者模型解耦合、削峰填谷的好處,需要的朋友可以參考下2023-07-07SpringCloud gateway如何修改返回數(shù)據(jù)
這篇文章主要介紹了SpringCloud gateway如何修改返回數(shù)據(jù)的操作,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-06-06