RabbitMQ笔记
比较常用的就是以上三种：直连(DirectExchange)，发布订阅(FanoutExchange)，通配符(TopicExchange)。熟练运用这三种交换机类型，基本上可以解决大部分的业务场景。实际上稍微思考一下，可以发现通配符(TopicExchange)这种模式其实是可以达到直连(Dire
RabbitMq踩坑记录
检查你的连接配置，很可能是你的yml里面的端口配置的是15672，更改为5672即可；2、连接报错：org.springframework.amqp.AmqpIOException: java.io.IOException。step1：登陆rabbitmq的管理页面(PS：地址为localhost:
RabbitMQ - 以 MQ 为例，手写一个 RPC 框架 demo
本篇文章来自于笔者之前写过的一个系列 —— “根据源码，模拟实现 RabbitMQ” 系列，不妨可以去看看~
【RabbitMQ】使用SpringAMQP的Publish/Subscribe(发布/订阅)
*发布(Publish)、订阅(Subscribe)：**允许将同一个消息发送给多个消费者**注意：**exchange负责消息路由，而不是存储，路由失败则消息丢失。
消息队列之RabbitMQ的安装配置
RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。点击跳转RabbitMQ官方地址简单模式，work模式 ，Publish/Subscri
RabbitMQ、kafaka、rocketmq等消息队列MQ消息堆积如何解决
1.产生背景： 生产者投递消息的速率与我们消费者消费的速率完全不匹配。2.生产者投递消息的速率>消费者消费的速率导致我们消息会堆积在我们 mq 服务器端中，没有及时的被消费者消费 所以就会产生消息堆积的问题3.注意的是：rabbitmq 消费者我们的消息消费如果成功的话 消息会被立即删除（自动ack
消息队列选型（RabbitMq、RocketMq、Kafaka）
当引入消息队列时，常见的选择包括ActiveMQ、Kafka、RabbitMQ和RocketMQ。然而，近年来，ActiveMQ的活跃度已经下降，很多公司已经不再使用这款消息队列中间件，因此在比较中不再涉及该产品。其实如果一般来说你业务使用mq，对消息的安全性要求较高，选择RocketMq；如果对于
rabbitmq延时队列相关配置
在设置延时队列时，你需要使用 x-delayed-type 参数来指定该交换机的类型为 x-delayed-message，并使用 x-delayed-message 的头部属性 x-delay 来指定消息的延迟时间。消息将立即被路由到匹配的队列，没有任何延迟。使用 x-delayed-messag
SpringBoot——整合RabbitMQ收发消息
SpringBoot整合RabbitMQ收发消息的一个项目示例
MQ基础（RabbitMQ）
同步通信：就相当于打电话，双方交互是实时的。同一时刻，只能与一人交互。异步通信：就相当于发短信，双方交互不是实时的。不需要立刻回应对方，可以多线程操作，跟不同人同时聊天。
Rabbit MQ和Kafka的区别
优点: 提供丰富的消息路由功能，适合复杂的消息传递和任务处理，支持多种消息传递模式，适合需要低延迟和高可靠性的场景。缺点: 吞吐量和扩展性相对较低，不适合大规模数据流处理。
【大批量数据处理方式】monggoDB+xxxJob+rabbitMQ逐步提升查询性能
monggoDB大批量数据处理的实现思路
关于rabbitmq的prefetch机制
消息预取机制（Prefetch Mechanism）是RabbitMQ中用于控制消息传递给消费者的一种机制。它定义了在一个信道上，消费者允许的最大未确认的消息数量。一旦未确认的消息数量达到了设置的预取值，RabbitMQ就会停止向该消费者发送更多消息，直到至少有一条未完成的消息得到了确认。这个值指定
2024-05-19 RabbitMq整合SpringBoot快速入门
rabbitmq的基础使用示例
RabbitMQ 延时消息实现
RabbitMQ 延时消息实现
JAVA 整合 RabbitMQ
JAVA 整合 RabbitMQ。
RabbitMQ简介
MQ的概览情况，里面包括集群各个节点的信息、端口映射信息；Totals： 准备消费的消息数、待确认的消息数、消息总数以及消息的各种处理速率（发送速率、确认速率、写入硬盘速率等等）。Nodes： 其实就是支撑 RabbitMQ 运行的一些机器，相当于集群的节点。点击每个节点，可以查看节点的详细信息。C
RabbitMQ-同步和异步区别&快速入门
Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！在Direct模型下，队列与交换机的绑定，不能是任意绑定了，而是要指定一个RoutingKey（路由key）.消息的发送方在向Exchange发送消
RabbitMQ如何测试
结合上一篇的我们来学习下，如何使用RabbitMQ管理台来测试MQ；还是之前的例子，用图片简单介绍下逻辑。
RabbitMQ 之 死信队列
但是发生了上面所说的三种情况中的一种，成为了死信，然后被转换到死信交换机中，这个死信交换机也是 direct 类型，它们之间的 routingKey 是 "lisi",然后就进入了死信队列，死信队列由 C2 消费。生产者正常情况下走的是普通的交换机，这个交换机的类型是 direct ，它和普通队列
