RabbitMQ 介绍与 SpringBootAMQP使用

一、MQ概述

异步通信的优点：

  • 耦合度低
  • 吞吐量提升
  • 故障隔离
  • 流量削峰

异步通信的缺点：

  • 依赖于Broker的可靠性、安全性、吞吐能力
  • 架构复杂，业务么有明显的流程线，不方便追踪管理

什么是的MQ
MQ（Message Queue）,消息队列，就是放消息的队列。也是事件驱动架构中的Broker。

RabbitMQActiveMQRocketMQKafka
公司/社区RabbitApache阿里Apache
开发语言ErlangJavaJavaScala&Java
协议支持AMQP、XMPP、
SMTP、STOMP		OpenWire、STOMP、
REST、XMPP、AMQP		自定义协议自定义协议
可用性高一般高高
单机吞吐量一般差高非常高
消息延迟微秒级毫秒级毫秒级毫秒级
消息可靠性高一般高一般

二、RabbitMQ概述

1. RabbitMQ的结构和概念

  • Channel：操作MQ的工具
  • Exchange：路由消息到队列中
  • Queue：缓存消息
  • Virtual Host：虚拟主机，是对Queue、Exchange等资源的逻辑分组

在这里插入图片描述
2. 常见消息模型

  • 基本消息队列（BasicQueue）
    在这里插入图片描述

    • Publisher：消息发布者，将消息发送到队列Queue
    • Queue：消息队列，负责接受并缓存消息
    • Consumer：订阅队列，处理队列中的消息

    在这里插入图片描述

  • 工作消息队列（WorkQueue）
    在这里插入图片描述
    Work queues，也被称为（Task queues），任务模型。简单来说就是让多个消费者绑定到一个队列，共同消费队列中的消息。

    当消息处理比较耗时的时候，可能生产消息的速度会远远大于消息的消费速度。长此以往，消息就会堆积越来越多，无法及时处理。此时就可以使用work 模型，多个消费者共同进行消息处理，提高消费速度。

    在这里插入图片描述

  • 发布订阅（Publish、Subscribe），根据交换机类型不同分为三种：

  • Publisher：生产者，也就是要发送消息的程序，但是不再发送到队列中，而是发给X（交换机）

  • Exchange：交换机，图中的X。一方面，接收生产者发送的消息。另一方面，知道如何处理消息，例如递交给某个特别队列、递交给所有队列、或是将消息丢弃。到底如何操作，取决于Exchange的类型。Exchange有以下3种类型：

    • Fanout：广播，将消息交给所有绑定到交换机的队列
    • Direct：定向，把消息交给符合指定routing key 的队列
    • Topic：通配符，把消息交给符合routing pattern（路由模式） 的队列

  • Consumer：消费者，与以前一样，订阅队列，没有变化

  • Queue：消息队列也与以前一样，接收消息、缓存消息。

    在这里插入图片描述
    Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！

在这里插入图片描述

  • Fanout Exchange： 广播
    在这里插入图片描述
    在广播模式下，消息发送流程：

    - 1）  可以有多个队列
- 2）  每个队列都要绑定到Exchange（交换机）
- 3）  生产者发送的消息，只能发送到交换机，交换机来决定要发给哪个队列，生产者无法决定
- 4）  交换机把消息发送给绑定过的所有队列
- 5）  订阅队列的消费者都能拿到消息

在这里插入图片描述

  • Direct Exchange：路由
    在这里插入图片描述

    在Fanout模式中，一条消息会被所有订阅的队列都消费。但是，在某些场景下，希望不同的消息被不同的队列消费。这时就要用到Direct类型的Exchange。
    在这里插入图片描述

    在Direct模型下：

    • 队列与交换机的绑定，不能是任意绑定了，而是要指定一个RoutingKey（路由key）
    • 消息的发送方在 向 Exchange发送消息时，也必须指定消息的 RoutingKey。
    • Exchange不再把消息交给每一个绑定的队列，而是根据消息的Routing Key进行判断，只有队列的Routingkey与消息的 Routing key完全一致，才会接收到消息

  • Topic Exchange：主题
    在这里插入图片描述

