Message queue 消息队列--RabbitMQ 【基础入门】

                            🎉🎉欢迎来到我的CSDN主页！🎉🎉

                    🏅我是平顶山大师，一个在CSDN分享笔记的博主。📚📚

    🌟推荐给大家我的博客专栏《Message queue 消息队列--RabbitMQ 【基础入门】》。🎯🎯

                    🎁如果感觉还不错的话请给我关注加三连吧！🎁🎁

目录

一，Message queue介绍：

二，RabbitMQ介绍：

2.1什么是RabbitMQ？

2.2RabbitMQ组成？

2.3RabbitMQ工作原理

2.4RabbitMQ在企业项目中使用场景：

2.5Docker安装部署RabbitMQ

2.6创建springboot项目嵌套RabbitMQ

传递字符串类型

传递实体类型

访问测试：

一，Message queue介绍：

1.1使用消息队列的优点：

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

如下：如果我们不使用MQ的话由订单直接调用其他的方法就会有几个问题：

1.过度耦合：如果后面创建订单时,需要触发新的动作,那就得去改代码,在原有的创建订单函数末尾,再追加一行代码

2.缺少缓冲：如果创建订单时,会员系统恰好处于非常忙碌或者宕机的状态,那这时更新会员信息就会失败,我们需要一个地方,来暂时存放无法被消费的消息

解决：需要一个消息中间件,来实现解耦和缓冲的功能.

二，RabbitMQ介绍：

2.1什么是RabbitMQ？

RabbitMQ是一个功能强大的消息队列中间件，被广泛应用于分布式系统、微服务架构和异步任务处理等场景。它提供了丰富的特性和灵活的配置选项，能够满足各种不同的需求。同时也有其他的MQ，RabbitMQ只是消息队列的一种。

2.2RabbitMQ组成？

  1. 消息队列：消息队列是一种在应用程序之间进行异步通信的方式。发送方将消息发送到队列，接收方从队列中接收消息并进行处理。这种方式能够解耦发送方和接收方，提高系统的可靠性和可扩展性。

  2. AMQP协议：RabbitMQ使用AMQP（Advanced Message Queuing Protocol）作为消息传递的协议。AMQP是一个标准化的消息传递协议，支持多种编程语言和操作系统。

  3. 生产者和消费者：RabbitMQ中的消息发送方称为生产者，消息接收方称为消费者。生产者将消息发送到队列中，而消费者则从队列中接收并处理消息。

  4. 队列：队列是RabbitMQ中存储消息的地方。消息会被顺序写入队列，并按照先进先出的原则进行处理。

  5. 交换机：交换机是RabbitMQ中消息的路由器，它决定了消息应该发送到哪个队列。根据不同的路由策略，交换机可以将消息发送到一个或多个队列。

  6. 绑定：绑定是将交换机和队列关联起来的过程。绑定可以指定特定的路由规则，从而让交换机将消息发送到指定的队列。

  7. 路由策略：RabbitMQ支持多种路由策略，包括直接路由、主题路由和扇形路由等。不同的路由策略适用于不同的场景，可以实现灵活的消息路由。

  8. 可靠性：RabbitMQ提供了多种机制来确保消息的可靠传递，包括持久化、确认机制和发布者确认等。这些机制可以防止消息丢失或重复消费。

2.3RabbitMQ工作原理

RabbitMQ的工作原理主要基于生产者-消费者模型和消息队列。以下是其基本的工作流程：

生产者：生产者是创建消息的应用程序。它创建消息并发送到RabbitMQ。

队列：队列是RabbitMQ的内部结构，用于存储消息。多个生产者可以发送消息到一个队列，多个消费者可以从一个队列中获取消息。

交换器：生产者发送消息到交换器（Exchange），然后交换器根据一定的规则（路由键）将消息路由到一个或多个队列。RabbitMQ提供了几种类型的交换器，如直接交换器、主题交换器、头交换器和扇出交换器。

