目录 消息模型 集群部署 NameServer producer消息队列选择器MessageQueueSeleetor 消息存储 commitLog数据存储文件 ConsumeQueue索引文件 IndexFile索引文件 消息查找 根据偏移量查询 根据消息id查询 根据消息key查询 实时更新消息消费队列与索引文件 消息队列与索引文件恢复 过期...
NameServer配置属性 参数名 参数类型 描述 默认参数（时间为单位ms,数据单位为byte） rocketmqHome String RockerMQ主目录，默认用户主目录 namesrvAddr String NameServer地址 kvConfigPath String kv配置文件路径，包含顺序...
一、项目背景 由于当前生产环境RocketMQ机器使用年限较长，已经过保，并且其中一台曾经发生过异常宕机事件。并且早期网络规划较乱，生产、开发、测试等网络没有分开，公司决定对当前网络进行规划，区分各个环境网段、机柜，涉及到MQ集群需要迁移，由于物理机比较老旧，使用决定使用新机器替换老机器，并且之前的MQ集群为多master模式，当master宕机是会导...
RocketMQ为4.3.0版本（我这种写法4.2.0不行） 如果你之前用的其他版本，需要去修改下系统的环境变量 maven工程用到的jar包 <dependencies> <!-- RocketMQ --> <dependency> <groupId>org.apache.rocketmq<...
今天我们一起来探讨： 全量的消息队列究竟有哪些？ Kafka、RocketMQ、RabbitMQ的优劣势比较 以及消息队列的选型 最全MQ消息队列有哪些 那么目前在业界有哪些比较知名的消息引擎呢？如下图所示 这里面几乎完全列举了当下比较知名的消息引擎，包括： ZeroMQ 推特的Distributedlog ActiveMQ：Apach...
首先整理这个文章是因为我正好有机会实战了一下rocketmq，阿里巴巴的一个开源消息中间件。所以就与以往中rabbitmq进行小小的比较一下。这里主线的根据常见面试问题进行整理。 一.消息队列常用的场景 1.削峰 例如我们做得考试系统中，用户通过人脸识别登录系统，考虑到考试系统的特殊性，三万名考生参加考试，需要记录人脸识别登录照片。从考试完结果上...
一、RocketMq有3中消息类型 1.普通消费 2. 顺序消费 3.事务消费 顺序消费场景 在网购的时候，我们需要下单，那么下单需要假如有三个顺序，第一、创建订单 ，第二：订单付款，第三：订单完成。也就是这个三个环节要有顺序，这个订单才有意义。RocketMQ可以保证顺序消费。 rocketMq实现顺序消费的原理 produce在发送消息的时候，把消息...
参考携程官网提供的https://github.com/ctripcorp/apollo/wiki/Java%E5%AE%A2%E6%88%B7%E7%AB%AF%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97 整个项目组的代码如下 项目的pom.xml代码如下 <project xmlns="http://maven...
一、rocketMQ是什么 rocketmq是一款低延迟、高可靠、可伸缩、已使用的消息中间件。具有以下特性： 1、支持发布/订阅、点对点（p2p）消息模型 2、同一个队列中支持先进先出（FIFO）和严格的顺序传递 3、支持拉（pull）和推（push）两种消息模式 4、单一队列百万消息的堆积能力 5、支持多种消息协议，比如： JMS 、MQTT 6、分布式...
1. 下载rocketmq-console-ng 官网地址：https://github.com/apache/rocketmq-externals 拉下来之后，使用idea打开rocketmq-console，在application.properties配置文件中修改rocketmq.config.namesrvAddr(前面集群环境下的...