rocketMQliunx部署记录

作者：爱旅游的星琴 | 来源：互联网 | 2023-08-26 05:49

rocketMQ消息队列liunx部署记录一、概念消息队列主要解决了应用耦合、异步处理、流量削锋等问题。当前使用较多的消息队列有RabbitMQ、RocketMQ、ActiveM

rocketMQ 消息队列 liunx部署记录

一、概念

消息队列主要解决了应用耦合、异步处理、流量削锋等问题。当前使用较多的消息队列有RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等&＃xff0c;而部分数据库如Redis、Mysql以及phxsql也可实现消息队列的功能。rocketMQ 纯java、分布式、队列模型的开源消息中间件 &＃xff0c;原为阿里巴巴处理交易项目&＃xff0c;后贡献给Apache 作为了开源项目

二、集群模式

Broker集群有多种配置方式&＃xff1a;1&＃xff0c;单Master优点&＃xff1a;除了配置简单没什么优点缺点&＃xff1a;不可靠&＃xff0c;该机器重启或宕机&＃xff0c;将导致整个服务不可用2&＃xff0c;多Master优点&＃xff1a;配置简单&＃xff0c;性能最高缺点&＃xff1a;可能会有少量消息丢失&＃xff08;配置相关&＃xff09;&＃xff0c;单台机器重启或宕机期间&＃xff0c;该机器下未被消费的消息在机器恢复前不可订阅&＃xff0c;影响消息实时性3&＃xff0c;多Master多Slave&＃xff0c;每个Master配一个Slave&＃xff0c;有多对Master-Slave&＃xff0c;HA采用异步复制方式&＃xff0c;主备有短暂消息延迟&＃xff0c;毫秒级优点&＃xff1a;性能同多Master几乎一样&＃xff0c;实时性高&＃xff0c;主备间切换对应用透明&＃xff0c;不需人工干预缺点&＃xff1a;Master宕机或磁盘损坏时会有少量消息丢失4&＃xff0c;多Master多Slave&＃xff0c;每个Master配一个Slave&＃xff0c;有多对Master-Slave&＃xff0c;HA采用同步双写方式&＃xff0c;主备都写成功&＃xff0c;向应用返回成功优点&＃xff1a;服务可用性与数据可用性非常高缺点&＃xff1a;性能比一部HA略低&＃xff0c;当前版本主宕备不能自动切换为主

三、实战部署&＃xff08;以下搭建的双主模式&＃xff09;

服务器

服务器A&＃xff1a; 192.168.14.190 服务器B&＃xff1a; 192.168.14.52

准备的软件

Jdk&＃xff1a; jdk-7u80-linux-x64 Mq&＃xff1a; alibaba-rocketmq-3.2.6.tar 这里用的原阿里巴巴版本rocketmq-all-4.3.2-source-release 这是给Apache 之后开源版本 &＃xff08;有时间自己研究一下&＃xff09;Maven&＃xff1a; apache-maven-3.6.0-bin.tar RocketMq-console&＃xff1a; rocketmq-externals-release-rocketmq-console-1.0.0 MQ监控可视化软件

百度云下载链接&＃xff08;提取码&＃xff1a;4ikb&＃xff09;&＃xff1a;Jdk、Mq、Maven、RocketMq-console-下面网页自己下载下

xhell 上传文件命令&＃xff1a;rz 下载命令sz 如提示无命令则要安装对应软件软件才行
上传以上文件&＃xff0c;【tar -vxf 文件名】解压&＃xff0c;配置环境变量&＃xff0c;直到都验证没问题
配置环境变量&＃xff1a;

vim /etc/profile 末尾添加&＃xff1a;export JAVA_HOME&＃61;/usr/java/default export MAVEN_HOME&＃61;/usr/local/maven/apache-maven-3.6.0 export ROCKETMQ_HOME&＃61;/usr/local/rocketmq/alibaba-rocketmq export PATH&＃61;$PATH:$JAVA_HOME/bin:$MAVEN_HOME/bin:$ROCKETMQ_HOME/bin export CLASSPATH&＃61;.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar-------查看安装程序是否成功 javac java -version mvn -version