消费者：消费者是接收消息的应用程序。消费者连接到RabbitMQ并订阅一个队列，当新的消息到达队列时，RabbitMQ会将消息推送给消费者，或者消费者可以主动从队列中拉取消息。

消息确认：当消费者处理完一个消息后，它需要向RabbitMQ发送一个确认，告诉RabbitMQ这个消息已经被处理，可以从队列中删除。如果消费者处理消息时发生错误，它可以发送一个拒绝，告诉RabbitMQ这个消息没有被正确处理。

持久化：为了防止消息丢失，RabbitMQ提供了消息持久化的功能。生产者在发送消息时可以设置消息为持久化，RabbitMQ会将这些消息存储到磁盘，即使RabbitMQ服务器重启，这些消息也不会丢失。

通过这种方式，RabbitMQ可以在分布式系统中实现消息的可靠传递。 

RabbitMQ是一个实现了AMQP(Advanced Message Queuing Protocol)高级消息队列协议的消息队列服务,用Erlang语言.

Server(Broker):接收客户端连接,实现AMQP协议的消息队列和路由功能的进程.
Virtual Host：虚拟主机的概念,类似权限控制组,一个Virtual Host里可以有多个Exchange和Queue.
Exchange:交换机,接收生产者发送的消息,并根据Routing Key将消息路由到服务器中的队列Queue.
ExchangeType:交换机类型决定了路由消息行为,
RabbitMQ中有三种类型Exchange,分别是fanout、direct、topic.
Message Queue：消息队列,用于存储还未被消费者消费的消息. Message：由Header和body组成,Header是由生产者添加的各种属性的集合,包括Message是否被持久化、优先级是多少、由哪个Message Queue接收等.body是真正需要发送的数据内 容.
BindingKey：绑定关键字,将一个特定的Exchange和一个特定的Queue绑定起来.

2.4RabbitMQ在企业项目中使用场景：

有一个商城项目，可以使用RabbitMQ来实现以下场景：

  1. 异步订单处理：当用户下单后，可以将订单信息封装成消息发送到订单队列中。然后由消费者异步地进行订单处理，例如库存扣减、物流跟踪等。这样可以提高系统的响应速度和可靠性。

  2. 库存同步：在商城项目中，库存是一个重要的资源。可以使用RabbitMQ来实现库存同步，例如将库存变更的消息发送到库存队列中，然后由消费者将库存信息同步到数据库中。

  3. 商品推荐：在商城项目中，推荐系统是一个重要的组件。可以使用RabbitMQ来实现商品推荐的场景，例如将用户浏览历史封装成消息发送到推荐队列中，然后由推荐引擎进行商品推荐。

  4. 优惠券发放：在商城项目中，优惠券是一种常见的促销方式。可以使用RabbitMQ来实现优惠券的发放，例如将优惠券信息封装成消息发送到优惠券队列中，然后由消费者将优惠券发放给符合条件的用户。

  5. 日志收集：商城项目通常需要进行大量的日志记录和统计。可以使用RabbitMQ来实现日志收集，例如将日志信息封装成消息发送到日志队列中，然后由消费者对日志进行分类、统计和分析。

2.5Docker安装部署RabbitMQ

下载镜像：

docker pull rabbitmq:management
docker run -d --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=admin -e RABBITMQ_DEFAULT_PASS=admin --restart=always rabbitmq:management

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

-p：这里有两个端口

-e：指定环境变量: RABBITMQ_DEFAULT_VHOST：默认虚拟机名 RABBITMQ_DEFAULT_USER：默认的用户名

RABBITMQ_DEFAULT_PASS：默认用户名的密码

执行流程：用于在Docker中运行RabbitMQ的命令。它会创建一个名为"my-rabbitmq"的容器，并映射5672和15672端口到主机上，分别用于AMQP和管理界面访问。容器的数据存储在主机的"/home/rabbitmq"目录下，RabbitMQ的默认虚拟主机为"my_vhost"，默认用户名和密码为"admin"。容器会在Docker启动时自动重启。

