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

文章 2022-02-16 来自：开发者社区

[六]RabbitMQ-客户端源码之AMQCommand

AMQCommand是用来处理AMQ命令的，其包含了Method, Content Heaeder和Content Body. 下面是通过wireshark抓包的AMQP协议上图中的Basic.Publish命令就包含Method, Content header以及Content body。 AMQCommand不是直接包含Method等成员变量的，而是通过CommandAssemb...

文章 2022-02-16 来自：开发者社区

[五]RabbitMQ-客户端源码之AMQChannel

AMQChannel是一个抽象类，是ChannelN的父类。其中包含唯一的抽象方法： /** * Protected API - called by nextCommand to check possibly handle an incoming Command before it is returned to the caller of nextCommand. If this met...

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

【原创】Windows下使用 Eclipse 管理 RabbitMQ 源码之问题解决

使用 Eclipse + Erlide 来管理 Erlang 代码是一种常见方式。本文简要说明下，本人在 Windows 下管理 RabbitMQ 代码时遇到的小问题。首先，搭建好 Eclipse + Erlide 的环境，方法略；然后，将下载好的 RabbitMQ 源码放置在指定的目录中，比如 D:\...

文章 2022-01-05 来自：开发者社区

RocketMQ第九章：手把手教老婆代码实现-事务消息生产者和事务消息消费者及深入源码探索事务的消息回查

RocketMQ使用教程相关系列目录目录第一节：介绍RocketMQ事务消息介绍事务消息流程介绍使用限制第二节：使用场景第三节：代码实战事务消息生产者事务监听器事务消息消费者效果：第四节：checkLocalTransaction不会触发调整后的生产者效果：第二个问题，回查的次数和定时时间是多少？科学验证：第一节：介绍RocketMQ事务消息介绍在4.3.0版本后，有了事务消息这一个特性，对....

文章 2022-01-05 来自：开发者社区

RocketMQ源码解析：手把手教老婆看懂DefaultMQProducer

RocketMQ使用教程相关系列目录DefaultMQProducer类简介public class DefaultMQProducer extends ClientConfig implements MQProducerDefaultMQProducer类是应用用来投递消息的入口，开箱即用，可通过无参构造方法快速创建一个生产者。主要负责消息的发送，支持同步/异步/oneway的发送方式，这些....

文章 2022-01-05 来自：开发者社区

RocketMQ源码解析：手把手教老婆看懂consumer接收到的MessageExt

RocketMQ使用教程相关系列目录目录源代码说明MessageExt的源码解析继承于Message，Message源码解析喝点毒鸡汤源代码说明MessageExt位于此包下：package org.apache.rocketmq.common.message;MessageExt的源码解析参数说明在代码里public class MessageExt extends Message { ...

文章 2021-12-18 来自：开发者社区

一文看懂RocketMQ生产者发送消息源码解析（下）

sendKernelImpl()构建发送消息的请求头部 RequestHeader上下文SendMessageContext然后调用方法MQClientAPIImpl#sendMessage()，将消息发送给队列所在Broker。至此，消息被发送给远程调用的封装类MQClientAPIImpl，完成后续序列化和网络传输等步骤。RocketMQ的Producer无论同步....

文章 2021-12-18 来自：开发者社区

一文看懂RocketMQ生产者发送消息源码解析（中）

启动过程通过单元测试中的代码可以看到，在init()和terminate()这两个测试方法中，分别执行了Producer的start和shutdown方法。说明RocketMQ Producer是个有状态服务，在发送消息前需要先启动Producer。这个启动过程，实际上就是为了发消息做的准备工作，所以，在分析发消息流程之前，我们需要先理清Producer中维护了哪些状态，在启动过程中，Produ....

文章 2021-12-18 来自：开发者社区

一文看懂RocketMQ生产者发送消息源码解析（上）

基于最新的release-4.7.1代码分析。客户端是个单独模块从UT看Producer API阅读源码，不推荐从入口开始看到底，毕竟你太年轻，把握不住它的底。我们可以带着问题去研究源码：Producer是如何发消息的？推荐从UT用例入手。通过这些小流程，debug查看关键流程即可。RocketMQ客户端的Producer的所有测试用例都在DefaultMQProducerTest类，这就很方便....