RabbitMQ入门概念

目录

一、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.129port: 5672#rabbitmq注册用户与密码username: ycxwpassword: 123virtual-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 {@Beanpublic 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 {@Autowiredprivate 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 {//处理接受的信息@RabbitHandlerpublic 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 {@Autowiredprivate ObjectMapper objectMapper;//处理接受的信息@RabbitHandlerpublic void process(String json) throws JsonProcessingException {//将接受的json数据转换成实体User ycxw = objectMapper.readValue(json, User.class);log.warn("接收到:" + ycxw);}
}

5、测试

消费者接受的信息

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

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

相关文章

02-opencv简单实例效果和基本介绍-上

02-opencv简单实例效果和基本介绍-上

机器视觉概述 机器视觉是人工智能正在快速发展的一个分支。简单说来，机器视觉就是用机器代替人眼来做测量和判断。机器视觉系统是通过机器视觉产品(即图像摄取装置，分CMOS和CCD两种)将被摄取目标转换成图像信号，传送给专用的图像处理系统，得到被摄目标的形态信息，根据像素…
阅读更多...
Win10+wsl2+mmdetection3d(GPU)

Win10+wsl2+mmdetection3d(GPU)

2024部署mmdetection3d在win10wsl2 实现过程安装wsl2安装docker与VSCode插件连接其他问题 实现过程 安装WSL2 踩坑点&#xff1a; 基于发行版安装&#xff0c;无法更新wsl1&#xff0c;查证了当前的wi10的驱动是满足要求的&#xff0c;但是无法更新。所以一定要先去更新驱动&…
阅读更多...
iZotope RX 10.4.2 mac激活版 音频修复和增强工具

iZotope RX 10.4.2 mac激活版 音频修复和增强工具

iZotope RX 10 for Mac是一款专业的音频修复软件&#xff0c;旨在提供强大、精确的工具&#xff0c;让用户能够清晰、纯净地处理音频。以下是其主要功能和特点&#xff1a; 软件下载&#xff1a;iZotope RX 10.4.2 mac激活版下载 强大的降噪功能&#xff1a;iZotope RX 10采用了…
阅读更多...
SRC实战 | 信息泄露挖掘

SRC实战 | 信息泄露挖掘

本文由掌控安全学院 - 叴龙 投稿 1. 信息搜集 首先老语法先搜集一波&#xff0c;毕竟没有钓鱼和sg的能力&#xff0c;只能找注册站去挖挖了。 web.title”XX大学”&&web.body”忘记密码”&&web.body”注册” 2. 漏洞挖掘 这里找到一个可以注册网站接口&…
阅读更多...
Python之PyMySQL模块

Python之PyMySQL模块

Python之PyMySQL模块 目录 Python之PyMySQL模块安装连接数据库connect拓展 获取游标操作数据查找添加更新 安装 pip install pymysql连接数据库 使用connect函数创建连接对象 此对象提供数据库的关闭、事务提交、事务回滚等操作 示例&#xff1a; import pymysql# 以下为必…
阅读更多...
java大文件分片上传

java大文件分片上传

1.效果图 2.前端html <!DOCTYPE html> <html> <head></head> <body> <form><input type"file" id"fileInput" multiple><button type"button" onclick"upload()" >大文件分片上传&l…
阅读更多...
【JAVA】Long类型返回到前端，精度丢失

【JAVA】Long类型返回到前端，精度丢失

一. 问题阐述 20位long类型的数字&#xff0c;从后端接口返回到前端后【四舍五入】 MYSQL端 &#xff08;1&#xff09;bigint (20) &#xff08;2&#xff09;具体某一条数据 JAVA端 &#xff08;1&#xff09;实体类 &#xff08;2&#xff09;服务类 &#xff08;3&…
阅读更多...
【Vue.js设计与实现】第一篇：框架设计概览-阅读笔记（完结）

【Vue.js设计与实现】第一篇：框架设计概览-阅读笔记（完结）

从高层设计的角度去探讨框架需要关注的问题。 参考&#xff1a;速读《Vue.js 设计与实现》 - 掘金 (juejin.cn) 系列目录&#xff1a; 标题博客第一篇&#xff1a;框架设计概览【Vue.js设计与实现】第一篇&#xff1a;框架设计概览-阅读笔记第二篇&#xff1a;响应系统【Vue.…
阅读更多...
注册亚马逊店铺用动态IP可以吗？

注册亚马逊店铺用动态IP可以吗？

注册亚马逊店铺可以用动态IP&#xff0c;只要是独立且干净的网线就没问题&#xff0c;亚马逊规则要求一个IP地址只能出现一个亚马逊店铺&#xff0c;若使用不当会导致关联账户。 固定ip可以给我们的账户带来更多的安全&#xff0c;要知道关联问题是亚马逊上的一个大问题&#…
阅读更多...
Leetcode—1265. 逆序打印不可变链表【中等】Plus

Leetcode—1265. 逆序打印不可变链表【中等】Plus

2024每日刷题&#xff08;一零三&#xff09; Leetcode—1265. 逆序打印不可变链表 实现代码 /*** // This is the ImmutableListNodes API interface.* // You should not implement it, or speculate about its implementation.* class ImmutableListNode {* public:* v…
阅读更多...
KubeSphere 核心实战之四【在kubesphere平台上部署Ruoyi-cloud项目】（实操篇 4/4）

KubeSphere 核心实战之四【在kubesphere平台上部署Ruoyi-cloud项目】（实操篇 4/4）

**《KubeSphere 核心实战系列》** KubeSphere 核心实战之一&#xff08;实操篇 1/4&#xff09; KubeSphere 核心实战之二&#xff08;实操篇 2/4&#xff09; KubeSphere 核心实战之三&#xff08;实操篇 3/4&#xff09; KubeSphere 核心实战之四&#xff08;实操篇 4/4&…
阅读更多...
.net core 6 集成 elasticsearch 并 使用分词器

.net core 6 集成 elasticsearch 并 使用分词器

1、nuget包安装NEST、安装elasticsearch、kibana、ik分词器、拼音分词器 2、创建操作对象 //索引库 static string indexName "testparticper"; //es 操作对象 ElasticClient elasticClient new ElasticClient(new ConnectionSettings(new Uri("http://192.…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023