RabbitMQ 详解
MQ 全称为,即消息队列。“消息队列” 是在消息的传输过程中保存消息的容器。它是典型的:生产者、消费者模型。生产者不断向消息队列中生产消息,消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的,而且只关心消息的发送和接收,没有业务逻辑的侵入,这样就实现了生产者和消费者的解耦。消息,两台计算机
Spring RabbitMQ那些事(3-消息可靠传输和订阅)
在RabbitMQ官方文档描述中,持久化的消息在Broker重启时也是应该存活的,这里的词用的是应该,因为消息有可能在落地磁盘前Broker就挂了,导致消息丢失。,一旦Broker处理完就会确认消息,而且这个过程是异步的,生产者可以流式发布消息,不需要等待Broker,并且Broker会批量高效将消
RabbitMQ--MQ介绍和RabbitMQ安装
初识MQ和安装RabbitMQ
整合MQ-----RabbitMQ
个体自学内容 如有错误请指正
SpringBoot 整合 RabbitMQ
当我们在构建分布式系统时,消息队列成为了一个不可或缺的组件,用于解耦系统中的不同部分,提高系统的可靠性和可扩展性。Spring Boot 提供了良好的支持,使得与消息队列的集成变得相对简单。在本篇博客中,我们将讨论如何使用 Spring Boot 整合 RabbitMQ,一个功能强大的开源消息代理。
Spring Boot + RabbitMQ 配置参数解释
默认是true(与参数acknowledge-mode有关系)spring.rabbitmq.listener.simple.transaction-size: 指定一个事务处理的消息数量,最好是小于等于prefetch的数量.spring.rabbitmq.listener.simple.retr
SpringBoot集成RabbitMQ之ACK确认机制(第三节)
ACK机制能够确保消息的【可靠性】,消费者失败了,如何处理,成功了又如何处理,本文章介绍了消费者端确认模式,生产者确认模式
初识RabbitMQ
初识RabbitMQ
Java中使用RabbitMQ(持续更新中)
RabbitMQ
Ubuntu/Linux安装JDK、Mysql、Redis、Rabbitmq、Nginx 并设置开机自启动
Ubuntu/Linux安装JDK、Mysql、Redis、Rabbitmq、Nginx 并设置开机自启动
第二十一章 : Spring Boot 集成RabbitMQ(五)
本章重点:消息可靠性场景、消息100%可靠性发送的技术架构以及实践案例。
带你了解RabbitMQ:消息丢失、重复、积压的原因及其解决方案
首先说一点,企业中最常用的实际上既不是RocketMQ,也不是Kafka,而是RabbitMQ。RocketMQ很强大,但主要是阿里推广自己的云产品而开源出来的一款消息队列,其实中小企业用RocketMQ的没有想象中那么多。深层次的原因在于兔宝在中小企业普及更早,经受的考验也更久,很容易产生「回头客
rabbitMQ引入死信队列
指的是,从队列当中取出来的消息,到达消费方后,因为某些原因导致消息并没有被正常消费掉,这些没有被后续处理的消息就是“死信”,而保存死信的队列,就是死信队列。
第二十章 : Spring Boot 集成RabbitMQ(四)
本章知识点:死信队列的定义、场景、作用以及原理、TTL方法的使用以及演示代码示例。
RabbitMq------初级+高级(一)
基于spring-boot-AMQP来对rabbitmq进行消息的异步发送,以及对应的队列。
【RabbitMQ高级消息可靠性、高可用、延时、消息堆积问题】
修改publisher服务的单元测试类:@Slf4j@Autowired@Test//设置生产者消息确认机制publish-confirm的回调方法@Overrideif(ack){log.info("消息发送到交换机成功,消息ID:{}", correlationData.getId
RabbitMQ基本使用
没有topic 使用的是AMQP协议。
【RabbitMQ学习日记】——死信队列与延迟队列
介绍了死信队列与延迟队列的概念与用法,也包括通过死信队列实现延迟队列、通过占位符传参优化延迟队列、通过插件设置延迟队列等
RabbitMQ中channel与try()结合导致的消息不消费或消息无法接收的问题分析与定位
本文依照编码运行顺序进行梳理,解决了该场景下为何RabbitMQ 中有消息但消费者无法接收的问题
【RabbitMQ】- 延迟队列
延时队列,队列内部是有序的,最重要的特性就体现在它的延时属性上,延时队列中的元素是希望在指定时间到了以后或之前取出和处理,简单来说,延时队列就是用来存放需要在指定时间被处理的元素的队列。