Topic类型的Exchange与Direct相比，都是可以根据RoutingKey把消息路由到不同的队列。只不过Topic类型Exchange可以让队列在绑定Routing key 的时候使用通配符。

通配符规则：

  • #：匹配一个或多个词
  • *：匹配不多不少恰好1个词

如下图：

  • Queue1：绑定的是china.# ，因此凡是以 china.开头的routing key 都会被匹配到。包括china.news和china.weather
  • Queue2：绑定的是#.news ，因此凡是以 .news结尾的 routing key 都会被匹配。包括china.news和japan.news
    在这里插入图片描述

3. RabbitMQ的安装

1、安装Erlang：RabbitMQ是用Erlang编写的，因此首先需要安装Erlang运行环境（注意Erlang与RabbitMQ的对应版本）。运行以下命令进行安装：sudo apt install erlang

2、在线拉取镜像：docker pull rabbitmq:3-management

3、运行以下命令来下载并启动RabbitMQ Docker镜像：docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

4、浏览器访问RabbitMQ管理页面：http://IP:15672/（注意：若网页无法访问，可能是rabbitmq_management插件未启用）

5、进入sbin目录下，查看插件，命令：rabbitmq-plugins list
在这里插入图片描述

6、 若 rabbitmq_management 插件未启用（状态无 * ），通过命令启用该插件：rabbitmq-plugins enable rabbitmq_management
在这里插入图片描述

7、启用后，重新访问地址，用户名/密码默认：guest/guest
在这里插入图片描述

三、SpringAMQP

AMQP，Adanced Message Queuing Protocol，是用于在应用程序之间传递业务消息的开发标准，与语言和平台无关。

SpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。

SpringAmqp的官方地址：https://spring.io/projects/spring-amqp

SpringAMQP提供了三个功能：

  • 自动声明队列、交换机及其绑定关系
  • 基于注解的监听器模式，异步接收消息
  • 封装了RabbitTemplate工具，用于发送消息

1、使用SpringBootAMQP- SimpleQueue的步骤

  • 引入AMQP的Starter依赖
<!--AMQP依赖，包含RabbitMQ-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
  • 配置RabbitMQ地址
logging:pattern:dateformat: MM-dd HH:mm:ss:SSS
spring:rabbitmq:host: 127.0.0.1port: 5672username: guestpassword: guestvirtual-host: /listener:simple:prefetch: 3 # 每次只能获取一条消息，处理完成才能获取下一个消息
  • 利用RabbitTemplate的convertAndSend方法
package com.example.rabbitmq_demo;import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class)
@SpringBootTest
class RabbitmqDemoApplicationTests {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSimpleQueue() {//queueNameString queueName = "ty.simple.queue";//messageString message = "hello world ";//send MessagerabbitTemplate.convertAndSend(queueName, message);}}

2、使用SpringBootAMQP- FanoutExchange的步骤

  • 创建Spring配置类，绑定交换机 - 队列
package com.example.rabbitmq_demo.consumer.config;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class FanoutConfig {@Beanpublic FanoutExchange fanoutExchange(){return new FanoutExchange("ty.fanout");}@Beanpublic Queue fanoutQueue1(){return new Queue("fanout.queue1");}@Beanpublic Queue fanoutQueue2(){return new Queue("fanout.queue2");}/*** 绑定交换机与队列*/@Beanpublic Binding fanoutBinding1(Queue fanoutQueue1, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}@Beanpublic Binding fanoutBinding2(Queue fanoutQueue2, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);}
}
  • 利用RabbitTemplate的convertAndSend方法
package com.example.rabbitmq_demo;import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class)
@SpringBootTest
class RabbitmqDemoApplicationTests {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSendFanoutExchange() {//exchangeNameString exchangeName = "ty.fanout";//messageString message = "hello world fanout";//send MessagerabbitTemplate.convertAndSend(exchangeName, "", message);}}

2、使用SpringBootAMQP- Direct的步骤

