基础信息 服务器信息 OS IP hostname CentOS 7.9 192.168.22.202 rabbit1 CentOS 7.9 192.168.22.203 rabbit2 CentOS 7.9 192.168.22.204 rabbit3 hosts 三台机器都如下配置： 192.168.22.202 rabbit1 192.168.22.203 rabbit2 192.168.22.204 rabbit3 每台机器还可以配上自己对应的 hosts，比如在 192.168.22.202 上： 127…
官方的一些文档 Erlang 与 RabbitMQ 版本对照 官方安装说明 官方推荐的安装方式：推荐 安装 安装依赖 $ yum install socat logrotate -y 安装 gpgkey 密钥 $ rpm --import https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc $ rpm --import https://packagecloud.io/rabbi…
SpringBoot 的支持 SpringBoot 已经提供了对 AMQP 协议完全支持的 spring-boot-starter-amqp 依赖，引入此依赖即可快速方便的在 SpringBoot 中使用 RabbitMQ。参考：Spring AMQP。 特点 用于异步处理消费消息的监听器容器。 用于发送和接收消息的 RabbitTemplate。 RabbitAdmin 用于自动声明队列、交换和绑定。 RabbitAdmin 作用 declareExchange：创建交换机。 deleteExchange：删除交…
简介 如上图所示，从 Publisher 开始，发送一个消息并指定 Routing key，经由 Connection 中的 Channel 到达对应的 Exchange，消息到达 Exchange 之后根据 Routing Key 路由到对应的 Queue。消息再从 Queue 中经由 Consumer 端的 Connection 中的 Channel 到达对应的 Consumer。 Publisher: 消息的生产方。 消息: 一条消息想要发送到 RabbitMQ Server，需要指定 Exchange 和 …
死信队列的作用 使用 RabbitMQ 的时候可能会碰到以下几个问题： 消费者端调用了 basicNack 或者 basicReject，并且没有进行 requeue，如果没做其他措施的话，这个消息也就丢失了。 消息在队列的存活时间超过设置的 TTL 时间。 消息队列的消息数量已经超过最大队列长度。 以上几个问题都会导致消息丢失，消息丢失的代价可大可小，视自己业务情况而定，有些业务如果消息丢失无所谓的话就不用理睬，相信大部分业务都是不允许丢失的。死信队列的出现就可以解决以上三个问题，当以上三个问题出现时，消…
软件版本 软件 版本 Spring Boot 2.5.0 spring-boot-starter-amqp 2.5.0 Erlang 24.0 RabbitMQ 3.8.19 发送消息 配置信息 spring: rabbitmq: host: localhost port: 5672 username: admin password: 123456 virtual-host: 'example' # 生产者 ==>> Exchange 确认方式 publisher-confirm-type: corre…
最终结构图： RabbitMQ镜像集群简介 RabbitMQ镜像集群是通过在RabbitMQ服务器配置相应的规则，把交换器、队列的数据进行Node之间Copy，对内网流量要求较高。在生产者扔消息时，会在所有Node之间同步完毕之后才会响应扔消息成功。 RabbitMQ镜像集群的安装 环境声明 三台CentOS 7.4 /etc/hosts配置分别为: 192.168.1.219 rabbit1 192.168.1.220 rabbit2 192.168.1.221 rabbit3 三台机器全部安装Erlang，Ra…