搜索结果
查询Tags标签： RocketMQ，共有 213条记录-
Rocketmq学习3——消息发送原理源码浅析
一丶概述 RocketMQ 消息发送的原理流程可以分为以下几个步骤： 1. 创建生产者 在发送消息前，客户端首先需要创建一个消息生产者（Producer）实例，并设置必要的配置参数，如NameServer地址、生产组名称、消息发送失败的重试次数等。 2. 启动生产者 创建生产者后，需要调用…
2024/1/21 18:02:28 人评论 次浏览 -
Rocketmq学习2——Rocketmq消息过滤&事务消息&延迟消息原理源码浅析
系列文章目录和关于我 零丶引入 在《Rocketmq学习1——Rocketmq架构&消息存储&刷盘机制》中我们学习了rocketmq的架构，以及消息存储设计，在此消息存储设计之上，rocketmq提供了诸如：延时消息、事务消息、消息过滤、消息回溯等高级特性。这一篇将对这些高级特性…
2024/1/16 5:02:43 人评论 次浏览 -
Rocketmq学习1——Rocketmq架构&消息存储&刷盘机制
系列文章目录和关于我 一丶什么是Rocketmq RocketMQ是一款开源的分布式消息中间件，由阿里巴巴团队最初开发，并于2016年贡献给Apache软件基金会，后成为Apache*项目。RocketMQ设计用于处理高并发、高吞吐量的场景，支持丰富的消息交互模式。 以下是RocketMQ的一些关键特性…
2024/1/8 11:02:20 人评论 次浏览 -
【RocketMQ】顺序消息实现总结
全局有序 在RocketMQ中，如果使消息全局有序，可以为Topic设置一个消息队列，使用一个生产者单线程发送数据，消费者端也使用单线程进行消费，从而保证消息的全局有序，但是这种方式效率低，一般不使用。 局部有序 假设一个Topic分配了两个消息队列，生产者在发送消息的时…
2023/9/20 11:23:02 人评论 次浏览 -
MQ系列13：消息大量堆积如何为解决
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障MQ系列9：高可用架构分…
2023/6/9 18:22:15 人评论 次浏览 -
MQ系列12：如何保证消息顺序性
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障MQ系列9：高可用架构分…
2023/6/7 18:22:35 人评论 次浏览 -
Redis系列14：使用List实现消息队列
Redis系列1：深刻理解高性能Redis的本质Redis系列2：数据持久化提高可用性Redis系列3：高可用之主从架构Redis系列4：高可用之Sentinel(哨兵模式）Redis系列5：深入分析Cluster 集群模式 追求性能极致：Redis6.0的多线程模型追求性能极致：客户端缓存带来的革命Redis系列8…
2023/6/5 18:24:09 人评论 次浏览 -
详解RocketMQ 顺序消费机制
摘要：顺序消息是指对于一个指定的 Topic ，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。 本文分享自华为云社区《RocketMQ 顺序消费机制》，作者： 勇哥java实战分享 。 顺序消息是指对于一个指定的 Topic ，消息…
2023/5/30 18:23:02 人评论 次浏览 -
【RocketMQ】NameServer总结
NameServer是一个注册中心，提供服务注册和服务发现的功能。NameServer可以集群部署，集群中每个节点都是对等的关系（没有像ZooKeeper那样在集群中选举出一个Master节点），节点之间互不通信。服务注册 Broker启动的时候会向所有的NameServer节点进行注册，注意这里是向集…
2023/5/26 5:22:06 人评论 次浏览 -
大型网站架构系列：分布式消息队列（一）
一、消息队列概述消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，Me…
2022/11/14 23:23:57 人评论 次浏览 -
rocketmq安装
4、启动 （1）启动NAMESERVER 使用cmd打开命令窗口，进入到rocketmq的bin目录下，执行：start mqnamesrv.cmd，若成功会弹出如下提示框，请勿关闭此框。（2）启动BROKER 同样在rocketmq的bin目录下，执行：start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=tr…
2022/8/31 23:23:13 人评论 次浏览 -
RocketMQ 延时消息
一、什么是延时消息 当消息写入到Broker后，不能立刻被消费者消费，需要等待指定的时长后才可被消费处理的消息，称为延时消息。 二、延时消息等级 RocketMQ延时消息的延迟时长不支持随意时长的延迟，是通过特定的延迟等级来指定的。默认支持18个等级的延迟消息，延时等级…
2022/8/11 6:23:21 人评论 次浏览 -
RocketMQ
消息中间件常用消息中间件对比RocketMQ相比其他两种有一个不可替代的优势：支持事务消息作用异步解耦（提高效率）削峰填谷（缓解压力）分布式缓存同步 消息分发写磁盘方式RocketMQ的消息是存储到磁盘上的，这样既能保证断电后恢复，又可以让存储的消息量超出内存的限制。…
2022/8/4 6:25:36 人评论 次浏览 -
Windows系统下RocketMQ JDK11启动脚本修改
RocketMQ 版本：4.9.4 RocketMQ 的bin目录下修改runserver.cmd文件删除 -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection删除-XX:-UseParNewGC删除-XX:+PrintGCDetails修改-Xloggc->Xlog:gc还有一个配置是-XX:+PrintGCDateStamps，我的在执行上面四步仍然…
2022/7/23 5:24:14 人评论 次浏览 -
RocketMQ系列二：RocketMQ监控/告警一站式搭建应用
实验简介 研究RocketMQ的同学都知道，RocketMQ的生态目前并不是很完善，包括官方的文档资料也有限，官方的Console存在一些Bug，页面 的样式有的也有问题，但是正是由于这些原因，我们针对RocketMQ能做的事有很多，不像Kafka，生态已经很完善，一些企业也对Kafka 做了开…
2022/7/22 23:27:49 人评论 次浏览
