2024-12-05 厉飞雨 阅读(61) 评论(0) 赞(2)

大家好，我是指北君。 消息中间件是我们工作中使用最频繁的一类中间件，它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。今天，指北君就来详细讲讲RocketMQ生产者和消费者在使用时的一些注意事项 ...

2024-09-03 厉飞雨 阅读(97) 评论(0) 赞(2)

<p>Docker部署RocketMQ</p> <p>rocketmq 安装（docker版）</p> <p><a href="https://blog.csdn.net/a2868221132/article/details/118156511?spm=1001.2101.3001.6650.7&am...

2024-09-03 厉飞雨 阅读(116) 评论(0) 赞(1)

<p>k8s kubesphere 部署 rocketmq</p> <p><a href="https://blog.csdn.net/WzpPy643739651/article/details/135114755">k8s kubesphere 部署 rocketmq_kubeshere 搭建rocketm...

2024-09-03 厉飞雨 阅读(123) 评论(0) 赞(3)

<p>这篇文章，我们来分析 RocketMQ中 Topic，Queue，Consumer，Consumer Group 之间的关系。</p> <h1>Topic 和 Queue 的关系 {#Topic-和-Queue-的关系}</h1> <p>Topic，Queue 和 Broker的关系如下图：</p> ...

2024-09-03 厉飞雨 阅读(184) 评论(0) 赞(6)

<p>你好，我是猿java。</p> <p>Tag 是 RocketMQ 提供的一种消息过滤机制，允许生产者在发送消息时指定一个或多个标签，消费者则可以根据这些标签来选择性地消费消息。这篇文章，我们将详细介绍 RocketMQ 中 Tag 的原理、源码分析以及示例。</p> <h1>Tag 的原理 {#Tag-的原理}...

2024-09-03 厉飞雨 阅读(118) 评论(0) 赞(4)

你好，我是猿java。 提起分布式消息中间件，作为一名 Java程序员，很自然会想起阿里巴巴开源的RocketMQ，它是一款高性能、高吞吐量的消息队列系统，在大数据、微服务、事件驱动架构等领域大放异彩，因此，本文我们将从全貌上介绍 RocketMQ的核心组件及其各自的作用，帮助大家能从整理上掌握 RocketMQ的脉络。 RocketMQ 核心组件 {#RocketMQ-核...

2024-09-03 厉飞雨 阅读(169) 评论(0) 赞(5)

<p>你好，我是猿java。</p> <p>今天我们来一起深入分析 RocketMQ的注册中心 NameServer。</p> <blockquote> <p>本文基于 RocketMQ release-5.2.0</p> </blockquote> <p>首先，我们回顾...

2024-09-03 厉飞雨 阅读(301) 评论(0) 赞(4)

<p>你好，我是猿java。</p> <p>在 RocketMQ 中，有 3种简单的消息发送方式：同步发送、异步发送和单向发送。这篇文章，我们将详细分析这三种发送方式的原理、优缺点、使用场景以及使用该方式是否会丢失数据。</p> <blockquote> <p>本文源码基于: Apache RocketMQ...

2024-09-03 厉飞雨 阅读(150) 评论(0) 赞(6)

你好，我是猿java。 这篇文章，我们将深入探讨 RocketMQ 的事务消息原理，并从源码角度进行分析，以及事务消息适合什么场景，使用事务消息需要注意哪些事项。 什么是事务消息 {#什么是事务消息} ================== 事务消息是为了保证分布式系统中消息的一致性而引入的一种消息类型。事务消息允许消息发送方在发送消息后，进行本地事务操作，并根据本地事务的...

2024-09-03 厉飞雨 阅读(141) 评论(0) 赞(5)

<p>你好，我是猿java。</p> <p>在 <a href="https://mp.weixin.qq.com/s?__biz=MzIwNDAyOTI2Nw==&amp;mid=2247498678&amp;idx=1&amp;sn=34f904c0cd1d31d99eb50d44b87fc3eb&...