RabbitMQ 系列教程

一、RabbitMQ 部署及配置详解(集群部署)

二、RabbitMQ 部署及配置详解 (单机)

三、RabbitMQ 详解及实例（含错误信息处理）

四、RabbitMq死信队列及其处理方案

五、RabbitMQ Java开发教程—官方原版 

六、RabbitMQ Java开发教程（二）—官方原版

七、RabbitMQ Java开发教程（三）—官方原版_

 

 

一、RabbitMQ 核心概念

1. 生产者和消费者

Producer: 消息的生产者,用于发布消息；

Consumer: 消息的消费者，用于从队列中获取消息.消费者只需关注队列即可，不需要关注交换机和路由键。消费者可以通过basicConsume(订阅模式可以从队列中一直持续的自动的接收消息)或者basicGet(先订阅消息,然后获取单条消息，再然后取消订阅。也就是说basicGet一次只能获取一条消息，如果还想再获取下一条还要再次调用basicGet)来从队列中获取消息。

2. RabbitMQ broker 服务器

RabbitMQ broker: 官方定义"RabbitMQ isn’t a food truck, it’s a delivery service"，指明RabbitMQ是一种传输服务。

3. ExChange 交换机

Exchange: 生产者会将消息发送到交换机，然后交换机通过路由策略(规则)将消息路由到匹配的队列中去。ExchangeType决定了Exchange路由消息的行为，在RabbitMQ中，ExchangeType有direct、Fanout、Topic和Header 4种。Exchange 类似于数据通信网络中的交换机,提供消息路由策略。

在RabbitMQ 中，Producer 不是通过信道直接将消息发送给 Queue，而是先发送给 ExChange. 一个 ExChange 可以和多个 Queue 进行绑定，Producer 在传递消息的时候，会传递一个 ROUTING_KEY, ExChange 会根据这个 ROUTING_KEY 按照特定的路由算法,将消息路由给指定的 Message Queue。与 Queue 一样, ExChange 也可设置为持久化，临时或者自动删除。

4. Binding 绑定

所谓绑定就是将一个特定的 ExChange 和一个特定的 Queue 绑定起来,所以Binding不是一个概念，而是一种操作。RabbitMQ中通过绑定,以路由键作为桥梁将Exchange与Queue关联起来()Exchange—>Routing Key—>Queue，这样RabbitMQ就知道如何正确地将消息路由到指定的队列了，通过queueBind()方法将Exchange、Routing Key、Queue绑定起来.ExChange 和 Queue 的绑定可以是多对多的关系。

5. Binding Key 绑定键

Binding Key: 它表示的是Exchange与Message Queue是通过binding key进行绑定联系的，这个关系是固定的。初始化的时候，我们就会建立该队列。

6. Routing Key 路由键

Routing Key: 它是一个String值，用于定义路由规则。生产者在将消息发送给Exchange的时候，一般会指定一个routing key，来指定这个消息的路由规则。在队列绑定的时候需要指定路由键，在生产者发布消息的时候需要指定路由键，当消息的路由键和队列绑定的路由键匹配时，消息就会发送到该队列。

7. Message Queue 消息队列

用于存储消息的容器,可以看成一个有序的数组,生产者生产的消息会发送到交换机中,最终交换机将消息存储到某个或某些队列中。队列可被消费者订阅,消费者从订阅的队列中获取消息。

Message Queue: 消息队列,我们发送给RabbitMQ的消息最后都会到达各种queue,并且存储在其中(如果路由找不到相应的queue则数据会丢失),等待消费者来取.

消息队列提供了 FIFO 的处理机制,具有缓存消息的能力.在RabbitMQ 中,队列消息可以设置为持久化,临时或者自动删除.

设置为持久化的队列,Queue 中的消息会在 Server 本地硬盘存储一份,防止系统 Crash,数据丢失;

设置为临时的队列,Queue 中的数据在系统重启之后就会丢失;

设置为自动删除的队列,当没有用户连接到 Server,队列中的数据会被自动删除。

8. Virtual Host 虚拟主机