查看my-rabbitmq是否在运行：

docker logs my-rabbitmq

2.6创建springboot项目嵌套RabbitMQ

创建两级父子项目，父项目为maven项目mq1，子项目为springboot项目有两个provider,consumer

修改application的配置

consumer.application

server:
    port: 9999
spring:
    application:
        name: xx
    rabbitmq:
        host: 192.168.124.131
        username: springboot
        password: 123456
        port: 5672
        virtual-host: my_vhost

provider.application

server:
    port: 8888
spring:
    application:
        name: xx
    rabbitmq:
        host: 192.168.124.131
        username: springboot
        password: 123456
        port: 5672
        virtual-host: my_vhost

这是一个创建MQ的方法

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

Queue("firstQueue");是内置方法

firstQueue是消息队列的名字。

导入指定的包：

AmqpTemplate pom文件中引入了

    @Autowired
    private AmqpTemplate rabbitTemplate;
    @RequestMapping("/sender")
    @ResponseBody
    public String sendFirst() {
        rabbitTemplate.convertAndSend("firstQueue", "Hello World");
        return "zhu";
    }
传递字符串类型

访问：localhost:8888/sender

报错：Connection refused: connect

解决添加连接的账号密码：

检查：

继续访问：localhost:8888/sender

成功：

构建消费者 Consumer

传递实体类型

使用了@Autowired注解来自动注入AmqpTemplate和ObjectMapper对象。AmqpTemplate是Spring提供的一个操作RabbitMQ的工具，可以用来发送和接收消息。ObjectMapper是Jackson库提供的一个工具，可以用来将对象转换为JSON字符串，或者将JSON字符串转换为对象。
sender02方法创建了一个User对象，然后使用ObjectMapper将这个对象转换为JSON字符串，然后发送这个JSON字符串到名为secondQueue的队列中。消费者会接收指定的队列消息使用了log.warn来打印接收到的消息从而消费。

    @RequestMapping("/sender2")
    @ResponseBody
    public String sender2() {
        com.example.provide.User user = new com.example.provide.User("1", "1");
        rabbitTemplate.convertAndSend("secondQueue", user);
        return "zhu2";
    }

package com.example.consumer;

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

@SuppressWarnings("all")
@Component
@Slf4j
@RabbitListener(queues = "firstQueue")
public class SecondReceiver {


    @RabbitHandler
    public void send(User user) {
        log.warn("接收到:" + user);
        }
    }

这里显示不能够这样传递：

原因是

 SimpleMessageConverter 这个类时，接收到了不支持的消息类型。SimpleMessageConverter 只支持 String、byte[] 和 Serializable 类型的消息内容。

根据异常信息，你传递给它的消息内容是 com.example.provide.User 类型，因此引发了这个异常。你需要将消息内容转换为 SimpleMessageConverter 支持的类型。

生产者：

    @RequestMapping("/sender2")
    @ResponseBody
    public String sender2() throws JsonProcessingException {
        User user = new User("1", "1");
        // 序列化对象转换为JSON字符串
        String json = objectMapper.writeValueAsString(user);
        rabbitTemplate.convertAndSend("secondQueue", json);
        return "zhu2";
    }

实体：注意实现Serializable

package com.example.provide;


import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.Setter;
import lombok.NoArgsConstructor;

import java.io.Serializable;

@SuppressWarnings("all")
@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
public class User implements Serializable {
private String username;
private String userpwd;
}

访问响应：

    @RequestMapping("/sender2")
    @ResponseBody
    public String sender2() throws JsonProcessingException {
        User user = new User("1", "1");
        // 序列化对象转换为JSON字符串
        String json = objectMapper.writeValueAsString(user);
        rabbitTemplate.convertAndSend("secondQueue", json);
        return "zhu2";
    }

消费者：

@Component
@Slf4j
@RabbitListener(queues = "secondQueue")
public class SecondReceiver {
    @Autowired
    private ObjectMapper objectMapper;

