MQ组件之RabbitMQ学习

MQ组件之RabbitMQ入门

同步调用和异步调用

在微服务架构中,服务之间的调用有同步调用和异步调用两种方式。
我们使用OpenFeign去调用是同步调用,同步调用的缺点很明显,在下图的场景中,支付完成后需要调用订单服务、仓库服务、短信服务。没每调用一个服务耗时150ms,那么全部调用完成就需要450ms,如果后面还需要调用更多的服务,那么耗时会更久,而且如果后期需求变更,支付完成后还需要调用其它服务,那么还需要改代码。综上所述

  • 同步调用的优点:
    • 时效性较强,可以立即得到结果
  • 同步调用的缺点:
    • 耦合度高
    • 性能和吞吐能力下降
    • 有额外的资源消耗
    • 有级联失败问题
      在这里插入图片描述
      在这里插入图片描述

异步调用常见的实现是基于事件驱动的方式。
在这里插入图片描述

  • 异步调用的优点:
    • 耦合度低
    • 吞吐量提升
    • 故障隔离
    • 流量削峰
  • 异步调用的缺点:
    • 依赖于Broker的可靠性、安全性、吞吐能力
    • 架构复杂了,业务没有明显的流程线,不好追踪管理

什么是MQ

MQ (MessageQueue),中文是消息队列,字面来看就是存放消息的队列。也就是事件驱动架构中的Broker。

下图是常见MQ组件的对比。
在这里插入图片描述

RabbitMQ安装

这里使用的是docker镜像安装的方式。

  1. 首先把RabbitMQ镜像上传到虚拟机中,然后加载RabbitMQ镜像
 docker load -i /usr/local/mq.tar
  1. 启动RabbitMQ容器
docker run  -e RABBITMQ_DEFAULT_USER=root  -e RABBITMQ_DEFAULT_PASS=root  -v mq-plugins:/plugins  --name mq  --hostname mq  -p 15672:15672  -p 5672:5672  -d  rabbitmq:3-management

输入虚拟机的ip和开放的端口,即可访问RabbitMQ的管理后台:
在这里插入图片描述

RabbitMQ管理后台介绍

下图是RabbitMQ管理后台的预览页面,展示了RabbitMQ节点的相关信息,如节点的名字、状态、运行时间等
在这里插入图片描述

下图Connections(连接)页面,在这个页面查看、管理和关闭当前所有的TCP连接。
在这里插入图片描述

下图是Channels(通道)页面,这里展示了所有当前打开的通道以及它们的详细信息
在这里插入图片描述

下图是Exchanges(交换机)页面,这里可以查看、创建和删除交换机。交换机是RabbitMQ消息路由的重要组成部分,它决定了消息如何被路由到正确的队列。
在这里插入图片描述

下图是Queues(队列)页面,可以在这里看到所有的队列。队列是RabbitMQ的核心,它保存了所有待处理的消息。
在这里插入图片描述

下图是Admin(管理)页面,在这里可以管理RabbimtMQ的用户,并分配相关功能。为了给不同的用户授权不同的功能,RabbitMQ设计了一个virtual host(虚拟主机)的概念,每个用户只能看到它所在虚拟主机下的资源。virtual host是对queue、exchange等资源的逻辑分组。
在这里插入图片描述

下面是RabbitMQ官方关于如何监控RabbitMQ以及RabbitMQ管理后台的介绍。
如何监控RabbitMQ
RabbitMQ的管理插件介绍

RabbitMQ相关概念

下图是AMQP的通讯模型,由消息发送者、消息接收者、交换机、队列组成。

  • 消息发送者:发送消息
  • 消息接收者:消费消息
  • 交换机:路由消息,决定消息路由到哪个队列
  • 队列:负责存储消息
    在这里插入图片描述
    下图是RabbitMQ对于AMQP通讯模型的实现。
    在这里插入图片描述

RabbitMQ中常见的通讯模型主要可以分为两种,队列和发布/订阅,而这两种又可以往下细分。

  • 队列
    • 基本消息队列
    • 工作消息队列
  • 发布订阅,根据交换机类型不同可以分为三种
    • Fanout Exchange:广播
    • Direct Exchange:路由
    • Topic Exchange:主题

使用

下面介绍RabbitMQ中简单队列的使用。

消息发布者代码

