一 RabbitMQ简介

1.1 消息队列中间件

消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题实现高性能，高可用，可伸缩和最终一致性[架构]

使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ。其使用场景为：异步处理，应用解耦，流量削锋和消息通讯四个场景。

1.2 什么是RabbitMQ

RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。

AMQP ：Advanced Message Queue，高级消息队列协议。它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。

RabbitMQ 最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。具体特点包括：

可靠性(Reliability)：RabbitMQ 使用一些机制来保证可靠性，如持久化、传输确认、发布确认。
灵活的路由(Flexible Routing)：在消息进入队列之前，通过 Exchange 来路由消息的。对于典型的路由功能，RabbitMQ已经提供了一些内置的 Exchange 来实现。针对更复杂的路由功能，可以将多个Exchange 绑定在一起，也通过插件机制实现自己的 Exchange 。
消息集群(Clustering)：多个 RabbitMQ 服务器可以组成一个集群，形成一个逻辑 Broker 。
高可用(Highly Available Queues)：队列可以在集群中的机器上进行镜像，使得在部分节点出问题的情况下队列仍然可用。
多种协议(Multi-protocol)：RabbitMQ 支持多种消息队列协议，比如 STOMP、MQTT 等等。
多语言客户端(Many Clients)：RabbitMQ 几乎支持所有常用语言，比如 Java、.NET、Ruby 等等。
管理界面(Management UI)：RabbitMQ 提供了一个易用的用户界面，使得用户可以监控和管理消息 Broker 的许多方
面。
跟踪机制(Tracing)：如果消息异常，RabbitMQ 提供了消息跟踪机制，使用者可以找出发生了什么。
插件机制(Plugin System)：RabbitMQ 提供了许多插件，来从多方面进行扩展，也可以编写自己的插件

1.3 架构图

1.4 主要概念

RabbitMQ Server：也叫broker server，它是一种传输服务。他的角色就是维护一条从Producer到Consumer的路线，保证数据能够按照指定的方式进行传输。

Producer：消息生产者，如图A、B、C，数据的发送方。消息生产者连接RabbitMQ服务器然后将消息投递到Exchange。

Consumer：消息消费者，如图1、2、3，数据的接收方。消息消费者订阅队列，RabbitMQ将Queue中的消息发送到消息消费者。

Exchange：生产者将消息发送到Exchange（交换器），由Exchange将消息路由到一个或多个Queue中（或者丢弃）。Exchange并不存储消息。RabbitMQ中的Exchange有direct、fanout、topic、headers四种类型，每种类型对应不同的路由规则。

Queue：（队列）是RabbitMQ的内部对象，用于存储消息。消息消费者就是通过订阅队列来获取消息的，RabbitMQ中的消息都只能存储在Queue中，生产者生产消息并最终投递到Queue中，消费者可以从Queue中获取消息并消费。多个消费者可以订阅同一个Queue，这时Queue中的消息会被平均分摊给多个消费者进行处理，而不是每个消费者都收到所有的消息并处理。

RoutingKey：生产者在将消息发送给Exchange的时候，一般会指定一个routing key，来指定这个消息的路由规则，而这个routing key需要与Exchange Type及binding key联合使用才能最终生效。在Exchange Type与binding key固定的情况下（在正常使用时一般这些内容都是固定配置好的），我们的生产者就可以在发送消息给Exchange时，通过指定routing key来决定消息流向哪里。RabbitMQ为routing key设定的长度限制为255bytes，

Connection：（连接）：Producer和Consumer都是通过TCP连接到RabbitMQ Server的。以后我们可以看到，程序的起始处就是建立这个TCP连接。

Channels：（信道）：它建立在上述的TCP连接中。数据流动都是在Channel中进行的。也就是说，一般情况是程序起始建立TCP连接，第二步就是建立这个Channel。

VirtualHost：权限控制的基本单位，一个VirtualHost里面有若干Exchange和MessageQueue，以及指定被哪些user使用

二 RabbitMQ安装

安装看我这篇博文：十次方——Linux部分

三 RabbitMQ三种模式

3.1 直接模式

3.1.1 介绍

我们需要将消息发给唯一一个节点时使用这种模式，这是最简单的一种形式。

任何发送到Direct Exchange的消息都会被转发到RouteKey中指定的Queue。

一般情况可以使用rabbitMQ自带的Exchange：”"(该Exchange的名字为空字符串，下文称其为default Exchange)。
这种模式下不需要将Exchange进行任何绑定(binding)操作
消息传递时需要一个“RouteKey”，可以简单的理解为要发送到的队列名字。
如果vhost中不存在RouteKey中指定的队列名，则该消息会被抛弃。

3.1.2 创建队列

首先在浏览器登录RabbitMQ：http://192.168.2XX.129:15672 ，按照下图创建一个队列就可以了

3.1.3 写代码

