RabbitMQ介绍及简单操作

文章目录

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

一、同步调用

例如:

支付服务
1.用户登录
2.交易服务
3.通知服务
4.积分服务

通过openfeign进行服务之间通信实现商城的支付服务,需要用户登录、交易服务、通知服务、积分服务,四个服务缺一不可。
每一个服务都不能出现问题,一旦出现问题就会影响性能,甚至报错中断。
openfeign同步调用:

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

二、异步调用

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

发送消息通知
发送消息通知
支付服务
1.用户登录
2.交易服务
消息代理
通知服务
积分服务

优势:

  • 解耦,拓展性强
  • 无需等待,性能好
  • 故障隔离
  • 缓存消息,流量削峰填谷
    缺点:
  • 实时性差
  • 不确定下游业务是否执行成功
  • 业务安全依赖于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.页面简单使用

  1. 登录在这里插入图片描述

  2. 创建用户
    在这里插入图片描述

  3. 创建exchange,我创建的是test在这里插入图片描述

  4. 创建queue在这里插入图片描述

  5. 将exchange和queue关联起来,关联可以在queues中操作,也可以在exchanges中操作
    在这里插入图片描述在这里插入图片描述

  6. 测试发送消息
    在这里插入图片描述

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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/664116.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

[Angular 基础] - Angular 渲染过程 组件的创建

[Angular 基础] - Angular 渲染过程 & 组件的创建 之前的笔记为了推进度写的太笼统了(只有功能没有其他),当时学的时候知道是什么东西,但是学完后重新复习发现有些内容就记不清了,所以重新用自己的语言总结一下 …

java中如何使用Lambda表达式(十一)

Lambda表达式如何支持默认方法 在Java 8中,引入了默认方法(Default Methods)的概念,这使得接口可以包含具有默认实现的方法。Lambda表达式可以与默认方法一起使用,以便在接口中提供一组默认的行为,并且可以…

IDEA常用快捷健

一、常用功能 Alt Shift F 显示添加到收藏夹弹出层 / 添加到收藏夹多行注释 ctrl shift /单行注释 ctrl /提示补全 (Class Name Completion) alt/执行(run) Shift F10复制代码 ctrl c 撤销 ctrl z反撤销 ctrl shift z剪切 ctrl x粘贴 ctrl v保存 ctrl s全选 ctrl…

被审查?ChatGPT陷入数据风波!

在近期的一项声明中,意大利的数据保护机构(DPA)对外宣布,他们已正式启动对OpenAI公司开发的聊天机器人ChatGPT的调查。该机构指出,ChatGPT违反了欧盟的通用数据保护条例(GDPR),这一法…

Aigtek超声功率放大器的作用是什么

超声功率放大器是一种用于放大超声信号的设备,其作用是增强超声信号的功率,使其能够在超声应用中达到所需的强度和能量。下面西安安泰将详细解释超声功率放大器的作用以及其在不同领域的应用。 超声技术是通过利用超声波的高频振动传递和检测能量&#x…

springboot在线问诊系统-计算机毕业设计源码00211

摘 要 针对医院门诊等问题,对在线问诊进行研究分析,然后开发设计出在线问诊系统以解决问题。在线问诊系统主要功能模块包括首页、轮播图管理、公告信息管理、资源管理、系统用户管理(管理员、患者用户、医生用户)、模块管理&#…

从编程中理解:大脑的自我实现预言

在心理学中,自我实现预言(Self-fulfilling Prophecy)是指一个人的信念、期望或预测可以影响其行为和决策,进而使这个预言变为现实的现象。从编程的角度理解,这就像程序中的条件判断和循环结构,基于预设的条件执行不同的代码路径,最终导致预期的结果。 在Unity C#环境中…

node环境打包js,webpack和rollup两个打包工具打包,能支持vue

引言 项目中经常用到共用的js,这里就需要用到共用js打包,这篇文章讲解两种打包方式,webpack打包和rollup打包两种方式 1、webpack打包js 1.1 在根目录创建 webpack.config.js,配置如下 const path require(path); module.expo…

[激光原理与应用-74]:数据采集卡 - 数模转换芯片AD7606

