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

文章 2024-10-15 来自：开发者社区

DIY可视化整合MQTT生成UniApp源码

DIY可视化整合MQTT生成UniApp源码 MQTT协议是什么？ MQTT（Message Queuing Telemetry Transport）是一种轻量级的、基于发布/订阅模式的通信协议，专门设计用于在低带宽、不稳定的网络环境下进行物联网设备之间的通信。具有以下特点（优势）： ...

问答 2024-07-23 来自：开发者社区

想研究一下RocketMQ源码，研究4.x比较好还是5.x比较好啊？

文章 2024-07-17 来自：开发者社区

RocketMQ 是大家耳熟能详的消息队列，开源项目 rocketmq-spring 可以帮助开发者在 Spring Boot 项目中快速整合 RocketMQ。这篇文章会介绍 Spring Boot 项目使用 rocketmq-spring SDK 实现消息收发的操作流程，同时笔者会从开发者的角度解读 SDK 的设计逻辑。1 SDK 简介项目地址：https://github.com/apac....

问答 2024-06-19 来自：开发者社区

RocketMQ官网上显示的消息体大小限制与源码中的不一致，一般消息体建议大小不超过多少合适呢？

文章 2024-06-14 来自：开发者社区

Rabbitmq 搭建使用案例 [附源码]

RabbitMQ搭建 docker docker run -d --hostname rabbitmq --name rabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -e RABBIT...

文章 2024-05-23 来自：开发者社区

蓝易云 - 直播小程序源码有用的协议知识：MQTT协

直播小程序源码在设计和实现过程中，一个重要的组成部分是消息传递协议，其中MQTT协议是一个常见的选择。MQTT，全称为消息队列遥测传输，是一种基于发布/订阅模式的轻量级消息协议，专为低带宽和不稳定网络环境设计。 MQTT协议的主要特点包括：轻量级：MQTT协议的头部信息非常小，最小只...

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

【深度挖掘RocketMQ底层源码】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行调度的流程（Pull模式）

承接上文承接上一章节的内容，下面我们看继续看拉取的调度模式，PULL与PUSH模式相比，PULL模式需要应用层不间断地进行拉取消息然后再执行消费处理，提高了应用层的编码复杂度，为了Pull方式的编程复杂度，RocketMQ提供了调度消费服务（MQPullConsumerScheduleService），在topic的订阅发送变化（初次订阅或距上次拉取消息超时）就触发PULL方式拉取消息...

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

精华推荐 | 【深入浅出 RocketMQ原理及实战】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行核心的流程（上篇）

上篇：分析对应总体消费流程的判断和校验以及限流控制和回调等处理流程分析下篇：分析基于上篇的总体流程的底层的消息通讯以及拉去处理数据传输流程分析 RocketMQ的消息模型 RocketMQ的基础消息模型是发布-订阅（Pub/Sub）是一种消息范式，消息的发送者（称为发布者、生产者、Producer）会将消息直接发送给特定的接收者（称为订阅者、消费者、Coms...

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

【深度挖掘 RocketMQ底层源码】「底层源码挖掘系列」抽丝剥茧贯穿RocketMQ的消费者端的运行核心的流程（Pull模式-下）

承接【【深度挖掘 RocketMQ底层源码】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行核心的流程（Pull模式-上）】 pullBlockIfNotFound方法通过该方法获取该MessageQueue队列下面从offset位置开始的消息内容，其中maxNums=32即表示获取的最大消息个数，offset为该MessageQueue对象的开始消费位置，可以...

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

【深度挖掘 RocketMQ底层源码】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行核心的流程（Pull模式-上）

消息消费者（Consumer）负责消费消息，一般是后台系统负责异步消费。一个消息消费者会从Broker服务器拉取消息、并将其提供给应用程序。从用户应用的角度而言提供了两种消费形式：拉取式消费、推动式消费。我们接下来主要介绍Pull模式 Pull模式的处理机制 Consumer消费的一种类型，应用通常主动调用Consumer的拉消息方法从Broker服务器拉消...