Producer端在发送消息时，会先根据Topic找到指定的TopicPublishInfo，根据TopicPublishInfo使用随机递增取模算法获取一个MessageQueue发送消息。
RocketMQ 是笔者非常喜欢的消息队列，4.9.X 版本是目前使用最广泛的版本，但它的消费逻辑相对较重，很多同学学习起来没有头绪。
queue 就是来源于数据结构的 FIFO 队列。而 Topic 是个抽象的概念，每个 Topic 底层对应N个 queue，而数据也真实存在 queue 上的。
前文了解了 RocketMQ消息存储的相关原理，本文将讲讲消息消费的过程及相关概念。
并发消费是默认的处理方法，一个消费者使用线程池技术，可以并发消费多条消息，提升机器的资源利用率。默认配置是 20 个线程，所以一台机器默认情况下，同一瞬间可以消费 20 个消息。关注公众后码猿技术专栏获取更多面试资源。
2019年10月12日微信开放了小程序订阅消息的功能。按官方的说法，目前的模板消息在实现小程序服务闭环上存在缺陷：
首先我们想一下，两个公司之间如果有互相调用接口的业务需求，如果没有引入中间件技术，是怎么实现的呢？
1、适用场景 kafka适合日志处理 rocketmq适合业务处理 结论：两者没有区别，根据具体业务定夺 2、性能 kafka单机写入TPS号称在百万条/秒 rocketmq大约在10万条/秒 结论：追求性能方面，kafka单机性能更高 3、可靠性 kafka使用异步刷盘方式，异步Replication rocketmq支持异步/同步刷盘，异步/同步Replication 结论：rocketmq所支持的同步方式提升了数据的可靠性 4、实时性 kafka和rocketmq均支持pull长轮询，rocketmq消息实时性更高 结论：rocketmq胜出 5、支持的队列数 kafka单机超过64个队列/分区，消息发送性能降低严重 rocketmq单机支持最高5W个队列，性能稳定 结论：长远看，rocketmq胜出， 6、消息顺序性 kafka某些配置下，支持消息顺序，但是一台Broker宕机后，就会产生消息乱序 rocketmq支持严格的消息顺序，一台Broker宕机后，发送消息会失败，但是不会乱序 结论：rocketmq胜出 7、消息失败重试机制 kafka消费失败不支持重试 rocketmq消费失败支持定时重试，每次重试间隔时间顺延 8、定时/延时消息 kafka不支持定时消息 rocketmq支持定时消息 9、分布式事务消息 kafka不支持分布式事务消息 rocketmq未来会支持 10、消息查询机制 kafka不支持消息查询 rocketmq支持根据message id查询消息，也支持根据消息内容查询消息 11、消息回溯 kafka可以按照offset回溯消息 rocketmq支持按照时间回溯消息，例如从一天之前的某时某分开始重新消费消息 问题一：push和pull模式 push模式：客户端与服务端建立连接后，当服务端有消息时，将消息推送到客户端 pull模式：客户端不断的轮询请求服务端，来获取新的消息 在具体实现时，push和pull模式都是采用消费端主动拉取的方式，即consumer轮询从broker拉取消息 区别： push 方式中，consumer把轮询过程封装了，并注册了MessageListener监听器，取到消息后，唤醒MessageListener的consumerMessage来消费，用户而言，觉得消息被推送过来的 pull方式中，取消息的过程需要用户自己写，首先通过打算消费的Topic拿到MessageQueue的集合，遍历MessageQueue集合，然后针对每个MessageQueue批量获取消息，一次取完之后，记录该队列下一次要取的开始offset，直到取完了，再换另一个MessageQueue 疑问：既然都是采用pull方式实现，rocketmq怎么保证消息的实时性？ 长轮询：rocketmq时采用长轮询的方式实现的，指的是在请求的过程中，若是服务器端数据并没有更新，那么则将这个连接挂起，直到服务器推送新的数据，再返回，然后进入循环周期 客户端像传统轮询一样从服务端请求数据，服务端会阻塞请求不会立刻返回，直到有数据或者超时才返回给客户端，然后关闭连接，客户端处理完响应信息后再向服务器发送新的请求
前面已经介绍了 生产消息、存储消息 两大块内容，那接下来，我们白话一下RocketMQ是如何消费消息的，揭秘消息消费全过程。
前传：分布式消息队列 RocketMQ 源码分析 —— Message 拉取与消费（上） 本文主要基于 RocketMQ 4.0.x 正式版 1、概述 2、Consumer 3、PushConsumer 一览 4、PushConsumer 订阅 5、PushConsumer 消息队列分配 6、PushConsumer 消费进度读取 7、PushConsumer 拉取消息 8、PushConsumer 消费消息 9、PushConsumer 发回消费失败消息 10、Consumer 消费进度 11、结尾 --
最近生产环境的消息通知队列发生了大量的数据积压问题，从而影响到整个平台商户的交易无法正常进行，最后只能通过临时关闭交易量较大的商户来缓解消息队列积压的问题，经线上数据分析，我们的消息队列在面对交易突发洪峰的情况下无法快速的消费并处理队列中的数据，考虑到后续还会出现各种交易量突发状况，以下为针对消息队列（ActiveMQ）的优化过程。
当一个业务系统部署多台机器时，每台机器都启动了一个Consumer，并且这些Consumer都在同一个ConsumerGroup也就是消费组中，此时一个消费组中多个Consumer消费一个Topic，而一个Topic中会有多个MessageQueue。 那么就会有一个问题，比如有2个Consumer，3个MessageQueue，那么这3个MessageQueue怎么分配呢？这就涉及到Consumer的负载均衡了。 首先 Consumer 在启动时，会把自己注册给所有 Broker ，并保持心跳，让每一个 Broker 都知道消费组中有哪些 Consumer 。 然后 Consumer 在消费时，会随机链接一台 Broker ，获取消费组中的所有 Consumer 。 主要流程如下：
MQ（Message Queue）是一种消息中间件，广泛应用于分布式系统中的解耦、异步、负载均衡和消息传递等场景。在高性能、高可用的分布式系统中，事务消息是一种常见的设计模式，可以确保消息的原子性、可靠性和一致性。本文将介绍 MQ 事务消息方案的设计原理、实现方法和代码 demo。
单服务下，用 JDK 中的 synchronized 或 Lock 的实现类可实现对共享资源的并发访问
本文主要讲解PushConsumer，部分讲解PullConsumer，跳过顺序消费。 本文主要讲解PushConsumer，部分讲解PullConsumer，跳过顺序消费。 本文主要讲解PushConsumer，部分讲解PullConsumer，跳过顺序消费。
不会永久保存消息文件,而是启用文件过期策略,在磁盘空间不足或在凌晨4点删除过期文件,文件默认保存72小时,删除时不会判断该文件上的消息是否被消费
保证消息传送有3个主要部分：消息自主性，存储并转发以及底层消息确认，下面具体看一下这些概念；
“发消息”过程，往往是为通知另外一个系统更新数据，MQ的“事务”，主要解决消息生产者和消息消费者的数据一致性问题。
在群组管理中，最常见的其中一种管理场景就是禁言管理了，今天我就带大家看看IM的禁言管理如何实现。
消息中间件基于队列模型实现异步/同步传输数据 作用：可以实现支撑高并发、异步解耦、流量削峰、降低耦合度。
在描述消息的写入和读取流程之前，首先要弄清楚消息队列的模型是怎么样的，包括消息是怎么存储的。
既然在项目中使用了MQ，那么就不可避免的需要考虑消息丢失问题。在一些涉及到了金钱交易的场景下，消息丢失还是很致命的。那么在RocketMQ中存在哪几种消息丢失的场景呢？
昨天，在我的开源项目chat-system中查看聊天记录时，发现消息中如果有图片滚动条的位置就会算错，导致最后一条消息定位不准确。
当微信客户、接待人员发消息或有行为动作时，企业微信后台会将事件的回调数据包发送到企业指定URL；企业收到请求后，再通过读取消息接口主动读取具体的消息内容。
最近mq越来越火，很多公司在用，很多人在用，其重要性不言而喻。但是如果我让你回答下面的这些问题：
Redis 发布订阅 (pub/sub) 是一种消息通信模式：发送者 (pub) 发送消息，订阅者 (sub) 接收消息。
在 Netty 中，所有的 I/O 操作都是异步的，这意味着任何 I/O 调用都会立即返回，而不是像传统 BIO 那样同步等待操作完成。异步操作会带来一个问题：调用者如何获取异步操作的结果？
前言： 环信SDK 头像、昵称、表情自定义和群聊设置的实现 一（附源码） 接着上面说的，我们来说说表情，它在哪里可以自定义，怎么写，那个方法是添加表情的我们都说说，找到 ChatViewController.m文件，它里面有这个方法； -(NSArray*)emotionFormessageViewController:(EaseMessageViewController *)viewController 你可以在这里方法里面添加自己的表情，先看看Demo里面的源码，上面有自己的一些注释； -(N
文章摘要：在发送消息给RocketMQ后，消费者需要消费。消息的消费比发送要复杂一些，那么RocketMQ是如何来做的呢？ 在RocketMQ系列文章的前面几篇幅中已经对其“RPC通信部分”和“普通消息发送”两部分进行了详细的阐述，本文将主要从消息消费为切入点简要地介绍下“RocketMQ中Pull和Push的两种消费方式”、“RocketMQ中消费者（Push模式）的启动流程”和“RocketMQ中Pull和Push两种消费方式的简要流程”。在阅读本篇之前希望读者能够先仔细阅读下关于RocketMQ分布式消息队列的前几篇文章： （1）消息中间件—RocketMQ的RPC通信（一） （2）消息中间件—RocketMQ的RPC通信（二） （3）消息中间件—RocketMQ消息发送
比如事件A发生在下午3点一刻，而事件B发生在下午4点，那么我们认为事件A发生在事件B之前，他们的顺序关系为先A后B。
Linux：进程间通信（二.共享内存详细讲解以及小项目使用和相关指令、消息队列、信号量）
Redis相关知识：https://www.runoob.com/redis/redis-tutorial.html
RocketMQ是由阿里巴巴开源的分布式消息中间件，支持顺序消息、定时消息、自定义过滤器、负载均衡、pull/push消息等功能。RocketMQ主要由 Producer、Broker、Consumer 、NameServer四部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。NameServer充当名字路由服务，整体架构图如下所示：
REmote DIctionary Server(Redis) 是一个由 Salvatore Sanfilippo 写的 key-value 存储系统，是跨平台的非关系型数据库。
7. broker判断是否消息失败，成功则直接返回元数据【可选】，失败判断是否重试，对应做相应处理
摘要: 原创出处 http://www.iocoder.cn/RocketMQ/message-pull-and-consume-first/ 「芋道源码」欢迎转载，保留摘要，谢谢！
1. 有序消息的基本概念 为什么要用有序消息 有序消息是什么 有序消息又叫顺序消息(FIFO消息)。 是指消息的消费顺序和产生顺序相同，在有些业务逻辑下，必须保证顺序。 比如订单的生成、付款、发货，这
TCC分段提交适用分布式架构中对一致性、实时性要求较高的业务场景，在实际业务中也存在实时性比较低的业务，例如常见的短信通知，客户端消息，运营体系更新等业务，这时候为了减轻核心流程的复杂度和压力，可以采取最大努力通知方式实现柔性事务的管理。
部分接口需要经过用户授权统一才能调用。我们把这些接口按使用范围分成多个scope，用户选择对scope进行授权，当授权给一个scope之后，其对应的所有接口都可以直接使用，此类接口调用时：
独立消息服务是一种将消息发送方与消息接收方解耦的方式，它是建立在独立的消息中间件上的。消息发送方将消息发送到消息中间件，由消息中间件负责将消息传递给消息接收方，使得消息的传递过程与具体的应用程序逻辑解耦，提高了系统的可扩展性和可维护性。
HongLiang，携程高级技术专家，专注系统性能、稳定性、承载能力和交易质量，在技术架构演进、高并发等领域有丰富的实践经验。
oldproducer是生产者scala版本的生产者，支持同步模式，和异步模式，通过实行producer.type进行配置。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议
