RabbitMQ：我们通常谈到消息队列，就会联想到这其中的三者：生产者、消费者和消息队列，生产者将消息发送到消息队列，消费者从消息队列中获取消息进行处理。对于RabbitMQ，它在此基础上做了一层抽象，引入了交换器exchange的概念，交换器是作用于生产者和消息队列之间的中间桥梁，它起了一种消息路由的作用，也就是说生产者并不和消息队列直接关联，而是先发送给交换器，再由交换器路由到对应的队列，至于它是根据何种规则路由到消息队列的，就是我们下面需要介绍的内容了。这里的生产者并没有直接将消息发送给消

1.什么是MQ MQ就是消息队列。是软件和软件进行通信的中间件产品，队列里存放的是message，是一种跨进程的通信机制，用于上下游传递信息2.MQ解决的问题流量削峰，减少高峰时期对服务器压力，将超出的请求可以到信息队列，处理时间会变长应用解耦，A将BC都需要的数据发送到MQ，BC就不需要找A了，到MQ里面消费即可，A不需要在考虑给谁发了，也不需要在维护这个数据了异步处理 A调用B，B花费的时间很长，但是A需要知道B什么时候执行完 使用MQ，当A 调用 B 服务后，只需要监听 B 处理完成的消息

确定是否安装延迟交换机插件 rabbitmq_delayed_message_exchange  windows环境    RabbitMQ 3.9.13        Erlang 24.3.2 **************************************************************************************************** windows 安装RabbitMQ  可跳过进入下栏 *********************

【重难点】【RabbitMQ 02】如何避免消息重复投递和消息重复消费、如何防止消息丢失、如何保证消息的顺序性、如何保证消息队列的可用性 一、如何避免消息重复投递和消息重复消费 为了防止 RabbitMQ 没收到生产者发送的消息，所以生产者需要重复投递。但是消息重复投递就有可能会带来消息重复消费的问题。解决消息重复消费的关键在于消息处理逻辑的幂等性，也就是说同一条消息无论被消费多少次，产生的结果和消息被消费一次是一样的。比如银行要给一个账户增加 50元，我们就可以先查询出账户的余

RabbitMQ中的一些角色：### publisher：生产者 consumer：消费者 exchange个：交换机，负责消息路由 queue：队列，存储消息 virtualHost：虚拟主机，隔离不同租户的exchange、queue、消息的隔离 基本消息队列的消息发送流程：### 建立connection 创建channel 利用channel声明队列 利用channel向队列发送消息 基本消息队列的消息接收流程：### 建立connection

一：RabblitMQ应用场景： 1. 异步处理； 2.应用解耦； 3.流量控制； 二：RabblitMQ概述： 1.消息代理和目的地： 当消息发送消息以后，将由消息代理（message Borker）接管，消息代理保证消息传递到指定目的地； 2.消息对列主要有两种形式的目的地： 1）队列：点对点消息通信； 2）主题：发布/订阅 消息通信； 3.点对点式： 1）消息发送者发送消息，消息代理将其放入一个队列种，消息接收者从队列种获取消息内容，消息读取后被移除队列； 2）特点

💂 个人主页: 陶然同学 🤟 版权: 本文由【陶然同学】原创、在CSDN首发、需要转载请联系博主 💬 如果文章对你有帮助、欢迎关注、点赞、收藏(一键三连)和订阅专栏哦 💅 想寻找共同成长的小伙伴，请点击【Java全栈开发社区】 目录 1.MQ消息队列 1.1什么是MQ 1.2实现方式：AMQP、JMS 1.3常见MQ产品 2.RabbitMQ 2.1RabbitMQ概述 2.1.1什么是Rabbit 2.1.2RabbitMQ的工作原理 2.1.3

1.MQ 的基本概念 1.1 MQ概述 MQ全称 Message Queue（消息队列），是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。 为什么使用MQ： 在项目中，可将一些无需即时返回且耗时的操作提取出来，进行异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。 1.2 MQ 的优势和劣势 1.2.1 优势 开发中消息队列通常有如下应用场景： 任务异步处理提速：将不需要同步处理的并且耗时长的操作由消

在centos7下安装 1、安装依赖环境： yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c ++ kernel-devel m4 ncurses-devel tk tc xz 2、安装Erlang 首先创建一个rabbitmq目录： 上传： erlang-18.3-1.el7.centos.x86_64.rpm soca

1.1. MQ 的相关概念 1.1.1. 什么是MQ MQ(message queue)，M表示【消息】，Q表示【队列】，MQ就是【消息队列】； 消息队列：从字面意思上看，本质是个队列，只不过队列中存放的内容是 message 而已。 遵循先入先出原则(FIFO)：好比运输水的水管，先流入水管的水，肯定也会先流出水管。 还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ 是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了 MQ 之后，消息发送上游只需要依

1、业务与技术背景 1、为了促进公司商城项目的推广与引流，项目组引入了第三方的电子卡系统，该电子卡系统可以通过生成相应的红包类型，运营人员可以通过该系统将红包发放给需要引流的客户来促进消费与推广。 2、由于目前该电子卡发红包行为只能在小程序端触发，无法从后台进行派发和控制，希望礼品卡可以实现运营端应用，业务可以像发优惠券那样派发红包，实现多样化的用户运营。 3、由于目前该电子卡每个红包只能有一百个用户领取，而业务希望开发可以在后台系统中增加用户列表excel文件的解析，对列表中的用户去

一 引入的POM依赖 <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>3.6.5</version> </dependency> 二 声明队列的源码 package com.rabbitmq.client; public interfa