The 'consumeThreadMax' in annotation @RocketMQMessageListener 到底有什么用
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Idoneità per principianti
- 35/100
- Tipo di issue
- Bug
- Chiarezza
- Da chiarire
- Stato di attività
- Tranquilla
- Stack tecnologico
- java
- Ambito
- backend, distributed-systems
Direzione di ricerca
Inizia confrontando il comportamento di RocketMQMessageListener e ConsumeMessageConcurrentlyService tra SDK 4.9.3 e 5.1.0, concentrandoti su consumeThreadMax, consumeThreadMin e sulla consumeRequestQueue non limitata utilizzata da ThreadPoolExecutor. Traccia il modo in cui queste impostazioni vengono applicate, quindi chiarisci se consumeThreadMax svolge effettivamente un ruolo e documenta il risultato.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
rocketmq RocketMQMessageListener 注解中有 consumeThreadMax， consumeThreadNumber 参数，在我之前使用的 sdk 4.9.3 中，consumeThreadMax 被标记成过期，可以参看源码，可以看到 consumeThreadMax 属性是不会生效的。而最近在升级 sdk 到 5.1.0 时，发现过期标记被去除了，而且 consumeThreadMax 和 consumeThreadMin 会被正确设置。而在 ConsumeMessageConcurrentlyService 类中，consumeRequestQueue 的定义却又是使用无界队列，这我就很困惑了，这个参数到底有没有用？ ConsumeMessageConcurrentlyService 类里有如下声明：
this.consumeExecutor = new ThreadPoolExecutor(this.defaultMQPushConsumer.getConsumeThreadMin(), this.defaultMQPushConsumer.getConsumeThreadMax(), 60000L, TimeUnit.MILLISECONDS, this.consumeRequestQueue, new ThreadFactoryImpl("ConsumeMessageThread_"));
- Lingua principale
- Java
- Stelle
- 2.3k
- Fork
- 941
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Preparare l'ambiente
- Nessun Dockerfile né file Docker Compose
- Ha un modello di pull request
- Nessuna guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di apache/rocketmq-spring
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operationsForse già presa @wang-jiahua l’ha presa 57 giorni fa. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 88/100
apache/rocketmq-spring#780 · 3 commenti ·
-
编译报错Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
apache/rocketmq-spring#692 · 1 commento ·
-
消费者注册时候对nameserver取值有点问题Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 68/100
apache/rocketmq-spring#678 · 2 commenti ·
-
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 82/100
apache/rocketmq-spring#670 · 1 commento ·
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 62/100
apache/rocketmq-spring#609 · 3 commenti ·
Tutte le issue di apache/rocketmq-spring
Issue simili
-
bug
Difficoltà 2/5 1-3 ore Idoneità per principianti 73/100
I maintainer di solito rispondono entro 2 giorni
-
code-health feature/sync OS/Android QA/Test-Plan-Specified QA/Yes
Difficoltà 2/5 1-3 ore Idoneità per principianti 75/100
brave/brave-browser#60327 ·
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
aws/context-ontology-accelerator#325 ·
I maintainer di solito rispondono entro 1 giorno
-
The README tells to run `mvn jeo:disassemble`, which fails with `No plugin found for prefix 'jeo'`Aperta
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 82/100
objectionary/jeo-maven-plugin#1938 ·
I maintainer di solito rispondono entro 2 giorni
-
effort/l priority/p2 risk/high triage/deferred
Difficoltà 2/5 1-3 ore Idoneità per principianti 77/100
iflytek/skillhub#1039 · 1 commento ·
I maintainer di solito rispondono entro 1 giorno