rocketmq原理？

一、rocketmq原理？

RocketMQ概述，主要是概念上的一些内容RocketMQ的特点以及消息发送、消费模型RocketMQ原理：mmap+write，文件系统，数据存储结构，队列，刷盘策略，消息查询，消息过滤，事务消息，发送、订阅负载均衡，同步双写/异步复制，充分利用内存，消息堆积能力以及解决办法

二、rocketmq和rabbitmq的区别rocketmq使用？

1. RabbitMQ

是基于AMQP 协议的 具有跨语言的特性，支持多种开发语言,基于erlang语言编写,天生具有高并发.

2. rocketMQ

是基于JMS的 是阿里巴巴旗下开发的mq,只能用java语言,声称可用性极高,消息从来不会丢失.

两者的区别和联系:

JMS是定义了统一的接口，来对消息操作进行统一；AMQP是通过规定协议来统一数据交互的格式

JMS限定了必须使用Java语言；AMQP只是协议，不规定实现方式，因此是跨语言的。

JMS规定了两种消息模型；而AMQP的消息模型更加丰富

三、rocketmq工作模式？

（1）集群模式：同一个consumerGroupName下的多个consumer平摊消息队列中的消息，例如三个消费者处于同一个group下，且订阅了同一个topic，加入生产者往消息队列中放入了这个topic的6条消息，那么消费者消费消息的总和为6条，消费完的消息不能被其他实例所消费

（2）广播模式：指的是consumer属于同一个ConsumerGroup,消息也会被ConsumerGroup中的每个Consumer都消费一次，广播消费中ConsumerGroup概念可以认为在消息划分方面无意义

四、rocketmq怎么广播订阅？

在左下角有一个订阅，点击订阅，就可以订阅广播。

五、rabbitmq和rocketmq区别？

RabbitMQ是基于AMQP 协议的 具有跨语言的特性，支持多种开发语言,基于erlang语言编写,天生具有高并发.rocketMQ是基于JMS的 是阿里巴巴旗下开发的mq,只能用java语言,声称可用性极高,消息从来不会丢失.

六、rocketmq延时队列实现原理？

RocketMQ是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠、万亿级容量、灵活可伸缩的消息发布与订阅服务。

它前身是MetaQ，是阿里基于Kafka的设计使用Java进行自主研发的。在2012年，阿里将其开源， 在2016年，阿里将其捐献给Apache软件基金会（Apache Software Foundation，简称为ASF），正式成为孵化项目。2017 年，Apache软件基金会宣布RocketMQ已孵化成为 Apache顶级项目（Top Level Project，简称为TLP ），是国内首个互联网中间件在 Apache上的顶级项目。

延迟消息

生产者把消息发送到消息队列中以后，并不期望被立即消费，而是等待指定时间后才可以被消费者消费，这类消息通常被称为延迟消息。

在RocketMQ中，支持延迟消息，但是不支持任意时间精度的延迟消息，只支持特定级别的延迟消息。如果要支持任意时间精度，不能避免在Broker层面做消息排序，再涉及到持久化的考量，那么消息排序就不可避免产生巨大的性能开销。

消息延迟级别分别为1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h，共18个级别。在发送消息时，设置消息延迟级别即可，设置消息延迟级别时有以下3种情况：

设置消息延迟级别等于0时，则该消息为非延迟消息。

设置消息延迟级别大于等于1并且小于等于18时，消息延迟特定时间，如：设置消息延迟级别等于1，则延迟1s；设置消息延迟级别等于2，则延迟5s，以此类推。

设置消息延迟级别大于18时，则该消息延迟级别为18，如：设置消息延迟级别等于20，则延迟2h。

延迟消息示例

首先，写一个消费者，用于消费延迟消息：

再写一个延迟消息的生产者，用于发送延迟消息：

运行生产者以后，就会发送一条延迟消息：

10秒钟后，消费者收到的这条延迟消息：

延迟消息的原理分析

以下分析的RocketMQ源码的版本号是4.7.1，版本不同源码略有差别。

CommitLog

在org.apache.rocketmq.store.CommitLog中，针对延迟消息做了一些处理：

可以看到，每一个延迟消息的主题都被暂时更改为SCHEDULE_TOPIC_XXXX，并且根据延迟级别延迟消息变更了新的队列Id。接下来，处理延迟消息的就是org.apache.rocketmq.store.schedule.ScheduleMessageService。

ScheduleMessageService

ScheduleMessageService是由org.apache.rocketmq.store.DefaultMessageStore进行初始化的，初始化包括构造对象和调用load方法。最后，再执行ScheduleMessageService的start方法：

遍历所有延迟级别，根据延迟级别获得对应队列的偏移量，如果偏移量不存在，则设置为0。然后为每个延迟级别创建定时任务，第一次启动任务延迟为1秒，第二次及以后的启动任务延迟才是延迟级别相应的延迟时间。

然后，又创建了一个定时任务，用于持久化每个队列消费的偏移量。持久化的频率由flushDelayOffsetInterval属性进行配置，默认为10秒。

定时任务

ScheduleMessageService的start方法执行之后，每个延迟级别都创建自己的定时任务，这里的定时任务的具体实现就在DeliverDelayedMessageTimerTask类之中，它核心代码是executeOnTimeup方法之中，我们来看一下主要部分：

如果没有获取到对应的消息队列，则在DELAY_FOR_A_WHILE（默认为100）毫秒后再执行任务。如果获取到了，就继续执行下面操作：

如果没有获取到有效消息，则在DELAY_FOR_A_WHILE（默认为100）毫秒后再执行任务。如果获取到了，就继续执行下面操作：

如果当前消息不到消费的时间，则在countdown毫秒后再执行任务。如果到消费的时间，就继续执行下面操作：

如果获取到消息，则继续执行下面操作：

清除了消息的延迟级别，并且恢复了真正的消息主题和队列Id，重新把消息发送到真正的消息队列上以后，消费者就可以立即消费了。

总结

经过以上对源码的分析，可以总结出延迟消息的实现步骤：

如果消息的延迟级别大于0，则表示该消息为延迟消息，修改该消息的主题为SCHEDULE_TOPIC_XXXX，队列Id为延迟级别减1。

消息进入SCHEDULE_TOPIC_XXXX的队列中。

定时任务根据上次拉取的偏移量不断从队列中取出所有消息。

根据消息的物理偏移量和大小再次获取消息。

根据消息属性重新创建消息，清除延迟级别，恢复原主题和队列Id。

重新发送消息到原主题的队列中，供消费者进行消费。

七、rocketmq为什么性能高？

rocketmq性能高的原因是：生产者和消费者可以直接和 Broker 交互了，这种点对点的交互方式最大限度降低了消息传递的中间环节，缩短了链路耗时。

八、rocketmq和rabbitmq的区别？

rabbitmq比rocketmq的性能好。

九、rocketmq消息push和pull区别？

对于任何一款消息中间件而言，消费者客户端一般有两种方式从消息中间件获取消息并消费。

严格意义上来讲，RocketMQ并没有实现PUSH模式，而是对拉模式进行一层包装，名字虽然是 Push 开头，实际在实现时，使用 Pull 方式实现。通过 Pull 不断不断不断轮询 Broker 获取消息。

当不存在新消息时，Broker 会挂起请求，直到有新消息产生，取消挂起，返回新消息。

这样，基本和 Broker 主动 Push 做到接近的实时性（当然，还是有相应的实时性损失）。

十、rocketmq nameser是否可设置密码？

可以进行设置密码的，方便用户使用的。