温馨提示&＃xff1a;
mq解压后的文件直接放这下面&＃xff1a;/usr/local/rocketmq
不要像我那样&＃xff1a;/usr/local/rocketmq/alibaba-rocketmq 这样后面启动查资料-操作很麻烦

一. 修改开放端口

&＃xff08;1&＃xff09;、虚拟机&＃xff1a;

vim /etc/sysconfig/iptables 打开该文件在添加的22端口后添加---切记坑一-A INPUT -m state --state NEW -m tcp -p tcp --dport 9876 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 8080 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 10911 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 10909 -j ACCEPT/etc/init.d/iptables restart 重新加载配置文件10909 在后面Mq视图监控程序需要用到注意&＃xff1a; 如果是虚拟机&＃xff0c;并且第二个虚拟机是克隆出来的&＃xff0c;在重启iptables 配置文件会出现如下面图提示的解决方案&＃xff1a; udev将mac与网卡名称的对应关系保存在 # vi /etc/udev/rules.d/70-persistent-net.rules 中&＃xff0c; 可以看到文件内容如下 # PCI device 0x8086:0x100f (e1000) SUBSYSTEM&＃61;&＃61;"net", ACTION&＃61;&＃61;"add", DRIVERS&＃61;&＃61;"?*", ATTR{address}&＃61;&＃61;"00:0c:29:7b:60:38", ATTR{type}&＃61;&＃61;"1", KERNEL&＃61;&＃61;"eth*", NAME&＃61;"eth0"# PCI device 0x8086:0x100f (e1000) SUBSYSTEM&＃61;&＃61;"net", ACTION&＃61;&＃61;"add", DRIVERS&＃61;&＃61;"?*", ATTR{address}&＃61;&＃61;"00:0c:29:29:b9:c5", ATTR{type}&＃61;&＃61;"1", KERNEL&＃61;&＃61;"eth*", NAME&＃61;"eth1"处理步骤步骤1&＃xff1a;将克隆出的虚拟机中只要删除与 NAME&＃61;"eth0" 相关的行&＃xff0c;并把下行的 eth1 的改为 eth0 &＃xff1b;并记录一下 ATTR{address} 的值&＃xff1b; 步骤2&＃xff1a;记录此克隆机MAC地址&＃xff0c;然后编辑 # vi /etc/sysconfig/network-scripts/ifcfg-eth0 将 HWADDR 及 IPADDR 修改一下&＃xff1b; 步骤3: 重启系统&＃xff1b;

&＃xff08;2&＃xff09;、阿里服务器&＃xff1a;到阿里配置页面开启对应端口权限

在这里插入图片描述

亲博主小程序开发不易能顺手-----------------微信扫码 ------帮忙增加个访问量吗非常感谢谢谢
在这里插入图片描述

二. 修改主机文件&＃xff08;两台机子&＃xff09;修改mq配置

vim /etc/hosts 添加&＃xff1a;192.168.14.52 rocketmq-nameserver1 192.168.14.52 rocketmq-master1 192.168.14.190 rocketmq-nameserver2 192.168.14.190 rocketmq-master2 192.168.14.52 lc1 192.168.14.190 lc2 最后面两条因为我在启动的时候报无法解析主机名-lc1 所以加了这么两条标识自己看着来一般是不加的 ping 下两机通不通

在这里插入图片描述

三. 创建日志文件目录&＃xff08;两台机子&＃xff09;

mkdir /usr/local/rocketmq/store mkdir /usr/local/rocketmq/store/commitlog mkdir /usr/local/rocketmq/store/consumequeue mkdir /usr/local/rocketmq/store/index修改日志配置文件&＃xff1a; mkdir -p /usr/local/rocketmq/logs cd /usr/local/rocketmq/conf && sed -i &＃39;s#${user.home}#/usr/local/rocketmq#g&＃39; *.xml

四. 修改mq配置&＃xff08;两台机子&＃xff09;

