快捷導(dǎo)航

關(guān)于springboot使用rocketmq?RocketMQMessageListener參數(shù)問題

更新時(shí)間：2022年11月18日 11:27:54 作者：路過君_P

這篇文章主要介紹了springboot使用rocketmq?RocketMQMessageListener參數(shù)問題，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值需要的朋友可以參考下

1. consumerGroup 消費(fèi)者分組
2. topic 主題
3. selectorType 消息選擇器類型
4. selectorExpression 選擇器表達(dá)式
5. consumeMode 消費(fèi)模式
6. messageModel 消息模型
7. consumeThreadMax 最大線程數(shù)
8. consumeTimeout 超時(shí)時(shí)間
9. accessKey
10. secretKey
11. enableMsgTrace 啟用消息軌跡
12. customizedTraceTopic 自定義的消息軌跡主題
13. nameServer 命名服務(wù)器地址
14. accessChannel

參數(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)識(shí)訂閱所有消息
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

語(yǔ)法:

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 超時(shí)時(shí)間

默認(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:}
沒有配置此配置項(xiàng)則使用默認(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)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: