RabbitMQ入门概念

news2024/11/24 3:20:52

目录

一、RabbitMQ入门

1.1 rabbitmq是啥？

1.2 应用场景

1.3 AMQP协议与RabbitMQ工作流程

1.4 Docker安装部署RabbitMQ

二、SpringBoot连接MQ配置

2.1 示例1

 2.1 示例2 —— 发送实体

一、RabbitMQ入门

1.1 rabbitmq是啥？

MQ（Message queue 释义）：消息队列，本质上就是一个队列。

  • 服务之间最常见的通信方式是直接调用彼此来通信,消息从一端发出后立即就可以达到另一端,称为即时消息通讯(同步通信)
  • 消息从某一端发出后,首先进入一个容器进行临时存储,当达到某种条件后,再由这个容器发送给另一端,称为延迟消息通讯(异步通信)

        而消息队列(Message Queue)是在消息的传输过程中保存消息的容器。在消息队列中，通常有生产者和消费者两个角色。生产者只负责发送数据到消息队列，谁从消息队列中取出数据处理，他不管。消费者只负责从消息队列中取出数据处理，他不管这是谁发送的数据。

1.2 应用场景

        RabbitMQ是一个消息代理 - 一个消息系统的媒介。它可以为你的应用提供一个通用的消息发送和接收平台，并且保证消息在传输过程中的安全。

ribbitmq主要解决异步处理、应用解耦、流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构

  • 异步处理

如图所示：当一个用户购买了商品，订单开始发送发货通知——>刷新商品推荐（重新计算用户的喜好）——>增加会员积分，这些时间加一起就要150ms。而使用的RabbitMQ之后，将订单的求情放到rabbitmq容器中，不需要等待其他服务处理完再返回结果，让他们自己去rabbitmq排队处理。

  • 解耦 

如图所示：假设有系统B、C、D都需要系统A的数据，于是系统A调用三个方法发送数据到B、C、D。这时，系统D不需要了，那就需要在系统A把相关的代码删掉。假设这时有个新的系统E需要数据，这时系统A又要增加调用系统E的代码。为了降低这种强耦合，就可以使用MQ，系统A只需要把数据发送到MQ，其他系统如果需要数据，则从MQ中获取即可。 

  • 削峰 

应用场景：秒杀活动，一般会因为流量过大，导致流量暴增，应用挂掉。为解决这个问题，一般需要在应用前端加入消息队列

  1. 可以控制活动的人数
  2. 可以缓解短时间内高流量压垮应用 

如图所示：这其实是MQ一个很重要的应用。假设用户在某一段时间请求数暴增，有5000个请求发送过来，系统这时就会发送5000条SQL进入MySQL进行执行，MySQL对于如此庞大的请求当然处理不过来，MySQL就会崩溃，导致系统瘫痪。如果使用MQ，系统不再是直接发送SQL到数据库，而是把数据发送到MQ，MQ短时间积压数据，然后由消费者每次拉取2000条进行处理，防止在请求峰值时期大量的请求直接发送到MySQL导致系统崩溃。

1.3 AMQP协议与RabbitMQ工作流程

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

像RabbitMQ这样的消息队列实现是基于AMQP协议的，如果先了解一条消息从投递到消息队列到被消费者消费的生命周期，再来深入了解RabbitMQ的使用那就很easy。

  • 消息（Message）：即客户端与消息中间件传送的数据。
  • 生产者（Publisher）：消息发起人。
  • 消费者（Consumer）：消息消费者。
  • 交换机（Exchange）：接收消息，并将消息路由转发给消息队列。
  • 虚拟主机（Virtual Host）：进行逻辑隔离，一个虚拟主机可以创建若干个交换机和队列。
  • 绑定（Binding）：交换机和队列之间的虚拟连接。
  • 路由键（Routing Key）：路由规则，虚拟机可以用来确定如何路由一个特定的消息。
  • 队列（Queue）：存储即将被消费者消费掉的消息。
  • 中间件（Broker ）：实现AMQP实体服务，比如常见的RabbitMQ、Azure Service Bus等。
  • 信道（Channel）：网络信道，是建立在Connection连接之上的一种轻量级的连接，可以创建多个信道。
  • 连接（Connection）：一个网络连接，比如TCP/IP连接。AMQP连接通常是长连接，当一个应用不再需要连接到AMQP代理的时候，需要释放掉 AMQP 连接，而不是直接将TCP连接关闭。

工作过程：

1.生产者发布消息，经由交换机。
2.交换机根据路由规则将收到的消息分发给与该交换机绑定的队列。
3.最后消息中间件会将消息投递给订阅了此队列的消费者，或者消费者按照需求自行获取。

4.消费者在成功处理消息后向 RabbitMQ 发送确认（ACK）。这告诉 RabbitMQ 可以安全地从队列中删除该消息。如果消费者在处理消息时发生错误，RabbitMQ 可以将消息重新分发给其他消费者。

