[I] rocketmq-spring-boot-starter 如何支持广播模式，尝试1天了还是不通；只能使用集群模式？怎么解决？ [rocketmq]

[via GitHub]

jikuanyu opened a new issue, #9046:
URL: https://github.com/apache/rocketmq/issues/9046

   ### Before Creating the Bug Report
   
   - [X] I found a bug, not just asking a question, which should be created in 
[GitHub Discussions](https://github.com/apache/rocketmq/discussions).
   
   - [X] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq/discussions)  of this 
repository and believe that this is not a duplicate.
   
   - [X] I have confirmed that this bug belongs to the current repository, not 
other repositories of RocketMQ.
   
   
   ### Runtime platform environment
   
   Windows10
   
   ### RocketMQ version
   
   RocketMQ version5.0
   
   ### JDK Version
   
   jdk1.8
   
   ### Describe the Bug
   
   rocketmq-spring-boot-starter 调整广播模式无法接收消息。只有集群模式才能接收到消息。
   因为是旧的项目我只能使用springboot2.1.x。
   
   
   ### Steps to Reproduce
   
   ```
   import lombok.extern.slf4j.Slf4j;
   import org.apache.rocketmq.spring.annotation.MessageModel;
   import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
   import org.apache.rocketmq.spring.annotation.SelectorType;
   import org.apache.rocketmq.spring.core.RocketMQListener;
   import org.springframework.stereotype.Service;
   
   /**
    * @author yujikuan
    * @Classname SyncBookMqService
    * @Description 同步培优服务务
    * @Date 2024/12/10 15:59
    */
   @Service
   @Slf4j
   @RocketMQMessageListener(topic = "nrms_qg_normal_topic",
           consumerGroup = "nrms_qg_group",
           accessKey = "${rocketmq.default.username}", secretKey = 
"${rocketmq.default.password}",
           selectorType = SelectorType.TAG
         //  ,messageModel = MessageModel.BROADCASTING
   )
   //接收消息
   public class SyncBookMqService implements RocketMQListener<String> {
       @Override
       public void onMessage(String s) {
           log.info("接收到同步数据库消息：{}", s);
       }
   }
   
   //发送消息
       @GetMapping("send2")
       public ResponseEntity<ResponseWrapper> send2(String message) {
   
           log.info("message={}",message);
           org.springframework.messaging.Message msg = 
MessageBuilder.withPayload("rsend2 message " + message).build();
               String topic="nrms_qg_normal_topic";
               String tagId="syncBookDBOutputTag";
   
           rocketmqTemplate.send(topic +":"+tagId, msg);
           return WrapResponseMapper.ok();
       }
   ```
   配置
   ```
   rocketmq:
     name-server: ${rocketmq.default.address}
     producer:
       # 发送消息超时时间，默认3000
       sendMessageTimeout: 10000
       # 发送消息失败重试次数，默认2
       retryTimesWhenSendFailed: 2
       # 异步消息重试此处，默认2
       retryTimesWhenSendAsyncFailed: 2
       # 消息最大长度，默认1024 * 1024 * 4(默认4M)
       maxMessageSize: 40960
       # 压缩消息阈值，默认4k(1024 * 4)
       compressMessageBodyThreshold: 4096
       # 是否在内部发送失败时重试另一个broker，默认false
       retryNextServer: true
       access-key: ${rocketmq.default.username}
       secret-key: ${rocketmq.default.password}
       group: qqrms-res-producer-group
   依赖
   ```
         <dependency>
               <groupId>org.apache.rocketmq</groupId>
               <artifactId>rocketmq-spring-boot-starter</artifactId>
               <version>2.1.1</version>
              <!--<exclusions>
                   <exclusion>
                       <artifactId>rocketmq-client</artifactId>
                       <groupId>org.apache.rocketmq</groupId>
                   </exclusion>
                   <exclusion>
                       <artifactId>rocketmq-common</artifactId>
                       <groupId>org.apache.rocketmq</groupId>
                   </exclusion>
                   <exclusion>
                       <artifactId>rocketmq-logging</artifactId>
                       <groupId>org.apache.rocketmq</groupId>
                   </exclusion>
                   <exclusion>
                       <artifactId>rocketmq-remoting</artifactId>
                       <groupId>org.apache.rocketmq</groupId>
                   </exclusion>
               </exclusions>-->
           </dependency>
   
   
   ### What Did You Expect to See?
   
   能够每一个服务实例都收到消息。
   
   ### What Did You See Instead?
   
   能够每一个服务实例都收到消息。
   
   ### Additional Context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org