打开目录&＃xff1a; cd /usr/local/rocketmq/conf/2m-noslave/ vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;和&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;broker-b.properties 网上配置都差不多&＃xff0c;有两个server 这里就会出现两个配置文件&＃xff0c;在多个则在添加文件#所属集群名字 brokerClusterName&＃61;rocketmq-cluster #broker名字&＃xff0c;注意此处不同的配置文件填写的不一样 brokerName&＃61;broker-a&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;对应&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;broker-b #0 表示Master, >0 表示Slave brokerId&＃61;0 #nameServer地址&＃xff0c;分号分割 namesrvAddr&＃61;rocketmq-nameserver1:9876;rocketmq-nameserver2:9876 #虚拟机可能出现两个虚拟网络可能在调用的时候出现问题所以加这个配置 brokerIP1&＃61;rocketmq-nameserver1 #在发消息时&＃xff0c;自动创建服务器不存在的topic,默认创建的队列数 defaultTopicQueueNums&＃61;4 #是否允许Broker自动创建Topic&＃xff0c;建议线下开启&＃xff0c;线上关闭 autoCreateTopicEnable&＃61;true #是否允许Broker自动创建订阅组&＃xff0c;建议线下开启&＃xff0c;线上关闭 autoCreateSubscriptionGroup&＃61;true #Broker 对外服务的监听端口 listenPort&＃61;10911 #删除文件时间点&＃xff0c;默认凌晨4点 deleteWhen&＃61;04 #文件保留时间&＃xff0c;默认48小时 fileReservedTime&＃61;120 #commitLog每个文件的大小默认1G mapedFileSizeCommitLog&＃61;1073741824 #ConsumeQueue每个文件默认存30W条&＃xff0c;根据业务情况调整 mapedFileSizeConsumeQueue&＃61;300000 #destroyMapedFileIntervalForcibly&＃61;120000 #redeleteHangedFileInterval&＃61;120000 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio&＃61;88 #存储路径 storePathRootDir&＃61;/usr/local/rocketmq/store #commitLog存储路径 storePathCommitLog&＃61;/usr/local/rocketmq/store/commitlog #消费队列存储路径 storePathConsumeQueue&＃61;/usr/local/rocketmq/store/consumequeue #消息索引存储路径 storePathIndex&＃61;/usr/local/rocketmq/store/index #checkpoint 文件存储路径 storeCheckPoint&＃61;/usr/local/rocketmq/store/checkpoint #abort 文件存储路径 abortFile&＃61;/usr/local/rocketmq/store/abort #限制的消息大小 maxMessageSize&＃61;65536#flushCommitLogLeastPages&＃61;4 #flushConsumeQueueLeastPages&＃61;2 #flushCommitLogThoroughInterval&＃61;10000 #flushConsumeQueueThoroughInterval&＃61;60000#Broker 的角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE brokerRole&＃61;ASYNC_MASTER#刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType&＃61;ASYNC_FLUSH#checkTransactionMessageEnable&＃61;false #发消息线程池数量 #sendMessageThreadPoolNums&＃61;128 #拉消息线程池数量 #pullMessageThreadPoolNums&＃61;128lushDiskType&＃61;ASYNC_FLUSH

五. 修改启动脚本参数&＃xff08;两台机器内存1g&＃xff09;默认4g 生产可不动 &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61; 坑二&＃xff08;注意两个文件并且注意 Xmn512m 单位m&＃xff09;

vim /usr/local/rocketmq/bin/runbroker.sh vim /usr/local/rocketmq/bin/runserver.shJAVA_OPT&＃61;"${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize&＃61;128m -XX:MaxPermSize&＃61;320m"

六. 启动先起 nameserver 在起 broker 停止先停broker 在停 nameserver
------》如果报错先看控制台&＃xff0c;在看日志&＃xff0c;日志目录如果没手动设置更改&＃xff0c;则在/usr/local/rocketmq/conf/2m-noslave 下面

两台机器&＃xff1a; cd /usr/local/rocketmq/bin nohup sh mqnamesrv &查看是否启动&＃xff1a;jps 11578 Jps 4494 NamesrvStartup机器一&＃xff1a; cd /usr/local/rocketmq/bin nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &机器二&＃xff1a; cd /usr/local/rocketmq/bin nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-b.properties >/dev/null 2>&1 &查看是否启动&＃xff1a;jps 4537 BrokerStartup 11578 Jps 4494 NamesrvStartup说明都启动了停止服务关闭broker服务 &＃xff1a;sh bin/mqshutdown broker 关闭namesrv服务&＃xff1a;sh bin/mqshutdown namesrv

