The 'consumeThreadMax' in annotation @RocketMQMessageListener 到底有什么用
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Aptitud para principiantes
- 35/100
- Tipo de issue
- Error
- Claridad
- Necesita aclaración
- Estado de actividad
- Tranquilo
- Stack tecnológico
- java
- Área
- backend, distributed-systems
Línea de trabajo
Empieza comparando el comportamiento de RocketMQMessageListener y ConsumeMessageConcurrentlyService entre SDK 4.9.3 y 5.1.0, centrándote en consumeThreadMax, consumeThreadMin y la consumeRequestQueue sin límite utilizada por ThreadPoolExecutor. Rastrea cómo se aplican estos ajustes y, a continuación, aclara si consumeThreadMax desempeña realmente alguna función y documenta el resultado.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
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_"));
- Lenguaje dominante
- Java
- Estrellas
- 2.3k
- Forks
- 941
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Preparar el entorno
- Sin Dockerfile ni archivo de Docker Compose
- Tiene una plantilla de pull request
- Sin guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/rocketmq-spring
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operationsPosiblemente ocupada @wang-jiahua la tomó hace 56 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 88/100
apache/rocketmq-spring#780 · 3 comentarios ·
-
编译报错Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
apache/rocketmq-spring#692 · 1 comentario ·
-
消费者注册时候对nameserver取值有点问题Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
apache/rocketmq-spring#678 · 2 comentarios ·
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 82/100
apache/rocketmq-spring#670 · 1 comentario ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 62/100
apache/rocketmq-spring#609 · 3 comentarios ·
Todos los issues de apache/rocketmq-spring
Issues similares
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100
oracle/graalvm-reachability-metadata#11472 ·
Los mantenedores suelen responder en 1 día
-
OkHttp versions 5.4.0+ no longer include baseline-prof.txtPosiblemente ocupada Un pull request vinculado a esta issue está abierto o ya se fusionó. Abiertobug
Dificultad 1/5 Menos de una hora Aptitud para principiantes 83/100
lysine-dev/okhttp#9828 ·
Los mantenedores suelen responder en 1 día
-
status: waiting-for-triage
Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100
spring-projects/spring-ai#7269 ·
Los mantenedores suelen responder en 1 día
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 89/100
objectionary/hone-maven-plugin#1353 ·
Los mantenedores suelen responder en 9 días
-
ClassNotFoundException: io.netty.channel.kqueue.KQueueEventLoop stack trace printed during native build on main (Netty 4.2 removed the class)Posiblemente ocupada @gastaldi la tomó hoy. Abiertoarea/netty kind/bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
quarkusio/quarkus#57939 · 1 comentario ·
Los mantenedores suelen responder en 1 día