rocket-mq的使用(有队列使用经验)

2022-04-16 20:23:37 浏览数 (1)

应用

rocket-mq有四个概念

  • consumer
  • producer
  • name-server
  • broker

如果我要建一个队列,需要建立一个topic,topic支持group,group下支持两种模式:广播和集群。

集群就是所有的Consumer合起来消费一份全部消息,广播所有consumer都消费一份全部消息

name-server存储了所有broker的状态,存储消息到内存里面

broker控制消息的写入文件和内存队列

  • consumeQueue(逻辑队列,每个consumerQueue一个)和CommitLog(实际存储)

消费者支持pull和push两种模式

  • pull,自己去拉,做各种控制,需要处理异常场景和提交offset
  • push,服务端通过长连接,定时推送消息

支持tag和key进行消息过滤

保证消息有序,全局有序只能是单队列了

局部有序,可以在生产端实现MessageQueueSelector接口即可,消费端实现MessageListenOrder

消息发送

同步刷盘和异步刷盘

  • 异步刷盘,写内存成功返回
  • 同步刷盘,写入磁盘成功返回

同步复制和异步复制

  • 同步复制:都写入成功才返回给客户度
  • 异步复制:只要master broker写入就返回

0 人点赞