首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

RocketMQ

还有个重要功能是挡住前端的数据洪峰,保证后端系统的稳定性,这就要求消息中间件具有一定的消息堆积能力 rocket相比其他mq的优点 能够保证严格的消息顺序 提供丰富的消息拉取模式 实时的消息订阅机制 亿级消息堆积能力 rocketmq...使用同步复制 可以保证消息100%不丢失(但是性能下降10%) rocketmq节点 Name Server Broker 部署相对复杂,Broker 分为 Master 与 Slave 一个 Master...由于 RocketMQ 所有消息都是持久化的,所以如果按照优先级来排序,开销会非常大,因此 RocketMQ 没有特意支持消息优先级,但是可以通过变通的方式实现类似功能,即单独配置一个优先级高的队列,和一个普通优先级的队列...每个优先级可以用不同的 topic 表示,发消息时,指定不同的 topic 来表示优先级,这种方式可以解决绝大部分的优先级问题,但是对业务的优先级精确性做了妥协 刷盘方式 rocketmq 建议使用多主多从同步复制

2.2K10

RocketMQ

RocketMQ快速入门 RocketMQ是阿里巴巴2016年MQ中间件,使用Java语言开发,在阿里内部,RocketMQ承接了例如“双11”等高并发场景的消息流转,能够处理万亿级别的消息。...2.1 准备工作 2.1.1 下载RocketMQ RocketMQ最新版本:4.5.1 下载地址 2.2.2 环境要求 Linux64位系统 JDK1.8(64位) 源码安装需要安装Maven...ROCKETMQ_HOME=/usr/local/rocketmq/rocketmq-all-4.4.0-bin-release PATH=$PATH:$ROCKETMQ_HOME/bin export...RocketMQ的消息用顺序写,保证了消息存储的速度。 ####2)消息发送 Linux操作系统分为【用户态】和【内核态】,文件操作、网络操作需要涉及这两种形态的切换,免不了进行数据复制。...=E:\\RocketMQ\\data\\rocketmq\\dataDir\\index # checkpoint文件路径 storeCheckpoint=E:\\RocketMQ\\data\\rocketmq

75710

RocketMQ详解(2)——RocketMQ核心概念

RocketMQ详解(2)——RocketMQ核心概念 一. RocketMQ专业术语 Producer 消息生产者,负责产生消息,一般由业务系统负责产生消息。...RocketMQ的消费方式 广播消息 一条消息被多个Consumer消费,即使这些Consumer属于同一个Consumer Group,消息也会被Consumer Group中的每一个Consumer...在JMS规范中,类似于P2P模型,但是RocketMQ的集群消费功能大于等于JMS的P2P消费。...因为集群消费模式下,RocketMQ单个Consumer Group内的消费类似于P2P,但是一个Topic/Queue可以被多个Consumer Group消费。...在RocketMQ中,该顺序主要指局部顺序,即一类消费为满足顺序性,必须Producer单线程发送,且发送到同一个队列,这样Consumer就可以按照Producer的发送顺序来消费消息。

1.3K20

RocketMQ

本文参考 消息存储 不会永久保存消息文件,而是启用文件过期策略,在磁盘空间不足或在凌晨4点删除过期文件,文件默认保存72小时,删除时不会判断该文件上的消息是否被消费...fileName是以创建时的时间戳命名的,固定的单个IndexFile文件大小约为400M,一个IndexFile可以保存2000W个索引,IndexFile的底层存储设计为在文件系统中实现HashMap结构,故rocketmq...该消息的主题名称为重试主题,其他属性与原先的消息保持相同 在存入commitlog文件之前,如果消息的延迟级别大于0,替换消息的主题为定时任务主题 SCHEDULE_TOPIC_XXX,队列ID为延迟级别减1 顺序消费 ROCKETMQ...master汇报 消息消费者向master拉取消息时,如果消息消费者内存中存在消息消费进度时,master会尝试跟新消息消费进度 读写分离 master负责读写,slave可以为读,也可以什么都不做 RocketMQ

2.1K30
领券