Java汇总 第303页

大数据篇：MapReduce MapReduce是什么? MapReduce源自于Google发表于2004年12月的MapReduce论文，是面向大数据并行处理的计算模型、框架和平台，而Hadoop MapReduce是Google Ma...

赞(0)站长2020-07-30阅读(827)

大数据篇：HDFS HDFS是什么? Hadoop分布式文件系统(HDFS)是指被设计成适合运行在通用硬件(commodity hardware)上的分布式文件系统（Distributed File System）。它和现有的分布式文件系统...

赞(0)站长2020-07-30阅读(808)

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

赞(0)站长2020-07-29阅读(841)

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

赞(0)站长2020-07-29阅读(926)

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

赞(0)站长2020-07-29阅读(941)

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

赞(0)站长2020-07-29阅读(857)

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

赞(0)站长2020-07-29阅读(859)

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

赞(0)站长2020-07-29阅读(777)

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

赞(0)站长2020-07-29阅读(791)

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

赞(0)站长2020-07-29阅读(882)