參數(shù) version 4.6

1. consumerGroup 消費(fèi)者分組

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 消費(fèi)模式

• 默認(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)文章希望大家以后多多支持腳本之家！

最新評論