    @RabbitHandler
    public void send(String json) throws JsonProcessingException {
        User user = objectMapper.readValue(json, User.class);
        // 处理user对象
        log.warn("接收到:" + user.toString());
    }

实体：注意实现Serializable

package com.example.consumer;


import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;

import java.io.Serializable;

@SuppressWarnings("all")
@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
public class User implements Serializable {
private String username;
private String userpwd;
}

@Component
@Slf4j
@RabbitListener(queues = "secondQueue")
public class SecondReceiver {
    @Autowired
    private ObjectMapper objectMapper;

    @RabbitHandler
    public void send(String json) throws JsonProcessingException {
        User user = objectMapper.readValue(json, User.class);
        // 处理user对象
        log.warn("接收到:" + user.toString());
    }

访问测试：

总结：

为什么使用消息队列？

答：1.业务解耦，2实现异步，3.流量削峰填谷（时间换空间）

消息队列：同步与异步差异
    同步：
        优点:时效性强，立即得到结果
        缺点：1.耦合度高（加业务导致改代码困难）
、                2.性能：每次执行调用需要等待上一个进程走完之后才进行
                    3.cpu资源浪费，等待需要执行后再执行
                    4.练级失败，一个服务或者进程甭溃，会导致集体阵亡

    异步：
         优点:1.降低耦合度，2.cpu资源运用合理，3.流量削峰填谷（时间换空间）
         缺点：效率没有同步高

                认真写博客的人，见一个少一个🤩🤩🤩🤩🤩🤩🤩🤩🤩

