RebbitMQ 消息队列(简单使用)

news2025/7/15 3:01:30

消息队列介绍

MQ的优势
1.业务解耦:不同系统消费信息互不关联,灵活增减系统数量,修改某个系统其他系统也不影响
2.异步提速:不同系统之间可同时响应,提升并发量
3.削峰填谷:处理消息高峰期,均摊到后面处理,保护系统的稳定性
MQ的不足
1.系统可用性降低:系统引入的外部依赖越多,系统稳定性越差
2.系统复杂度提高:怎么保证消息没有被重复消费,消息丢失,消息传递的顺序性等问题
3.一致性问题:MQ如何解决不同系统处理的一致性问题

MQ需要满足什么条件?
1.生产者不需要获取反馈
2.容器短暂的不一致性
3.能够体现MQ的优势在系统中,获得解耦,提速,削峰这些方面的收益

AMQP是一个消息队列协议,是应用层协议的一个开放标准,面向消息的中间件设计,基于此协议的客户端和消息中间件可传递消息
RabbitMQ由Erlang语言开发
在这里插入图片描述
rabbitmq相关概念
Broker:接受和分发消息的应用,rabbitmq server就是message broker
virtual host:用户空间,每个用户可在自己的vhost创建exchange/queue等
Connection:publisher/consumer和broker之间的tcp连接
channel:作为轻量级的connection极大减少操作系统建立tcp connection的开销
exchange:message到达broker的第一站,根据分发规则,查询表中的routing key,分发消息到queue中,常用类型有direct(point-to-point),topic(publish-subscribe)and fanout(multicast 多路传播)
queue:消息最终被送到这里等待被consumer取走
binding:exchange和queue之间的虚拟连接,binding中可以包含routing key,binding信息被保存到exchange中查询表中,用于message的分发依据

rabbitmq提供的六种工作模式:简单模式,work queues,publish/subscribe发布订阅模式,routing路由模式,topics主题模式,rpc远程调用模式(不常用)
jms:java消息服务应用程序接口,是一个Java平台中关于消息中间件的api

rabbitmq安装

安装亲测有效

rabbitmq简单实现

简单实现 基本实现

rabbitmq工作模式

工作模式就是不同的消息分发方式
1.hello world 模式就是生产消费者模式
在这里插入图片描述

2.work queues工作队列模式
在这里插入图片描述

多个消费端共同消费一个队列中的消息,常用于对于任务过重或任务过多情况使用工作队列可以提高任务处理的速度,各个消费端之间是竞争关系(存在负载均衡和公平模式)
3.pub/sub订阅模式
在这里插入图片描述
在订阅模式中,多了一个exchange交换机的角色
p:生产者,c:消费者,queue:消息队列,exchange:交换机(X)
交换机负责将某个消息交给某个队列或者某些队列,这取决于exchange的类型
fanout:广播,direct:定向,topic:通配符
exchange只负责转发消息,不具备存储消息的能力,因此没有任何队列与exchange绑定或者符合路由规则的队列时时,消息就会丢失
4.routing路由工作模式
在这里插入图片描述

队列与交换机的绑定,不能是任意绑定了,而是要指定一个routing(路由key)
消息发送方在exchange发送消息时,必须指定消息的routingkey
exchange不再是把消息交给每一个绑定的队列,而是根据消息的routingkey进行判断,只有队列的routingkey与消息的routingkey完全一致时才会收到消息
5.topics通配符模式
在这里插入图片描述

  • 表示一个单词,#表示一个或零个单词

springboot整合rabbitmq

参考步骤亲测有效

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

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

相关文章

《图机器学习》-Graph Neural Network

前言 回顾之前的Node Embedding: 将图中的节点嵌入到d维空间,并确保图中相似的节点能够嵌在一起。 即学习一个编码器ENCENCENC确保图的节点嵌入到embedding space依然能够描述原空间节点之间的相似性。 在Node Embedding中,我们需要设计&…

DEXTUpload .NET增强的上传速度和可靠性

DEXTUpload .NET增强的上传速度和可靠性 DEXTUpload.NET Pro托管在Windows操作系统上的Internet Information Server(IIS)上,服务器端组件基于HTTP协议,支持从web浏览器到web服务器的文件上载。它也可以在ASP.NET服务器应用程序平台开发的任何网站上使用…

记一次攻防演练溯源实例

缘起 在今年的攻防期间,通过安全设备告警分析,需要对某个源攻击IP进行溯源反制,并且需要记录整个溯源过程和提交溯源报告。 开展溯源 研判 在溯源之前,首先应该判断是否真的存在攻击行为,攻击的特征,攻…

Linux学习(7.5)linux目录配置与重点回顾

鸟哥的 Linux 私房菜 -- Linux 的文件权限与目录配置 (vbird.org) 怎么记啊,直接点进去看吧 目录 Linux目录配置的依据--FHS 绝对路径与相对路径 重点回顾 以下内容转载自鸟哥的Linux私房菜 Linux目录配置的依据--FHS 是希望让使用者可以了解到已安装软件通常…

ARouter::Compiler The user has configuration the module name, it was

