目录 什么是中间件 消息队列协议 AMQP协议 MQTT协议 OpenMessage协议 Kafka协议 消息队列持久化 ...
目录 过期时间TTL 设置队列TTL 消息确认机制的配置 死信队列 内存磁盘的监控 RabbitMQ的内存控制 命令的方式 配置文件方式 rabbitmq.conf RabbitMQ的内存换页 RabbitMQ的磁盘预警 集群 RabbitMQ 集群 集群搭建 分布式事务 分布式事务的方式 两阶段提交 PC 需要数据库产商的支持,java组件有atomikos等 补偿事务 TCC 严选,阿里,蚂 ...
2021-09-05 18:57 5 340 推荐指数:
目录 什么是中间件 消息队列协议 AMQP协议 MQTT协议 OpenMessage协议 Kafka协议 消息队列持久化 ...
1. 简介 MQ(Message Queue)消息队列,是基础数据结构中“FIFO(先进先出)”的一种数据结构。 一般用来解决应用解耦,异步消息,流量削峰等问题,实现高性能,高可用,可伸缩和最终一 ...
1.简介 为什么要对消费端进行限流? 其实很好理解,比如我们常能接触到的消费场景:春运期间12306火车票的抢购,双11期间的下单等。这些场景都有一个共同点就是都会导致短暂时间内请求数激增,如果我 ...
一、现网问题描述 1.理想情况 现网mq倒换演练,即关闭rabbitmq主,此时keepalived的检测脚本检查到rabbitmq服务异常,触发脚本关闭主服务的keepalived,那么keepalived的虚拟ip就会绑定到从服务器上,继续使用rabbitmq从节点。 2.实际情况 ...
概述 fanout扇出也称之为广播 在广播模式下,消息发送的流程是这样的,如下所示: 可以有多个消费者。 每个消费者有自己的 queue(队列) 每个队列都要绑定到 Excha ...
1. 简介 我们在上一篇博文中遗留了一个小问题,就是虽然TTL + DLX能实现延迟队列的功能,但是有两个问题。 首先业务场景为:比如海底捞预约,每个人预约的时间段不一致,有个可能一个小时后,有的 ...
Overview Overview 概览 connections:无论生产者还是消费者,都需要与 RabbitMQ 建立连接后才可以完成消息的生产和消费,在这里可以查看连接情况 channels:通道,建立连接后,会形成通道,消息的投递获取依赖 ...
对于有异常的消息我们可以有如下做法: 记录下来再ack。 nack或者reject,同时将requeue设为false。 在第2条的基础上增加死信(Dead Letter)。 ...