【消息中间件】1小时快速上手RabbitMQ

简介: 【消息中间件】1小时快速上手RabbitMQ

1.MQ的介绍

1.1 MQ的基本概念

cb037f263dbd42deacbd51686b3f8f94.png


1.2 MQ的优缺点

下面是MQ的优缺点


8c545271e6d548b496da36da6c9993bc.png

1.2.1 优点1:应用解耦

考虑由订单系统与库存系统、支付系统、物流系统直接通过远程调用方式通信,模块耦合度较高的情况。


50294129037d42b4a6a9d5f505e44792.png

会存在问题:

(1)容错性较低。

一个库存系统出问题,通信链路断了,订单下单就失败了。


244eaeaf82c94b7ab50466794be4f4a7.png


(2)可维护性低

增加x系统,需要修改订单系统的代码。再加再改,撤回也改。


a73bfafa962c4346ae231722757882c4.png


引入消息中间件MQ后。订单系统作为消息生产者生产订单消息生产消息到MQ,库存、支付、物流作为消息消费者消费消息。即使库存系统出现问题,也可以在恢复以后再从MQ中消费消息,而不会导致订单失败。

image.png


扩展新的x系统,只需要x系统把MQ中的消息再消费一次即可,订单系统无需改代码。

e0b6b83aec7e401fa81636f5e4e49801.png


1.2.2 优点2:异步提速

引入中间件之前,需要同步完成订单系统对其它模块的调用,即调用库存返回后调用支付,调用支付返回后调用物流。


image.png



引入中间件之后,25ms返回请求。


image.png


1.2.3 优点3:削峰填谷

引入消息中间件前,假如A系统来个秒杀活动,会寄。

image.png

引入之后,MQ就像一个大仓库,5000个请求,对MQ小意思。A系统慢慢从仓库里运货吧。


image.png


image.png


image.png


1.2.4 缺点


image.png


image.png

1.3常见的消息中间件

网络异常,图片无法展示
|

2.RabbitMQ的介绍与安装

2.1 RabbitMQ简介

image.png


image.png

网络异常,图片无法展示
|


image.png

2.2 JMS概念

image.png

2.3 RabbitMQ安装

官网地址:https://www.rabbitmq.com/


image.png

往下翻一翻,下载软件和文档。


image.png由于只是方便学习,本文基于windows安装rabbitmq,如果使用linux推荐使用docker进行部署。

2.3.1 安装依赖环境

由于rabbitmq是基于erlang语言开发的,因此需要有erlang语言环境。

先看看官方文档中,对于erlang的版本要求说明。

https://www.rabbitmq.com/which-erlang.html

可以看到,不同版本的rabbitmq需要的erlang版本不同。这里我们使用3.11.5版的rabbitmq。因此需要的erlang版本是25.0-25.2

image.png

通过下列网址可以下载erlang25.2:https://www.erlang.org/patches/otp-25.2

选择下图中的windows installer,下载exe安装包。


image.png

点击exe文件安装即可。

配置环境变量。


image.png


image.png

cmd键入erl -version判断是否配置成功

C:\Users\24724>erl -version
Erlang (SMP,ASYNC_THREADS) (BEAM) emulator version 13.1.3

2.3.2 安装rabbitmq

下载exe安装包。

https://www.rabbitmq.com/install-windows.html

版本选用:3.11.5

image.png

双击安装。从安装目录打开cmd,

image.png

使用如下命令安装管理页面的插件

rabbitmq-plugins enable rabbitmq_management


image.png

双击bat脚本启动

image.png

这时,打开浏览器输入http://localhost:15672,账号密码默认是:guest/guest

大功告成咯!


image.png

2.4 rabbitmq管控台的使用

rabbitmq的管控台还是比较友好的,可以随便点点。这里带大家简单熟悉下。

添加用户。

image.png

image.png


image.png


image.png

点击添加的虚拟机ittest,进入详情页面为其授权。


image.png