学习组件化使用的是阿里的ARouter,我是照着案例敲的,在编译的时候报了这么一个错。 我查了好多资料,大部分都是说build.gradle 配置出现了问题,比如没有配置 javaCompileOptions {annotationProcessorOptions {arguments [AROUTE…

shader(光栅化)

1.定义将模型经过mvp得到的标准立方体映射到屏幕。屏幕是像素数组组成,像素是一个颜色均匀的小方块。2.屏幕变换矩阵3.直接采样(锯齿严重)4.先模糊再采样(抗锯齿有好转)5.傅里叶变换6.高通滤波(图像边界&am…

robot remote server用这个server去远程获取ip

server端配置: 1、安装python环境 2、下载robot remote server 下载地址:https://pypi.python.org/pypi/robotremoteserver/(不要用pip下载,把robotremoteserver.py文件下载下来) 3、首先创建一个目录E:\rfremote\ &a…

canvas初学2

一、碰撞检测 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta http-equiv"X-UA-Compatible" content"IEedge"><meta name"viewport" content"widthdevice-width,…

Linux下java服务占用cpu过高如何处理

Linux下java服务占用cpu过高如何处理 top命令查看进程信息 top按下shiftp,按cpu使用率排行,可见进程1932占用最高,并且是一个java服务 使用jps命令确认java服务 [rootVM-16-16-centos ~]# jps 1011 Jps 9462 yuan_back-0.0.1-SNAPSHOT.jar 1932 spigot-1.18.jar查找异常进程中…

在windows11上安装openssh服务端并修改端口号

在windows11上安装openssh服务端并修改端口号 目录1.软件下载地址2.修改端口3.启动ssh原文链接&#xff1a;https://blog.csdn.net/qq_62129885/article/details/1268467751.软件下载地址 Release v9.2.0.0p1-Beta PowerShell/Win32-OpenSSH (github.com) https://github.co…

【BBuf的CUDA笔记】八,对比学习OneFlow 和 FasterTransformer 的 Softmax Cuda实现

0x1. OneFlow/FasterTransformer SoftMax CUDA Kernel 实现学习 这篇文章主要学习了oneflow的softmax kernel实现以及Faster Transformer softmax kernel的实现&#xff0c;并以个人的角度分别解析了原理和代码实现&#xff0c;最后对性能做一个对比方便大家直观的感受到onefl…

光伏行业规模“狂飙”至87.41GW,机器视觉检测成保量提质“王牌”?

在产业政策引导和市场需求驱动的双重作用下&#xff0c;我国光伏产业已成为具备国际竞争优势的产业&#xff0c;在制造规模、技术水平和市场份额等方面均位居全球前列。近日&#xff0c;国家能源局公布了2022年光伏新增装机规模&#xff1a;87.41GW&#xff0c;增长率59.27%。行…

一文带你了解MySQL的Server层和引擎层是如何交互的?

对于很多开发小伙伴来说&#xff0c;每天写SQL是必不可少的一项工作。 那不知道大家有没有深入了解过&#xff0c;当我们的一条SQL命令被执行时&#xff0c;MySQL是如何把数据从硬盘/内存中查出来并展示到用户面前的呢&#xff1f; 其实&#xff0c;MySQL也没有大家想象的那么…

DateTimeParseException

前端请求为字符串的时间格式2023-02-16 19:19:51&#xff0c;服务端用LocalDateTime类型接收时报解析异常java.time.format.DateTimeParseException: Text 2023-02-16 19:19:51 could not be parsed at index 10方法一&#xff1a;JsonFormat(shape Shape.STRING, pattern &q…

第四章.神经网络—BP神经网络

第四章.神经网络 4.3 BP神经网络 BP神经网络(误差反向传播算法)是整个人工神经网络体系中的精华&#xff0c;广泛应用于分类识别&#xff0c;逼近&#xff0c;回归&#xff0c;压缩等领域&#xff0c;在实际应用中&#xff0c;大约80%的神经网络模型都采用BP网络或BP网络的变化…

详解Ubuntu1804安装Anaconda(附网盘极速下载链接)

2022版的anaconda下载如下 百度网盘链接链接&#xff1a;https://pan.baidu.com/s/1RZICFpR_MYVxOxHzEbStRg 提取码&#xff1a;z864 下面是具体的安装过程 1、进入下载文件存放的位置打开终端运行.sh文件&#xff1a;&#xff08;我本人的下载位置就在“下载”里面&#x…

【ROS学习笔记3】ROS的架构

【ROS学习笔记3】ROS的架构 文章目录【ROS学习笔记3】ROS的架构零、前言一、ROS系统文件二、ROS文件系统相关命令三、ROS计算图四、Reference写在前面&#xff0c;本系列笔记参考的是AutoLabor的教程&#xff0c;具体项目地址在 这里 零、前言 从系统架构方面来看&#xff0c;…

jwt,accesstoken、refresh token详解

jwt&#xff0c;accesstoken、refresh token详解 JWT(json web token) 概念 JWT定义了一种紧凑的&#xff0c;自包含的形式&#xff0c;被用作在网络中安全的传输信息 格式 例如&#xff1a;xxxx.yyyyyyy.zzz 根据.分割&#xff0c;可以得到三部分&#xff0c;header&#x…

git创建自模块submodule

一、git仓库创建并拉取主项目 1、创建project项目和submodule项目 2、拉取主项目project1和project2 二、主模块增加子模块 1、进入主项目project1并初始化子模块 A、初始化 git submodule add http://ip:port/path/submodule.git aa B、 查看状态 git status C、添加到主项…

Leetcode.1801 积压订单中的订单总数

题目链接 Leetcode.1801 积压订单中的订单总数 Rating &#xff1a; 1711 题目描述 给你一个二维整数数组 orders&#xff0c;其中每个 orders[i] [pricei, amounti, orderTypei]表示有 amounti笔类型为 orderTypei、价格为 pricei的订单。 订单类型 orderTypei 可以分为两种…