云消息队列 MQ源码的相关内容

文章 2024-03-29 来自：开发者社区

【深入浅出 RocketMQ原理及实战】「底层源码挖掘系列」透彻剖析贯穿一下RocketMQ和Kafka索引设计原理和方案

背景介绍文件索引，是存储设计的关键，一个好的索引，应该能够在最短的时间里，找到你想要的数据，同时，还能尽量少的使用内存或磁盘空间。但是这里说的索引并不是指MySQL或者NoSQL这些数据库索引，而是MQ中间件的索引。相对而言较为简单的MQ索引。我们可以通过研究MQ的索引，看看他们为何如此设计，我们又有哪些借鉴之处，并且也可以根据他们索引文件的设计模式，进行分析他们的性能问题，...

文章 2024-02-28 来自：开发者社区

RocketMQ事务消息, 图文、源码学习探究~

介绍 RocketMQ是阿里巴巴开源的分布式消息中间件，它是一个高性能、低延迟、可靠的消息队列系统，用于在分布式系统中进行异步通信。从4.3.0版本开始正式支持分布式事务消息~ RocketMq事务消息支持最终一致性：在普通消息基础上，支持二阶段的提交能力。将二阶段提交和本地事务绑定，实现全局提交结果的一致性。 ...

文章 2024-01-02 来自：开发者社区

RocketMQ-初体验RocketMQ(08)-IDEA拉取调测RocketMQ源码

从Git上迁出源码Github： https://github.com/apache/rocketmq/clone ,等待…完成后，如下修改源码，启动namersrv需要ROCKETMQ_HOME ，这里可以通过配置IDEA的方式，也可以通过修改源码直接setRocketmqHome,我们选择后者修改org.apache.rocketmq.namesrv.NamesrvStartup#crea....

文章 2023-12-27 来自：开发者社区

RocketMQ源码（三）简单探索Producer和Consumer与Queue之间的负载均衡策略

RocketMQ源码（三）简单探索Producer和Consumer与Queue之间的负载均衡策略在RocketMQ架构中，我们都知道一个topic下可以创建多个queue，生产者通过负载均衡策略可以将消息均匀的分发在各个queue中，而这些queue可以通过负载均衡给多个消费者订阅从而提升消费效率，本文将从以下两个方面从源码角度分析producer和consumer的负载均衡原理： ...

文章 2023-12-19 来自：开发者社区

Linux MQTT智能家居（源码使用分析）

前言本篇文章开始我们来分析一下大佬写的MQTT源码，并且来看看怎么样使用MQTT连接到服务器。MQTT源码地址：源码地址这里找到源码中的test.c进行分析：一、连接服务器1.初始化客户端首先使用mqtt_lease函数初始化客户端：里面主要使用platform_memory_alloc函数进行客户端的内存分配初始化。platform_memory_alloc函数可以支持不同的操作系统，比如Li....

文章 2023-12-13 来自：开发者社区

关于 Spring Integration 你知道多少，包含集成MQTT案例讲述及源码3

关于 Spring Integration 你知道多少，包含集成MQTT案例讲述及源码2：https://developer.aliyun.com/article/13949284.4、入站适配器MqttInboundConfiguration @Slf4j @Configuration @IntegrationComponentScan public class ...

文章 2023-12-13 来自：开发者社区

关于 Spring Integration 你知道多少，包含集成MQTT案例讲述及源码2

关于 Spring Integration 你知道多少，包含集成MQTT案例讲述及源码1：https://developer.aliyun.com/article/13949271.3、常规方式的优缺点优点：1、学习成本相对较低，代码理解难度低，上手快。2、易封装，没有其他框架的限制，自定义化程度高。缺点：1、业务耦合性大。较少的主题下，可能还不会有什么感觉，如果后期topic慢慢多了起来，不同....

文章 2023-12-13 来自：开发者社区

关于 Spring Integration 你知道多少，包含集成MQTT案例讲述及源码1

适合的读者，略微了解SpringBoot、消息队列的朋友，想了解和尝试使用Spring Integration框架，想扩展知识边界。前言后文案例代码：GitHub 代码 github.com/ningzaichun…MQTT我想大部分朋友应该都是知道的，即使没有使用过MQTT，肯定也使用过它的兄弟们，RabbitMQ、RocketMQ和Kafka等消息队列.但这次的主角并非是MQTT，而是 Sp....

文章 2023-11-29 来自：开发者社区

RocketMQ源码（二）消息消费的模式到底是Push还是Pull？

RocketMQ源码（二）消息消费的模式到底是Push还是Pull？ RocketMQ为开发者提供了两种消息的消费模式，分别是Pull和Push，对应的实现是DefaultMQPullConsumer和DefaultMQPushConsumer；接下来我将带大家通过以下几个方面了解这两种模式： Pu...

文章 2023-11-26 来自：开发者社区

RocketMQ5 PopAck源码拆解

01 RocketMQ5 架构 RocketMQ已经开启5.X时代，4.X已成为LTS版本。各大云厂商也推出支持RocketMQ5.X版本的产品，在介绍Pop，ack之前需要先了解RocketMQ5的架构。 1.1 RocketMQ5.X架构如上图，在RocketMQ5.X的架构中，新增组件如下： 02 C...