可靠性与持久性：RabbitMQ 提供了消息的持久性选项，允许将消息和队列标记为持久的。这确保即使 RabbitMQ 服务器重启，消息和队列也不会丢失。

技术选型：

1.4 Docker安装部署RabbitMQ

  •  拉取镜像
docker pull rabbitmq:management

注意获取镜像的时候要获取management版本的，不要获取last版本的，management版本的才带有管理界面。

  •  创建容器

1、创建宿主机目录

防火墙开放端口：

firewall-cmd --zone=public --add-port=5672（15672）/tcp --permanent

docker run -itd \
--name my-rabbitmq \
-p 5672:5672 -p 15672:15672 \
-v /home/rabbitmq:/var/lib/rabbitmq \
--hostname my-rabbitmq-host \
-e RABBITMQ_DEFAULT_VHOST=my_vhost \
-e RABBITMQ_DEFAULT_USER=ycxw \
-e RABBITMQ_DEFAULT_PASS=123 \
--restart=always \
rabbitmq:management

--hostname：主机名(RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据,默认为主机名)

-e：指定环境变量:

  • RABBITMQ_DEFAULT_VHOST：默认虚拟机名
  • RABBITMQ_DEFAULT_USER：默认的用户名
  • RABBITMQ_DEFAULT_PASS：默认用户名的密码
  • 访问RabbitMQ管理平台

 登录进入之后就可看到一些用户数据、所管理的虚拟主机、队列等等。。。这里不做详细讲解，简单了解请看目录：1.3。

二、SpringBoot连接MQ配置

2.1 示例1

1、创建项目：publisher 生成者 ， consumer 消费者

rabbitmq需要导入amqp依赖

        <!--amqp协议-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

 2、rabbitmq连接配置

生产者端口：8888        消费者端口：6666

注意！！！：

        需等生产者创建队列后并发送过一次信息被rabbitmq接受，消费者才能启动项目，不然会报错找不到连接的队列名

server:
  port: 8888
spring:
  rabbitmq:
    #虚拟机地址
    host: 192.168.83.129
    port: 5672
    #rabbitmq注册用户与密码
    username: ycxw
    password: 123
    virtual-host: my_vhost
  • 生产者（publisher） 

3、创建Rabbit配置类RabbitConfig，配置类主要用来配置队列、交换器、路由等高级信息

package com.ycxw.publisher.demos;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@SuppressWarnings("all")
public class RabbitConfig {
    @Bean
    public Queue firstQueue() {
        return new Queue("firstQueue");
    }
}

4、创建消息产生者类

package com.ycxw.publisher.demos;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class Sender {
    @Autowired
    private AmqpTemplate rabbitTemplate;

    @RequestMapping("/send1")
    public String sendFirst() {
        /*向消息队列发送消息 converAndSend(队列名，发送的信息)*/
        rabbitTemplate.convertAndSend("firstQueue", "Hello World");
        return "🫶";
    }
}

  • 消费者

5、编写接受队列的消息方法

package com.ycxw.consumer.demos;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@SuppressWarnings("all")
@Slf4j
@RabbitListener(queues = "firstQueue") //监听消息队列
public class Receiver {

    //处理接受的信息
    @RabbitHandler
    public void process(String msg) {
        log.warn("接收到:" + msg);
    }
}

 6、测试

生产者发起请求：

rabbitmq管理界面查看数据：

消费者接受信息：

 2.1 示例2 —— 发送实体

注意！！！：

  1. 处理不同请求许再创建一个队列
  2. 实体需进行序列化才可发送
  3. 发送实体，需要两个模块的实体必须同名同包下         

1、创建实体类

package com.ycxw.publisher.demos;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

//实现spring自带序列化接口
@SuppressWarnings("all")
@AllArgsConstructor
@NoArgsConstructor
@Data
public class User implements Serializable {
    private String username;
    private String userpwd;
}

 

 2、创建队列（生产者）

3、 编写发送信息方法

注入ObjectMapper类将实体装换成json格式的数据进行发送 

 4、接受信息（消费者）

package com.ycxw.consumer.demos;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
@SuppressWarnings("all")
@Slf4j
@RabbitListener(queues = "secondQueue") //监听消息队列
public class Receiver2 {

    @Autowired
    private ObjectMapper objectMapper;

    //处理接受的信息
    @RabbitHandler
    public void process(String json) throws JsonProcessingException {
        //将接受的json数据转换成实体
        User ycxw = objectMapper.readValue(json, User.class);
        log.warn("接收到:" + ycxw);
    }
}

5、测试

消费者接受的信息

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

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

相关文章

Hutool导入导出用法

Hutool导入导出用法

