RabbitMQ介绍及简单操作

文章目录

一、同步调用
二、异步调用
三、MQ介绍
- 1.安装RabbitMQ
- 2.介绍RabbitMQ
- 3.页面简单使用

一、同步调用

例如：

通过openfeign进行服务之间通信实现商城的支付服务，需要用户登录、交易服务、通知服务、积分服务，四个服务缺一不可。

每一个服务都不能出现问题，一旦出现问题就会影响性能，甚至报错中断。

openfeign同步调用：

优势：时效性强，等待结果后返回
缺点：拓展性差
缺点：性能下降
缺点：级联失败问题

二、异步调用

支付服务通过异步的方式调用业务关联度降低，发送消息通知到Broker。

例如：

优势：

解耦，拓展性强
无需等待，性能好
故障隔离
缓存消息，流量削峰填谷

缺点：
实时性差
不确定下游业务是否执行成功
业务安全依赖于Broker（消息代理）的可靠性

三、MQ介绍

MQ（消息队列），存放消息的队列，异步调用中的Broker，先进先出（FIFO）。

在这里插入图片描述

Kafka每秒吞吐量达百万级；

RockertMQ每秒吞吐量达十万级；

RabbitMQ每秒吞吐量达十万级左右，但是它消息延迟仅仅是微秒的，可靠性高；

考虑大部分情况下公司是达不到每秒吞吐量百万级的，所以选择RabbitMQ。

RabbitMQ官网

1.安装RabbitMQ

docker run -d -p 15672:15672  -p  5672:5672  -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin --name rabbitmq --hostname=rabbitmqhostone  rabbitmq

下载rabbitmq并且启动成功之后，可以直接访问http://localhost:15672，用户名密码都是admin

在这里插入图片描述

2.介绍RabbitMQ

RabbitMQ整体架构及核心概念：

publisher：消息发送者
exchange：交换机，负责路由消息
queue：队列，存储消息
consumer：消息的消费者
virtual-host：虚拟主机，起到数据隔离的作用

3.页面简单使用

登录
创建用户
创建exchange，我创建的是test
创建queue
将exchange和queue关联起来,关联可以在queues中操作，也可以在exchanges中操作
测试发送消息

进入exchange搜索我们创建的exchange
点击Name，可以进入详情页，查看到绑定的queue，可以发送消息
发送消息之后可以看到有发送的记录数据
进去queue页面可以看到通过exchange发送消息的队列中有了1条消息
点击Name进入详情，可以查看消息内容

本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://www.net2asp.com/6f4beaca00.html