目录 一、简介 二、AD7606 三、AD7606的管脚定义如下: 三、c主要接口寄存器 四、AD7606数据带宽 五、AD7606 六、AD7606的使用 一、AD7606简介 AD7606是一款由Analog Devices(ADI)公司生产的16通道高速模拟数字转换器(ADC…

课时12:shell基础_开发规范解读

1.3.6 脚本开发规范 学习目标 这一节,我们从 开发规范、规范解析、小结 三个方面来学习。 开发规范 脚本规范 1、脚本命名要有意义,文件后缀是.sh 2、脚本文件首行是而且必须是脚本解释器#!/bin/bash 3、脚本文件解释器后面要有脚本的基本信息等内容…

MongoDB从入门到实战之MongoDB快速入门

前言 上一章节主要概述了MongoDB的优劣势、应用场景和发展史。这一章节将快速的概述一下MongoDB的基本概念,带领大家快速入门MongoDB这个文档型的NoSQL数据库。 MongoDB从入门到实战的相关教程 MongoDB从入门到实战之MongoDB简介👉 MongoDB从入门到实战…

go_view同后端集成时的注意事项

goview是一个不错的可视化大屏配置工具;提供了丰富的功能可供调用。 官方地址和文档: https://gitee.com/dromara/go-view https://www.mtruning.club/guide/start/ 同nodejs集成可参考;https://gitee.com/qwdingyu/led (建议–后端集成有api功能,可直接配置sql)同dotne…

力扣面试题 17.11. 单词距离(双指针)

Problem: 面试题 17.11. 单词距离 文章目录 题目描述思路复杂度Code 题目描述 思路 Problem力扣面试题 16.06. 最小差 该题目只需预先做一些处理,即可以转换为上述题目: 1.预处理操作:定义两个数组w1ps,w2ps用于记录在words数组中…

【ARM Coresight 系列文章 8.1 - ARM Coresight 通过 APBIC arbiter】

请阅读【ARM Coresight SoC-400/SoC-600 专栏导读】 文章目录 APBIC arbiter仲裁使用举例APBIC arbiter 在 SoC-600中,APBIC 是用来为 APB4 master 和 APB4 slave 提供 连接关系的组件。APB 是一种简单的总线协议,通常用于低带宽或低性能外设,如定时器、接口控制等。APBIC …

查找二叉树结点C++,数组模拟二叉树

已知一棵二叉树用邻接表结构存储,中序查找二叉树中权值为 x 的结点,并指出该结点在中序遍历中的排列位置。 例:如图二叉树的数据文件的数据格式如下: 输入格式 第一行包含整数 n,表示二叉树的结点数,结点编号从 1 到…

项目学习——canvas标签

canvas在本次项目中是重难点,经过这次项目我对canvas也有了部分认识,学习中没有查canvas标签的名字,因此,我将他称为画布标签。 首先,canvas的宽高与其他标签不同,他的宽高是标签内属性,在我使…

Arduino控制器使用Udp网络对8路IO输出控制

一、实现功能 1、创建串口连接,将接收的Udp数据通过串口发送出去。 2、创建Udp连接,用以接收Udp数据和对发送数据的Udp机器反馈Udp数据 3、对接收到的Udp数据进行解析,然后对8路IO进行输出控制。 4、1对应IO输出低电平,‘0’对…

LeetCode第824题 - 山羊拉丁文

题目 解答 String toGoatLatin(String S) {if (S null) {return "";}S S.trim();if (S.isEmpty()) {return "";}StringBuilder sb new StringBuilder();String[] tokens S.split(" ");for (int i 0, j 1, length tokens.length; i <…

stack_queue:三个关键注意事项解析

一、stack与容器 template<class T, class Container> class stack { private:Container _con; };Container 为容器&#xff0c;在实例化创建对象时&#xff0c;我们可以传 vector<T> 或 list<T> 等作为栈的底层。 举例&#xff1a; int main() {stack<i…

DES加密解密算法(简单、易懂、超级详细)

目录 一、基础补充 二、什么是DES算法 &#xff08;1&#xff09;对称加密算法 &#xff08;2&#xff09;非对称加密算法 &#xff08;3&#xff09;对称加密算法的应用 三、DES算法的基础操作步骤 1.明文的加密整体过程 2.F轮函数解析 3.密钥的形成过程 四、AC代码 五、D…