關(guān)于springboot使用rocketmq?RocketMQMessageListener參數(shù)問題
參數(shù) version 4.6
1. consumerGroup 消費者分組
2. topic 主題
3. selectorType 消息選擇器類型
默認(rèn)值 SelectorType.TAG 根據(jù)TAG選擇
僅支持表達(dá)式格式如:“tag1 || tag2 || tag3”,如果表達(dá)式為null或者“*”標(biāo)識訂閱所有消息
SelectorType.SQL92 根據(jù)SQL92表達(dá)式選擇
- 關(guān)鍵字:
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 選擇器表達(dá)式
默認(rèn)值 ”*“
5. consumeMode 消費模式
- 默認(rèn)值 ConsumeMode.CONCURRENTLY 并行處理
- ConsumeMode.ORDERLY 按順序處理
6. messageModel 消息模型
- 默認(rèn)值 MessageModel.CLUSTERING 集群
- MessageModel.BROADCASTING 廣播
7. consumeThreadMax 最大線程數(shù)
默認(rèn)值 64
8. consumeTimeout 超時時間
默認(rèn)值 30000ms
9. accessKey
默認(rèn)值 ${rocketmq.consumer.access-key:}
10. secretKey
默認(rèn)值 ${rocketmq.consumer.secret-key:}
11. enableMsgTrace 啟用消息軌跡
默認(rèn)值 true
12. customizedTraceTopic 自定義的消息軌跡主題
默認(rèn)值 ${rocketmq.consumer.customized-trace-topic:}
沒有配置此配置項則使用默認(rèn)的主題
13. nameServer 命名服務(wù)器地址
默認(rèn)值 ${rocketmq.name-server:}
14. accessChannel
默認(rèn)值 ${rocketmq.access-channel:}
到此這篇關(guān)于springboot使用rocketmq RocketMQMessageListener參數(shù)的文章就介紹到這了,更多相關(guān)springboot使用rocketmq內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
SpringBoot中實現(xiàn)數(shù)據(jù)脫敏處理的方法詳解
項目開發(fā)中,在處理敏感信息時,數(shù)據(jù)脫敏是一項重要的安全措施,本文主要為大家介紹了如何在SpringBoot項目中進(jìn)行數(shù)據(jù)脫敏處理,有需要的可以了解下2025-03-03
Java19新特性中結(jié)構(gòu)化并發(fā)的使用
Java19在并發(fā)編程領(lǐng)域引入了一個全新的概念:結(jié)構(gòu)化并發(fā),這一特性旨在簡化并發(fā)任務(wù)的管理,提升多線程程序的可維護(hù)性和安全性,使其生命周期和控制流更加有序和明確,感興趣的可以了解一下2024-09-09
java wait()/notify() 實現(xiàn)生產(chǎn)者消費者模式詳解
這篇文章主要介紹了java wait()/notify() 實現(xiàn)生產(chǎn)者消費者模式詳解,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-07-07
Mybatis有查詢結(jié)果但存不進(jìn)實體類的解決方案
這篇文章主要介紹了Mybatis有查詢結(jié)果但存不進(jìn)實體類的解決方案,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-11-11
java配置多個過濾器優(yōu)先級以及幾個常用過濾器操作
這篇文章主要介紹了java配置多個過濾器優(yōu)先級以及幾個常用過濾器的操作,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-07-07

