消息队列目前流行的有KafKa、RabbitMQ、ActiveMQ等,它们的诞生无非不是为了解决消息的分布式消费,完成项目、服务之间的解耦动作。消息队列提供者与消费者之间完全采用异步通信方式,极力的提高了系统的响应能力,从而提高系统的网络请求吞吐量。
每一种的消息队列都有它在设计上的独一无二的优势,在实际的项目技术选型时根据项目的需求来确定。
本章目标
基于SpringBoot
项目整合RabbitMQ
消息队列,完成DirectExchange(路由键)
分布式消息消费。
Exchange
在RabbitMQ
中有三种常用的转发方式,分别是:
DirectExchange
:路由键方式转发消息。FanoutExchange
:广播方式转发消息。TopicExchange
:主题匹配方式转发消息。
我们本章先来讲解DirectExchange
路由键方式,根据设置的路由键的值进行完全匹配时转发,下面我们来看一张图,形象的介绍了转发消息匹配流程,如下图所示:
我们可以看到上图,当消息被提供者发送到RabbitMQ
后,会根据配置队列的交换以及绑定实例进行转发消息,上图只会将消息转发路由键为KEY
的队列消费者对应的实现方法逻辑中,从而完成消息的消费过程。
安装RabbitMQ
因为RabbitMQ
是跨平台的分布式消息队列服务,可以部署在任意的操作系统上,下面我们分别介绍在不同的系统下该怎么去安装RabbitMQ
服务。
我们本章采用的环境版本如下:
- RabbitMQ Server 3.6.14
- Erlang/OTP_X64 20.1
Windows下安装
我们先去RabbitMQ
官方网站下载最新版的安装包,下载地址:https://www.rabbitmq.com/download.html
,可以根据不同的操作系统选择下载。
我们在安装RabbitMQ
服务端时需要Erlang
环境的支持,所以我们需要先安装Erlang
。
我们通过
Erlang
官方网站http://www.erlang.org/downloads
下载最新的安装包我们访问
RabiitmQ
官方下载地址https://www.rabbitmq.com/download.html
下载最新安装包。
因为是国外的网站所以下载比较慢,大家下载时会浪费时间,我已经将安装包分享到了百度网盘,下载地址:安装包下载地址,密码:
pexf
运行安装
Erlang
运行安装
RabbitMQ
5.检查服务是否安装完成,RabbitMQ
安装完成后会以服务的形式创建,并且随着开机启动,如下所示:
注:本文内容来自互联网,旨在为开发者提供分享、交流的平台。如有涉及文章版权等事宜,请你联系站长进行处理。