接下来开始写代码，准备工作还是老三套，jar包，配置文件与启动类（我们这只是一个测试队列模式的模块，在后面无需在十次方项目里面进行集成，所以像配置文件里面的端口号，名字啥都可以不写）

接下来我们写生产者代码（生产者采用Junit和SpringBoot整合），在test->java目录下

package com.tensquare.test;import com.tensquare.rabbit.RabbitApplication;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class)
@SpringBootTest(classes = RabbitApplication.class)
public class ProductTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void sendMsg(){rabbitTemplate.convertAndSend("itcast","直接模式测试");}
}

此时你运行生产者函数时，在消息队列的界面会显示一条消息（Ready）

消费者代码，在mian->java目录下

package com.tensquare.rabbit.customer;import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
@RabbitListener(queues = "itcast")
public class Customer1 {@RabbitHandlerpublic void getMsg(String msg){System.out.println("111直接模式消费消息"+msg);}
}

当你运行消费者代码时，在run栏会打印出：

当然，你想设置多个消费者时，我们可以将springboot单例运行选项去掉

然后改掉配置文件的端口号，重新把程序跑一次，这样，就有两个消费者了，再改端口号，再运行就是三个消费者了。多运行几次生产者的测试函数，三个消费者会轮流输出（因为这里是默认负载均衡的，所有会轮流输出）。

3.2 分裂模式

3.2.1 介绍

当我们需要将消息一次发给多个队列时，需要使用这种模式。如下图：

任何发送到Fanout Exchange的消息都会被转发到与该Exchange绑定(Binding)的所有Queue上。

可以理解为路由表的模式
这种模式不需要RouteKey
这种模式需要提前将Exchange与Queue进行绑定，一个Exchange可以绑定多个Queue，一个Queue可以同多个Exchange进行绑定。
如果接受到消息的Exchange没有与任何Queue绑定，则消息会被抛弃。

3.2.2 交换器绑定队列

先创建三个队列itcast，itheima，kudingyu

创建chuanzhi交换器

将chuanzhi交换器与三个队列绑定

这样向chuanzhi交换器里发消息，交换器就会向绑定的三个消息队列里面发消息（）。

3.2.3 代码实现

生产者

package com.tensquare.test;//省略@RunWith(SpringRunner.class)
@SpringBootTest(classes = RabbitApplication.class)
public class ProductTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void sendMsg2(){rabbitTemplate.convertAndSend("chuanzhi","","分裂模式测试");}
}

消费者1，2，3

@Component
@RabbitListener(queues = "itcast")
public class Customer1 {@RabbitHandlerpublic void getMsg(String msg){System.out.println("itcast："+msg);}
}

@Component
@RabbitListener(queues = "itheima")
public class Customer2 {@RabbitHandlerpublic void getMsg(String msg){System.out.println("itheima："+msg);}
}

@Component
@RabbitListener(queues = "kudingyu")
public class Customer3 {@RabbitHandlerpublic void getMsg(String msg){System.out.println("kudingyu："+msg);}
}

运行后可得下面结果

3.3 主题模式

3.3.1 介绍

任何发送到Topic Exchange的消息都会被转发到所有关心RouteKey中指定话题的Queue上

如上图所示此类交换器使得来自不同的源头的消息可以到达一个对列，其实说的更明白一点就是模糊匹配的意思，例如：上图中红色对列的routekey为usa.#，#代表匹配任意字符，但是要想消息能到达此对列，usa.必须匹配后面的#好可以随意。图中usa.newsusa.weather,都能找到红色队列，符号 # 匹配一个或多个词，符号 * 匹配不多不少一个词。因此 usa.# 能够匹配到 usa.news.XXX ，但是 usa.* 只会匹配到 usa.XXX 。

注：
交换器说到底是一个名称与队列绑定的列表。当消息发布到交换器时，实际上是由你所连接的信道，将消息路由键同交换器上绑定的列表进行比较，最后路由消息。任何发送到Topic Exchange的消息都会被转发到所有关心RouteKey中指定话题的Queue上

这种模式较为复杂，简单来说，就是每个队列都有其关心的主题，所有的消息都带有一个“标题”(RouteKey)，Exchange会将消息转发到所有关注主题能与RouteKey模糊匹配的队列。
这种模式需要RouteKey，也许要提前绑定Exchange与Queue。
在进行绑定时，要提供一个该队列关心的主题，如“#.log.#”表示该队列关心所有涉及log的消息(一个RouteKey为”MQ.log.error”的消息会被转发到该队列)。
“#”表示0个或若干个关键字，“”表示一个关键字。如“log.”能与“log.warn”匹配，无法与“log.warn.timeout”匹配；但是“log.#”能与上述两者匹配。
同样，如果Exchange没有发现能够与RouteKey匹配的Queue，则会抛弃此消息

3.3.2 创建队列与绑定