public class Send {private static final String QUEUE_NAME = "hello";public static void send() {//建立和RabbitMQ Server的连接ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("192.168.200.215");connectionFactory.setUsername("root");connectionFactory.setPassword("root");try (Connection connection = connectionFactory.newConnection()) {//创建通道Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false, false, false, null);String message = "Hello World1";//发送消息channel.basicPublish("", QUEUE_NAME, null, message.getBytes());} catch (IOException e) {e.printStackTrace();} catch (TimeoutException e) {e.printStackTrace();}}public static void main(String[] args) {send();}}

消息接收者代码

public class Recv {private static final String QUEUE_NAME = "hello";public static void receive() {ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.168.200.215");factory.setUsername("root");factory.setPassword("root");try(Connection connection = factory.newConnection()) {Channel channel = connection.createChannel();//这里声明队列是因为,消费者有可能先启动,此时要确保有队列,才能尝试从队列中获取消息channel.queueDeclare(QUEUE_NAME, false, false, false, null);DeliverCallback callback = new DeliverCallback() {@Overridepublic void handle(String s, Delivery delivery) throws IOException {String message = new String(delivery.getBody(), "UTF-8");System.out.println("receive message: " + message);}};channel.basicConsume(QUEUE_NAME, true, callback, s -> {});} catch (IOException e) {e.printStackTrace();} catch (TimeoutException e) {e.printStackTrace();}}public static void main(String[] args) {receive();}}

消息发送成功后,可以在RabbitMQ管理后台中看到

在这里插入图片描述
通过下面的Get Message按钮可以获取未消费的消息
在这里插入图片描述

参考

