RocketMQ学习笔记（8）----RocketMQ的Producer API简介
在RocketMQ中提供了三种发送消息的模式： 1.NormalProducer（普通） 2.OrderProducer（顺序） 3.TransactionProducer（事务） 下面来介绍一下producer中的各个API的使用： 1. producerGroup ...
原文：RocketMQ学习笔记（12）----RocketMQ的Consumer API简介
由于消息的消费方式有两种，所以两种方式也有不同的API： . PushConsumer的配置 .consumerGroup： 默认值为DEFAULT CONSUMER，Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组 .messageModel： 消息模型，默认值为CLUSTERING，支持集群消费，广播消费两种模型 .consum ...
2018-11-14 14:36 0 1182 推荐指数：
相关推荐
RocketMQ学习笔记（6）----RocketMQ的Client的使用 Producer/Consumer
1. 添加依赖 pom.xml如下： 2. Producer 的开发步骤 1. 实例化Producer Gr ...
RocketMQ学习笔记（6）----RocketMQ的Client的使用 Producer/Consumer
1. 添加依赖 pom.xml如下： 2. Producer 的开发步骤 1. 实例化Producer Group，如下： 2. 设置namesrvA ...
RocketMQ学习笔记（13）----RocketMQ的Consumer消息重试
1. 概念 Producer端重试： 生产者端的消息失败，也就是Producer往MQ上发消息没有发送成功，比如网络抖动导致生产者发送消息到MQ失败。 这种消息失败重试我们可以手动设置发送失败重试的次数。 Consumer端重试： Consumer消费消息失败后，要提供一种 ...
RocketMQ之Consumer
一、Consumer 介绍 1.1 核心参数 二、消费模式 2.1 集群模式 2.2 广播模式 三、Offset 介绍 3.1 Offset 是什么 3.2 Offset 类结构 从类结构可以看出 Offset 分为本地文件类型和远程文件类型。 3.2 消费 ...
RocketMQ（八）RocketMQ的Consumer负载均衡
一、问题描述 RocketMQ的Consumer是如何做的负载均衡？比如：5个Consumer进程同时消费一个Topic，这个Topic只有4个queue会出现啥情况？反之Consumer数量小于queue的数据是啥情况？ 二、源码剖析 1、RebalancePushImpl ...
【rocketmq学习笔记】rocketmq入门学习
基本介绍 rocketmq是阿里巴巴团队使用java语言开发的一款基于发布订阅模型的分布式消息队列中间件，是一款低延迟，高可用，拥有海量消息堆积能力和灵活拓展性的消息队列。 特点 可以实现集群无单点故障问题，节点高可用，水平可扩展； 支持消息存储，写入低延迟，支持实时消息查询 ...
RocketMQ之NameServer学习笔记
org.apache.rocketmq.namesrv.NamesrvController NameserController,NameServer的核心控制类。 1.1 NamesrvConfig NamesrvConfig,主要指定nameserver的相关配置目录属性 ...