HappyDoyourself

> > 如果代码中没有实现RocketMQMessageListener 的annotation，是不会创建RocketMQListenerContainer的。 > > 我现在是同一个项目同一套代码部署在两个集群,一个集群服务客户端http请求,一个集群专门处理后台脚本包括消息队列的消费者, 第一个集群我是不希望消费者启动过的,但是我找不到方法在第一个集群关掉consumer的 listener 这个解决了吗？我现在也遇到了这样的问题。springboot在启动时候回先去消费，而不是启动成功后再去消费。如果有大量的堆积mq，启动时候发现会特别慢。就是因为mq堆积导致在启动过程中先去消费造成的。

> 我还没实现。我的思路是通过实现BeanFactory、ApplicationRunner，尝试启动时候先不注入spring容器，想要通过spring的监听来达到同样的效果。但是我看了RocketMQAutoConfiguration源码里面是通过import引入的，只要有RocketMQMessageListener的注解，都会注入到容器，所以启动时候就就自动去加载。这就和我想通过监听重复了。目前也没有更好的思路。我想想按照你的思路怎么实现吧。Thanks

堆栈信息没有显示： 2022-09-06 18:00:13 | 2022-09-06 18:00:13.728 TID:N/A [ERROR] [com.alibaba.nacos.client.Worker] [c.a.n.c.r.client:99] --- Send request fail, request = ConfigBatchListenRequest{headers={charset=UTF-8, Client-AppName=unknown, Client-RequestToken=80cc1141f527888120cd1222451645bc, Client-RequestTS=1662458413527, exConfigInfo=true}, requestId='null'}, retryTimes = 1, errorMessage = Client not connected,...

> https://nacos.io/zh-cn/docs/2.0.0-compatibility.html 感谢回复，我还是不确定是客户端gRPC无法和服务端创建连接。telnet和本地都是通的。