每一个RabbitMQ服务器都能创建多个虚拟消息服务器,我们称之为虚拟主机.每一个vhost本质上是一个mini版的RabbitMQ服务器,拥有自己的交换机、队列、绑定等,拥有自己的权限机制.vhost相对于RabbitMQ就像虚拟机之于物理机一样.他们通过在各个实例间提供逻辑上的分离,允许不同的应用程序安全保密的运行数据,这很有用,它既能将同一个Rabbit的众多客户区分开来,又可以避免队列和交换器的命名冲突.RabbitMQ提供了开箱即用的默认的虚拟主机“/”,如果不需要多个vhost可以直接使用这个默认的vhost,通过使用缺省的guest用户名和guest密码来访问默认的vhost.

vhost之间是相互独立的,这避免了各种命名的冲突,就像App中的沙盒的概念一样,每个沙盒是相互独立的,且只能访问自己的沙盒,以保证非法访问别的沙盒带来的安全隐患.

二、RabbitMQ部署

rabbitmq部署有三种模式：单机模式，普通集群模式，镜像集群模式

RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现

1、安装erlang环境

由于rabbitmq是基于erlang语言开发的，所以必须先安装erlang。

wget http://erlang.org/download/otp_src_20.0.tar.gz
tar -zxvf otp_src_20.0.tar.gz
cd otp_src_20.0
./configure --prefix=/usr/local/erlang --without-javac
make
make install

加入环境变量

vim /etc/profile
在最后添加：
export ERLANG_HOME=/usr/local/erlang
export PATH=$PATH:/usr/local/erlang/bin

运行以下命令，使环境变量立即生效

source /etc/profile

验证erl是否成功安装

erl

2、单机模式安装

安装 rabbitmq

可以去官网手动下载（Downloading and Installing RabbitMQ — RabbitMQ）也可以通过wget命令下载

cd /opt
wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.11.6/rabbitmq-server-3.11.6.tar.xz
xz -d rabbitmq-server-generic-unix-3.11.6.tar.xz
tar -xvf rabbitmq-server-generic-unix-3.6.10.tar
cp -r /opt/rabbitmq_server-3.6.10 /usr/local/rabbitmq
注：该方式安装的RabbitMQ是没有配置文件的，如需要配置文件，需手动进行配置，文件置于自己Rabbitmq安装路径下的 /etc/rabbitmq/rabbitmq.conf 即可，再管理页面或者日志中都可以查看到路径位置 
/usr/local/rabbitmq/sbin/rabbitmq-server -detached
echo "/usr/local/rabbitmq/sbin/rabbitmq-server -detached" >> /etc/rc.local      #添加开机自启动。

开启 web 管理界面

/usr/local/rabbitmq/sbin/rabbitmq-plugins enable rabbitmq_management

RabbitMQ默认的账号用户名和密码都是guest。

rabbitmqctl delete_user guest

创建RabbitMQ管理员用户

#创建一个新用户
rabbitmqctl add_user <用户名> <密码>
#将创建的新用户设置为管理员
rabbitmqctl set_user_tags <用户名> administrator
#赋予新创建的用户所有权限
rabbitmqctl set_permissions -p / <用户名> ".*" ".*" ".*"

在本地主机中，使用浏览器访问Linux实例的公网IP:15672。

显示如下页面，说明RabbitMQ安装成功。

3、普通集群模式

在多台机器上启动多个rabbitmq实例，每个机器启动一个。

但是你创建的queue，只会放在一个rabbtimq实例上，但是每个实例都同步queue的元数据(存放含queue数据的真正实例位置)。消费的时候，实际上如果连接到了另外一个实例，那么那个实例会从queue所在实例上拉取数据过来。

三、配置文件详解

所有​ ​受支持的RabbitMQ版本​​​ 的主配置文件都使用​ ​类似ini的sysctl配置文件格式​​。该文件通常命名为Rabbitmq.conf。

rabbitmq.conf

新样式格式（sysctl或类似ini的格式）

​主配置文件​​。应该用于大多数设置。对于人类来说，阅读和机器（部署工具）的生成更容易。并非所有设置都可以这种格式表示。

advanced.config

经典（Erlang术语）

不能以新样式配置格式表示的有限数量的设置，例如​ ​LDAP查询​​。仅在必要时使用。

rabbitmq-env.conf

环境变量对

用于在一处设置与RabbitMQ相关的​ ​环境变量​​。

 

 四、开发实例

 1、引入依赖，pom文件：

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

2、基本配置文件：

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

/*rabbitMq基本配置*/
@Configuration
public class RabbitMqConfig {
    public final static String productExchange = "productExchange ";
    private String productQueue = "productQueue";
    public final static String ERROR_EXCHANGE = "le.error.exchange";
    private String topicExchangeName = "";

