由于消息的消费方式有两种，所以两种方式也有不同的API： 1. PushConsumer的配置 　　1. consumerGroup： 默认值为DEFAULT_CONSUMER，Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一 ...

1. 添加依赖 　　pom.xml如下： 2. Producer 的开发步骤 　　1. 实例化Producer Group，如下： 　　2. 设置namesrvAddr,集群环境多个 ...

1. 添加依赖 　　pom.xml如下： 2. Producer 的开发步骤 　　1. 实例化Producer Group，如下： 　　2. 设置namesrvAddr,集群环境多个nameserver用;分割，如下： 　　3. 调用start ...

1. 事务消息原理图 　RocketMQ除了支持普通消息，顺序消息之外，还支持了事务消息。 1. 什么是分布式事务？ 　　分布式事务就是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。以上是百度百科的解释，简单的说，就是一次大的操作 ...

1. 事务消息原理图 　RocketMQ除了支持普通消息，顺序消息之外，还支持了事务消息。 1. 什么是分布式事务？ 　　分布式事务就是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。以上是百度百科的解释，简单的说，就是一次大的操作 ...

RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的？ 目录 RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的？ 前言 项目结构 rocketmq-client 模块 ...

一、Producer 介绍 1.1 消息发送的步骤 1.2 生产者核心参数 二、不同类型的生产者 生产者向消息队列中写入消息，根据不同的业务场景需要采用不同的写入策略，如同步发送、异步发送、延迟发送和发送事务消息等。 2.1 同步发送 2.2 异步发送 2.3 延迟 ...

基本介绍 rocketmq是阿里巴巴团队使用java语言开发的一款基于发布订阅模型的分布式消息队列中间件，是一款低延迟，高可用，拥有海量消息堆积能力和灵活拓展性的消息队列。 特点 可以实现集群无单点故障问题，节点高可用，水平可扩展； 支持消息存储，写入低延迟，支持实时消息查询 ...