整理了下Hutool导入导出的简单使用。 导入maven或jar包&#xff08;注意这里导入的poi只是为了优化样式&#xff09; <!-- https://mvnrepository.com/artifact/cn.hutool/hutool-all --> <dependency><groupId>cn.hutool</groupId><artifactId&g…
阅读更多...
Kube-Promethus配置Nacos监控

Kube-Promethus配置Nacos监控

Kube-Promethus配置Nacos监控 前置&#xff1a;Kube-Promethus安装监控k8s集群 一.判断Nacos开启监控配置 首先通过集群内部任一节点访问Nacos的这个地址<NacosIP>:端口号/nacos/actuator/prometheus&#xff0c;查看是否能够获取监控数据。 如果没有数据则修改Nacos集群…
阅读更多...
qt中使用mysql 数据库

qt中使用mysql 数据库

QT 版本介绍 虽然版本是这个&#xff0c;但是工作目录确是&#xff1a; 下面陈述安装步骤 第一步&#xff1a; 就是安装MYSQL 数据库&#xff0c;在此不再赘述了&#xff0c;很多博主已经上传了。 第二步&#xff1a; 就是拷贝QT 对应mysql 的版本驱动到 QT 的编译器文件中…
阅读更多...
基于人工智能的质量保证(QA)流程

基于人工智能的质量保证(QA)流程

AI模型质量保证需知 推出准确、可靠、公正的人工智能&#xff08;AI&#xff09;模型无疑是一项挑战。设法成功实施AI计划的企业很可能意识到&#xff0c;AI质量保证&#xff08;QA&#xff09;流程与传统QA流程迥然不同。 质量保证对于AI模型的准确性至关重要&#xff0c;不…
阅读更多...
SD卡写保护无法格式化怎么办？

SD卡写保护无法格式化怎么办？

一般来说&#xff0c;写保护&#xff08;也称为只读&#xff09;是数据存储设备防止写入新数据或修改旧信息的能力。换句话说&#xff0c;您可以读取存储在磁盘上的信息&#xff0c;但是却不能删除、更改或复制它们&#xff0c;因为访问会被拒绝。那么SD卡有写保护怎么格式化呢…
阅读更多...
【图像拼接 精读】Parallax-Tolerant Unsupervised Deep Image Stitching

【图像拼接 精读】Parallax-Tolerant Unsupervised Deep Image Stitching

【精读】Parallax-Tolerant Unsupervised Deep Image Stitching 在这篇论文中&#xff0c;"warp"&#xff08;变形&#xff09;和"composition"&#xff08;组合&#xff09;是两个关键的概念。"Warp"指的是图像变形的过程&#xff0c;用于调整…
阅读更多...
【乳腺肿瘤诊断分类及预测】基于LVQNN学习向量量化神经网络

【乳腺肿瘤诊断分类及预测】基于LVQNN学习向量量化神经网络

课题名称&#xff1a;基于LVQ神经网络的乳腺肿瘤诊断&#xff08;类型分类&#xff09; 版本日期&#xff1a;2023-03-10 运行方式: 直接运行0501_LVQ0501.m 文件即可 代码获取方式&#xff1a;私信博主或QQ&#xff1a;491052175 模型描述&#xff1a; 威斯康辛大学医学院…
阅读更多...
NetCore实现输入用户名和密码后访问Swagger页面

NetCore实现输入用户名和密码后访问Swagger页面

1 原理说明 在后端编程时&#xff0c;通常使用swagger文档来呈现接口文档。为了接口的安全性&#xff0c;可通过输入用户名和密码的方式来进行验证。 这里用到了Basic认证方式。原理图如下&#xff1a; 步骤 1&#xff1a; 当请求的资源需要 B A S I C \textcolor{red}{BA…
阅读更多...
力扣238. 除自身以外数组的乘积（前后缀和）

力扣238. 除自身以外数组的乘积（前后缀和）

Problem: 238. 除自身以外数组的乘积 文章目录 题目描述思路复杂度Code 题目描述 思路 思路1&#xff1a; 1.先求取数组的包括当前下标值得前后缀乘积&#xff08;利用两个数组记录下来分别为leftProduct和rightProduct&#xff09; 2.当求取一个下标为i的数组中的元素&#x…
阅读更多...
正则表达式补充以及sed

正则表达式补充以及sed

正则表达式&#xff1a; 下划线算 在单词里面 解释一下过程&#xff1a; 在第二行hello world当中&#xff0c;hello中的h 与后面第一个h相匹配&#xff0c;所以hello中的ello可以和abcde匹配 在world中&#xff0c;w先匹配h匹配不上&#xff0c;则在看0&#xff0c;r&#…
阅读更多...
【Java 数据结构】LinkedList与链表

【Java 数据结构】LinkedList与链表

