RocketMQ有哪些特性

73次阅读
没有评论

共计 3777 个字符,预计需要花费 10 分钟才能阅读完成。

这篇文章主要介绍了 RocketMQ 有哪些特性,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让丸趣 TV 小编带着大家一起了解一下。

一 nameserver
 

相对来说,nameserver 的稳定性非常高。原因有二:

1 nameserver 互相独立,彼此没有通信关系,单台 nameserver 挂掉,不影响其他 nameserver,即使全部挂掉,也不影响业务系统使用,这点类似于 dubbo 的 zookeeper。

2 nameserver 不会有频繁的读写,所以性能开销非常小,稳定性很高。

二 broker
 

1 与 nameserver 关系
 

连接

      单个 broker 和所有 nameserver 保持长连接

心跳

      心跳间隔:每隔 30 秒(
  此时间无法更改)向所有 nameserver 发送心跳,心跳包含了自身的 topic 配置信息。

      心跳超时:nameserver 每隔 10 秒钟(
  此时间无法更改),扫描所有还存活的 broker 连接,若某个连接 2 分钟内(
  当前时间与最后更新时间差值超过 2 分钟,此时间无法更改)没有发送心跳数据,则断开连接。

断开

      时机:broker 挂掉;心跳超时导致 nameserver 主动关闭连接

      动作:一旦连接断开,nameserver 会立即感知,更新 topc 与队列的对应关系,但不会通知生产者和消费者

2 负载均衡
 

一个 topic 分布在多个 broker 上,一个 broker 可以配置多个 topic,它们是多对多的关系。

如果某个 topic 消息量很大,应该给它多配置几个队列,并且尽量多分布在不同 broker 上,减轻某个 broker 的压力。

topic 消息量都比较均匀的情况下,如果某个 broker 上的队列越多,则该 broker 压力越大。

3 可用性
 

    由于消息分布在各个 broker 上,一旦某个 broker 宕机,则该 broker 上的消息读写都会受到影响。所以 rocketmq 提供了 master/slave 的结构,salve 定时从 master 同步数据,如果 master 宕机,则 slave 提供消费服务,但是不能写入消息,此过程对应用透明,由 rocketmq 内部解决。
 

这里有两个关键点:
 

一旦某个 broker master 宕机,生产者和消费者多久才能发现?受限于 rocketmq 的网络连接机制,默认情况下,最多需要 30 秒,但这个时间可由应用设定参数来缩短时间。这个时间段内,发往该 broker 的消息都是失败的,而且该 broker 的消息无法消费,因为此时消费者不知道该 broker 已经挂掉。

消费者得到 master 宕机通知后,转向 slave 消费,但是 slave 不能保证 master 的消息 100% 都同步过来了,因此会有少量的消息丢失。但是消息最终不会丢的,一旦 master 恢复,未同步过去的消息会被消费掉。

4 可靠性
 

所有发往 broker 的消息,有同步刷盘和异步刷盘机制,总的来说,可靠性非常高

同步刷盘时,消息写入物理文件才会返回成功,因此非常可靠

异步刷盘时,只有机器宕机,才会产生消息丢失,broker 挂掉可能会发生,但是机器宕机崩溃是很少发生的,除非突然断电

5 消息清理
 

扫描间隔

      默认 10 秒,由 broker 配置参数
  cleanResourceInterval
  决定
 

空间阈值

      物理文件不能无限制的一直存储在磁盘,当磁盘空间达到阈值时,不再接受消息,broker 打印出日志,消息发送失败,阈值为固定值 85%
 

清理时机

      默认每天凌晨 4 点,由 broker 配置参数
  deleteWhen 决定;或者磁盘空间达到阈值
 

文件保留时长

      默认 72 小时,由 broker 配置参数
  fileReservedTime
  决定
 

6 读写性能
 

文件内存映射方式操作文件,避免 read/write 系统调用和实时文件读写,性能非常高

永远一个文件在写,其他文件在读

顺序写,随机读

利用 linux 的 sendfile 机制,将消息内容直接输出到 sokect 管道,避免系统调用

7 系统特性
 

大内存,内存越大性能越高,否则系统 swap 会成为性能瓶颈

IO 密集

cpu load 高,使用率低,因为 cpu 占用后,大部分时间在 IO WAIT

磁盘可靠性要求高,为了兼顾安全和性能,采用 RAID10 阵列

磁盘读取速度要求快,要求高转速大容量磁盘

三 消费者
 

1 与 nameserver 关系
 

连接

      单个消费者和一台 nameserver 保持长连接,定时查询 topic 配置信息,如果该 nameserver 挂掉,消费者会自动连接下一个 nameserver,直到有可用连接为止,并能自动重连。
 

心跳

