• RocketMQ-08-auth manage 权限管理
  权限控制 1.权限控制特性介绍 权限控制（ACL）主要为RocketMQ提供Topic资源级别的用户访问控制。用户在使用RocketMQ权限控制时，可以在Client客户端通过 RPCHook注入AccessKey和SecretKey签名； 同时，将对应的权限控制属性（包括Topic访问权限、IP白名单和AccessKey和SecretKey签名等）设置在distribution/c...
  2022-03-18 13:01:55 | MQ
• RocketMQ-07-message trace 消息跟踪
  消息轨迹 1. 消息轨迹数据关键属性 Producer端 Consumer端 Broker端 生产实例信息 消费实例信息  消息的Topic 发送消息时间 投递时间,投递轮次  消息存储位置 ...
  2022-03-18 13:01:55 | MQ
• RocketMQ-06-best practice 最佳实践
  1 生产者 1.1 发送消息注意事项 1 Tags的使用 一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。 tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags(“TagA”)。 2 Keys的使用 每个消息在业务层面的唯一标识码要设置到keys字段...
  2022-03-18 13:01:55 | MQ
• RocketMQ-05-example 例子
  1 基本样例 在基本样例中我们提供如下的功能场景： 使用RocketMQ发送三种类型的消息：同步消息、异步消息和单向消息。 其中前两种消息是可靠的，因为会有发送是否成功的应答。 使用RocketMQ来消费接收到的消息。 引入依赖 <dependency> <groupId>org.apache.rocketmq</groupId> ...
  2022-03-18 13:01:55 | MQ
• RocketMQ-04-设计
  1 消息存储 消息存储是RocketMQ中最为复杂和最为重要的一部分，本节将分别从RocketMQ的消息存储整体架构、PageCache与Mmap内存映射以及RocketMQ中两种不同的刷盘方式三方面来分别展开叙述。 1.1 消息存储整体架构 消息存储架构图中主要有下面三个跟消息存储相关的文件构成。 (1) CommitLog：消息主体以及元数据的存储主体，存储Producer端...
  2022-03-18 13:01:55 | MQ
• RocketMQ-03-架构设计
  1 技术架构 RocketMQ架构上主要分为四部分，如上图所示: Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递，投递的过程支持快速失败并且低延迟。 Consumer：消息消费的角色，支持分布式集群方式部署。支持以push推，pull拉两种模式对消息进行消费。同时也支持集群方式和广播方式的消费，...
  2022-03-18 13:01:55 | MQ
• RocketMQ-02-特性
  1 订阅与发布 消息的发布是指某个生产者向某个topic发送消息；消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。 2 消息顺序 消息有序指的是一类消息消费时，能按照发送的顺序来消费。 例如：一个订单产生了三条消息分别是订单创建、订单付款、订单完成。 消费时要按照这个顺序消费才能有意义，但是同时订单之间是可以并行消费的。RocketM...
  2022-03-18 13:01:55 | MQ
• RocketMQ-01-基本概念
  1 消息模型（Message Model） RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。 Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。 Me...
  2022-03-18 13:01:55 | MQ