  • 基于注解来声明队列和交换机
package com.example.rabbitmq_demo.consumer;import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class ConsumerDemo {/*** 基于@Bean的方式声明队列和交换机比较麻烦，Spring还提供了基于注解方式来声明* 在consumer的SpringRabbitListener中添加两个消费者，同时基于注解来声明队列和交换机* @param msg*/@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "ty.direct.queue1"),exchange = @Exchange(name = "ty.direct", type = ExchangeTypes.DIRECT),key = {"red", "green"}))public void listenDirectQueue1(String msg){System.out.println("listener ty.direct.queue1 Get message : " + msg);}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "ty.direct.queue2"),exchange = @Exchange(name = "ty.direct", type = ExchangeTypes.DIRECT),key = {"red", "blue"}))public void listenDirectQueue2(String msg){System.out.println("listener ty.direct.queue2 Get message : " + msg);}
}
  • 通过convertAndSend发送消息，会根据的RoutingKey，将消息发送至指定队列。
package com.example.rabbitmq_demo;import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class)
@SpringBootTest
class RabbitmqDemoApplicationTests {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSendDirectExchange(){String exchangeName = "ty.direct";String message = "hello ty";rabbitTemplate.convertAndSend(exchangeName, "red", message);}
}

3、使用SpringBootAMQP- Tpic的步骤

  • 基于注解来声明队列和交换机
package com.example.rabbitmq_demo.consumer;import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class ConsumerDemo {/*** Topic类型的Exchange与Direct相比，都是可以根据RoutingKey把消息路由到不同的队列。只不过Topic类型Exchange可以让队列在绑定Routing key的时候使用通配符* @param msg*/@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "ty.topic.queue1"),exchange = @Exchange(name = "ty.topic", type = ExchangeTypes.TOPIC),key = "ty.#"))public void listenTopicQueue1(String msg){System.out.println("listener ty.topic.queue1 Get message : " + msg);}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "ty.topic.queue2"),exchange = @Exchange(name = "ty.topic", type = ExchangeTypes.TOPIC),key = "#.tyty"))public void listenTopicQueue2(String msg){System.out.println("listener ty.topic.queue2 Get message : " + msg);}
}
  • 根据RoutingKey通配符，发送到对应Queue
package com.example.rabbitmq_demo;import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class)
@SpringBootTest
class RabbitmqDemoApplicationTests {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSendTopicExchange(){String exchangeName = "ty.topic";String message = "hello ty";rabbitTemplate.convertAndSend(exchangeName, "ty.tyty", message);}}

4、SpringBootAMQP对象序列化

SpringBootAMQP默认使用的是 x-java-serialized-object，JDK序列化数据体积过大、有安全漏洞，且可读性差。
在这里插入图片描述
可通过配置JSON转换器，使用Json的方式做序列化和反序列化。

  • 引入jar
<dependency><groupId>com.fasterxml.jackson.dataformat</groupId><artifactId>jackson-dataformat-xml</artifactId><version>2.9.10</version>
</dependency>
  • 配置类中增加Bean
@Bean
public MessageConverter jsonMessageConverter(){return new Jackson2JsonMessageConverter();
}

在这里插入图片描述

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

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

相关文章

ARM-day5作业

ARM-day5作业

.text .global _start _start: 1、设置GPIOE、GPIOF寄存器的时钟使能 RCC_MP_AHB4ENSETR[4]->1 0x50000a28 LDR R0,0x50000a28 LDR R1,[R0] ORR R1,R1,#(0x3<<4) STR R1,[R0]2、设置PE10、PF10、PE8管脚为输出模式 GPIOE_MODER[21:20]->01 0x50006000…
阅读更多...
Flask与PyQt结合使用时候,阻塞,界面卡死

Flask与PyQt结合使用时候,阻塞,界面卡死

一.问题起因 做了个服务端, 使用到了python的PYQT6和Flask, PYQT做的是个简单的设置界面: 但是在点击开始运行, 写入flask run的代码的时候, PYQT界面卡死了 代码如下: # 生产环境模式server make_server(0.0.0.0, ser_port, app)server.serve_forever()app.run() 二.问题产…
阅读更多...
【Python】WebUI自动化—如何用Selenium IDE录制脚本生成单元测试代码（基于Chrome）（17）

【Python】WebUI自动化—如何用Selenium IDE录制脚本生成单元测试代码（基于Chrome）（17）

