rocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
本文主要研究一下rocketmq的registerConsumer与unregisterConsumer
本文主要研究一下rocketmq的consumeMessageBatchMaxSize
RocketMQ Consumer 分为 Pull Consumer 和 Push Consumer ，其实就是推拉消费者。
集群模式是指 RocketMQ 中的一条消息只能被同一个消费者组中的一个消费者消费。如下图，Producer 向 TopicTest 这个 Topic 并发写入 3 条新消息，分别被分配到了 MessageQueue1~MessageQueue3 这 3 个队列，然后 Group 中的三个 Consumer 分别消费了一条消息：
本周有点琐事，没有源码文章输出，掉一次链子。整理了几个最近被问的问题，大家随便看看。
本文主要研究一下rocketmq的suspendCurrentQueueTimeMillis
本文主要研究一下rocketmq的adjustThreadPoolNumsThreshold
io/openmessaging/rocketmq/consumer/PushConsumerImpl.java
本文主要研究一下rocketmq的getOrCreateMQClientInstance
根据使用者对读取操作的控制情况，分为两种类型。一个是DefaultMQPushConsumer，由系统控制读取操作，收到消息后自动调用传入的处理方法来处理；另一个是DefaultMQPullConsumer，读取操作中的大部分功能由使用者自主控制。 1.DefaultMQPushConsumer的使用 使用DefaultMQPushConsumer主要是设置好各种参数和传入处理消息的函数。系统收到消息后自动调用处理函数来处理消息，自动保存Offset，而且加入新的DefaultMQPushConsumer后会自动做负载均衡。下面结合org.apache.rocketmq.example.quickstart包中的源码来介绍。 代码清单1-1 DefaultMQPushConsumer示例 public class QuickStart {
20170712182011089.gif 题外话 什么情况下的异步操作需要使用消息队列而不是多线程消息队列和多线程两者并不冲突，多线程可以作为队列的生产者和消费者。 使用外部的消息队列时，第一是可以提高应用的稳定性，当程序fail后，已经写入外部消息队列的数据依旧是保存的，如果使用两步commit的队列的话，可以更加提高这个项目。 用线程的话，会占用主服务器资源， 消息队列的话， 可以放到其他机器上运行， 让主服务器尽量多的服务其他请求。我个人认为， 如果用户不急着知道结果的操作， 用消息队列， 否则再考
本文主要研究一下rocketmq的consumeConcurrentlyMaxSpan
在进行常用的三种消息类型例子展示的时候，我们先来说一说RocketMQ的几个重要概念：
实际运行 中的系统，难免 会遇到重新消费某条消息、 跳过 一段 时间内的消息等情况 。 这些异常情况的处理，都和 Offset 有关。
org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
现在的的互联网系统中，mq已经必备基础设施了，我们已明显感觉它的必要性与强大。然而，它的本质是啥？存储转发系统罢了！
DefaultMQPushConsumer主要功能实现在DefaultMQPushConsumerImpl中，消息处理逻辑是在pullMessage()方法的PullCallback回调中。在PullCallback回调中有个switch语句，根据Broker返回的消息类型做响应的处理，具体逻辑看源码：
注：如果使用CONSUME_FROM_TIMESTAMP ,需设置参数 DefaultMQPushConsumer.setConsumeTimestamp(“20131223171201”) 时间戳字符串格式为yyyyMMddHHmmss
这篇文章我们聊聊广播消费，因为广播消费在某些场景下真的有奇效。笔者会从基础概念、实现机制、实战案例、注意事项四个方面一一展开，希望能帮助到大家。
前言 生产者和消费者是消息队列的两个重要角色，生产者向消息队列写人数据， 消费者从消息队列里读取数据。本篇讲解两种类型的消费者，一个是 DefaultMQPushConsumer，由系统控制读取操作，收到消息后自动调用传人的 处理方法来处理;另 一个是 DefaultMQPullConsumer，读取操作中的大部分功 能由使用者自主控制 。
这篇文章我们聊聊广播消费，因为广播消费在某些场景下真的有奇效。笔者会从基础概念、实现机制、实战案例三个方面一一展开，希望能帮助到大家。
项目中各个中台都使用同一个DB。而DB下会使用中间件监听binlog转换成MQ消息，而下游的各个中台去MQ去拿自己感兴趣的消息。
rocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
首先git下载文件 地址：https://github.com/apache/rocketmq-externals.git
这是因为 RocketMQ 触发了流量控制。今天我们来聊一聊哪些场景下 RocketMQ 会触发流量控制。
文章摘要：在发送消息给RocketMQ后，消费者需要消费。消息的消费比发送要复杂一些，那么RocketMQ是如何来做的呢？ 在RocketMQ系列文章的前面几篇幅中已经对其“RPC通信部分”和“普通消息发送”两部分进行了详细的阐述，本文将主要从消息消费为切入点简要地介绍下“RocketMQ中Pull和Push的两种消费方式”、“RocketMQ中消费者（Push模式）的启动流程”和“RocketMQ中Pull和Push两种消费方式的简要流程”。在阅读本篇之前希望读者能够先仔细阅读下关于RocketMQ分布式消息队列的前几篇文章： （1）消息中间件—RocketMQ的RPC通信（一） （2）消息中间件—RocketMQ的RPC通信（二） （3）消息中间件—RocketMQ消息发送
在分布式系统中，消息队列（MQ）是一种常见的用于实现系统之间解耦、消息传递和异步通信的技术。本文将介绍如何使用Java连接MQ并实现信息查询的过程。
本文主要研究一下rocketmq的ConsumeMode.CONCURRENTLY
折腾了好长时间才写这篇文章，顺序消费，看上去挺好理解的，就是消费的时候按照队列中的顺序一个一个消费；而并发消费，则是消费者同时从队列中取消息，同时消费，没有先后顺序。RocketMQ也有这两种方式的实现，但是在实践的过程中，就是不能顺序消费，好不容易能够实现顺序消费了，发现采用并发消费的方式，消费的结果也是顺序的，顿时就蒙圈了，到底怎么回事？哪里出了问题？百思不得其解。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