    @Bean
    public FanoutExchange productExchange() {
        return new FanoutExchange(productExchange);
    }

    public TopicExchange topicExchange() {
        return new TopicExchange(topicExchangeName);
    }

    @Bean
    public DirectExchange errorExchang() {
        return new DirectExchange(ERROR_EXCHANGE, true, false);
    }

    @Bean
    public Queue productQueue() {
        return new Queue(productQueue, true);
    }

    @Bean
    public Binding productBinding(Queue productQueue, FanoutExchange productExchange) {
        return BindingBuilder.bind(productQueue).to(productExchange);
    }
}

3、生产者:

@Component
public class ProductProducer {


    Logger logger = LoggerFactory.getLogger(ProductProducer.class);

    @Autowired
    RabbitTemplate rabbitTemplate;

    @Autowired
    Gson gson;

    public void push(ProfitEntity profitEntity) {
        String json = gson.toJson("");
        logger.info("###消息发送者: json＝" + json); 
        rabbitTemplate.convertAndSend(RabbitmqConfig.Product_EXCHANGE, null, json);
    }


}

4、消费者：

@Component
public class TransProductConsumer {

    Logger logger = LoggerFactory.getLogger(TransproductConsumer.class);

    @Autowired
    RabbitTemplate rabbitTemplate;

    @Autowired
    ErrorProducer errorProducer;

    @Autowired
    ProductService productService;

    
    @RabbitHandler
    @RabbitListener(queues = RabbitmqConfig.productQueue )
    public void comsume(String json) {
        try {
            logger.info("##start##消费者：TransProductConsumer ，接收到消息：json＝" + json);
           
        } catch (Exception e) {
            logger.error("计算消息队列出错 zf.Product.caculate.queue ", e);
            errorProducer.push(RabbitmqConfig.ERROR_PROFIT_CACULATE_QUEUE, json);
        }
    }
}

5、错误消息处理生产者：

@Component
public class ErrorProducer {
 
    Logger logger = LoggerFactory.getLogger(TransDetailProducer.class);
 
    @Autowired
    RabbitTemplate rabbitTemplate;
 
    @Autowired
    Gson gson;
 
    public void push(String queueName, String errorJson) {
        logger.info("###异常消息发送者: queueName=" + queueName + " errorJson＝" + errorJson);
        rabbitTemplate.convertAndSend(RabbitmqConfig.ERROR_EXCHANGE, queueName, errorJson);
    }
 
    public void push(String queueName, Object obj) {
        String errorJson = gson.toJson(obj);
        logger.info("###异常消息发送者: queueName=" + queueName + " errorJson＝" + errorJson);
        rabbitTemplate.convertAndSend(RabbitmqConfig.ERROR_EXCHANGE, queueName, errorJson);
    }
 
}

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

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

相关文章

视频编软件会声会影2024中文版功能介绍

视频编软件会声会影2024中文版功能介绍

会声会影2024中文版是一款加拿大公司Corel发布的视频编软件。会声会影2024官方版支持视频合并、剪辑、屏幕录制、光盘制作、添加特效、字幕和配音等功能&#xff0c;用户可以快速上手。会声会影2024软件还包含了视频教学以及模板素材&#xff0c;让用户剪辑视频更加的轻松。 会…
阅读更多...
FPGA配置采集AR0135工业相机，提供2套工程源码和技术支持

FPGA配置采集AR0135工业相机，提供2套工程源码和技术支持

目录 1、前言免责声明 2、AR0135工业相机简介3、我这里已有的 FPGA 图像处理解决方案4、设计思路框架AR0135配置和采集图像缓存视频输出 5、vivado工程1–>Kintex7开发板工程6、vivado工程1–>Zynq7100开发板工程7、上板调试验证8、福利&#xff1a;工程代码的获取 1、前…
阅读更多...
投票助手图文音视频礼物打赏流量主小程序开源版开发

投票助手图文音视频礼物打赏流量主小程序开源版开发

投票助手图文音视频礼物打赏流量主小程序开源版开发 图文投票&#xff1a;用户可以发布图文投票&#xff0c;选择相应的选项进行投票。 音视频投票&#xff1a;用户可以发布音视频投票&#xff0c;观看音视频后选择相应的选项进行投票。 礼物打赏&#xff1a;用户可以在投票过…
阅读更多...
安卓开发实例：高德地图

