Rocketmq-02-mac/linux 安装笔记
从零手写实现 mq
Quick Start
quick start
需要
64位操作系统,最好是Linux/Unix/Mac;
64位JDK 1.6+;
Maven 3.x
Git
Screen
JDK
houbinbindeMacBook-Pro:aliyun-ons-client-java houbinbin$ java -version
java version ...
2022-03-18 13:01:55 |
Apache
Rocketmq-01-入门介绍
Message Queue
消息队列(Message Queue,简称 MQ)是阿里巴巴集团中间件技术部自主研发的专业消息中间件。
产品基于高可用分布式集群技术,提供消息发布订阅、消息轨迹查询、定时(延时)消息、资源统计、监控报警等一系列消息云服务,是企业级互联网架构的核心产品。
为分布式应用系统提供异步解耦、削峰填谷的能力,同时具备海量消息堆积、高吞吐、可靠重试等互联网应用所需的特性...
2022-03-18 13:01:55 |
Apache
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