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

news2024/11/16 23:59:39

一，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来实现以下场景：

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

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

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

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

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

2.3Docker安装部署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启动时自动重启。

docker logs my-rabbitmq

2.4创建springboot项目嵌套RabbitMQ

修改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());
    }

        

访问测试：

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

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

相关文章

数据集成时表模型同步方法解析

数据集成时表模型同步方法解析

01 背景介绍 数据治理的第一步，也是数据中台的一个基础功能 — 即将来自各类业务数据源的数据，同步集成至中台 ODS 层。业务数据源多种多样，单单可能涉及到的主流关系型数据库就有近十种。功能更加全面的数据中台通常还具有对接非关系型数据…
阅读更多...
c++:基于c语言基础上的语法不同（1）

c++:基于c语言基础上的语法不同（1）

前言&#xff1a;此篇文章适合学完c语言基础概念的同学&#xff0c;是帮助c向c语言的同学快速掌握基本语法。 基础格式 #include<iostream>using namespace std; int main() {system("pause");return 0; } 输入&#xff1a; cin>>a;//a是输入内容 输出…
阅读更多...
使用Python的pygame库实现下雪的效果

使用Python的pygame库实现下雪的效果

使用Python的pygame库实现下雪的效果 关于Python中pygame游戏模块的安装使用可见 https://blog.csdn.net/cnds123/article/details/119514520 先给出效果图&#xff1a; 源码如下&#xff1a; import pygame import random# 初始化pygame pygame.init()# 设置屏幕尺寸 width…
阅读更多...
深入理解Redis数据结构

深入理解Redis数据结构

目录 Redis的单线程 Redis单线程快的原因 Redis 单线程处理高并发客户端连接 Redis数据结构 字符串&#xff08;String&#xff09; 常用方法 数据结构 哈希表&#xff08;Hash&#xff09; 常用方法 数据结构 列表&#xff08;List&#xff09; 常用方法 数据结构…
阅读更多...
[bat]0基础实现自动化办公-基于start实现一键打开常用软件/文档

[bat]0基础实现自动化办公-基于start实现一键打开常用软件/文档

一、应用背景 每次开机时&#xff0c;都要一个个打开常用软件&#xff0c;比如微信、QQ或是word文档、excel表格等程序&#xff0c;比较费时。 二、方案 使用bat脚本中的start方法&#xff0c;通过将需要打开的程序或文件写入到bat脚本中&#xff0c;运行bat脚本从而实现一键…
阅读更多...
X-Bogus加密参数分析与jsvmp算法（仅供学习）

X-Bogus加密参数分析与jsvmp算法（仅供学习）

文章目录 1. 抓包分析2. X-Bogus参数分析 【作者主页】&#xff1a;吴秋霖 【作者介绍】&#xff1a;Python领域优质创作者、阿里云博客专家、华为云享专家。长期致力于Python与爬虫领域研究与开发工作&#xff01; 【作者推荐】&#xff1a;对JS逆向感兴趣的朋友可以关注《爬虫…
阅读更多...
【根据loss曲线看模型微调效果】如何使用loss曲线诊断机器学习模型性能

【根据loss曲线看模型微调效果】如何使用loss曲线诊断机器学习模型性能

一、Loss曲线 在模型的预训练或者微调过程中&#xff0c;我们一般通过观察loss曲线来得出模型对于数据集的学习效果等信息。那么我们如何根据loss曲线得到一些信息呢&#xff1f; 通常数据集会被划分成三部分&#xff0c;训练集&#xff08;training dataset&#xff09;、验证…
阅读更多...
VR风景园林虚拟仿真系统编辑工具支持可视化预览成本低

VR风景园林虚拟仿真系统编辑工具支持可视化预览成本低

为了帮助更多人快速、高效地构建虚拟现实应用系统&#xff0c;提高开发效率&#xff0c;降低成本投入&#xff0c;VR虚拟现实交互系统编辑器作为一种用于创建和编辑虚拟现实应用程序的工具&#xff0c;采用可视化界面提示和简单操作就能快速制作VR虚拟现实交互系统。 VR虚拟现实…
阅读更多...
centos7安装nginx，按图文步骤操作

centos7安装nginx，按图文步骤操作

下载nginx&#xff1a; 官方网站&#xff1a;http://nginx.org/ 我这使用的版本是1.8.0版本。 1.nginx要求的安装环境 1.1、需要安装gcc的环境。 yum install gcc-c 1.2、第三方的开发包。 pcre PCRE(Perl Compatible Regular Expressions)是一个Perl库&#xff0c;包括…
阅读更多...
行云部署前端架构解析-前言 | 京东云技术团队