  • RabbitMQ官方教程
  • rabbitMQ入门指南:管理页面全面指南及实战操作

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

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

相关文章

SpringBoot集成WebService

1&#xff09;添加依赖 <dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-spring-boot-starter-jaxws</artifactId><version>3.3.4</version><exclusions><exclusion><groupId>javax.validation<…

九.pandas绘图基础

目录 九.pandas绘图基础 1-柱状图 --参数stackedTrue堆积 --参数figsize(宽,高) --自定义横坐标 --设置字体&显示负号 2.箱型图 3. 折线图 九.pandas绘图基础 Pandas的DataFrame和Series&#xff0c;在matplotlib基础上封装了一个简易的绘图函数, 使得我们在数据处…

17.WEB渗透测试--Kali Linux(五)

免责声明&#xff1a;内容仅供学习参考&#xff0c;请合法利用知识&#xff0c;禁止进行违法犯罪活动&#xff01; 内容参考于&#xff1a; 易锦网校会员专享课 上一个内容&#xff1a;16.WEB渗透测试--Kali Linux&#xff08;四&#xff09;-CSDN博客 1.ettercap简介与使用…

丘一丘正则表达式

正则表达式(regular expression,regex,RE) 正则表达式是一种用来简洁表达一组字符串的表达式正则表达式是一种通用的字符串表达框架正则表达式是一种针对字符串表达“简洁”和“特征”思想的工具正则表达式可以用来判断某字符串的特征归属 正则表达式常用操作符 操作符说明实…

倪诗韵古琴雷期展示,琴体秀气

音色通透、细腻&#xff0c;灵敏度高&#xff0c;好不好自己听吧&#xff0c;绝对是入门演奏利器。想不想听试音&#xff1f;试音已经发出来了&#xff0c;但是这床琴已经订出去了&#xff0c;不过琴友可以听听雷期的音色&#xff0c;那就关注我吧

Streamlit实战手册:从数据应用到机器学习模型部署

Streamlit实战手册&#xff1a;从数据应用到机器学习模型部署 简介Streamlit核心功能介绍Streamlit的安装创建第一个Streamlit应用界面布局与导航数据处理与展示 Streamlit的进阶应用交互式组件按钮复选框单选按钮滑块 图表与可视化使用Matplotlib绘图使用Plotly创建交互式图表…

视频号下载助手失效了?如何解决下载视频问题!

在刷短视频的时候难免会遇到部分的视频号视频下载不下来&#xff0c;那我们该如何解决视频号下载问题呢&#xff1f; 视频号下载助手解决方案 视频号下载助手失效分为两种情况! 1、可以解析&#xff0c;但不能下载 根据使用视频号下载助手常见的问题&#xff0c;我们发现会有…

超声波气象站和气象雷达有什么区别

TH-CQX5超声波气象站和气象雷达在气象监测领域各自扮演着重要的角色&#xff0c;但它们的工作原理和应用范围存在明显的区别。 首先&#xff0c;超声波气象站的工作原理主要基于超声波在大气中的传播特性。它利用超声波发射器向周围环境发射超声波信号&#xff0c;并通过测量这…

Emotion Prompt-LLM能够理解并能通过情感刺激得以增强

Large Language Models Understand and Can be Enhanced by Emotional Stimuli 情感智能对我们的日常行为和互动产生了显著的影响。尽管大型语言模型&#xff08;LLMs&#xff09;被视为向人工通用智能迈进的一大步&#xff0c;在许多任务中表现出色&#xff0c;但目前尚不清楚…

MES管理系统在生产计划与排产调度流程中的应用

在现代工业生产中&#xff0c;MES管理系统已经成为企业优化生产流程、提升生产效率的重要工具。MES管理系统在生产计划与排产调度中的具体应用&#xff0c;不仅能够帮助企业更好地控制生产过程&#xff0c;还能实现资源的合理配置&#xff0c;从而提高企业的整体竞争力。 首先&…

5G网络架构与组网部署03--5G网络组网部署

1. SA组网与NSA组网 &#xff08;1&#xff09;NSA 非独立组网&#xff1a;终端同时接入4G基站和5G基站&#xff0c;只能实现5G部分功能 &#xff08;2&#xff09;SA组网【最终目标】&#xff1a;5G基站可以单独提供服务&#xff0c;接入的是5G核心网 区别&#xff1a;同一时间…

许战海战略文库|橋頭品牌突破区域局限打透全国市场的4个建议

自宣统元年(公元1908年)起&#xff0c;重庆南岸区海棠溪古石桥边诞生了一家传奇火锅店——桥头火锅。凭借深厚的文化底蕴和独特的风味&#xff0c;历经百年沉淀桥头火锅已成为南岸区乃至中华餐饮文化中的璀璨明珠。 桥头火锅不仅荣获了“中华老字号”和“中国名菜”两项殊荣&a…

Google云计算原理与应用(四)

目录 七、海量数据的交互式分析工具Dremel&#xff08;一&#xff09;产生背景&#xff08;二&#xff09;数据模型&#xff08;三&#xff09;嵌套式的列存储&#xff08;四&#xff09;查询语言与执行&#xff08;五&#xff09;性能分析&#xff08;六&#xff09;小结 八、…

【网络原理】HTTP 请求 (Request)详解

文章目录 &#x1f38d;请求格式&#x1f384;认识URL&#x1f338;query string&#x1f338;关于 URL encode &#x1f340;认识 “方法” (method)&#x1f338;GET方法&#x1f338;POST 方法&#x1f338;GET 和 POST 的区别 &#x1f332;认识请求 “报头” (header)&…

管理能力学习笔记一:角色转身

管理能力学习是为了解决角色转身后面临的更多更复杂的的问题。初晋管理层&#xff0c;需要转变工作习惯&#xff0c;学会分配时间。 角色转身 建立“授权”意识 通过匹配工作内容与下属员工能力&#xff0c;分配工作&#xff0c;避免陷入下属能力不足 -> 不愿授权 -> 下…

MS08-067 漏洞利用与安全加固

文章目录 环境说明1 MS08_067 简介2 MS08_067 复现过程3 MS08_067 安全加固 环境说明 渗透机操作系统&#xff1a;2024.1漏洞复现操作系统: Windows XP Professional with Service Pack 2- VL (English)安全加固复现操作系统&#xff1a;Windows XP Professional with Service …

Docusaurus和HelpLook:谁更适合做知识库管理

在当今信息化时代&#xff0c;企业建立和维护一个好用、高效、能持续更新的知识库&#xff0c;对内部沟通、团队合作和客户服务都很重要。Docusaurus和HelpLook都是很好的知识库管理工具&#xff0c;但它们的功能和优势各有不同。跟着我一起深入了解两个工具之间的优劣&#xf…

Web框架开发-开发图书管理页面

一、项目需求1.列出图书列表、出版社列表、作者列表2.点击作者,会列出其出版的图书列表3.点击出版社,会列出旗下图书列表4.可以创建、修改、删除 图书、作者、出版社二、项目实现 bookms |-- app01 # 项目应用 | |-- views.py # 视图层代码 | |-- admin.py | |-- app…

launchctl及其配置、使用、示例

文章目录 launchctl 是什么Unix / Linux类似的工具有什么哪个更常用配置使用常用子命令示例加载一个 launch agent:卸载一个 launch daemon:列出所有已加载的服务:启动一个服务:停止一个服务:禁用一个服务:启用一个服务: 附com.example.myagent.plist内容有趣的例子参考 launch…

HuggingChat

HuggingChat 文章目录 HuggingChat一、关于 HuggingChat二、ChatLogin进入对话首页对话 三、Assistants1、使用2、创建新的助理 一、关于 HuggingChat HuggingFace 发布的 Chat 工具 网站&#xff1a;https://huggingface.co/chat/chat-ui space : https://huggingface.co/sp…