在企业实践RocketMQ时基本上80%都是不消费问题,而由于消费进度问题导致不消费的问题又是最难确认的和排查的。RocketMQ的消费进度分为本地消费进度管理...
最近突然感觉:很多软件、硬件在设计上是有root reason的,不是by desgin如此,而是解决了那时、那个场景的那个需求。一旦了解后,就会感觉在和设计者...
说明proder发送异常,也有可能是消息过期了,因为rocketmq的消息默认保存72h,此时到producer端的日志进一步确认即可。
可以在 Rocket_HOME/distribution/target/apache-rocketmq 下执行 " sh bin/mqbroker -m " 来...
出现了重复消费的问题,同一个消息被重复消费了多次,导致了用户端收到了多条重复的消息,最终排查发现,是因为消费者在处理消息的方法onMessage中有异常没有捕获...
今天将一个SpringBoot项目的配置参数从原有的.yml文件迁移到Apollo后,启动报错“Bean method 'rocketMQTemplate' i...
假如 没有 Spring Boot Starter,我们有两种方式来创建 Spring Bean。
org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
RocketMQ 是一款高性能、可扩展的分布式消息中间件,目前已经成为各大互联网公司的主流解决方案之一。本文将介绍 RocketMQ 的底层实现原理,以及如何使...
set “JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%”
conf目录下新建一个配置文件conf/namesrv.properties,文件内容为:
创建Topic使用的命令 mqadmin updateTopic: .\mqadmin updateTopic Java HotSpot(TM) 64-Bit ...
首先在RocketMQ 官网下载二进制安装文件: http://rocketmq.apache.org/dowloading/releases/
腾讯 · 资深后端开发工程师 (已认证)
以下全部操作在的目录在:/etc/rocketmq, 并且Namesrv、Broker、Dashboard在同一个机器上
RocketMQ 支持两种消息模式:集群消费( Clustering )和广播消费( Broadcasting )。
宿主机需要远程访问虚拟机的rocketmq服务和web服务,需要开放相关的端口号,简单粗暴的方式是直接关闭防火墙
有位工作五年的小伙伴在面试的时候被问到RocketMQ的分布式事务实现原理。他说他只知道RocketMQ能够支持事务,但是没有了解过它的事务实现原理。
本文章我们将通过一些实际的案例,引出解决方案,并实际通过代码来实现。通过本节的学习,你可以确切的掌握实际编码能力。 本文选自北京大学出版社的《分布式中间件核心原...
集群模式下,每个消费者实例会被分配到若干条队列。正因为消费者拿到了明确的队列,所以它们才能针对对应的队列做循环拉取消息的处理,以下是消费者客户端和broker通...
master和slave都可以提供读服务,但是只有master允许做写入操作,slave仅从master同步数据并不断上报自己的同步进度(slave自己的物理m...
扫码关注腾讯云开发者
领取腾讯云代金券