Hacktoberfest 2026: le issue che i maintainer hanno segnato per ottobre, aperte e adatte ai principianti. Sfoglia le issue Hacktoberfest

Native-image之后无法连接namesvr,但是在jdk环境里面可以连接

Aperta
#633 8 commenti 0 reazioni 0 assegnatari Vedi su GitHub

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
4/5
Tempo stimato
3-5 giorni
Idoneità per principianti
38/100
Tipo di issue
Bug
Chiarezza
Da chiarire
Stato di attività
Attiva
Stack tecnologico
java

Direzione di ricerca

Inizia riproducendo la differenza tra gli ambienti JDK e Native Image con Spring Boot 3.1.6, rocketmq-spring-boot-starter 2.2.3 e la configurazione name-server mostrata. Traccia il fallimento da ListenerContainerConfiguration passando per MQClientInstance.updateTopicRouteInfoFromNameServer e NettyRemotingClient.invokeSync. Il lavoro è completato quando l'eseguibile nativo si connette a 192.168.192.214:8876 e registra correttamente entrambi i listener.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

版本:
SpringBoot3.1.6版本 和 rocketmq-spring-boot-starter 2.2.3版本

Native-Image之后错误信息
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'userRegisterListener': java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to <192.168.192.214:8876> failed
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:605) ~[ai:6.0.14]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:520) ~[ai:6.0.14]
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:325) ~[ai:6.0.14]
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234) ~[ai:6.0.14]
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:323) ~[ai:6.0.14]
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) ~[ai:6.0.14]
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:973) ~[ai:6.0.14]
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:950) ~[ai:6.0.14]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:616) ~[ai:6.0.14]
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:146) ~[ai:3.1.6]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:738) ~[ai:3.1.6]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:440) ~[ai:3.1.6]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:316) ~[ai:3.1.6]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1306) ~[ai:3.1.6]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1295) ~[ai:3.1.6]
at com.huyu.App.main(App.java:13) ~[ai:na]
at [email protected]/java.lang.invoke.LambdaForm$DMH/sa346b79c.invokeStaticInit(LambdaForm$DMH) ~[na:na]
Caused by: java.lang.RuntimeException: java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to <192.168.192.214:8876> failed
at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.registerContainer(ListenerContainerConfiguration.java:109) ~[ai:na]
at org.apache.rocketmq.spring.annotation.RocketMQMessageListenerBeanPostProcessor.postProcessAfterInitialization(RocketMQMessageListenerBeanPostProcessor.java:55) ~[ai:na]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsAfterInitialization(AbstractAutowireCapableBeanFactory.java:434) ~[ai:6.0.14]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1773) ~[ai:6.0.14]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:598) ~[ai:6.0.14]
... 16 common frames omitted
Caused by: java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to <192.168.192.214:8876> failed
at org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:671) ~[ai:5.0.0]
at org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:500) ~[ai:5.0.0]
at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.updateTopicSubscribeInfoWhenSubscriptionChanged(DefaultMQPushConsumerImpl.java:1206) ~[na:na]
at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.start(DefaultMQPushConsumerImpl.java:969) ~[na:na]
at org.apache.rocketmq.client.consumer.DefaultMQPushConsumer.start(DefaultMQPushConsumer.java:737) ~[na:na]
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.start(DefaultRocketMQListenerContainer.java:343) ~[ai:2.2.3]
at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.registerContainer(ListenerContainerConfiguration.java:106) ~[ai:na]
... 20 common frames omitted
Caused by: org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to <192.168.192.214:8876> failed
at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:436) ~[ai:5.0.0]
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:455) ~[na:na]
at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1785) ~[na:na]
at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1776) ~[na:na]
at org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:610) ~[ai:5.0.0]
... 26 common frames omitted

本地使用JDK:
a producer (ai-project) init on namesrv 192.168.192.214:8876
2024-02-26T22:52:24.294+08:00 INFO 25819 --- [ main] a.r.s.s.DefaultRocketMQListenerContainer : running container: DefaultRocketMQListenerContainer{consumerGroup='close-order-group', namespace='', nameServer='192.168.192.214:8876', topic='ORDER_CLOSE_TOPIC', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='', messageModel=CLUSTERING', tlsEnable=false, instanceName=DEFAULT}
2024-02-26T22:52:24.294+08:00 INFO 25819 --- [ main] o.a.r.s.a.ListenerContainerConfiguration : Register the listener to container, listenerBeanName:orderCloseListener, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_1
2024-02-26T22:52:24.325+08:00 INFO 25819 --- [ main] a.r.s.s.DefaultRocketMQListenerContainer : running container: DefaultRocketMQListenerContainer{consumerGroup='user-register-group', namespace='', nameServer='192.168.192.214:8876', topic='USER_REGISTER_SUCCESS_TOPIC', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='
', messageModel=CLUSTERING', tlsEnable=false, instanceName=DEFAULT}
2024-02-26T22:52:24.325+08:00 INFO 25819 --- [ main] o.a.r.s.a.ListenerContainerConfiguration : Register the listener to container, listenerBeanName:userRegisterListener, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_2
就可以连接成功

配置如下
rocketmq:
producer:
group: ai-project
retry-next-server: true
send-message-timeout: 10
name-server: 192.168.192.214:8876

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

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di apache/rocketmq-spring

Tutte le issue di apache/rocketmq-spring

Issue simili

Altre issue su Java

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.