一.Selenium IDE介绍 Selenium IDE是Chrome和FireFox浏览器中的插件&#xff0c;Selenium IDE结合浏览器提供脚本录制、脚本回放、脚本编辑、元素定位等功能&#xff0c;使用Selenium IDE可以将录制的脚本生成相应单元测试框架的自动化测试脚本&#xff0c;录制脚本支持导出Py…
阅读更多...
Meta分析的流程及方法

Meta分析的流程及方法

Meta分析是针对某一科研问题&#xff0c;根据明确的搜索策略、选择筛选文献标准、采用严格的评价方法&#xff0c;对来源不同的研究成果进行收集、合并及定量统计分析的方法&#xff0c;最早出现于“循证医学”&#xff0c;现已广泛应用于农林生态&#xff0c;资源环境等方面。…
阅读更多...
【数据结构】栈和队列-- OJ

【数据结构】栈和队列-- OJ

目录 一 用队列实现栈 二 用栈实现队列 三 设计循环队列 四 有效的括号 一 用队列实现栈 225. 用队列实现栈 - 力扣&#xff08;LeetCode&#xff09; typedef int QDataType; typedef struct QueueNode {struct QueueNode* next;QDataType data; }QNode;typedef struct …
阅读更多...
使用docker搭建nacos单机、集群 + mysql

使用docker搭建nacos单机、集群 + mysql