七. 安装可视化监控项目 - 参考博客-点击我 ----------坑三折腾了不短项目下载&＃61;&＃61;https://github.com/apache/rocketmq-externals原因如参考博客一样下载后maven 编译监控项目 – 始终报错

下载项目&＃xff1a;rocketmq-externals-release-rocketmq-console-1.0.0

坑四&＃xff1a; 本地访问虚拟机 &＃xff1a;http://192.168.14.52:8080/#/cluster 能加载出项目 ---- 然后连接不上mq 在虚拟机上访问可以然而不知道为啥 &＃xff0c; 有知道的告知一声或评论留言谢谢

八. 项目应用Mq
RocketMQ常用命令使用示例及说明------推荐博客

创建topicsh mqadmin updateTopic -t TopicTest -c DefaultCluster -n 192.168.0.1:9876如下应用场景

在这里插入图片描述
九. 遇到过的异常 &＃xff08;太多了&＃xff09;记录了两个 ------解决 - 百度&＃xff0c;看日志

1&＃xff1a;TopicTest Topic不存在程序调用会报错如上会建立一个Topiccom.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest See https://github.com/alibaba/RocketMQ/issues/264 for further details.at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:591)at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:992)at com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:109)at com.md.util.rocketMqProduceUtil.send(rocketMqProduceUtil.java:28)at com.md.notify.WechatNotifyController.wechatNotify(WechatNotifyController.java:119)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)at java.lang.reflect.Method.invoke(Unknown Source)at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:221)at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:137)at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:110)at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:777)at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:706)at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:943)at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:877)at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:966)at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:868)at javax.servlet.http.HttpServlet.service(HttpServlet.java:727)at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:842)at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)at org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511)at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1221)at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:88)at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:399)at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:182)at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:766)at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:450)at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)at org.mortbay.jetty.Server.handle(Server.java:326)at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)at org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:945)at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:756)at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218)at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:410)at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582)2&＃xff1a;10911 无法连接通端口未开如开始开通对应端口com.alibaba.rocketmq.client.exception.MQClientException: Retry many times, still failed For more information, please visit the url, https://github.com/alibaba/RocketMQ/issues/64at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:581)at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:992)at com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:109)at com.md.util.rocketMqProduceUtil.send(rocketMqProduceUtil.java:28)at com.md.notify.WechatNotifyController.wechatNotify(WechatNotifyController.java:119)at sun.reflect.GeneratedMethodAccessor93.invoke(Unknown Source)at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)at java.lang.reflect.Method.invoke(Unknown Source)at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:221)at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:137)at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:110)at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:777)at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:706)at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:943)at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:877)at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:966)at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:868)at javax.servlet.http.HttpServlet.service(HttpServlet.java:727)at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:842)at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)at org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511)at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1221)at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:88)at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:399)at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:182)at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:766)at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:450)at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)at org.mortbay.jetty.Server.handle(Server.java:326)at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)at org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:945)at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:756)at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218)at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:410)at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582) Caused by: com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.14.190:10911> failedat com.alibaba.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:629)at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:324)at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:307)at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:676)at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:512)... 39 more3. connect to <172.17.10.19:10911> failedcom.alibaba.rocketmq.client.exception.MQClientException: Retry many times, still failed For more information, please visit the url, https://github.com/alibaba/RocketMQ/issues/64at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:581)at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:992)at com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:109)at com.md.util.rocketMqProduceUtil.send(rocketMqProduceUtil.java:89)at com.md.notify.WechatNotifyController.wechatNotify(WechatNotifyController.java:119)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:498)at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:221)at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:137)at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:110)at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:777)at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:706)at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:943)at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:877)at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:966)at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:868)at javax.servlet.http.HttpServlet.service(HttpServlet.java:727)at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:842)at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)at org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511)at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1221)at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:88)at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:399)at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:182)at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:766)at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:450)at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)at org.mortbay.jetty.Server.handle(Server.java:326)at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)at org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:945)at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:756)at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218)at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:410)at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582) Caused by: com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.10.19:10911> failedat com.alibaba.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:629)at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:324)at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:307)at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:676)at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:512)... 40 more配置文件 ip要写成外网

亲博主小程序开发不易能顺手-----------------微信扫码 ------帮忙增加个访问量吗非常感谢谢谢

在这里插入图片描述