博客网站首页设计网站 伪静态

当前位置： 首页 > news >正文

博客网站首页设计,网站 伪静态,成都app开发价格表,免费的网站后台管理系统文章目录 前言一、RocketMQ 连接报错处理1.1 报错信息1.2 修改 broker.conf 文件1.3 Linux 开放端口1.4 项目启动成功 前言 上一篇文章#xff1a;基于SpringBoot整合RocketMQ异步发送短信功能在项目启动的过程中报了 RocketMQ 连接错误。针对这个问题#xff0c;本文给予记… 文章目录 前言一、RocketMQ 连接报错处理1.1 报错信息1.2 修改 broker.conf 文件1.3 Linux 开放端口1.4 项目启动成功 前言 上一篇文章基于SpringBoot整合RocketMQ异步发送短信功能在项目启动的过程中报了 RocketMQ 连接错误。针对这个问题本文给予记录。 一、RocketMQ 连接报错处理 1.1 报错信息 Error starting ApplicationContext. To display the conditions report re-run your application with debug enabled. 2023-12-24 21:12:22.374 ERROR 26188 — [ restartedMain] o.s.boot.SpringApplication : Application run failedjava.lang.RuntimeException: java.lang.IllegalStateException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to [192.168.57.129:9876] failedat org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.registerContainer(ListenerContainerConfiguration.java:123) ~[rocketmq-spring-boot-2.2.2.jar:2.2.2]at java.util.HashMap.forEach(HashMap.java:1289) ~[na:1.8.0_181]at org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration.afterSingletonsInstantiated(ListenerContainerConfiguration.java:79) ~[rocketmq-spring-boot-2.2.2.jar:2.2.2]at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:963) ~[spring-beans-5.3.6.jar:5.3.6]at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:918) ~[spring-context-5.3.6.jar:5.3.6]at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:583) ~[spring-context-5.3.6.jar:5.3.6]at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:144) ~[spring-boot-2.4.5.jar:2.4.5]at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:782) [spring-boot-2.4.5.jar:2.4.5]at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:774) [spring-boot-2.4.5.jar:2.4.5]at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:439) [spring-boot-2.4.5.jar:2.4.5]at org.springframework.boot.SpringApplication.run(SpringApplication.java:339) [spring-boot-2.4.5.jar:2.4.5]at org.springframework.boot.SpringApplication.run(SpringApplication.java:1340) [spring-boot-2.4.5.jar:2.4.5]at org.springframework.boot.SpringApplication.run(SpringApplication.java:1329) [spring-boot-2.4.5.jar:2.4.5]at com.huang.quickstart.QuickStartApplication.main(QuickStartApplication.java:12) [classes/:na]at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_181]at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_181]at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49) [spring-boot-devtools-2.4.5.jar:2.4.5]简单的理解就是 RocketMQ 连接不上虚拟机地址 192.168.57.129:9876 信息。 1.2 修改 broker.conf 文件 进入 broker.conf 目录下 cd /mydata/rocketmq/rocketmq-4.9.1/confvim broker.conf加入两行(建议直接复制然后再修改为自己的IP)一定是大写IP。 namesrvAddr192.168.57.129:9876 brokerIP1192.168.57.129然后重启 nameserver 和 broker (一定要先启动 namesrv因为消息服务器是注册到命名服务器上的)。 nohup sh mqnamesrv再启动消息服务器同时指定刚刚修改过的 conf 文件不然还是会读取原本默认的阿里外网IP还是会报错。 nohup sh mqbroker -n 192.168.57.129:9876 -c ../conf/broker.conf备注 -n 指定的是注册到哪个消息服务器上 -c 指定的是刚刚修改的conf配置文件 查看日志信息 namesrv 和broker 启动成功 [rootlocalhost bin]# cat nohup.out Java HotSpot™ 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release Java HotSpot™ 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release. The Name Server boot success. serializeTypeJSON The broker[broker-a, 192.168.57.129:10911] boot success. serializeTypeJSON and name server is 192.168.57.129:9876重新启动 SpringBoot 项目发现还是报错
1.3 Linux 开放端口 排查了一下原因发现可能是 Linux 中 RocketMQ 的 9876 端口没有开放的问题 1、开启防火墙 systemctl start firewalld2、开放指定端口 firewall-cmd –zonepublic –add-port9876/tcp –permanent备注 –zone 作用域 –add-port9876/tcp 添加端口格式为端口/通讯协议 –permanent 永久生效没有此参数重启后失效 3、重启防火墙 firewall-cmd –reload4、查看端口号 netstat -ntlp #查看当前所有tcp端口 netstat -ntulp |grep 9876 #查看所有9876端口使用情况 1.4 项目启动成功 1、开放端口以及重启防火墙 [rootlocalhost bin]# firewall-cmd –zonepublic –add-port9876/tcp –permanent success [rootlocalhost bin]# firewall-cmd –reload success2、重启启动 SpringBoot 项目 2023-12-24 21:38:39.978 INFO 24612 — [ restartedMain] a.r.s.s.DefaultRocketMQListenerContainer : running container: DefaultRocketMQListenerContainer{consumerGroupscreening-record-consumer_status-change, namespace, nameServer192.168.57.129:9876, topicscreening-record-topic, consumeModeCONCURRENTLY, selectorTypeTAG, selectorExpressionstatus-change, messageModelCLUSTERING, tlsEnablefalse} 2023-12-24 21:38:39.978 INFO 24612 — [ restartedMain] o.a.r.s.a.ListenerContainerConfiguration : Register the listener to container, listenerBeanName:screeningRecordStatusChangeConsumer, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_2 2023-12-24 21:38:40.039 INFO 24612 — [ restartedMain] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 9090 (http) with context path 2023-12-24 21:38:40.053 INFO 24612 — [ restartedMain] c.h.quickstart.QuickStartApplication : Started QuickStartApplication in 8.829 seconds (JVM running for 10.857)3、项目启动成功RocketMQ连接报错问题解决