RabbitMQ-如何保证消费不被重复消费？
一 重复消息 为什么会出现消息重复？消息重复的原因有两个：1.生产时消息重复，2.消费时消息重复。 1.1 生产时消息重复 由于生产者发送消息给MQ，在MQ确认的时候出现了网络波动，生产者没有收到确认，实际上MQ已经接收到了消息。这时候生产者就会重新发送一遍这条消息。 生产者中如果消息未被 ...
原文：RabbitMQ-无法消费
一 现网问题描述 .理想情况 现网mq倒换演练，即关闭rabbitmq主，此时keepalived的检测脚本检查到rabbitmq服务异常，触发脚本关闭主服务的keepalived，那么keepalived的虚拟ip就会绑定到从服务器上，继续使用rabbitmq从节点。 .实际情况 消息队列无法被消费，必须重启应用才能正常消费 二 现网应用包参考 rabbitmq . . rabbitmq . . ...
2021-09-13 16:18 0 222 推荐指数：
相关推荐
RabbitMQ-消息消费日志rabbitmq_tracing
转 在使用rabbitmq时，我们有时需要查看消息队列生产/消费了那些消息，便于我们排错。rabbitmq中提供一个插件rabbitmq_tracing用于记录消息的日志，默认是未打开的，需要自己用命令打开 # 查看打开的插件（前面带e*） rabbitmq-plugins list ...
RabbitMQ-消费者"未处理完的消息"丢失
一个关于客户端(消费者)开启自动应答，重启后"未处理消息丢失"的小坑。（主要是对RabbitMQ理解不够） 首先，申明一下: 本文所谓的 "丢失消息" 不是指服务器宕机、重启等原因导致内存中消息丢失，也就是说不是关于消息持久化的问题。 使用C# 编写测试。 问题表象: 消费 ...
RabbitMQ-初见
目录 什么是中间件 消息队列协议 AMQP协议 MQTT协议 OpenMessage协议 Kafka协议 消息队列持久化 ...
RabbitMQ-基础
1. 简介 MQ（Message Queue）消息队列，是基础数据结构中“FIFO（先进先出）”的一种数据结构。 一般用来解决应用解耦，异步消息，流量削峰等问题，实现高性能，高可用，可伸缩和最终一致性架构。 应用解耦 MQ相当于一个中介，生产方通过MQ与消费方交互，它将应用程序进行解耦 ...
RabbitMQ-进阶
目录 过期时间TTL 设置队列TTL 消息确认机制的配置 死信队列 内存磁盘的监控 RabbitMQ的内存控制 命令的方式 配置文件方式 rabbitmq ...
RabbitMQ-限流
1.简介 为什么要对消费端进行限流？ 其实很好理解，比如我们常能接触到的消费场景：春运期间12306火车票的抢购，双11期间的下单等。这些场景都有一个共同点就是都会导致短暂时间内请求数激增，如果我们的Consumer最多只支持每秒1000的QPS，而由于请求的激增导致每秒2000甚至更多的并发 ...
RabbitMQ-广播模式
概述 fanout扇出也称之为广播 在广播模式下，消息发送的流程是这样的，如下所示： 可以有多个消费者。 每个消费者有自己的 queue（队列） 每个队列都要绑定到 Exchange（交换机） 生产者发送的消息，只能发送到交换机，交换机来决定要发给哪个队列，生产者无法 ...