本篇目录：

• 1、rocketmq总结以及自动化部署策略
• 2、RocketMQ的关键特性
• 3、面试官杠上重复消费、消息堆积、消息丢失、顺序消息?
• 4、rocketmq发送100mb
• 5、RocketMQ原理解析

rocketmq总结以及自动化部署策略

首先采用的是 随机策略 进行选择，失败后采用的是轮询策略。Broker充当着消息中转角色，负责存储消息、转发消息。Broker在RocketMQ系统中负责接收并存储从生产者发送来的消息，同时为消费者的拉取请求作准备。

扩容还解决不了的问题，还存在挤压现象，就要考虑broker 或client本身的故障 这种情况基本上是可以确定是RocketMQ本身的故障照成的，比如Broker故障，比如Broker的GC频率过高导致消息推送，copy性能降低，集群内部网络故障，等等。

刷盘策略 刷盘策略指的是broker中消息的落盘方式，即发送到broker内存后消息持久化到磁盘的方式。分为同步刷盘与异步刷盘。

RocketMQ会根据发送端设置的策略来决定是回滚还是继续发送确认消息。这样就保证了消息发送与本地事务同时成功或同时失败。

Group中的消费者，不仅Topic必须一致，tags也必须一致，具体原因可以参考上面的链接，大致是因为RocketMQ会检索最后一个注册的Consumer的监听策略，之前的会失效。

RocketMQ支持两种消费方式：顺序消费和并发消费。并发消费是默认的消费方式，日常开发过程中最常用的方式，除了顺序消费就是并发消费。并发消费也称为乱序消费，其原理是同一个消息队列提供给Consumer中的多个消费线程拉取消费。

RocketMQ的关键特性

1、在RocketMQ中，这种正常情况下无法被消费的消息被称为死信消息（Dead-Letter Message），存储死信消息的特殊队列称为死信队列（Dead-Letter Queue）。

2、低延迟消息引擎RocketMQ，在二代功能特性的基础上，为电商金融领域添加了可靠重试、基于文件存储的分布式事务等特性。使用在了阿里大量的应用上，典型如双11场景，具有万亿级消息流转。

3、安全性等 。- RabbitMQ：支持多种消息协议，如AMQP、STOMP等，具有良好的可扩展性和灵活性，支持多种语言和操作系统 。- RocketMQ：支持事务消息、顺序消息、延时消息等多种消息类型，具有良好的可扩展性和性能 。

4、当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。

面试官杠上重复消费、消息堆积、消息丢失、顺序消息?

1、顺序消息是指消息的 消费顺序 和 产生顺序 相同，在有些业务逻辑下，必须保证顺序，比如订单的生成、付款、发货，这个消息必须按顺序处理才行。

2、消息是顺序的，先进先出原则，这个由Rabbitmq保证，不同队列中的消息顺序，是没有保证的，例如：进地铁站的时候，排了三个队伍，不同队伍之间的，不能确保谁先进站。

3、其实，上述3中情况导致消息丢失归根结底是因为RabbitMQ的自动ack机制，即默认RabbitMQ在消息发出后就立即将这条消息删除，而不管消费端是否接收到，是否处理完，导致消费端消息丢失时RabbitMQ自己又没有这条消息了。

4、默认情况消费者收到消息，MQ就会从队列中删除消息，如果消费者没处理成功，消息就丢了，可以使用手动ACK机制，处理完成手动调用MQ的ACK方法通知MQ删除消息。

5、我们使用RocketMQ顺序消息来模拟一下订单的场景，顺序消息分为两部分：顺序发送、顺序消费。 顺序发消息 上面代码模拟了按顺序依次发送创建、支付、退款消息到TopicTest中。

6、消息不被及时回复很焦虑，可以采取以下措施：首先要正确认识自己的情绪，不要把没有得到正面反馈的事情当作负面反馈或对自己的否定。每个人都有自己的事要做，不及时回复或者不回复并不代表别人不重视你或者不喜欢你。

rocketmq发送100mb

确保RocketMQ配置正确。在RocketMQ的配置文件中，修改maxMessageSize的值为100MB，单位是字节（1MB=1024*1024字节）。例如：maxMessageSize=1024*1024*100 。编写代码发送消息。

接下来我们启动一下刚才编译的RocketMQ.在启动之前我们需要修改一下RocketMQ启动的内存大小（如果你的系统内存比较大的话，请忽略）。

阿里云消息队列RocketMQ版按量付费价格：一个Topic2元一天，2元100万消息（量大了之后有一个递减的收费标准）。

消息入库 消息入库，顾名思义就是将要发送的消息保存到数据库中。

比如Active MQ，Rabbit MQ，Rocket Mq。(1)应用将主干逻辑处理完成后，写入消息队列。消息发送是否成功可以开启消息的确认模式。

当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。

RocketMQ原理解析

就是必须要half消息进入到RocketMQ内部的RMQ_SYS_TRANS_HALF_TOPIC的comsumeQueue文件中，此时就认为half消息写入成功了，然后就会返回成功消息给订单系统了。

这其实就是RocketMQ集群化部署抗下高并发的主要原理，当然，具体怎么做才能让系统的流量分散在RocketMQ部署的多台机器上，这个以后再找机会做一个比较详细的分享，今天主要先讲大体上的一个架构原理。

RocketMQ是通过将“相同ID的消息发送到同一个队列，而一个队列的消息只由一个消费者处理“来实现顺序消息。这样对于同一个订单的创建、付款和完成消息，他们将保持这一顺序被发送和消费。

RocketMQ变成一个管理队列的系统 ，而分解下来的若干个 小的队列通过什么来区分呢 ？ 就是通过topic。 比如我的业务定义topic：tp_im_event。

并发消费的原理 RocketMQ支持两种消费方式：顺序消费和并发消费。并发消费是默认的消费方式，日常开发过程中最常用的方式，除了顺序消费就是并发消费。

到此，以上就是小编对于rocketmq 批量拉取消息个数的问题就介绍到这了，希望介绍的几点解答对大家有用，有任何问题和不懂的，欢迎各位老师在评论区讨论，给我留言。