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

文章 2023-02-24 来自：开发者社区

RocketMQ最新版源码剖析注释笔记关注我的技术博客:

# 1. 高级功能## 1.1 消息存储分布式队列因为有高可靠性的要求，所以数据要进行持久化存储。![](img/消息存储方式.png)1. 消息生成者发送消息2. MQ收到消息，将消息进行持久化，在存储中新增一条记录3. 返回ACK给生产者4. MQ push 消息给对应的消费者，然后等待消费者返回ACK5. 如果消息消费者在指定时间内成功返回ack，那么MQ认为消息消费成功，在存储中删除消息....

文章 2023-02-22 来自：开发者社区

从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（十二）日志篇(1)：rocketmq+ aop +自定义注解实现入参出参日志收集记录完整源码

入参出参日志我们日常开发中日志是不可缺少的一部分，如mini-cloud架构图所示，大型系统一般可用elk 等进行日志收集中小型系统也可以用spring-boot-admin 等进行收集，但我们业务场景经常会有一种需求，就是一些重要入参出参接口希望按照url 进行收集并便于以后排查分析比较典型的就是金融产品或者银行产品扣款，出账，转账，扣款等期望效果我们可能会希望通过一个url 或者关联参数定位....

文章 2023-01-14 来自：开发者社区

Kafka +深度学习+ MQTT搭建可扩展的物联网平台【附源码】

物联网+大数据+机器学习将会是以后的趋势，这里介绍一篇这方面的文章包含源码。混合机器学习基础架构构建了一个场景，利用Apache Kafka作为可扩展的中枢神经系统。公共云用于极大规模地训练分析模型（例如，通过Google ML Engine在Google Cloud Platform（GCP）上使用TensorFlow和TPU，预测（即模型推断）在本地Kafka基础设施的执行（例如，利用K....

问答 2023-01-08 来自：开发者社区

关于Apache RocketMQ，问个rocketmq源码的问题

[版本] 4.9.2 [问题] 为什么NettyRemotingClient中，《NameServer地址列表namesrvAddrList》和《被选中NameServer地址namesrvAddrChoosed》两个变量要用AtomicReference？对这两个变量的访问都是get和set，并没有CAS操作。多线程访问的下，似乎用volatile修饰就可以了。

文章 2022-12-17 来自：开发者社区

手把手教你使用Idea调试RocketMQ源码

前言为了更好地了解RocketMQ，我打算看一看它的源码了。随着RocketMQ5.0版本的发布，应该有更多小伙伴在实际应用中选择RocketMQ。那么我们就从这一篇文章开始，逐步来了解RocketMQ的神秘源码吧！接下来我们先把调试环境搭建好。下载源码源码地址：github.com/apache/rock…我们先把RocketMQ源码下载下来，为了方便一点，建议小伙伴先fork到自己的仓库，然....

文章 2022-12-17 来自：开发者社区

RocketMq之nameserver源码阅读

下载、编译源码1.下载源码点击rocketmq源码，fork一份到自己的repository中通过git工具下载到本地，不擅长命令行的小伙伴，可通过sourcetree等git可视化工具操作；没有创建自己账号的小伙伴可以直接clone一份代码下来，如下图所示的第一、二步骤所示：实在是不会用git的小伙伴，也可以直接下载项目压缩包，也就是上图所示的第三步。2.导入项目到idea通过idea导入，选....

文章 2022-12-15 来自：开发者社区

RocketMQ的路由中心：NameServer源码解析

1 前言对于大部分开发过分布式系统的同学来说，对于服务发现肯定不陌生，分布式系统中的服务注册中心主要是提供服务调用的解析服务，服务调用者可以通过注册中心找到对应的服务提供者，从而进行方法的调用。类似地，RocketMQ里也有一个注册中心，称之为NameServer。接下来，我们就通过这篇文章，来对NameServer一探究竟吧！2 RocketMQ的整体架构首先来看看RocketMQ的整体部署架....

文章 2022-12-14 来自：开发者社区

rocketmq消费源码

mq消费源码依赖com.aliyun.openservicesons-client阿里云rocketmq消息队列参考https://blog.csdn.net/alan_liuyue/article/details/86645887 SpringBoot整合阿里云rocketmq消息队列，创建生产者和消费者实例进来createConsumer方法return new ConsumerImpl(O....

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

从源码上看，RocketMQ 5.0 跟 RocketMQ 4.x相比增加了哪几个模块

大家好，我是君哥。今天来介绍一下 RocketMQ 5.0 源码上的变化。RocketMQ 5.0 是一个里程碑式的版本，经历了近 5 年的打磨，代码变更达到 60%。首先看一下源码中模块的变化，如下图：从图中可以看到，RocketMQ 5.0 主要增加了 4 个模块儿，下面介绍一下这 4 个模块儿。1 bazelbazel 是 Google 开源的构建工具，目前广泛用于云计算领域的开源软件（如....

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

读 RocketMQ 源码，学习并发编程三大神器

笔者是 RocketMQ 的忠实粉丝，在阅读源码的过程中，学习到了很多编程技巧。这篇文章，笔者结合 RocketMQ 源码，分享并发编程三大神器的相关知识点。 1 CountDownLatch 实现网络同步请求CountDownLatch 是一个同步工具类，用来协调多个线程之间的同步，它能够使一个线程在等待另外一些线程完成各自工作之后，再继续执行。下图是 CountDownLatch 的核心方法....