安卓开发实例：高德地图

想要在app里面显示高德地图&#xff0c;遇到了很多问题&#xff0c;开始想显示百度地图的&#xff0c;个人感觉不喜欢百度地图&#xff0c;跟高德地图有缘&#xff0c;所以就弄个高德地图。 当然你可以直接看开发文档啊&#xff0c;慢走不送&#xff0c;谢谢。 https://lbs.ama…
阅读更多...
3-知识补充-MVC框架

3-知识补充-MVC框架

3-知识补充-MVC框架 文章目录 3-知识补充-MVC框架MVC概述M、V、C各自负责功能及常用包MVC框架图非前后端分离框架图前后端分离框架图 MVC概述 MVC&#xff08;Model、View、Controller&#xff09;是软件工程中的一种**软件架构模式&#xff0c;它把软件系统分为模型、视图和控…
阅读更多...
【Python自学笔记】python os.getcwd文件目录找不对关于“None”在VSCode里面的奇葩报错

【Python自学笔记】python os.getcwd文件目录找不对关于“None”在VSCode里面的奇葩报错

写小组项目的时候需要按照路径读入数据表&#xff0c;数据库和图片列表显示到html&#xff0c;按ChatGPT的答案写了python os.getcwd()&#xff0c;结果迁移到同组同学的电脑上总是报错。 经过一番查询&#xff0c;在CSDN上发现一个完美解决问题的好帖&#xff0c;特此存下链接…
阅读更多...
商业模式思维导图

商业模式思维导图

一、什么是商业模式&#xff1f;简单的说&#xff0c;商业模式就是公司通过什么途径或方式来赚钱&#xff1f; 商业模式的核心是 创造价值-获取价值-传递价值。 它有3个重要的环节&#xff0c;创造价值是基于客户需求&#xff0c;提供解决方案&#xff0c;传递价值是通过资源配…
阅读更多...
Linux重定向和缓冲区

Linux重定向和缓冲区

文章目录 知识回顾&取地址重定向 重定向底层文件描述符分配规则dup2标准输出和标准错误的区别 缓冲区缓冲区总结 知识回顾 我们在之前有了解过输出重定向>, >>,可以让echo命令本来是打印到屏幕上而变成了把这些数据写到文件中&#xff0c;并且可以追加或者覆盖文…
阅读更多...
操作系统 day09（线程）

操作系统 day09（线程）

线程 为什么引入线程 在没引入进程之前&#xff0c;系统中的各个程序只能串行的执行&#xff0c;比如&#xff1a;只能先听歌&#xff0c;再聊QQ。引入进程之后&#xff0c;各个程序可以并发执行&#xff0c;比如&#xff1a;一边听歌&#xff0c;一边聊QQ。但是现在QQ可以一…
阅读更多...
使用篇(一):Ai绘图-Stable Diffusion WebUI

使用篇(一):Ai绘图-Stable Diffusion WebUI

1.介绍 1.1 概述 Stable Diffusion Web UI是一个基于Stable diffusion AI模型的AI绘画软件。它是一个多功能的AI绘画软件&#xff0c;支持以下几个功能&#xff1a; 用户可以输入一堆关键词或一句话来生成图片。 它使用了图像加噪去噪过程中的生成模型—— Duffusion&#xff…
阅读更多...
Xilinx FPGA SPIx4 配置速度50M约束语句（Vivado开发环境）

Xilinx FPGA SPIx4 配置速度50M约束语句（Vivado开发环境）

qspi_50m.xdc文件&#xff1a; set_property BITSTREAM.GENERAL.COMPRESS TRUE [current_design] set_property BITSTREAM.CONFIG.SPI_BUSWIDTH 4 [current_design] set_property BITSTREAM.CONFIG.CONFIGRATE 50 [current_design] set_property CONFIG_VOLTAGE 3.3 [curren…
阅读更多...
【Unity细节】Json序列化时出现：An item with the same key has already been added. Key:

【Unity细节】Json序列化时出现：An item with the same key has already been added. Key:

&#x1f468;‍&#x1f4bb;个人主页&#xff1a;元宇宙-秩沅 hallo 欢迎 点赞&#x1f44d; 收藏⭐ 留言&#x1f4dd; 加关注✅! 本文由 秩沅 原创 &#x1f636;‍&#x1f32b;️收录于专栏&#xff1a;unity细节和bug &#x1f636;‍&#x1f32b;️优质专栏 ⭐【…
阅读更多...
【Unity细节】如何让组件失活而不是物体失活

