rocketmq使用

2022-04-17  本文已影响0人  轻舞凋零

应用

rocket-mq有四个概念

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

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

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

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

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

支持tag和key进行消息过滤

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

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

消息发送

同步刷盘和异步刷盘

同步复制和异步复制

上一篇 下一篇

猜你喜欢

热点阅读