                           👍 点赞支持，⭐️ 收藏学习，❤️ 关注不迷路~
                                            💬 如有错漏请不吝指正~

平顶山大师-CSDN博客
https://blog.csdn.net/m0_73647713?spm=1011.2266.3001.5343

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

FPGA高端项目：Xilinx Zynq7020 系列FPGA纯verilog图像缩放工程解决方案 提供3套工程源码和技术支持

FPGA高端项目：Xilinx Zynq7020 系列FPGA纯verilog图像缩放工程解决方案 提供3套工程源码和技术支持

目录 1、前言版本更新说明给读者的一封信FPGA就业高端项目培训计划免责声明 2、相关方案推荐我这里已有的FPGA图像缩放方案本方案在Xilinx Kintex7 系列FPGA上的应用本方案在Xilinx Artix7 系列FPGA上的应用本方案在国产FPGA紫光同创系列上的应用本方案在国产FPGA高云系列上的应…
阅读更多...
【Linux】vim配置

【Linux】vim配置

我们普通用户打开未配置的vim的时候，和Windows中的vs界面差别很大，使用不是很便捷 这里我们可以配置一下vim，便于我们的操作 我们可以在gitee中搜索vimforcpp VimForCpp: 快速将vim打造成c IDE (gitee.com) curl -sLf https://gitee.com/HGt…
阅读更多...
基于YOLOv8的目标识别、计数、电子围栏的项目开发过程

基于YOLOv8的目标识别、计数、电子围栏的项目开发过程

0 前言 用于生产环境中物体检测、识别、跟踪，人、车流量统计，越界安全识别 1 YOLOv8概述 YOLOv8 是Ultralytics的YOLO的最新版本。作为一种前沿、最先进(SOTA)的模型，YOLOv8在之前版本的成功基础上引入了新功能和改进，以提高性…
阅读更多...
【Obsidian】【Git】使用gitee同步/保存obsidian笔记

【Obsidian】【Git】使用gitee同步/保存obsidian笔记

Obisidian是一款markdown软件，使用它可以方便地记笔记、记录科研日常。然而如果在多个设备上使用obsidian，会牵扯到笔记/vault/仓库同步问题。下面来介绍如何用git管理obsidian。 1.创建gitee账号 略 2.下载Obsidian 略 3.新建git仓库 3.1在gitee上…
阅读更多...
《WebKit 技术内幕》学习之九（1）： JavaScript引擎

《WebKit 技术内幕》学习之九（1）： JavaScript引擎

1　概述 1.1　JavaScript语言 说起JavaScript语言，又要讲一个典型的从弱小到壮大的奋斗史。起初，它只是一个非常不起眼的语言，用来处理非常小众的问题。所以，从设计之初，它的目标就是解决一些脚本语言的问题&#xff…
阅读更多...
rancher和k8s接口地址，Kubernetes监控体系，cAdvisor和kube-state-metrics 与 metrics-server

rancher和k8s接口地址，Kubernetes监控体系，cAdvisor和kube-state-metrics 与 metrics-server

为了能够提前发现kubernetes集群的问题以及方便快捷的查询容器的各类参数，比如，某个pod的内存使用异常高企 等等这样的异常状态（虽然kubernetes有自动重启或者驱逐等等保护措施，但万一没有配置或者失效了呢）&#xff0…
阅读更多...
yum仓库和NFS文件共享服务

yum仓库和NFS文件共享服务

一、yum仓库简介： 1.yum仓库简介： yum是一个基于RPM包（是Red-Hat Package Manager红帽软件包管理器的缩写）构建的软件更新机制，能够自动解决软件包之间的依赖关系。解决了日常工作中的大量查找安装依赖包的时间 为什…
阅读更多...
html 3D 倒计时爆炸特效

html 3D 倒计时爆炸特效

下面是代码&#xff1a; <!DOCTYPE html> <html><head><meta charset"UTF-8"><title>HTML5 Canvas 3D 倒计时爆炸特效DEMO演示</title><link rel"stylesheet" href"css/style.css" media"screen&q…
阅读更多...
【Linux C | 进程】创建进程 | vfork函数+exec函数，以及system函数——文中很多C语言例子帮助理解

【Linux C | 进程】创建进程 | vfork函数+exec函数，以及system函数——文中很多C语言例子帮助理解

&#x1f601;博客主页&#x1f601;&#xff1a;&#x1f680;https://blog.csdn.net/wkd_007&#x1f680; &#x1f911;博客内容&#x1f911;&#xff1a;&#x1f36d;嵌入式开发、Linux、C语言、C、数据结构、音视频&#x1f36d; &#x1f923;本文内容&#x1f923;&a…
阅读更多...
深入剖析Python最强大图片处理模块——Pillow

深入剖析Python最强大图片处理模块——Pillow

目录 一、引言 二、Pillow的功能与特点 三、Pillow的应用场景 四、代码示例 五、Pillow与其他图像处理库的对比 六、结论 一、引言 在Python中&#xff0c;Pillow是用于图像处理的最强大和最流行的库之一。它提供了丰富的功能&#xff0c;使得用户可以轻松地处理、编辑和…
阅读更多...
【RT-DETR有效改进】 | 主干篇 | EfficientViT高效的特征提取网络完爆MobileNet系列(轻量化网络结构)

【RT-DETR有效改进】 | 主干篇 | EfficientViT高效的特征提取网络完爆MobileNet系列(轻量化网络结构)

前言 大家好&#xff0c;我是Snu77&#xff0c;这里是RT-DETR有效涨点专栏。 本专栏的内容为根据ultralytics版本的RT-DETR进行改进&#xff0c;内容持续更新&#xff0c;每周更新文章数量3-10篇。 专栏以ResNet18、ResNet50为基础修改版本&#xff0c;同时修改内容也支持Re…
阅读更多...
HTTPS基本概念

HTTPS基本概念

HTTP 与 HTTPS 有哪些区别&#xff1f; HTTP 是超文本传输协议&#xff0c;信息是明文传输&#xff0c;存在安全风险的问题。HTTPS 则解决 HTTP 不安全的缺陷&#xff0c;在 TCP 和 HTTP 网络层之间加入了 SSL/TLS 安全协议&#xff0c;使得报文能够加密传输。HTTP 连接建立相…
阅读更多...
国家急救日倡议活动暨120急救大课堂公益培训在京成功举办

国家急救日倡议活动暨120急救大课堂公益培训在京成功举办

2024年1月20日&#xff0c;由国家卫生健康委员会等多个相关部门指导&#xff0c;中国医院协会急救中心&#xff08;站&#xff09;分会主办&#xff0c;北京急救中心承办的“国家急救日”倡议活动暨急救科普大课堂公益培训系列活动&#xff0c;在全国范围内启动。 健康中国行动…
阅读更多...
Kotlin程序设计 扩展篇（一）

Kotlin程序设计 扩展篇（一）

Kotlin程序设计&#xff08;扩展一&#xff09; **注意&#xff1a;**开启本视频学习前&#xff0c;需要先完成以下内容的学习&#xff1a; 请先完成《Kotlin程序设计》视频教程。请先完成《JavaSE》视频教程。 Kotlin在设计时考虑到了与Java的互操作性&#xff0c;现有的Ja…
阅读更多...
源 “MySQL 5.7 Community Server“ 的 GPG 密钥已安装，但是不适用于此软件包。请检查源的公钥 URL 是否配置正确

源 “MySQL 5.7 Community Server“ 的 GPG 密钥已安装，但是不适用于此软件包。请检查源的公钥 URL 是否配置正确

Is this ok [y/d/N]: y Downloading packages: 警告&#xff1a;/var/cache/yum/x86_64/7/mysql57-community/packages/mysql-community-server-5.7.44-1.el7.x86_64.rpm: 头V4 RSA/SHA256 Signature, 密钥 ID 3a79bd29: NOKEY 从 file:///etc/pki/rpm-gpg/RPM-GPG-KEY-mysql 检…
阅读更多...
加速社区数字化转型：物业app开发的最新趋势

加速社区数字化转型：物业app开发的最新趋势

在当今数字化时代&#xff0c;社区数字化转型已经成为业界焦点。特别是在物业管理领域&#xff0c;物业app开发正成为加速社区数字化转型的关键趋势。本文将探讨物业app开发的最新趋势&#xff0c;以及如何通过这些趋势推动社区数字化转型。 物业app开发的关键趋势 随着智能手…
阅读更多...
postman测试导入文件

postman测试导入文件

01 上传文件参数 1.选择请求方式 选择post请求方式&#xff0c;输入请求地址 2.填写Headers Key&#xff1a;Content-Type &#xff1b; Value&#xff1a;multipart/form-data 如下图 3.填写body 选择form-data&#xff0c;key选择file类型后value会出现按钮&#xff0…
阅读更多...
（十二）Head first design patterns代理模式（c++）

（十二）Head first design patterns代理模式（c++）

代理模式 代理模式&#xff1a;创建一个proxy对象&#xff0c;并为这个对象提供替身或者占位符以对这个对象进行控制。 典型例子&#xff1a;智能指针... 例子&#xff1a;比如说有一个talk接口&#xff0c;所有的people需要实现talk接口。但有些人有唱歌技能。不能在talk接…
阅读更多...
[AutoSar]BSW_OS 06 Autosar OS_Alarms

[AutoSar]BSW_OS 06 Autosar OS_Alarms

一、 目录 一、关键词平台说明一、Timer1.1 配置1.2Periodical Interrupt Timer (PIT)和High Resolution Timer (HRT) 二、Alarm 工作机制三、Code3.1创建一个15ms的runnable3.2mapping到basic task3.3生成代码 关键词 嵌入式、C语言、autosar、OS、BSW 平台说明 项目ValueO…
阅读更多...
【开源】基于JAVA语言的停车场收费系统

【开源】基于JAVA语言的停车场收费系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 停车位模块2.2 车辆模块2.3 停车收费模块2.4 IC卡模块2.5 IC卡挂失模块 三、系统设计3.1 用例设计3.2 数据库设计3.2.1 停车场表3.2.2 车辆表3.2.3 停车收费表3.2.4 IC 卡表3.2.5 IC 卡挂失表 四、系统实现五、核心代码…
阅读更多...
最新文章

Copyright @ 2022~2023