• RocketMQ-12-api 消费者接口文档
  DefaultPullConsumer 类简介 DefaultMQPullConsumer extends ClientConfig implements MQPullConsumer DefaultMQPullConsumer主动的从Broker拉取消息，主动权由应用控制，可以实现批量的消费消息。Pull方式取消息的过程需要用户自己写,首先通过打算消...
  2022-03-18 13:01:55 | MQ
• RocketMQ-11-api 生产者接口文档
  DefaultMQProducer 类简介 public class DefaultMQProducer extends ClientConfig implements MQProducer DefaultMQProducer类是应用用来投递消息的入口，开箱即用，可通过无参构造方法快速创建一个生产者。主要负责消息的发送，支持同步/异步/oneway的发送方式，这些发送方式均支...
  2022-03-18 13:01:55 | MQ
• RocketMQ-10-operation 集群部署
  运维管理 1 集群搭建 1.1 单Master模式 这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。 1）启动 NameServer ### 首先启动Name Server $ nohup sh mqnamesrv & ### 验证Name Server 是否启动成功 $ tail -f ~/logs/...
  2022-03-18 13:01:55 | MQ
• RocketMQ-09-dledger 快速搭建
  Dledger快速搭建 前言 该文档主要介绍如何快速构建和部署基于 DLedger 的可以自动容灾切换的 RocketMQ 集群。 详细的新集群部署和旧集群升级指南请参考 部署指南。 1. 源码构建 构建分为两个部分，需要先构建 DLedger，然后 构建 RocketMQ 1.1 构建 DLedger git clone https://github.com/openmess...
  2022-03-18 13:01:55 | MQ
• 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