行云部署前端架构解析-前言 | 京东云技术团队

一个简单的自我介绍 项目规模 截止目前上万次代码提交&#xff0c;总代码行数1超过21万行&#xff0c;其中人工维护的代码超过 13万行&#xff0c;近千个文件。 前端线上服务直接对接的后端服务&#xff0c;达十多个。 跟很多应用一样, 它有行云的入口, 也有独立的服务, 还…
阅读更多...
C++ 之LeetCode刷题记录（十三）

C++ 之LeetCode刷题记录（十三）

&#x1f604;&#x1f60a;&#x1f606;&#x1f603;&#x1f604;&#x1f60a;&#x1f606;&#x1f603; 开始cpp刷题之旅。 依旧是追求耗时0s的一天。 70. 爬楼梯 假设你正在爬楼梯。需要 n 阶你才能到达楼顶。 每次你可以爬 1 或 2 个台阶。你有多少种不同的方法可…
阅读更多...
TortoiseSVN客户端如何安装配置并实现公网访问服务端提交文件到本地服务器

TortoiseSVN客户端如何安装配置并实现公网访问服务端提交文件到本地服务器

文章目录 前言1. TortoiseSVN 客户端下载安装2. 创建检出文件夹3. 创建与提交文件4. 公网访问测试 前言 TortoiseSVN是一个开源的版本控制系统&#xff0c;它与Apache Subversion&#xff08;SVN&#xff09;集成在一起&#xff0c;提供了一个用户友好的界面&#xff0c;方便用…
阅读更多...
HarmonyOS—创建和运行Hello World

HarmonyOS—创建和运行Hello World

DevEco Studio配置开发环境完成后&#xff0c;可以通过运行Hello World工程来验证环境设置是否正确。接下来以创建一个Phone设备的工程为例进行介绍。 创建一个新工程 打开DevEco Studio&#xff0c;在欢迎页单击Create Project&#xff0c;创建一个新工程。根据工程创建向导&…
阅读更多...
【Linux】配置dns主从服务器，能够实现正常的正反向解析

【Linux】配置dns主从服务器，能够实现正常的正反向解析

​​​​​​1、首先&#xff0c;在主服务器上配置DNS解析器。打开配置文件/etc/named.conf&#xff0c;添加以下内容&#xff1a; zone"example.com" IN {type master;file "example.com.zone";allow-transfer { slave_ip_address: }; };zone"xx.16…
阅读更多...
kotlin Kmp多平台模板生成

kotlin Kmp多平台模板生成

地址: Kotlin Multiplatform Wizard | JetBrains 可生成kotlin多个平台模板 https://terrakok.github.io/Compose-Multiplatform-Wizard/
阅读更多...
SpringBoot连接远程服务器redis

SpringBoot连接远程服务器redis

SpringBoot连接远程服务器redis 1、指定redis配置启动 进入redis安装地址&#xff0c;我这里安装的是 /usr/local/src/redis-6.2.6 先copy一份配置文件 cp redis.conf redis.conf.bck然后修改配置文件信息 vim redis.conf bind 0.0.0.0 # 守护进程&#xff0c;修改为yes后即可…
阅读更多...
StructuredStreaming输出模式和结果输出文件中

StructuredStreaming输出模式和结果输出文件中

输出模式 #format指定输出位置 console&#xff1a;控制台 #append 不支持排序&#xff0c;不支持聚合&#xff0c; 每次输出数据都是最新的数据内容 #complete 必须聚合&#xff0c;支持聚合后排序 每次输出数据都会将原来的数据一起输出 #update 支持聚合&#xff0c;支持sel…
阅读更多...
小程序宿主环境-组件swiper

小程序宿主环境-组件swiper

巧识小程序的开发过程学习. 在我们的list.wxml中创建组件 <swiper class"swiper-container" indicator-dots indicator-color"white" indicator-active-color"grey" autoplay interval"2000" circular><!--第一个轮播图--&…
阅读更多...
gitlab 部署项目新分支

gitlab 部署项目新分支

公司代码管理平台新切换到gitlab下&#xff0c;上线发版流程随之变更 1新建分支&#xff0c;开发完成&#xff0c;提交新分支 2.去gitlab平台上找到Merge requests 3 点击右上角的New merge request select source branch 选择新建的分支 点击 compare branches and contin…
阅读更多...
Vue中使用echart引入图表

Vue中使用echart引入图表

下载echart安装包. 找到安装包里的dist文件夹中的echarts.js文件&#xff0c;复制到工作文件夹目录下 复制到工作文件夹目录下 官网查询使用方法快速上手 - 使用手册 - Apache ECharts eg:
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023