登录
首页 >  文章 >  java教程

SpringBoot3.2.2接入RocketMQ5.1.2报错处理攻略

时间:2025-04-28 09:45:13 115浏览 收藏

在使用Spring Boot 3.2.2尝试连接RocketMQ 5.1.2时,可能会遇到启动时的报错问题。本文详细介绍了在Windows 10环境下,启动namesrv、broker和proxy,并配置RocketMQ的name-server地址为本机IP:192.168.50.20:9876后,仍出现报错的情况。报错信息显示为“Started container failed”,并伴随“java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to 192.168.50.20:9876 failed”。针对此问题,文章提供了通过调整POM文件配置来解决的方法,并给出了具体的POM文件示例。

如何解决Spring Boot 3.2.2连接RocketMQ 5.1.2时报错的问题?

解决Spring Boot 3.2.2连接RocketMQ 5.1.2时报错的方案

在使用Spring Boot 3.2.2尝试连接RocketMQ 5.1.2时,可能会遇到启动时的报错问题。在Windows 10环境下启动了namesrv、broker和proxy,并配置了RocketMQ的name-server地址为本机IP:192.168.50.20:9876,但启动时仍会出现报错。报错信息如下:

<code>Started container failed. DefaultRocketMQListenerContainer{consumerGroup='topic_02_CONSUMER', namespace='', namespaceV2='', nameServer='192.168.50.20:9876', topic='topic_02', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='*', messageModel=CLUSTERING', tlsEnable=false, instanceName=DEFAULT}
java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to 192.168.50.20:9876> failed</code>

用户的配置文件为:

<code>rocketmq:
  name-server: 192.168.50.20:9876</code>

使用的版本信息包括:RocketMQ版本5.1.2,rocketmq-spring-boot版本2.3.2,以及Spring Boot版本3.2.2。用户尝试了降版本处理,但问题依旧存在。

解决此类报错问题的一种方法是调整项目的POM文件配置。以下是一个调整后的POM文件配置示例:

<code><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemalocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelversion>4.0.0</modelversion><groupid>com.example</groupid><artifactid>rocketmq-test</artifactid><version>0.0.1-SNAPSHOT</version><parent><groupid>org.springframework.boot</groupid><artifactid>spring-boot-starter-parent</artifactid><version>3.2.2</version></parent><dependencies><dependency><groupid>org.springframework.boot</groupid><artifactid>spring-boot-starter</artifactid></dependency><dependency><groupid>org.apache.rocketmq</groupid><artifactid>rocketmq-spring-boot-starter</artifactid><version>2.3.2</version></dependency><dependency><groupid>org.apache.rocketmq</groupid><artifactid>rocketmq-client</artifactid><version>5.1.2</version></dependency><dependency><groupid>org.apache.rocketmq</groupid><artifactid>rocketmq-acl</artifactid><version>5.1.2</version></dependency><dependency><groupid>org.apache.rocketmq</groupid><artifactid>rocketmq-common</artifactid><version>5.1.2</version></dependency><dependency><groupid>org.apache.rocketmq</groupid><artifactid>rocketmq-remoting</artifactid><version>5.1.2</version></dependency><dependency><groupid>org.apache.rocketmq</groupid><artifactid>rocketmq-srvutil</artifactid><version>5.1.2</version></dependency><dependency><groupid>org.apache.rocketmq</groupid><artifactid>rocketmq-proto</artifactid><version>2.0.2</version></dependency></dependencies><build><plugins><plugin><groupid>org.springframework.boot</groupid><artifactid>spring-boot-maven-plugin</artifactid></plugin></plugins></build></project></code>

通过调整POM文件的依赖配置,可以尝试解决Spring Boot 3.2.2连接RocketMQ 5.1.2时的报错问题。

到这里,我们也就讲完了《SpringBoot3.2.2接入RocketMQ5.1.2报错处理攻略》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于的知识点!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>