RabbitMQ 的安装 访问RabbitMQ官方网站，进入下载页面 在这里安装指南，自己是什么系统就下载RabbitMQ的安装包，同时 最下面的Erlang/OTP 也得下载，因为 RabbitMq 是 Erlang 写的，所以需要安装该语言的相关环境 查看erlang 版本与 rabbitMQ 版本之间的对应关系 https://www.rabbitmq.com/which-erlang.html 在这里我们要安装的是 erlang – 23.3

1.因为RabbitMQ是用Erlang语言编写的，所以我们需要安装Erlang 请参考博主的安装Erlang教程：Linux安装Erlang 2.下载RabbitMQ安装包 下载地址：官网链接 我们默认都下载最新的，这样才能适配起来 3.将安装包上传到服务器上面去 4.解压rabbitMq 这里大家留个心眼，因为rabbitMq的后缀名是这样的：.xz 所以通过常见的tar命令并不能解开： 快说，我细不细！！！ 所以我们使用 xz -d命令先给他解压 啥？xz

Spring Cloud Stream入门篇：https://blog.csdn.net/weixin_43888891/article/details/126490478 一、关于配置的问题 上一篇生产者所使用的配置如下： server: port: 8801 spring: application: name: cloud-stream-provider cloud: stream: binders: # 在此处配置要绑定的rabbi

什么是MQ MQ就是消息队列。是软件和软件进行通信的中间件产品 MQ的优点 简答 异步处理 - 相比于传统的串行、并行方式，提高了系统吞吐量。 应用解耦 - 系统间通过消息通信，不用关心其他系统的处理。 流量削锋 - 可以通过消息队列长度控制请求量；可以缓解短时间内的高并发请求。 日志处理 - 解决大量日志传输。 消息通讯 - 消息队列一般都内置了高效的通信机制，因此也可以用在纯的消息通讯。比如实 现点对点消息队列，或者聊天室等。 解耦、异步、削峰是什么？。 解耦：A 系统发送数据到 BCD

前言 交换机 （Exchange） 生产者将消息发送到Exchange，有Exchange再路由到一个或多个队列中 路由键 （RoutingKey） 生产者将信息发送给交换机时会指定RoutingKey指定路由规则 绑定键 （BindingKey） 通过绑定键将交换机和队列关联起来，这样RabbitMQ就知道如何正确的将消息路由到队列 关系小结 生产者将消息发送给哪个Exchange是需要由RoutingKey决定的，生产者需要将Excha

前言 专栏中之前进行了一系列各种模式的配置、使用和测试操作。但是都只是应用于使用阶段，暂未面向问题解决分析方向。 最近看了一篇资料，有大佬说到了消息积压问题的产生原因等问题。对此做出个人见解说明记录。 好记性不如烂笔头！ 消息积压产生的原因 正常而言，一般的消息从消息产生到消息消费需要经过以下几种阶段。 以Direct模式为例： 消息由生产者产生，比如新订单的创建等，经过交换机，将消息发送至指定的队列中，然后提供给对应的消费者进行消费。 在这个链路中，存在消息

本项目云E办，用到的所有技术： SpringBoot、SpringMVC、Mybatis-plus：搭建框架 lombok插件、依赖：简化在pojo实体类中的set、get方法 AutoGenerator：用的是mybatis-plus逆向工程。用起来比mybaits更加简单、便捷，提高开发的效率。例如单表的增删改查，通过service就可以调用对应的方法（没有实现类、mapper接口，mapper.xml）. Swagger2：接口文档 SpringSecurity：权限 JWT

1.从源码了解mq启动配置流程 1.1配置启动入口 1.1.1从factories我们可以看到mq的启动配置类 1.1.2然后我们找到 RabbitAutoConfiguration，发现它引入了RabbitAnnotationDrivenConfiguration这个配置类 @Configuration @ConditionalOnClass({ RabbitTemplate.class, Channel.class }) @EnableConfigurationPrope

一、绪论 上篇文章介绍了rabbitmq的基本知识、交换机类型实战《【消息队列之rabbitmq】学习RabbitMQ必备品之一》 这篇文章主要围绕着消息确认机制为中心，展开实战；接触过消息中间件的伙伴都知道，消息会存在以下问题： 1、消息丢失问题和可靠性投递问题； 2、消息如何保证顺序消费； 3、消息如何保证幂等性问题，即重复消费问题等等… 本文主要以Rabbitmq消息中间件解决问题一的实践，其他问题小编会重新写文章总结； 故从业务代码设计层面，我们需要保证生产者发送消息可靠性投

一、为什么使用消息队列 1、优点 核心的有 3 个：解耦、异步、削峰。 2、缺点 系统可用性降低 系统引入的外部依赖越多，越容易挂掉。 系统复杂度提高 怎么保证消息没有重复消费？怎么处理消息丢失的情况？怎么保证消息传递的顺序性？ 一致性问题 A 系统处理完了直接返回成功了，人都以为你这个请求就成功了；但是问题是，要是 BCD 三个系统那里，BD 两个系统写库成功了，结果 C 系统写库失败了，咋整？你这数据就不一致了。 二、如何保证消息队列的高可用？ 1、Rabb

1、命令重启rabbitMQ cd /root/rabbitmq/rabbitmq_server/sbin/ ./rabbitmq-server -detached  启动rabbit ./rabbitmqctl stop  停止rabbit 2、Linux中使用全局变量操作rabbitMQ vim /etc/profile export RABBIT_HOME=/root/rabbitmq/erlang/bin :/root/rabbitmq/erlang/bin:/root

1. 概述 RocketMQ是一个统一消息引擎、轻量级数据处理平台。更多介绍可参阅RocketMQ官网 1.1. 基本概念 消息(Message)：消息系统所传输信息的物理载体，生产和消费数据的最小单位，每条消息必须属于一个主题主题(Topic)：一类消息的集合，每个主题包含若干条消息，每条消息只能属于一个主题，是RocketMQ进行消息订阅的基本单位。 一个生产者可以同时发送多种Topic的消息，一个消费者只可以订阅和消费一张Topic的消息标签(Tag)：用于同一主题下区分不同类型