和分裂模式一样，只是在Exchanges设置里面添加Routing Key

3.3.3 代码编写

和分裂模式一样，只需要在3个Customer类里面修改下convertAndSend的参数就可以了

最后，控制台显示

只有itcast接收到了消息

所以可以看到，主题模式是加强版的分裂模式，它多了RoutingKey

四普通用户和后台用户的区别

十次方——RabbitMQ之介绍相关推荐

java十次方社交项目实战(完整)
资源目录: 前端系统开发 ├─1-1 十次方项目前端环境搭建 ├─1-2 前端 API文档与模拟数据接口 ├─1-3前端使用elementUI开发管理后台 ├─1-4 路由与状态管理 ├─1-5 ...
第五天黑马十次方 NUXT框架、前台的搭建、前台活动模块的功能、前台招聘模块的功能
第5章网站前台-活动与招聘学习目标: 掌握NUXT框架的基本使用方法完成十次方网站前台的搭建完成十次方网站前台活动模块的功能完成十次方网站前台招聘模块的功能 1 服务端渲染技术NUXT 1. ...
十次方专属社交平台前端系统开发网站前台-活动与招聘
学习目标: 掌握NUXT框架的基本使用方法完成十次方网站前台的搭建完成十次方网站前台活动模块的功能完成十次方网站前台招聘模块的功能 1服务端渲染技术NUXT 1.1什么是服务端渲染服务端渲染又 ...
十次方项目开发系列【8】：对评论点赞功能开发 Redis的配置和使用
使用对评论点赞和取消点赞功能开发一评论点赞功能开发 1.1 先根据评论的id查询,再对点赞数加一 1.1.1 在CommentController添加方法 1.1.2 在CommentServic ...
十次方项目开发系列【10】：接口加密Eureka微服务和网关服务开发
学习目标了解接口加密业务需求掌握常用加密算法和密钥格式实现十次方的接口加密微服务文章目录一业务场景介绍二加密方式 2.1 摘要算法 2.2 对称加密 2.3 非对称加密 2.4 数字签 ...
1小时学会：最简单的iOS直播推流（十）librtmp使用介绍
最简单的iOS 推流代码,视频捕获,软编码(faac,x264),硬编码(aac,h264),美颜,flv编码,rtmp协议,陆续更新代码解析,你想学的知识这里都有,愿意懂直播技术的同学快来看!! 源 ...
RabbitMq 消息中间件介绍初体验
RabbitMq 消息中间件介绍&为什么要使用消息中间件&什么时候使用消息中间件我们用java来举例子, 打个比方我们客户端发送一个下单请求给订单系统(order)订单系统发 ...
第六天黑马十次方用户注册、用户登陆掌握js-cookie、微信扫码登陆、nuxt嵌套路由
学习目标: ** 完成用户注册功能完成用户登陆功能,掌握js-cookie的使用完成微信扫码登陆的功能完成用户中心嵌套布局,掌握nuxt嵌套路由的使用 ** 1 用户注册 1.1 页面构建创建 ...
第七天黑马十次方吐槽列表与详细页、发吐槽与评论功能、问答频道功能、掌握DataURL和阿里云OSS
第7章网站前台-吐槽与问答学习目标: ** 完成吐槽列表与详细页完成发吐槽与评论功能,掌握富文本编辑器的使用完成问答频道功能掌握DataURL和阿里云OSS** 1 吐槽列表与详细页 1.1 ...

十次方——RabbitMQ之介绍

一 RabbitMQ简介

1.1 消息队列中间件

1.2 什么是RabbitMQ

1.3 架构图

1.4 主要概念

二 RabbitMQ安装

三 RabbitMQ三种模式

3.1 直接模式

3.1.1 介绍

3.1.2 创建队列

3.1.3 写代码

3.2 分裂模式

3.2.1 介绍

3.2.2 交换器绑定队列

3.2.3 代码实现

3.3 主题模式

3.3.1 介绍

3.3.2 创建队列与绑定

3.3.3 代码编写

四普通用户和后台用户的区别

十次方——RabbitMQ之介绍相关推荐

最新文章

热门文章

十次方——RabbitMQ之介绍

一 RabbitMQ简介

1.1 消息队列中间件

1.2 什么是RabbitMQ

1.3 架构图

1.4 主要概念

二 RabbitMQ安装

三 RabbitMQ三种模式

3.1 直接模式

3.1.1 介绍

3.1.2 创建队列

3.1.3 写代码

3.2 分裂模式

3.2.1 介绍

3.2.2 交换器绑定队列

3.2.3 代码实现

3.3 主题模式

3.3.1 介绍

3.3.2 创建队列与绑定

3.3.3 代码编写

四 普通用户和后台用户的区别

十次方——RabbitMQ之介绍相关推荐

最新文章

热门文章

四普通用户和后台用户的区别