假设我们有一个应用,平时访问量是每秒300请求,我们用一台服务器即可轻松应对

而在高峰期,访问量瞬间翻了十倍,达到每秒3000次请求,那么单台服务器肯定无法应对,这时我们可以考虑增加到10台服务器,来分散访问压力

但如果这种瞬时高峰的情况每天只出现一次,每次只有半小时,那么我们10台服务器在多数时间都只分担每秒几十次请求,这样就有点浪费资源了

这种情况,我们就可以使用RabbitMQ来进行流量削峰,高峰情况下,瞬间出现的大量请求数据,先发送到消息队列服务器,排队等待被处理,而我们的应用,可以慢慢的从消息队列接收请求数据进行处理,这样把数据处理时间拉长,以减轻瞬时压力

这是消息队列服务器非常典型的应用场景

考虑定外卖支付成功的情况

支付后要发送支付成功的通知,再寻找外卖小哥来进行配送,而寻找外卖小哥的过程非常耗时,尤其是高峰期,可能要等待几十秒甚至更长

这样就造成整条调用链路响应非常缓慢

而如果我们引入RabbitMQ消息队列,订单数据可以发送到消息队列服务器,那么调用链路也就可以到此结束,订单系统则可以立即得到响应,整条链路的响应时间只有200毫秒左右

寻找外卖小哥的应用可以以异步的方式从消息队列接收订单消息,再执行耗时的寻找操作

案例分析

书架就是一个消息队列 , 小红是生产者 , 小明是消费者 .

三、RabbitMQ基本概念

四、Docker安装部署RabbitMQ

安装RabbitMQ

注意获取镜像的时候要获取management版本的,不要获取last版本的,management版本的才带有管理界面

docker pull rabbitmq:management

 创建并启动RabbitMQ

docker run -d \
--name my-rabbitmq \
-p 5672:5672  -p 15672:15672 \
--hostname my-rabbitmq-host \
-e RABBITMQ_DEFAULT_VHOST=my_vhost \
-e RABBITMQ_DEFAULT_USER=admin \
-e RABBITMQ_DEFAULT_PASS=admin \
--restart=always \
rabbitmq:management

--hostname：主机名(RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据,默认为主机名)

-e：指定环境变量:

RABBITMQ_DEFAULT_VHOST：默认虚拟机名

RABBITMQ_DEFAULT_USER：默认的用户名

RABBITMQ_DEFAULT_PASS：默认用户名的密码

• 端口5672：这是RabbitMQ的AMQP（高级消息队列协议）端口。它用于客户端与RabbitMQ服务器之间的通信。生产者和消费者通过5672端口发送和接收消息。
• 端口15672：这是RabbitMQ的管理界面端口，也称为RabbitMQ Management Plugin端口。通过该端口，可以使用Web浏览器访问RabbitMQ的管理界面，查看和管理队列、交换机、绑定等信息。管理界面提供了可视化的方式来监控和管理RabbitMQ服务器。

开放端口

firewall-cmd --zone=public --add-port=5672/tcp --add-port=15672/tcp --permanent

刷新防火墙

firewall-cmd --reload

访问管理控制台 http://虚拟机IP:15672
用户名密码是 admin 

1. Overview（概览）：提供了关于 RabbitMQ 服务器的总体信息，包括节点的状态、内存和磁盘使用情况、连接数等。

2. Connections（连接）：显示当前与 RabbitMQ 服务器建立的所有连接。您可以查看每个连接的详细信息，例如连接的协议、通信状态和客户端地址等。

3. Channels（通道）：显示当前在 RabbitMQ 中打开的所有通道。通道是连接上的虚拟连接，用于在客户端和服务器之间传输消息。

4. Exchanges（交换机）：列出了在 RabbitMQ 中定义的所有交换机。交换机是消息的接收和路由中心，它将消息从发送者传递给一个或多个队列。

5. Queues and Streams（队列和流）：显示 RabbitMQ 中定义的所有队列和流。队列是消息的临时存储区域，消息在发送到消费者之前将被存储在队列中。流是一种新的数据结构，用于持久化和流式传输消息。

6. Admin（管理员）：提供了一些管理工具和操作，如添加用户、设置权限、查看日志等。管理员可以使用这些功能来管理 RabbitMQ 服务器的配置和运行状态。

添加RabbitMQ用户

我们使用admin进行登录是不太合适的，所以添加一个用户赋予admin权限

用户是添加好了，但是现在没有访问虚拟机的权限

点击weiwei找到Set permission赋权

五、Spring集成

1.环境搭建

这里我们创建一个SpringCloud项目，首先使用Maven项目作为我们的父项目

再创建子项目这里有两个身份项目，一个是生产者另一个是消费者，扮演不同的模块或不同服务

 勾选我们所需依赖

 现在我们的子项目创建出来了，但是它和父项目还没有任何关系，所以我们还需要让它继承父项目，在子项目中添加下面依赖

 <parent>
        <groupId>org.example</groupId>
        <artifactId>Rabbit</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>

 不但子项目要继承父项目，父项目那边也需要定义子项目才能双向奔赴

   <!--定义子项目-->
    <modules>
        <module>produce</module>
    </modules>

另项目直接复制生产者项目即可，随后将“produce”改为“consume”

 2.配置RabbitMQ文件

将下列配置修改成自己的配置即可

server:
    port: 9999
spring:
    application:
        name: consume
rabbitmq:
    host: localhost
    username: weiwei
    password: 123456
    port: 5672
    virtual-host: my_vhost

3.代码编写

• 生产者produce

通过在配置类中定义队列，可以使得该队列在应用启动时自动创建，并且在需要时可以被其他组件注入和使用。

package org.example.produce.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@SuppressWarnings("all")
public class RabbitConfig {
    @Bean
    public Queue firstQueue() {
        return new Queue("firstQueue");
    }
}

通过将 Sender 类注册为 Spring 容器中的一个组件，并注入 AmqpTemplate 对象，我们可以在需要时通过调用 send01 方法发送消息到指定的 RabbitMQ 队列中

package org.example.produce.controller;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;

@RestController
public class Sender {
    @Autowired
    private AmqpTemplate rabbitTemplate;

    @RequestMapping("send01")
    public void send01() {
        rabbitTemplate.convertAndSend("firstQueue", "Hello World");
    }
}

• 消费者consume

 通过将 Receiver 类注册为 Spring 容器中的一个组件，并使用 @RabbitListener 和 @RabbitHandler 注解，当有消息到达名为 "firstQueue" 的队列时，该类会自动触发 process 方法对消息进行处理。

package org.example.produce.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@SuppressWarnings("all")
@Slf4j
@RabbitListener(queues = "firstQueue")
public class Receiver {
    @RabbitHandler
    public void process(String msg) {
        log.warn("接收到:" + msg);
    }
}

现在我们在网页上访问一下

我们现在可以看到RabbitMQ的管理页面有七条队列

我们现在开启消费者看看能否接收到这些请求

 开启的瞬间我们的消息就被读取了

五、注意事项

如果在spring中集成RabbitMQ出现下列错误可能是以下情况

1. 没有同时开放15672和5672端口
2. 如果使用的是云服务器，需要开放云服务的安全组
3. pom.xml文件中的spring.rabbitmq.host所需要填写的IP是配置 RabbitMQ 主机地址，我这里用的是虚拟机就填写虚拟机的地址，诸如此类

​

到这里我的分享就结束了，欢迎到评论区探讨交流！！

💖如果觉得有用的话还请点个赞吧 💖