LinkedList与链表 1. ArrayList的缺陷2. 链表2.1 链表的概念及结构2.2 链表的实现 3. LinkedList的模拟实现4.LinkedList的使用4.1 什么是LinkedList4.2LinkedList的使用 5. ArrayList和LinkedList的区别 1. ArrayList的缺陷 上节课已经熟悉了ArrayList的使用&#xff0c;并且…
阅读更多...
多头 eRCD（Multi-Headed eRCD）

多头 eRCD（Multi-Headed eRCD）

&#x1f525;点击查看精选 CXL 系列文章&#x1f525; &#x1f525;点击进入【芯片设计验证】社区&#xff0c;查看更多精彩内容&#x1f525; &#x1f4e2; 声明&#xff1a; &#x1f96d; 作者主页&#xff1a;【MangoPapa的CSDN主页】。⚠️ 本文首发于CSDN&#xff0c…
阅读更多...
在哪里申请SSL证书

在哪里申请SSL证书

其实只是单纯的申请SSL证书来说&#xff0c;渠道还是比较多的。只是需要格外注意在申请SSL证书的过程中&#xff0c;对于自身需求的认知。 首先最重要的是&#xff0c;该证书是否可信。就目前而言&#xff0c;非可信根的证书是无法与主流浏览器兼容的&#xff0c;会时常发生风险…
阅读更多...
503 Service Temporarily Unavailable nginx 原因和解决办法

503 Service Temporarily Unavailable nginx 原因和解决办法

前言 HTTP 503 Service Temporarily Unavailable 错误通常表示服务器无法处理请求&#xff0c;可能是由于服务器过载、维护或其他临时性问题导致的。在 Nginx 中&#xff0c;这种错误通常与后端服务的可用性问题相关。以下是可能的原因和解决办法&#xff1a; 正文…
阅读更多...
RTC实时时钟之读取时间

RTC实时时钟之读取时间

1. RTC 基本介绍 RTC(Real Time Clock) 即实时时钟&#xff0c;它是一个可以为系统提供精确的时间基准的元器件&#xff0c;RTC一般采用精度较高的晶振作为时钟源&#xff0c;有些RTC为了在主电源掉电时还可以工作&#xff0c;需要外加电池供电 2. RTC 控制器 2.1 RTC的特点是:…
阅读更多...
VxTerm:SSH工具中的中文显示和乱码时的相关信息和一些基本的知识

VxTerm:SSH工具中的中文显示和乱码时的相关信息和一些基本的知识

当我们写的程序含有控制台(Console)输出时&#xff0c;如果输入内容包含中文时&#xff0c;我们一般需要知道下面的信息&#xff0c;才能正确的搞清楚怎么处理中文显示的问题&#xff1a; 1、实际程序或文件中的实际编码&#xff1a; Linux下的应用程序和文本文件&#xff0c;…
阅读更多...
mkcert的安装和使用，5分学会在本地开启localhost的https访问方式

mkcert的安装和使用，5分学会在本地开启localhost的https访问方式

mkcert官方仓库地址&#xff1a;https://github.com/FiloSottile/mkcert#installation mkcert 是一个简单的工具&#xff0c;用于制作本地信任的开发证书。它不需要配置。 简化我们在本地搭建 https 环境的复杂性&#xff0c;无需操作繁杂的 openssl 实现自签证书了&#xff…
阅读更多...
【开源操作系统】上海道宁为您带来稳定、安全、开源和易用的操作系统——Ubuntu，为您的数字化生活保驾护航

【开源操作系统】上海道宁为您带来稳定、安全、开源和易用的操作系统——Ubuntu，为您的数字化生活保驾护航

Ubuntu是 源于非洲的一种传统价值观 意为“人性、关爱和共享” 这种价值观在 开源、稳定、安全、易用的 Ubuntu操作系统中 得到了完美的体现 除此之外&#xff0c;Ubuntu还具有 强大的安全性 它自带了诸多安全功能 如防火墙、加密文件系统等 可以有效地保护用户的隐私…
阅读更多...
CRF条件随机场学习记录

CRF条件随机场学习记录

阅读建议 仔细阅读书[1]对应的序列标注章节&#xff0c;理解该方法面向的问题以及相关背景&#xff0c;然后理解基础的概念。 引言 威胁情报挖掘的相关论文中&#xff0c;均涉及到两部分任务&#xff1a;命名实体识别&#xff08;Named Entity Recognition&#xff0c;NER&a…
阅读更多...
【PyCharm教程】PyCharm 安装、卸载和升级包

【PyCharm教程】PyCharm 安装、卸载和升级包

PyCharm 为特定的 Python 解释器提供了安装、卸载和升级 Python 包的方法。默认情况下&#xff0c;PyCharm 使用 pip 来管理项目包。对于 Conda 环境&#xff0c;您可以使用conda 包管理器。 在 PyCharm 中&#xff0c;您可以在Python 包工具窗口和 Python 解释器Settings/Pre…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023