搜云库技术团队

1、Producer负载均衡 Producer端，每个实例在发消息的时候，默认会轮询所有的message queue发送，以达到让消息平均落在不同的queue上。而由于queue可以散落在不同的broker，所以消息就发送到不同的broke...

赞(0)站长2020-07-29Java汇总 阅读(786)

一、分布式集群 RocketMQ分布式集群是通过Master和Slave的配合达到高可用性的。 Master和Slave的区别：在Broker的配置文件中，参数brokerId的值为0表明这个Broker是Master，大于0表明这个Bro...

赞(0)站长2020-07-29Java汇总 阅读(870)

一、基本流程 分布式队列因为有高可靠性的要求，所以数据要进行持久化存储。 1、 消息生成者发送消息 2、 MQ收到消息，将消息进行持久化，在存储中新增一条记录 3、 返回 ACK给生产者 4、 MQ push 消息给对应的消费者，然后等待消...

赞(0)站长2020-07-29Java汇总 阅读(884)

1、背景： RockeyMQ实现分布式事务（拿下单和扣减库存为例，如果下单和扣减库存在一个分布式系统中，需要维持一个事务性） 如果下单后发消息提示需要扣减库存，保持一个分布式事务的一致性，就会出现以下场景： 场景一：先下单后发消息 问题：先...

赞(0)站长2020-07-29Java汇总 阅读(802)

背景 前文总结了RocketMQ消息的发送和消费之基本样例，发送消息分为发送同步、异步和单向消息，消费消息分为负载均衡模式和广播模式。下面针对于常见的消息类型做一个补充，分为顺序消息、延时消息、批量消息和过滤消息。 1 顺序消息 消息有序指...

赞(0)站长2020-07-29Java汇总 阅读(803)

1、整体步骤 导入 MQ客户端依赖 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-clien...

赞(0)站长2020-07-29Java汇总 阅读(718)

1 概述 RocketMQ有一个对其扩展的开源项目incubator-rocketmq-externals，这个项目中有一个子模块叫rocketmq-console，这个便是管理控制台项目了，先将incubator-rocketmq-ext...

赞(0)站长2020-07-29Java汇总 阅读(736)

1 使用方式 进入RocketMQ安装位置，在bin目录下执行./mqadmin {command} {args} 2 命令介绍 1）Topic相关 名称 含义 命令选项 说明 updateTopic 创建更新Topic配置 -b Brok...

赞(0)站长2020-07-29Java汇总 阅读(825)

1 各角色介绍 Producer：消息的发送者；举例：发信者 Consumer：消息接收者；举例：收信者 Broker：暂存和传输消息；举例：邮局 NameServer：管理 Broker；举例：各个邮局的管理机构 Topic：区分消息的种...

赞(0)站长2020-07-29Java汇总 阅读(761)

1 为什么要用MQ 消息队列是一种“先进先出”的数据结构 其应用场景主要包含以下3个方面: 应用解耦 系统的耦合性越高，容错性就越低。以电商应用为例，用户创建订单后，如果耦合调用库存系统、物流系统、支付系统，任何一个子系统出了故障或者因为升...

赞(0)站长2020-07-29Java汇总 阅读(779)