转自
producer发送，broker存储
RocketMQ源码分析——producer发送消息（转）
2018-11-15
1103
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《
阿里云开发者社区用户服务协议》和
《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写
侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
RocketMQ源码分析 producer发送消息
相关实践学习
目录
相关文章
|
6月前
|
消息中间件
缓存
物联网
MQTT常见问题之MQTT发送消息到阿里云服务器被拒如何解决
MQTT（Message Queuing Telemetry Transport）是一个轻量级的、基于发布/订阅模式的消息协议，广泛用于物联网（IoT）中设备间的通信。以下是MQTT使用过程中可能遇到的一些常见问题及其答案的汇总：
181
3
3
|
5月前
|
消息中间件
测试技术
RocketMQ
消息队列 MQ产品使用合集之在异步发送消息函数sendMessage()中出现了错误，错误代码为-3，该如何解决
消息队列（MQ）是一种用于异步通信和解耦的应用程序间消息传递的服务，广泛应用于分布式系统中。针对不同的MQ产品，如阿里云的RocketMQ、RabbitMQ等，它们在实现上述场景时可能会有不同的特性和优势，比如RocketMQ强调高吞吐量、低延迟和高可用性，适合大规模分布式系统；而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集，这些场景涵盖了多种行业和业务需求。
180
1
1
|
5月前
|
消息中间件
网络协议
RocketMQ
消息队列 MQ产品使用合集之broker开启proxy，启动之后producer生产消息始终都只到一个broker，该怎么办
消息队列（MQ）是一种用于异步通信和解耦的应用程序间消息传递的服务，广泛应用于分布式系统中。针对不同的MQ产品，如阿里云的RocketMQ、RabbitMQ等，它们在实现上述场景时可能会有不同的特性和优势，比如RocketMQ强调高吞吐量、低延迟和高可用性，适合大规模分布式系统；而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集，这些场景涵盖了多种行业和业务需求。
99
1
1
|
6月前
|
消息中间件
存储
RocketMQ
|
6月前
|
6月前
|
存储
缓存
物联网
MQTT常见问题之MQTT发送消息过多内存不够处理不过来如何解决
MQTT（Message Queuing Telemetry Transport）是一个轻量级的、基于发布/订阅模式的消息协议，广泛用于物联网（IoT）中设备间的通信。以下是MQTT使用过程中可能遇到的一些常见问题及其答案的汇总：
1035
2
2
|
消息中间件
存储
canal
|
6月前
|
消息中间件
负载均衡
算法
RocketMQ源码（三）简单探索Producer和Consumer与Queue之间的负载均衡策略
- Producer如何将消息负载均衡发送给queue？
- Consumer如何通过负载均衡并发消费queue的消息？
561
0
0
|
消息中间件
中间件
Kafka
RocketMQ源码（一）RocketMQ消息生产及消费通信链路源码分析
**RocketMQ**的核心架构主要分为Broker、Producer、Consumer，通过阅读源码看到他们之间是通过Netty来通信的
，具体来说Broker端是**Netty服务器**用来负责与客户端的连接请求处理，而Producer/Consumer端是**Netty客户端**用来负责与Netty服务器的通信及请求响应处理。
186
1
1
|
12月前
|
消息中间件
JSON
数据格式
热门文章
最新文章
1
信用算力基于 RocketMQ 实现金融级数据服务的实践
2
RocketMQ与MYSQL事务消息整合
3
RocketMQ：一个纯java的开源消息中间件--开发测试环境搭建
4
喜讯！RocketMQ成为Apache软件基金会顶级开源项目
5
开篇：在Spring生态中玩转RocketMQ
6
Docker 安装 RocketMQ 并结合 SpringBoot 使用实例
7
在华为鲲鹏OpenEuler20.03系统上安装RocketMQ
8
消息队列RocketMQ版：消费异常运维排查体验
9
喜马拉雅 Apache RocketMQ 消息治理实践
10
深度解读 RocketMQ 存储机制
1
【Linux】NUC977移植使用MQTT（基于mosquitto）
80
2
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
86
3
【深度挖掘 RocketMQ底层源码】「底层源码挖掘系列」抽丝剥茧贯穿RocketMQ的消费者端的运行核心的流程（Pull模式-下）
39
4
【深度挖掘 RocketMQ底层源码】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行核心的流程（Pull模式-上）
52
5
【深入浅出 RocketMQ原理及实战】「底层源码挖掘系列」透彻剖析贯穿一下RocketMQ和Kafka索引设计原理和方案
115
6
Linux下RabbitMQ安装与使用
101
7
MQTT常见问题之用单片机接入阿里MQTT实例失败如何解决
339
8
MQTT常见问题之MQTT出现尖峰如何解决
178
9
MQTT常见问题之mqtt 连接一直显示 Not authorized to connect如何解决
1128
10
MQTT常见问题之MQTT的topic超出上限25个如何解决
1231