消费者从Broker中获取消息的方式有两种：pull拉取方式和push推动方式。消费者组对于消息消费的模式又分为两种：集群消费Clustering和广播消费Broadcast...
发简信
IP属地：陕西
-
RocketMQ(十)——消息的消费 -
理论上是这样的，但一般来说，master使用raid镜像策略，slave就不必再使用了。
RocketMQ(六)——集群搭建理论
1.数据复制与刷盘策略 复制策略复制策略是Broker得Master与Slave间得数据同步方式。分为同步复制与异步复制： 同步复制：消息写入master后，master会等...
-
主从和RAID10解决的是不同问题，主从是多机器下的一种集群模式，目的是为了分担单节点的压力，提高系统性能。RAID10是单个服务器的磁盘存储策略，防止出现某块磁盘不可用导致数据丢失的问题，旨在保证数据可靠性
RocketMQ(六)——集群搭建理论
1.数据复制与刷盘策略 复制策略复制策略是Broker得Master与Slave间得数据同步方式。分为同步复制与异步复制： 同步复制：消息写入master后，master会等...
-
RocketMQ(九)——indexFile除了通过通常的指定Topic进行消息消费外，rocketMQ还提供了根据Key进行查询的功能。该查询是通过store目录中的index子目录中的indexFile进行索引实现...
-
RocketMQ(八)——消息的存储RocketMQ中的消息存储在本地文件系统中，这些相关文件默认在当前用户主目录下的store目录中。 abort：该文件在Broker启动后会自动创建，正常关闭Broker，...
-
RocketMQ(七)——消息的生产
1.消息的生产过程 Producer可以将消息写入到某Broker中的某Queue中，经历的如下过程： Producer发送消息之前，会先向NameServer发出获取消息T...
-
RocketMQ(扩展)——磁盘阵列RAID1.RAID历史 1988 年美国加州大学伯克利分校的 D. A. Patterson 教授等首次在论文 “A Case of Redundant Array of Inex...
-
RocketMQ(六)——集群搭建理论1.数据复制与刷盘策略 复制策略复制策略是Broker得Master与Slave间得数据同步方式。分为同步复制与异步复制： 同步复制：消息写入master后，master会等...
-
RocketMQ(五)——控制台安装与启动RocketMQ有一个可视化的的dashboard，通过该控制台可以直观的看到很多数据 1.下载 下载地址：https://github.com/apache/rocketm...
-
RocketMQ(四)——安装与启动1.环境准备 2.下载 下载地址：https://rocketmq.apache.org/[https://rocketmq.apache.org/] 我下载的是4.9.2版...
-
RocketMQ(三)——系统架构RocketMQ架构上主要分为四部分构成： 1.Producer 消息生产者，负责生产消息。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递，...
-
RocketMQ(二)——基本概念1.消息(Message) 消息是指，消息系统所传出信息的物理载体，生产和消费数据的最小单位，每条消息必须属于一个主题 2.主题(Topic) Topic表示一类消息的集合，...
-
RocketMQ(一)——概述
由于之前整理过activeMQ的文章，关于MQ的概述就不详细介绍了MQ的作用①限流削峰②异步解耦③数据收集 1.MQ常见协议 一般情况下MQ的实现是要遵循一些常规性协议的。常...
-
SpringCloud(46)——Seata1.Seata模式 Seata有四种模式 有AT、TCC、SAGA、XA模式我们在测试时候使用的是AT模式 2.Seata组件 Seata有三个组件，TC、TM、RM，那么我...
-
SpringCloud(45)——Seata的使用环境准备 我们准备好三个服务 订单服务Order-Module库存服务Storage-Module账户服务Account-Module 业务需求：下订单->减库存->扣余额-...
-
SpringCloud(44)——Seata数据库环境准备1.分布式事务业务说明 这里我们会创建三个服务，一个订单服务，一个库存服务，一个账户服务。 当用户下单时，会在订单服务中创建一个订单，然后通过远程调用库存服务来扣减下单商品的...
-
SpringCloud(43)——Seata简介与安装1.分布式事务的问题 当我们的单体应用被拆分成微服务应用，原来的三个模块被拆分成三个独立的应用，分别使用三个独立的数据源，业务需要调用三个服务来完成。例如：下订单的操作需要不...
-
SpringCloud(42)——Sentinel持久化1.问题描述 经过我们多次的测试发现，一旦重启服务后，sentinel配置的规则就被初始化了，需要我们重新再配置，如果上生产环境的话肯定需要持久化的。 2.持久化效果 例如我...
-
SpringCloud(41)——Sentinel自定义回滚方法配置我们都知道Sentinel默认的回滚提示是Blocked by Sentinel而且我也给大家演示了如何写自定义的回滚方法。 但是这样写还有一些问题：①依照现有条件，我们自定...
-
SpringCloud(40)——Sentinel热点Key什么是热点？我们看一下官网的解释 我个人理解，之前的流控和降级是针对接口级别来进行限流的，而热点可以做到更细粒度的限流，从参数的角度来进行限流。 回滚方法之前的case，当触...