首页
学习
活动
专区
工具
TVP
发布

RocketMQ

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

2.2K10
您找到你想要的搜索结果了吗?
是的
没有找到

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

RocketMQ 简介

事务消息:RocketMQ提供类似X/Open XA的分布事务功能,通过消息队列RocketMQ的事务消息能达到分布式事务的最终一致。...注册信息写入注册系统成功后,再发送消息至消息队列RocketMQ。消息队列RocketMQ会马上返回响应给注册系统,注册完成。用户可立即登录。...用户只需在注册页面等待注册数据写入注册系统和消息队列RocketMQ的时间,即等待55 ms即可登录。 异步解耦是消息队列RocketMQ的主要特点,主要目的是减少请求响应时间和解耦。...注册系统将注册信息写入注册系统之后,发送一条注册成功的消息到消息队列RocketMQ,邮件通知系统订阅消息队列RocketMQ的注册消息,做相应的业务处理,发送注册成功或者失败的邮件。...秒杀处理系统按照秒杀处理逻辑将满足秒杀条件的请求发送至消息队列RocketMQ。 下游的通知系统订阅消息队列RocketMQ的秒杀相关消息,再将秒杀成功的消息发送到相应用户。

1.7K30

RocketMQ入门

RocketMQ是一个分布式消息队列系统,它最初由阿里巴巴开发并开源。RocketMQ具有高可靠性、高吞吐量、高扩展性和良好的可维护性等特点,被广泛应用于金融、电商、物流、游戏等领域。...本文将介绍如何入门使用RocketMQ。...一、安装RocketMQ1.下载RocketMQ安装包从官网下载最新版本的RocketMQ安装包,地址:http://rocketmq.apache.org/release_notes/release-notes...-4.9.0/2.解压安装包将下载的安装包解压到指定目录下,如:/usr/local/rocketmq3.配置环境变量在/etc/profile文件中添加如下配置:export ROCKETMQ_HOME...4.启动RocketMQ进入RocketMQ安装目录下的bin目录,执行如下命令启动RocketMQ:sh mqnamesrvsh mqbroker -n localhost:9876二、使用RocketMQ1

56200

扫码

添加站长 进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

    运营活动

    活动名称
    广告关闭
    领券