【Unity细节】如何让组件失活而不是物体失活

&#x1f468;‍&#x1f4bb;个人主页&#xff1a;元宇宙-秩沅 hallo 欢迎 点赞&#x1f44d; 收藏⭐ 留言&#x1f4dd; 加关注✅! 本文由 秩沅 原创 &#x1f636;‍&#x1f32b;️收录于专栏&#xff1a;unity细节和bug &#x1f636;‍&#x1f32b;️优质专栏 ⭐【…
阅读更多...
揭秘！2024年热门的图标设计工具

揭秘！2024年热门的图标设计工具

在这个瞬息万变的世界里&#xff0c;设计师们对创新和实用的工具的渴望日益热切。我们需要时刻紧跟潮流&#xff0c;发掘和尝试最新&#xff0c;最有价值的图标设计工具&#xff0c;才能在剧烈的市场竞争中引人注目。以下是我们细心挑选的2024年图标设计工具的热门推荐&#xf…
阅读更多...
OpenAI开发者大会掀起风暴：GPT模型价格狂降50%，应用商店即将亮相，AI技术将引爆全球！

OpenAI开发者大会掀起风暴：GPT模型价格狂降50%，应用商店即将亮相，AI技术将引爆全球！

OpenAI首届开发者大会召开了&#xff01; 关键信息&#xff1a; GPT-4升级版GPT-4 Turbo来了&#xff0c;上下文窗口达到128k&#xff0c;为GPT-4的4倍&#xff1b;OpenAI还降低了几乎所有模型的API使用价格&#xff0c;整体便宜了一半多&#xff1b;GPT-4系列的多模态能力向B…
阅读更多...
2023年11月PHP测试覆盖率解决方案

2023年11月PHP测试覆盖率解决方案

【题记&#xff1a;最近进行了ExcelBDD PHP版的开发&#xff0c;查阅了大量资料&#xff0c;发现PHP测试覆盖率解决方案存在不同的历史版本&#xff0c;让我花费了蛮多时间&#xff0c;为了避免后人浪费时间&#xff0c;整理本文&#xff0c;而且网上没有给出Azure DevOps里面P…
阅读更多...
ElementUI之el-progress动态修改进度条里面文本颜色与进度条色块统一

ElementUI之el-progress动态修改进度条里面文本颜色与进度条色块统一

1.效果&#xff1a; 2.实现方式 通过行内style样式动态给整个progress赋颜色 再在样式里给进度条文字单独设置颜色为默认继承父级颜色就ok啦 <el-progress class"custom-progress" stroke-linecap"square" :style"{color:item.color}" :colo…
阅读更多...
cpu 支持内存带宽与内存最大长度的关系《鸟哥的 Linux 私房菜》

cpu 支持内存带宽与内存最大长度的关系《鸟哥的 Linux 私房菜》

鸟哥的 Linux 私房菜 -- 计算机概论 -- 計算机&#xff1a;辅助人脑的好工具 同理&#xff0c;64 位 cpu 一次接受内存传递的 64bit 数据&#xff0c;内存字节地址用 64 位记录&#xff0c;最多能记录2^64个字节2^64Bytes2^34GB17179869184GB2^24TB&#xff0c;理论上&#xff…
阅读更多...
使用 AIGC ，ChatGPT 快速合并Excel工作薄

使用 AIGC ，ChatGPT 快速合并Excel工作薄

职场数据处理&#xff0c;数据分析汇报与统计的过程中&#xff0c;经常会遇到这样的一个问题那就是需要统计的数据源在多个文件中&#xff0c;多个工作薄中&#xff0c;如果要进行数据处理&#xff0c;汇总的时候会很不方便 例如&#xff1a; 如果要汇总6个月的数据可能就得需…
阅读更多...
CSS实现透明度效果的两种方法—— opacity 和 rgba()

CSS实现透明度效果的两种方法—— opacity 和 rgba()

在实际开发过程中&#xff0c;为了给用户呈现一些效果&#xff0c;我们需要控制元素的透明度。CSS 提供了 opacity 属性和 rgba() 函数给我们控制透明度&#xff0c;接下来通过一个例子来感受一下两种方法的区别。 <style>.transparentBox {display: inline-block;width…
阅读更多...
最新文章

Copyright @ 2022~2023