与 nameserver 没有心跳
 

轮询时间

默认情况下,消费者每隔 30 秒从 nameserver 获取所有 topic 的最新队列情况,这意味着某个 broker 如果宕机,客户端最多要 30 秒才能感知。该时间由
      DefaultMQPushConsumer 的
      pollNameServerInteval 参数决定,可手动配置。
     

2 与 broker 关系
 

连接

单个消费者和该消费者关联的所有 broker 保持长连接。
 

心跳

默认情况下,消费者每隔 30 秒向所有 broker 发送心跳,该时间由 DefaultMQPushConsumer 的 heartbeatBrokerInterval 参数决定,可手动配置。broker 每隔 10 秒钟(此时间无法更改),扫描所有还存活的连接,若某个连接 2 分钟内(当前时间与最后更新时间差值超过 2 分钟,此时间无法更改)没有发送心跳数据,则关闭连接,并向该消费者分组的所有消费者发出通知,分组内消费者重新分配队列继续消费
 

断开

时机:消费者挂掉;心跳超时导致 broker 主动关闭连接

动作:一旦连接断开,broker 会立即感知到,并向该消费者分组的所有消费者发出通知,分组内消费者重新分配队列继续消费
 

3 负载均衡
 

集群消费模式下,一个消费者集群多台机器共同消费一个 topic 的多个队列,一个队列只会被一个消费者消费。如果某个消费者挂掉,分组内其它消费者会接替挂掉的消费者继续消费。

4 消费机制
 

本地队列

        消费者不间断的从 broker 拉取消息,消息拉取到本地队列,然后本地消费线程消费本地消息队列,只是一个异步过程,拉取线程不会等待本地消费线程,这种模式实时性非常高。对消费者对本地队列有一个保护,因此本地消息队列不能无限大,否则可能会占用大量内存,本地队列大小由
  DefaultMQPushConsumer 的
  pullThresholdForQueue 属性控制,默认 1000,可手动设置
 。
 

轮询间隔

      消息拉取线程每隔多久拉取一次?间隔时间由
  DefaultMQPushConsumer 的
  pullInterval
  属性控制,默认为 0,可手动设置。
 

消息消费数量

      监听器每次接受本地队列的消息是多少条?这个参数由
  DefaultMQPushConsumer 的
  consumeMessageBatchMaxSize
  属性控制,默认为 1,可手动设置。
 

5 消费进度存储
 

      每隔一段时间将各个队列的消费进度存储到对应的 broker 上,该时间由
  DefaultMQPushConsu
  mer 的
  persistConsumerOffsetInterval 属性控制,默认为 5 秒,可手动设置。
 

6 如果一个 topic 在某 broker 上有 3 个队列,一个消费者消费这 3 个队列,那么该消费者和这个 broker 有几个连接?
 

      一个连接,消费单位与队列相关,消费连接只跟 broker 相关,事实上,消费者将所有队列的消息拉取任务放到本地的队列,挨个拉取,拉取完毕后,又将拉取任务放到队尾,然后执行下一个拉取任务
 

四 生产者
 

1 与 nameserver 关系
 

连接

      单个生产者者和一台 nameserver 保持长连接,定时查询 topic 配置信息,如果该 nameserver 挂掉,生产者会自动连接下一个 nameserver,直到有可用连接为止,并能自动重连。
 

轮询时间

默认情况下,生产者每隔 30 秒从 nameserver 获取所有 topic 的最新队列情况,这意味着某个 broker 如果宕机,生产者最多要 30 秒才能感知,在此期间,发往该 broker 的消息发送失败。该时间由 DefaultMQProducer 的 pollNameServerInteval 参数决定,可手动配置。
 

心跳

与 nameserver 没有心跳
 

 
 

2 与 broker 关系
 

连接

单个生产者和该生产者关联的所有 broker 保持长连接。
 

心跳

默认情况下,生产者每隔 30 秒向所有 broker 发送心跳,该时间由 DefaultMQProducer 的 heartbeatBrokerInterval 参数决定,可手动配置。broker 每隔 10 秒钟(此时间无法更改),扫描所有还存活的连接,若某个连接 2 分钟内(当前时间与最后更新时间差值超过 2 分钟,此时间无法更改)没有发送心跳数据,则关闭连接。

连接断开

移除 broker 上的生产者信息
 

 
 

3 负载均衡
 

      生产者时间没有关系,每个生产者向队列轮流发送消息
 

感谢你能够认真阅读完这篇文章,希望丸趣 TV 小编分享的“RocketMQ 有哪些特性”这篇文章对大家有帮助,同时也希望大家多多支持丸趣 TV,关注丸趣 TV 行业资讯频道,更多相关知识等着你来学习!

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-08-16发表,共计3777字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)