单机搭建 1 拉取mysql镜像 docker pull mysql:5.7.40 2 启动mysql容器 docker run -d --namemysql-server -p 3306:3306 -v mysql-data:/var/lib/mysql -e MYSQL_ROOT_PASSWORD123456 mysql:5.7.40 3 执行nacos的数据库脚本 /* * Copyright 1999-2018 Alibaba Group Holding L…
阅读更多...
ctfshow web入门 php特性 web136-web140

ctfshow web入门 php特性 web136-web140

1.web136 还有一种写文件的命令时tee命令 payload&#xff1a; : ls /|tee 1 访问1下载查看文件1发现根目录下有flag cat /f149_15_h3r3|tee 2 访问下载查看文件22.web137 call_user_func <?php class myclass {static function say_hello(){echo "He…
阅读更多...
Graphviz 作图工具

Graphviz 作图工具

选择 Graphviz 作为作图工具&#xff0c;主要是想通过代码创建图标&#xff0c;按照 Graphviz 的代码规范就可以生成 svg 的图片。当然&#xff0c;这样的工具也有很多&#xff0c;有些 markdown 编辑器也做了集成&#xff0c;比如&#xff1a; flowchart.jsMermaid 了解 Gra…
阅读更多...
打印字节流和字符流

打印字节流和字符流

打印字节流和字符流 printStream/ printWriter的构造器和方法都是一样的 package printfile;import java.io.FileOutputStream; import java.io.OutputStream; import java.io.PrintStream; import java.io.PrintWriter; import java.nio.charset.Charset;public class Prin…
阅读更多...
Postgresql中的C/C++混编（JIT）

Postgresql中的C/C++混编（JIT）

1 Postgresql编译JIT 整体上看使用了GCC、G编译文件&#xff0c;最后用G汇总&#xff1a; GCC编译的三个.o文件llvmjit、llvmjit_deform、llvmjit_expr llvmjit.c -> llvmjit.o gcc -Wall -Wmissing-prototypes -Wpointer-arith -Wdeclaration-after-statement -…
阅读更多...
深入探索地理空间查询：如何优雅地在MySQL、PostgreSQL及Redis中实现精准的地理数据存储与检索技巧

深入探索地理空间查询：如何优雅地在MySQL、PostgreSQL及Redis中实现精准的地理数据存储与检索技巧

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…
阅读更多...
基于Springboot实现房屋租赁租房平台系统项目【项目源码+论文说明】分享

基于Springboot实现房屋租赁租房平台系统项目【项目源码+论文说明】分享

基于Springboot实现房屋租赁租房平台系统演示 摘要 在网络高速发展的时代&#xff0c;众多的软件被开发出来&#xff0c;给用户带来了很大的选择余地&#xff0c;而且人们越来越追求更个性的需求。在这种时代背景下&#xff0c;房东只能以用户为导向&#xff0c;所以开发租房网…
阅读更多...
实现协议互通：探索钡铼BL124EC的EtherCAT转Ethernet/IP功能

实现协议互通：探索钡铼BL124EC的EtherCAT转Ethernet/IP功能

钡铼BL124EC是一种用于工业网络通信的网关设备&#xff0c;专门用于将EtherCAT协议转换成Ethernet/IP协议。它充当一个桥梁&#xff0c;连接了使用不同协议的设备&#xff0c;使它们能够无缝地进行通信和互操作。 具体来说&#xff0c;BL124EC通过支持EtherCAT&#xff08;以太…
阅读更多...
docker安装运行环境相关的容器

docker安装运行环境相关的容器

docker安装常用软件步骤 docker安装Tomcat:latest 2023-10-09 1&#xff09;搜索镜像 以Tomcat为例子&#xff0c;先去官网仓库搜索https://hub.docker.com/search?qtomcat 或者直接命令查询 docker search tomcat2&#xff09;拉取镜像 docker pull tomcat3&#xff09…
阅读更多...
CamoDroid 与 Frida Android动态分析工具搭建流程（linux）

CamoDroid 与 Frida Android动态分析工具搭建流程（linux）

CamoDroid 与 Frida Android动态分析工具搭建流程&#xff08;linux&#xff09; 写在前面 这个东西配置起来比较复杂&#xff0c;其实最主要就是配置frida&#xff0c;如果你之前就使用过frida框架的话问题就不是很大 介绍camodroid CamoDroid 是一个开源和开放架构的 And…
阅读更多...
力扣第 365 场周赛虚拟参赛

力扣第 365 场周赛虚拟参赛

有序三元组中的最大值 I class Solution { public:long long maximumTripletValue(vector<int>& nums) {vector<long long> num;for (auto &item:nums) {num.push_back(item*1ll);}long long z 0,f 1000000;long long ans 0;long long maxx num[0],mi…
阅读更多...
基于指数趋近律的机器人滑模轨迹跟踪控制算法及MATLAB仿真

基于指数趋近律的机器人滑模轨迹跟踪控制算法及MATLAB仿真

机械手是工业制造领域中应用最广泛的自动化机械设备&#xff0c;广泛应用于工业制造、医疗、军工、半导体制造、太空探索等领域。它们虽然形式不同&#xff0c;但都有一个共同的特点&#xff0c;即能够接受指令&#xff0c;并能准确定位到三维(或二维)空间的某一点进行工作。由…
阅读更多...
NoSQL之Redis 主从复制配置详解及哨兵模式

NoSQL之Redis 主从复制配置详解及哨兵模式

目录 1 Redis 主从复制 1.1 主从复制的作用 1.2 主从复制流程 2 搭建Redis 主从复制 2.1 安装 Redis 2.2 修改 Redis 配置文件&#xff08;Master节点操作&#xff09; 2.3 修改 Redis 配置文件&#xff08;Slave节点操作&#xff09; 2.4 验证主从效果 3 Redis 哨兵模…
阅读更多...
PHP 伪协议：使用 php://filter 为数据流应用过滤器

PHP 伪协议：使用 php://filter 为数据流应用过滤器

文章目录 参考环境PHP 伪协议概念为什么需要 PHP 伪协议&#xff1f; php://filter概念格式 基本使用普通读写file_get_contents 与 file_put_contentsinclude 过滤器的基本使用base64 的编码与解码rot13 加解密rot13 算法string.rot13 过滤器列表多个过滤器的使用注意事项 处理…
阅读更多...
TensorFlow案例学习：对服装图像进行分类

TensorFlow案例学习：对服装图像进行分类

前言 官方为我们提供了一个 对服装图像进行分类 的案例&#xff0c;方便我们快速学习 学习 预处理数据 案例中有下面这段代码 # 预处理数据&#xff0c;检查训练集中的第一个图像可以看到像素值处于0~255之间 plt.figure() # 创建图像窗口 plt.imshow(train_images[0]) # …
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023