-
rocketsmq-08-quick start 快速开始
Dledger快速搭建
前言
该文档主要介绍如何快速构建和部署基于 DLedger 的可以自动容灾切换的 RocketMQ 集群。
详细的新集群部署和旧集群升级指南请参考 部署指南。
1. 源码构建
构建分为两个部分,需要先构建 DLedger,然后 构建 RocketMQ
1.1 构建 DLedger
git clone https://github.com/openmess...
2018-09-20 01:35:26 |
MQ
-
rocketsmq-07-auth admin 鉴权控台
权限控制
1.权限控制特性介绍
权限控制(ACL)主要为RocketMQ提供Topic资源级别的用户访问控制。用户在使用RocketMQ权限控制时,可以在Client客户端通过 RPCHook注入AccessKey和SecretKey签名;同时,将对应的权限控制属性(包括Topic访问权限、IP白名单和AccessKey和SecretKey签名等)设置在distribution/conf...
2018-09-20 01:35:26 |
MQ
-
rocketsmq-06-message trace 消息轨迹
消息轨迹
1. 消息轨迹数据关键属性
Producer端
Consumer端
Broker端
生产实例信息
消费实例信息
消息的Topic
发送消息时间
投递时间,投递轮次
消息存储位置
...
2018-09-20 01:35:26 |
MQ
-
rocketsmq-05-最佳实践
最佳实践
1 生产者
1.1 发送消息注意事项
1 Tags的使用
一个应用尽可能用一个Topic,而消息子类型则可以用tags来标识。tags可以由应用自由设置,只有生产者在发送消息设置了tags,消费方在订阅消息时才可以利用tags通过broker做消息过滤:message.setTags(“TagA”)。
2 Keys的使用
每个消息在业务层面的唯一标识码要设置到ke...
2018-09-20 01:35:26 |
MQ
-
rocketsmq-04-入门例子
1 基本样例
在基本样例中我们提供如下的功能场景:
使用RocketMQ发送三种类型的消息:同步消息、异步消息和单向消息。其中前两种消息是可靠的,因为会有发送是否成功的应答。
使用RocketMQ来消费接收到的消息。
1.1 加入依赖:
maven:
<dependency>
<groupId>org.apa...
2018-09-20 01:35:26 |
MQ
-
rocketsmq-03-Architecture&Design 架构与设计
架构设计
1 技术架构
RocketMQ架构上主要分为四部分,如上图所示:
Producer:消息发布的角色,支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递,投递的过程支持快速失败并且低延迟。
Consumer:消息消费的角色,支持分布式集群方式部署。支持以push推,pull拉两种模式对...
2018-09-20 01:35:26 |
MQ
-
rocketsmq-02-concept&features 基本概念与特性
基本概念
1 消息模型(Message Model)
RocketMQ主要由 Producer、Broker、Consumer 三部分组成,其中Producer 负责生产消息,Consumer 负责消费消息,Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器,每个 Broker 可以存储多个Topic的消息,每个Topic的消息也可以分片存储于不同的 Broker。...
2018-09-20 01:35:26 |
MQ
-
MQ Learn-01-Overview
MQ 的优势
1.通过持久性冗余
冗余是消息队列最明显的优势之一。应用程序崩溃,超时,代码中的错误以及其他问题只是常态的一部分。在每月处理数百万或数十亿交易的应用程序中尤其如此。
队列通过使读取消息的进程确认它已完成事务并且可以安全地删除它来帮助实现冗余。如果出现任何问题,最糟糕的情况是,该消息会持久保存到某处,并且不会丢失。它可以在以后重新处理。
2.交通高峰期
您并不总是确切知...
2018-09-20 01:35:26 |
MQ