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

文章 2023-10-20 来自：开发者社区

RocketMQ源码（一）RocketMQ消息生产及消费通信链路源码分析

RocketMQ源码（一）RocketMQ消息生产及消费通信链路源码分析 RocketMQ的核心架构主要分为Broker、Producer、Consumer，通过阅读源码看到他们之间是通过Netty来通信的，具体来说Broker端是Netty服务器用来负责与客户端的连接请求处理，而Producer/Consumer端是Netty客户端用来负责与Netty服务器的通信及请求响应处理。 Tip：...

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

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

MQTT协议分析： MQTT协议中文全称为消息队列遥测传输协议，是一种实时通信协议，适用于物联网场景中。MQTT协议被应用到直播小程序源码平台中，确保了直播小程序源码平台音视频流的传输高效、低延迟，为直播小程序源码平台实现相关的实时互动功能提供了帮助。 MQTT协议在直播小程序源码的多种作用当然，MQTT作为一个强大的网络协议，可为直播小程序源码平台带来多种作用，以帮助平台变得更高质量。...

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

顺利拿下Offer 通过分析rocketMq消费者拉取消息源码

Rocketmq服务器和消费者之间的消息传输有push（推模式）和pull（拉模式）两种。Push模式：底层实现也是使用拉取模式,由Rocketmq客户端底层封装实现自动消息拉取，拉取到的消息会回调消费者注册的监听器函数，把消息传给消费者，让消费者进行消费。根据拉取的结果，设置队列下一次拉取的偏移量进行下一次拉取任务。Pull消费模式：更加灵活，可以让消费者自己决定拉取消息时机和更新队列的偏移量....

文章 2023-07-21 来自：开发者社区

C# Queue与RabbitMQ的爱恨情仇（文末附源码）：Q与MQ消息队列简单应用（二）

上一章我们讲了队列（ Queue），这一章我们讲Message Queue消息队列，简称MQ。定义：　　MQ是MessageQueue，消息队列的简称（是流行的开源消息队列系统，利用erlang语言开发）。MQ是一种应用程序对应用程序的通信方法。应用程序通过读写入队和出队的消息来通信，无需专用连接来链接它们。消息传递是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，一般应用于....

文章 2023-07-21 来自：开发者社区

C# Queue与RabbitMQ的爱恨情仇（文末附源码）：Q与MQ消息队列简单应用（一）

首先我们简单了解一下什么堆、栈、队列。堆是在程序运行时，而不是在程序编译时，申请某个大小的内存空间。即动态分配内存，对其访问和对一般内存的访问没有区别。栈就是一个容器，后放进去的先拿出来，它下面本来有的东西要等它出来之后才能出来。（先进后出or后进先出）队列只能在队头做删除操作,在队尾做插入操作.而栈只能在栈顶做插入和删除操作。（先进先出）注意：当前展示的是队列（Queue），下一章....

问答 2023-07-13 来自：开发者社区

RocketMQ dashboard一直报这个错，是哪里有问题？我没改dashboard的源码 !

RocketMQ dashboard一直报这个错，是哪里有问题？我没改dashboard的源码

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

深扒RocketMQ源码之后，我找出了RocketMQ消息重复消费的7种原因

在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。为什么需要保证幂等性呢？是因为消息会重复消费。为什么消息会重复消费？明明已经消费了，为什么消息会被再次被消费呢？不同的MQ产生的原因可能不一样本文就以RocketMQ为例，来扒一扒RocketMQ中会导致消息重复消息的原因，最终你会发现，其实消息重复消费算是RocketMQ无奈的“bug”。消息发送异常时重复发送首先，我....

问答 2023-06-28 来自：开发者社区

Apache RocketMQ rocketmq-client-java的源码在哪可以看?

问答 2023-06-28 来自：开发者社区

Apache RocketMQ这个版本支持mq5.1.0吗？，我看源码里面引用的5.0.0的版本

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

rocketmq源码打包

背景：升级broker版本，并修改broker源代码步骤：1.下载源码，地址：https://rocketmq.apache.org/download/binary是编译好的可以直接使用，source是还没编译过的源代码，需要自行编译。因为我需要修改源代码，所以我下载的source版本。2.进入rocketmq目录打包：mvn -Prelease-all -DskipTests clean in....