RocketMQ消费者无法消费问题解决

代码配置就不说了, 网上一堆 , 本次问题不是代码配置的问题 , 所以不好解决 , 浪费了很多时间

环境:
rocketmq4.5.2 , 使用广播消息 ,1:n一对多

问题描述:
生产者可以正常产生消息, 但是迟迟无法被消费者消费, 在本机上生产者可以自产自消
IDE控制台报错:
2021-04-01T10:51:23,171 http-nio-8080-exec-10 DEBUG org.springframework.web.servlet.DispatcherServlet- Completed 404

原因:
生产者和消费者的网段不一致 , 需要手动修改其配置文件, 由于本机开启了虚拟机网络(在网络和Internet处开启了VMware Network Adapter),导致修改ip失败 , 进而导致消费者无法获取消息

如何发现问题:
需要先安装rocketmq控制台,在该jar所在目录下cmd,然后输入命令启动:
java -jar rocketmq-console-ng-2.0.0.jar --server.port=9090 --rocketmq.config.namesrvAddr=此处输入你的ip:9876
然后分别比对生产者和消费者的控制台此处是否在一个网段

问题解决:
将此处关于VMware的网络全部禁用,然后修改rocketmq安装目录下的conf目录下的broker.conf

修改rocketmq安装目录下的conf目录下的broker.conf , 添加ip

RocketMQ消费者无法消费问题解决相关推荐

RocketMQ 消费者（1）概念和消费流程
1. 背景 RocketMQ 的消费可以算是 RocketMQ 的业务逻辑中最复杂的一块.这里面涉及到许多消费模式和特性.本想一篇文章写完,写到后面发现消费涉及到的内容太多,于是决定分多篇来写.本文作 ...
RocketMQ的顺序消费
前序问题引出: 假设现在有这么一个业务,上游系统通过消息队列,发送一个订单的状态操作信息,上游先发生操作订单价格乘以2倍,再操作订单价格减去10元,但是系统发送的两条消息时间相差不大,下游系统如何接 ...
rocketmq 消费者不能调用其他服务_Spring Cloud Alibaba RocketMQ - 构建异步通信的微服务...
引入MQ后的架构演进 MQ的选择消息队列对比参照表: RocketMQ vs. ActiveMQ vs. Kafka: 参考至: CentOS7上搭建RocketMQ 环境要求: CentOS 7. ...
rocketmq新扩容的broker没有tps_深入研究RocketMQ消费者是如何获取消息的
前言小伙伴们,国庆都过的开心吗?国庆后的第一个工作日是不是很多小伙伴还沉浸在假期的心情中,没有工作状态呢? 那王子今天和大家聊一聊RocketMQ的消费者是如何获取消息的,通过学习知识来找回状态吧. ...
源码分析RocketMQ顺序消息消费实现原理
本节目录 1.消息队列负载 2.消息拉取 3.消息顺序消息消费 3.1核心属性与构造函数 3.2 start方法 3.3 submitConsumeRequest 3.4 ConsumeMessage ...
5 张图带你理解 RocketMQ 消费者启动过程
大家好,我是君哥. 今天来分享 RocketMQ 中一个关键的知识点,消费者的启动过程. 多数消息队列中,消费者和 Broker 通信的方式有两种,PUSH 模式和 PULL 模式: PUSH 模式: ...
多生产者单消费者捆绑消费问题
1. 问题描述某商店有两种食品A和B,最大数量各为m个.该商店将A,B两种食品搭配出售,每次各取一个.为避免食品变质,遵循先到食品先出售的原则,有两个食品公司分别不断地供应AB两种食品(每次一个). ...
RocketMQ消息重复消费场景及解决办法
消息重复消费是各个MQ都会发生的常见问题之一,在一些比较敏感的场景下,重复消费会造成比较严重的后果,比如重复扣款等. 那么在什么情况下会发生RocketMQ的消息重复消费呢? 当系统的调用链路比较长的 ...
【kafka】一次磁盘故障后消费者无法消费
1.概述转载:Kafka 运维纪实 – 一次磁盘故障后消费者无法消费 Kafka 自从某个版本加入 isr 等机制后真是越来越复杂了,再也不是原来那个单纯的 The log 了,碰上网络有个什么风吹 ...

RocketMQ消费者无法消费问题解决

代码配置就不说了, 网上一堆 , 本次问题不是代码配置的问题 , 所以不好解决 , 浪费了很多时间

RocketMQ消费者无法消费问题解决相关推荐

最新文章

热门文章