RabbitMQ六种队列模式之简单队列模式

黎明大大

发布于 2021-03-09 15:16:38

6760

发布于 2021-03-09 15:16:38

文章被收录于专栏：java相关资料

点击“蓝字”关注我们吧

前言

RabbitMQ官网提供了七种队列模型，分别是：简单队列、工作队列、发布订阅、路由模式、主题模式、RPC模式,因为RPC模式不是MQ,所以文章系列中不会介绍RPC模式了。

那么接下来的几篇文章一起来看看这几种队列模式,本篇文章为简单队列模式

简单队列模式

什么是简单队列模式

简单队列模式从字面上理解,乍看就是一种非常简单的队列模式,其实实际也是如此,该队列模式分为两种角色,一个是消息生产者,另外一个是消息消费者,最后还有一个队列,俗称点对点模式。

功能介绍

功能描述:一个生产者 "P" 发送消息到 "Q" 队列由消费者 "C" 接受消息

P:生产者、红色:队列(可以缓存消息)、C:消费者

代码演示

本文是基于SpringBoot框架去集成的RabbitMQ,所以最好会SpringBoot基础,再跟着本文一起大家简单队列Demo

创建一个简单的maven项目

导入依赖

首先在我的父工程 pom.xml 导入maven依赖

<parent>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-parent</artifactId>    <version>2.0.0.RELEASE</version></parent>
<dependencies>    <!-- 添加springboot对amqp的支持 -->    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-amqp</artifactId>    </dependency></dependencies>

生产者

生产者项目结构

pom文件

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-web</artifactId></dependency>

yml文件

server:  port: 8081
spring:  rabbitmq:    ####连接地址    host: 192.168.137.5    ####端口号    port: 5672    ####账号    username: sunny    ####密码    password: sunny    ### 交换机    virtual-host: /sunny_vm

生产者配置类

@Componentpublic class RabbitMqConfig {
    /**     * 队列名称     */    public static final String QUEUE_NAME = "sunny_simple_queue";        @Bean    public Queue simpleQueue() {        return new Queue(QUEUE_NAME);    }}

生产者发送消息

@RestControllerpublic class ProducerController {
    @Autowired    private RabbitTemplate rabbitTemplate;
    @GetMapping("/send")    public void send(){        String message = "sunny发送爱心小礼包消息";
        rabbitTemplate.convertAndSend(QUEUE_NAME, message);
        System.out.println("生产者发送消息我:" + message + "成功");    }}

在简单队列模型中,发送消息的时候是不需要指定交换机的名称,它会将消息发送到"默认交换机"上,默认的Exchange不进行Binding操作，任何发送到该Exchange的消息都会被转发到"Queue名字和Routing key相同的队列"中，如果vhost中不存在和Routing key同名的队列，则该消息会被抛弃。

这里我们在发送消息的时候设置的Routing key为"sunny_simple_queue",那么就会将消息发送到队列名字为"sunny_simple_queue"的队列上去。

生产者测试发送消息

打开浏览器,访问指定网址

http://localhost:8081/send

登陆Mangerment界面，可以看到队列中阻塞了一条消息未消费

消费者

消费者项目结构

yml文件

spring:  rabbitmq:    ####连接地址    host: 192.168.137.5    ####端口号    port: 5672    ####账号    username: sunny    ####密码    password: sunny    ### 交换机    virtual-host: /sunny_vm
server:  port: 8080

消费类

@Component@RabbitListener(queues = "sunny_work_queue")public class ConsumerTwoController {
    /**     * @RabbitListener 和 @RabbitHandler 搭配使用     * 可以标注在类上面，需配合 @RabbitHandler 注解一起使用     * 标注在类上面表示当有收到消息的时候，就交给 @RabbitHandler 的方法处理，     * 具体使用哪个方法处理，根据 MessageConverter 转换后的参数类型     **/    @RabbitHandler    public void accept(String message) {        System.out.println("消费者接受消息:" + message + "成功");    }
}

启动消费者项目，项目启动后会自动消费消息