1. RocketMQ所需要的内存配置是?
答:name server需要4GB的内存,单个broker需要8内存。可以通过配置bin/runserver.sh和bin/runbroker.sh降低其内存需求。
2.RocketMQ配置可能遇到什么问题?
答:需要设置JAVA_HOME;记得关闭防火墙;需要export NAMESRV_ADDR=外网IP:9876;需要设置conf/broker.conf,添加brokerIP1=外网IP。启动broker的时候nohup sh bin/mqbroker -n 外网IP:9876 > autoCreateTopicEnable=true -c conf/broker.conf /dev/null 2>&1 &
3. 简要说明RocketMQ的架构
答:有四个组成部分。
- 每个Broker在启动的时候需要向所有的NameServer申请注册。
- 其中NameServer负责捕获Broker的注册事件,记录路由信息。官方推荐一个应用只用配置一个Topic(类似于rabbitMQ的vm),然后通过tag来获取自己所需要的消息。
-
每个Producer或者Consumer向NameServer发起申请连接某个Topic,NameServer找出适合的Broker,让之和该Producer或者Consumer一一对应,并且记录配对信息。
- 每个Broker内部都会有多个队列Queue用来存放消息,一个队列最多只能连接一个Consumer,是长链接。所以当Consumer个数多余总队列数的时候,是多余的。但是一个Consumer可以连接多个队列,并且拉取对应的信息。
-
其中Partition的意思是对应的物理分区,在逻辑上面还要进一步分为Queue。
-
为了实现高可用,一个Broker可以设置主从服务器,同时可以设置数据进入磁盘的方法,是同步还是异步。如果是同步的话,则需要等待主Broker的数据写入磁盘且从Broker的数据也写入磁盘,才能通知生产者消息存储成功。异步会带来可能的数据丢失,同步不会,但是速度可能没有那么快。
-
主从服务器的配置官方给了例子,在conf里面可以看到2m-2s-async/2m-2s-sync/2m-noslave的配置。
4. 顺序消息和普通消息有什么区别?
答:顺序消息分为分区顺序和全局顺序,实现方式都是把相关的消息分配到同一个队列里,这样就能保证顺序存储,只是分区顺序可以发送到多个队列,但是同一类型的队列还是在一个队列。要保证顺序消息,则需要生产者顺序产生消息,MQ顺序存储消息,消费者顺序消费消息。消费者消费消息的时候是一个Client多个线程,如果是顺序消费则会加锁。【如何加锁实现顺序消费?】其实现原理可以参考。
5. 顺序消息有什么缺陷?
6. 消费者获取信息的方式有哪两种?
答:消费者可以pull或者MQ可以push,但是在代码实现上,实际push是以pull的方式来实现的。推荐使用push方式,代码比较简单。
7. 简述定时消息的实现方式。
8. 使用批量处理消息需要注意什么限制?
答:1)需要处理相同topic相同tag的消息;2)不支持定时消息;3)建议批量消息不要超过1MB。
9. 事务消息的定义?
答:对于RocketMQ,指的是消息发送事件和本地事务同时成功或者同时失败。一般来说,会有回调,同时过了一段时间之后,发现没有回掉,还可以主动调用接口查询。事务消息不支持定时和批量。如果发现某些消息没有收到发送者的应答,则会出现消息堆积在队列中的情况。一个事务消息可能被检查或者消费多次。
10. 谈谈RocketMQ的最佳实践。
答:分三方面。
- Producer端最好一个应用只配置一个Topic,同时为每个消息设置一个key,方便排查错误。如果有可靠性要求,可以打印sendResult(即使返回了sendResult也不代表存储成功了)和key。如果相同性质的消息量大,则可以批量发送。消息不建议超过512KB。send方法会阻塞,如果有性能要求,建议使用send(msg, callback)异步调用。对于一个服务器来说,一般都是8核,所以建议3-5个生产者即可,多了会有资源争用。对于发送失败的消息,需要实现重发和存储该消息到本地数据库。
- Consumer端如果对重复敏感,需要在业务层面去重,因为RocketMQ无法去重。
-
NameServer的环境变量配置。
-