[聚合文章] 第四十一章: 基于SpringBoot & RabbitMQ完成DirectExchange分布式消息消费

消息系统 2017-11-26 17 阅读

消息队列目前流行的有KafKa、RabbitMQ、ActiveMQ等,它们的诞生无非不是为了解决消息的分布式消费,完成项目、服务之间的解耦动作。消息队列提供者与消费者之间完全采用异步通信方式,极力的提高了系统的响应能力,从而提高系统的网络请求吞吐量。
每一种的消息队列都有它在设计上的独一无二的优势,在实际的项目技术选型时根据项目的需求来确定。

本章目标

基于SpringBoot项目整合RabbitMQ消息队列,完成DirectExchange(路由键)分布式消息消费。

Exchange

RabbitMQ中有三种常用的转发方式,分别是:

DirectExchange:路由键方式转发消息。
FanoutExchange:广播方式转发消息。
TopicExchange:主题匹配方式转发消息。

我们本章先来讲解DirectExchange路由键方式,根据设置的路由键的值进行完全匹配时转发,下面我们来看一张图,形象的介绍了转发消息匹配流程,如下图所示:

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

  1. 我们通过Erlang官方网站http://www.erlang.org/downloads下载最新的安装包

  2. 我们访问RabiitmQ官方下载地址https://www.rabbitmq.com/download.html下载最新安装包。

因为是国外的网站所以下载比较慢,大家下载时会浪费时间,我已经将安装包分享到了百度网盘,下载地址:安装包下载地址,密码:pexf

  1. 运行安装Erlang

  2. 运行安装RabbitMQ

5.检查服务是否安装完成,RabbitMQ安装完成后会以服务的形式创建,并且随着开机启动,如下所示:

注:本文内容来自互联网,旨在为开发者提供分享、交流的平台。如有涉及文章版权等事宜,请你联系站长进行处理。