image.png

image.png

其它的您自己点点点吧,很简单。

3.RabbitMQ快速入门

3.1 需求描述

RabbitMQ有六种工作模式,先来介绍最简单的一种,实现一个helloworld。

需求如下:


image.png

图示如下。

image.png

3.2 准备工作

idea新建项目rabbitqmdemo,maven模块rabbitmq-producer,rabbitmq-consumer


image.png

在两个模块中引入依赖。

 <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.1.7.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit</artifactId>
            <version>2.1.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.1.7.RELEASE</version>
        </dependency>
    </dependencies>

3.3 生产者实现

producer下新建Producer_HelloWorld.java

其要实现的代码逻辑其实看着下图就会了。

image.png

代码如下。

/**
 *
 * 发送消息
 */
public class Producer_HelloWorld {
    public static void main(String[] args) throws IOException, TimeoutException {
        //1.创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        //2. 设置参数
        factory.setHost("localhost");//ip  默认值 localhost
        factory.setPort(5672); //端口  默认值 5672
        factory.setVirtualHost("/ittest");//虚拟机 默认值/
        factory.setUsername("guest");//用户名 默认 guest
        factory.setPassword("guest");//密码 默认值 guest
        //3. 创建连接 Connection
        Connection connection = factory.newConnection();
        //4. 创建Channel
        Channel channel = connection.createChannel();
        //5. 创建队列Queue
        /*
        queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
        参数:
            1. queue:队列名称
            2. durable:是否持久化,当mq重启之后,还在
            3. exclusive:
                * 是否独占。只能有一个消费者监听这队列
                * 当Connection关闭时,是否删除队列
                *
            4. autoDelete:是否自动删除。当没有Consumer时,自动删除掉
            5. arguments:参数。
         */
        //如果没有一个名字叫hello_world的队列,则会创建该队列,如果有则不会创建
        channel.queueDeclare("hello_world",true,false,false,null);
        /*
        basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body)
        参数:
            1. exchange:交换机名称。简单模式下交换机会使用默认的 ""
            2. routingKey:路由名称
            3. props:配置信息
            4. body:发送消息数据
         */
        String body = "hello rabbitmq~~~";
        //6. 发送消息
        channel.basicPublish("","hello_world",null,body.getBytes());
        //7.释放资源
        channel.close();
        connection.close();
    }
}

代码运行前,guest用户的管控台是这样的,没有queue

image.png

管控台变成了这个样子

image.png

3.4 消费者实现

consumer模块新建Consumer_HelloWorld.java

