目录 一、准备环境 1.下载Erlang 2.安装RabbitMQ 3.RabbitMQ安装时出现的问题  RabbitMQ的介绍：http://t.csdn.cn/6mSSu 一、准备环境 RabbitMQ是由Erlang语言开发的，所以需要安装Erlang环境以及配置对应的环境变量 1.下载Erlang 1.Erlang下载 官网下载地址：https://www.erlang.org/downloads 这里如果嫌官网下载麻烦，我这里提供了一个20.2的

一、Docker安装部署RabbitMQ 1、通过Docker拉取镜像 docker pull rabbitmq:3.7 需要管理后台可以使用management版本 docker pull rabbitmq:3.9-management 2、创建和启动RabbitMQ容器 docker run -it -p 5672:5672 -p 15672:15672 --name rabbitmq -d --restart always -v /data/rabbit/data:/var/

1、RabbitMQ的不公平分配 RabbitMQ默认采用的是轮循分发，但实际项目中可能某一个消费者处理的速度快，某一个处理的速度慢， 这个时候用轮循分发就会导致速度快的很长一段时间处于空闲状态，处理慢的就一直在干活。 为了避免上述情况： //消费者端开启不公平分配 channel.basicQos(1); 开启之后，意思就是说，我这一个消息还没有处理完或者说我还没有应答你，请你先不要分配消息给我； 这时候只能把新的消息分发给其它空闲的消费者。 1.1、预期值概念 Rabb

大家在项目当中遇到消息中间件，应该还是挺多的吧，在业务量大的情况下，就可以把消息中间件整合在项目当中，实现异步消峰，高可用等，今天先给大家分享一个在linux环境下手动安装以及容器安装消息中间件。 一、linux安装RabbitMQ 1. 首先下载erlang包和RabbitMQ包 下载erlang wget https://packages.erlang-solutions.com/erlang-solutions-2.0-1.noarch.rpm 下载RabbitMQ（也可以直

同步通讯（调用）与异步通讯（调用） 同步通讯的优点 实时通讯，比如说视频电话等，对方有什么变动你就会知道 同步通讯的缺点 耦合度高：每次加入新的需求，都要修改原来的代码 性能下降：调用者调用其他服务，调用时间等于其他服务时间的总和加上自己所耗时长 资源浪费：在调用的过程中，不能即使的释放所占用的资源，高并发场景下会极度的浪费系统资源 级联失败：如果一方出问题，其他的调用也会出问题，就像多米诺骨牌一样，会导致整个微服务崩溃 异步调用的优点 1.服务解耦 2.服务性能

引入依赖、创建topic等工作就不再赘述，可以参考上篇文章：【spring cloud】stream集成rabbitMQ，实现Topic订阅发布 此处重点拎出来消息分组和消息分区的配置。 配置如下： #消息分组 spring.cloud.stream.bindings.group-consumer.destination=group-topic spring.cloud.stream.bindings.group-consumer.group=Group-B #消费分区配置 spring.c

记录一次rabbitmq安装过程，供自己及有需要的人参考。 前言：RabbitMQ不同版本对Erlang版本有要求（版本对比参考：Erlang版本要求），也对操作系统版本有要求（暂时没在官网找到对应关系），几经努力成功安装rabbitmq3.9.10版本，主要是参考了官网（官网位置）。 环境：腾讯云轻量级云服务器，CentOS7 查看系统版本：cat /etc/redhat-release CentOS Linux release 7.9.2009 (Core) 1.添加rabbitmq y

SpringCloud stream消息驱动和链路追踪 简要说明 在学习消息驱动之前，肯定有之前并没有接触过rabbitMQ或者其他的MQ（消息中间件）的。为了保证springcloud系列学习的连续性为之后的springcloud alibaba做好准备，只能先提前简单的学习一下rabbitMQ的安装。保证整个学习的完整性。之后打算在学习一下中间件。重新温习一下redis等之后。作为普通学生今后连续性学习编程的时间可能就不多了。毕竟还有考研深造的打算。在在时间上总是要放弃一些的。个人也

1、什么是消息队列： 1.1、消息队列的优点： （1）解耦：将系统按照不同的业务功能拆分出来，消息生产者只管把消息发布到 MQ 中而不用管谁来取，消息消费者只管从 MQ 中取消息而不管是谁发布的。消息生产者和消费者都不知道对方的存在； （2）异步：主流程只需要完成业务的核心功能；对于业务非核心功能，将消息放入到消息队列之中进行异步处理，减少请求的等待，提高系统的总体性能； （3）削峰/限流：将所有请求都写到消息队列中，消费服务器按照自身能够处理的请求数从队列中拿到请求，防止请求并发过高将

今天在学习到SpringCloud Stream消息驱动时，工程cloud-stream-rabbitmq-provider8101，作为生产者进行发布消息，使用的RabbitMQ作为消息中间件，启动报错…针对以下几种错误，做出一些个人可行的解决方案，供参考 1. Failed to load property source from location 'classpath:/application.yml 由于视频给出的YAML配置文件是针对本地配置的RabbitMQ，所以原始的

1、死信队列 因为某些原因导致消息在queue里面无法被消费，并且这些消息没有后续的处理，那么这些消息就称为死信，后续处理死信的队列就是死信队列。 1.1、产生死信的来源 消息TTL过期； 队列达到最大长度，无法添加数据到队列中； 消息被拒绝并且没有设置直接丢弃; 1.2、模型图 1.2.1、TTL过期实例 import com.example.wwy.rabbit.units.ChannelUnit; import com.rabbitmq.client.AMQP;

1. 死信及死信队列 1.1 什么是死信 一般来说，生产者将消息投递到队列中，消费者从队列取出消息进行消费，但某些时候由于特定的原因导致队列中的某些消息无法被消费，这样的消息如果没有后续的处理，就变成了死信(Dead Letter)，所有的死信都会放到死信队列中。 为什么为有死信？消息变成死信一般是以下三种情况： 消息被拒绝，即basicReject/basicNack，并且设置 requeue 参数为 false，这种情况一般消息丢失 。 消息过期（TTL），TTL全称为Ti