Caoyu

I think it is possible to create another autoconfiguration just for consumer like `RocketMQListenerAutoConfiguration`, this configuration only register and start consumer listener threads, is this more normal for decouple producers...

> 如果代码中没有实现RocketMQMessageListener 的annotation，是不会创建RocketMQListenerContainer的。 我现在是同一个项目同一套代码部署在两个集群,一个集群服务客户端http请求,一个集群专门处理后台脚本包括消息队列的消费者, 第一个集群我是不希望消费者启动过的,但是我找不到方法在第一个集群关掉consumer的 listener

> > > 如果代码中没有实现RocketMQMessageListener 的annotation，是不会创建RocketMQListenerContainer的。 > > > > > > 我现在是同一个项目同一套代码部署在两个集群,一个集群服务客户端http请求,一个集群专门处理后台脚本包括消息队列的消费者, 第一个集群我是不希望消费者启动过的,但是我找不到方法在第一个集群关掉consumer的 listener > > 这个解决了吗？我现在也遇到了这样的问题。springboot在启动时候回先去消费，而不是启动成功后再去消费。如果有大量的堆积mq，启动时候发现会特别慢。就是因为mq堆积导致在启动过程中先去消费造成的。 我自己写了AOP并配合配置中心的配置，在不需要消费者的项目里统一把消费者取消注入了。 具体就是AOP切面切入 ListenerContainerConfiguration.afterSingletonsInstantiated() 方法，然后around()方法不做任何操作直接返回void，以此达到不注入所有用RocketMQMessageListener注解的消费者实例，切面类本身用外部配置配合ConditionalOnProperty注解控制，可以实现用不同的配置打开或者关闭这个AOP的功能。

hello