public class Consumer_HelloWorld {
    public static void main(String[] args) throws IOException, TimeoutException {
        //1.创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        //2. 设置参数
        factory.setHost("localhost");//ip  默认值 localhost
        factory.setPort(5672); //端口  默认值 5672
        factory.setVirtualHost("/ittest");//虚拟机 默认值/
        factory.setUsername("guest");//用户名 默认 guest
        factory.setPassword("guest");//密码 默认值 guest
        //3. 创建连接 Connection
        Connection connection = factory.newConnection();
        //4. 创建Channel
        Channel channel = connection.createChannel();
        //5. 创建队列Queue
        /*
        queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
        参数:
            1. queue:队列名称
            2. durable:是否持久化,当mq重启之后,还在
            3. exclusive:
                * 是否独占。只能有一个消费者监听这队列
                * 当Connection关闭时,是否删除队列
                *
            4. autoDelete:是否自动删除。当没有Consumer时,自动删除掉
            5. arguments:参数。
         */
        //如果没有一个名字叫hello_world的队列,则会创建该队列,如果有则不会创建
        channel.queueDeclare("hello_world",true,false,false,null);
        /*
        basicConsume(String queue, boolean autoAck, Consumer callback)
        参数:
            1. queue:队列名称
            2. autoAck:是否自动确认
            3. callback:回调对象
         */
        // 接收消息
        Consumer consumer = new DefaultConsumer(channel){
            /*
                回调方法,当收到消息后,会自动执行该方法
                1. consumerTag:标识
                2. envelope:获取一些信息,交换机,路由key...
                3. properties:配置信息
                4. body:数据
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("consumerTag:"+consumerTag);
                System.out.println("Exchange:"+envelope.getExchange());
                System.out.println("RoutingKey:"+envelope.getRoutingKey());
                System.out.println("properties:"+properties);
                System.out.println("body:"+new String(body));
            }
        };
        channel.basicConsume("hello_world",true,consumer);
        //关闭资源?不要,因为要一直监听消息
    }
}

执行结果如下,消费者成功的拿到了消息。


a05afad21bba4142843f96b61de0f5b1.png


相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
14天前
|
消息中间件 存储 Java
RocketMQ(一):消息中间件缘起,一览整体架构及核心组件
【10月更文挑战第15天】本文介绍了消息中间件的基本概念和特点,重点解析了RocketMQ的整体架构和核心组件。消息中间件如RocketMQ、RabbitMQ、Kafka等,具备异步通信、持久化、削峰填谷、系统解耦等特点,适用于分布式系统。RocketMQ的架构包括NameServer、Broker、Producer、Consumer等组件,通过这些组件实现消息的生产、存储和消费。文章还提供了Spring Boot快速上手RocketMQ的示例代码,帮助读者快速入门。
|
2月前
|
消息中间件 存储 RocketMQ
消息中间件-RocketMQ技术(二)
消息中间件-RocketMQ技术(二)
|
2月前
|
消息中间件 存储 中间件
消息中间件-RocketMQ技术(一)
消息中间件-RocketMQ技术(一)
|
24天前
|
消息中间件 编解码 Docker
【Docker项目实战】Docker部署RabbitMQ消息中间件
【10月更文挑战第8天】Docker部署RabbitMQ消息中间件
63 1
【Docker项目实战】Docker部署RabbitMQ消息中间件
|
7天前
|
消息中间件 存储 Java
吃透 RocketMQ 消息中间件,看这篇就够了!
本文详细介绍 RocketMQ 的五大要点、核心特性及应用场景,涵盖高并发业务场景下的消息中间件关键知识点。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
吃透 RocketMQ 消息中间件,看这篇就够了!
|
3月前
|
消息中间件 Java 测试技术
消息中间件RabbitMQ---SpringBoot整合RabbitMQ【三】
这篇文章是关于如何在SpringBoot应用中整合RabbitMQ的消息中间件。内容包括了在SpringBoot项目中添加RabbitMQ的依赖、配置文件设置、启动类注解,以及如何通过单元测试来创建交换器、队列、绑定,并发送和接收消息。文章还介绍了如何配置消息转换器以支持对象的序列化和反序列化,以及如何使用注解`@RabbitListener`来接收消息。
消息中间件RabbitMQ---SpringBoot整合RabbitMQ【三】
|
3月前
|
消息中间件 Docker 容器
消息中间件RabbitMQ---Docker安装RabbitMQ、以及RabbitMQ的基本使用【二】
这篇文章提供了RabbitMQ的安装和基本使用教程,包括如何使用Docker拉取RabbitMQ镜像、创建容器、通过浏览器访问管理界面,以及如何创建交换机、队列、绑定和使用direct、fanout和topic三种类型的交换器进行消息发布和接收的测试。
消息中间件RabbitMQ---Docker安装RabbitMQ、以及RabbitMQ的基本使用【二】
|
6月前
|
消息中间件 存储 负载均衡
消息中间件的选择:RabbitMQ是一个明智的选择
消息中间件的选择:RabbitMQ是一个明智的选择
106 0
|
5月前
|
消息中间件 存储 中间件
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
1254 0
|
4月前
|
消息中间件 编解码 Docker
Docker部署RabbitMQ消息中间件
【7月更文挑战第4天】Docker部署RabbitMQ消息中间件
270 3