RabbitMq架构原理剖析及应用

embedded/2024/9/23 3:21:51/

文章目录

      • RabbitMQ 架构组件
        • 1. **Broker** (Broker Server)
        • 2. **Exchange**
        • 3. **Queue**
        • 4. **Producer** (消息生产者)
        • 5. **Consumer** (消息消费者)
        • 6. **Virtual Hosts** (虚拟主机)
      • 工作流程
      • 内部原理
        • 1. **队列管理**
        • 2. **集群**
        • 3. **持久化与内存**
        • 4. **性能优化**
      • 高级特性
        • 1. **消息确认**
        • 2. **消息过期**
        • 3. **镜像队列**
      • 总结
      • 案例应用

RabbitMQ 是一个广泛使用的开源消息代理和队列服务器,它基于 AMQP(Advanced Message Queuing Protocol)标准,使用 Erlang 语言编写。RabbitMQ 提供了高可用性、灵活性和可扩展性,使其成为企业级应用程序中消息传递的首选解决方案之一。

RabbitMQ 架构组件

1. Broker (Broker Server)

这是 RabbitMQ 服务器实体,负责接收来自生产者的消息并将它们路由到队列。

2. Exchange

交换机定义了消息应该怎样路由到队列。有几种不同类型的交换机,比如 direct, fanout, topic 等。每种类型决定了消息如何被分发。

  • Direct: 消息只发送到与特定routing key绑定的队列。
  • Fanout: 消息广播到所有绑定到该交换机的队列。
  • Topic: 允许使用通配符来绑定队列,可以根据模式匹配来发送消息。
3. Queue

队列是消息的容器,消息被存储在这里直到被消费者消费。每个消息会被送到一个或多个队列。

4. Producer (消息生产者)

生产者是向 RabbitMQ 发送消息的应用程序。

5. Consumer (消息消费者)

消费者是从 RabbitMQ 接收消息的应用程序。通常,消费者会订阅一个队列,并且一旦队列中有消息就会接收到消息。

6. Virtual Hosts (虚拟主机)

虚拟主机是 RabbitMQ 中的命名空间,用于隔离不同的应用环境或租户。每个虚拟主机都有自己的交换机、队列和绑定。

工作流程

  1. 消息发布: 生产者将消息发送到交换机。
  2. 消息路由: 交换机会根据定义的规则将消息路由到一个或多个队列。
  3. 消息存储: 消息存储在队列中,等待被消费者消费。
  4. 消息消费: 消费者从队列中获取消息并处理。

内部原理

1. 队列管理
  • 队列中的消息在被消费者消费前,一直保留在队列中。
  • 每个队列只能存在于一个节点上,但其元数据会在所有集群节点间共享。
2. 集群
  • RabbitMQ 支持集群模式,允许水平扩展。
  • 集群中的所有节点共享相同的元数据(队列、交换机、绑定等),但实际的消息数据只存储在一个节点上。
3. 持久化与内存
  • RabbitMQ 可以将消息存储在内存或磁盘上。
  • 持久化消息确保即使服务重启也能保证消息不丢失。
4. 性能优化
  • RabbitMQ 使用 Erlang 实现,Erlang 以其轻量级进程和高并发能力而闻名。
  • 使用预取机制来减少网络往返延迟,提高消息处理速度。

高级特性

1. 消息确认
  • 消费者可以确认已正确处理的消息,以避免消息丢失。
  • 如果消费者崩溃,未确认的消息将重新发布。
2. 消息过期
  • 可以为消息设置TTL(Time To Live)属性,超过该时间的消息将自动被删除。
3. 镜像队列
  • 在集群环境中,可以配置镜像队列,使得队列的数据在多个节点上都有副本,提高可用性。

总结

RabbitMQ 的架构设计考虑到了可伸缩性、可靠性和灵活性。通过使用不同的交换机类型、队列管理和集群技术,RabbitMQ 能够满足复杂的应用场景需求,包括但不限于消息的发布/订阅、任务队列、事件驱动架构等。

案例应用

为了提供一个具体的代码示例,我们可以考虑一个简单的场景:一个系统需要发送电子邮件通知,使用RabbitMQ来异步处理这些邮件通知。

在这个例子中,我们将使用 Java 和 Spring Boot 框架来创建一个简单的服务,它包括以下几个部分:

  1. RabbitMQ 配置 - 设置RabbitMQ连接和队列。
  2. 生产者 - 当用户下单时,发送一条消息到RabbitMQ队列。
  3. 消费者 - 监听RabbitMQ队列,并处理邮件发送。

首先,我们需要添加Spring Boot依赖项。如果你使用的是Maven,可以在pom.xml文件中添加以下依赖项:

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><!-- 其他依赖项 -->
</dependencies>

接下来是RabbitMQ的配置类:

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitConfig {public static final String QUEUE_NAME = "emailQueue";@Beanpublic Queue queue() {return new Queue(QUEUE_NAME);}
}

这里定义了一个名为emailQueue的队列,用于存放邮件发送任务。

接着是生产者端的代码:

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class EmailProducerService {private static final String QUEUE_NAME = "emailQueue";@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendEmail(String email, String subject, String body) {System.out.println("Sending message = " + body);// 创建一个包含邮件信息的对象Email emailMessage = new Email(email, subject, body);// 发送到队列this.rabbitTemplate.convertAndSend(QUEUE_NAME, emailMessage);}static class Email {private String to;private String subject;private String body;public Email(String to, String subject, String body) {this.to = to;this.subject = subject;this.body = body;}public String getTo() {return to;}public String getSubject() {return subject;}public String getBody() {return body;}}
}

这里定义了一个EmailProducerService类,它负责发送邮件消息到队列。

最后,我们编写消费者端的代码:

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class EmailConsumerService {@RabbitListener(queues = "emailQueue")public void processEmail(Email email) {System.out.println("Received email: " + email.getBody());// 实现发送邮件的逻辑sendEmail(email.getTo(), email.getSubject(), email.getBody());}private void sendEmail(String to, String subject, String body) {// 这里可以使用JavaMailSender或其他邮件发送服务// 例如:// JavaMailSender mailSender = ...;// SimpleMailMessage message = new SimpleMailMessage();// message.setTo(to);// message.setSubject(subject);// message.setText(body);// mailSender.send(message);System.out.println("Email sent to: " + to + ", Subject: " + subject + ", Body: " + body);}
}

在上面的代码中,我们使用了@RabbitListener注解来监听emailQueue队列中的消息。当队列中有新消息时,processEmail方法会被调用,并发送邮件。

这个例子非常简单,但在实际应用中,你可能还需要处理错误、重试机制、日志记录等更复杂的情况。此外,你还需要配置RabbitMQ的连接参数,这可以通过application.propertiesapplication.yml文件来完成。

这个例子展示了如何使用RabbitMQ进行异步消息处理的基本原理。你可以在此基础上扩展功能和改进代码结构。

😍😍 海量H5小游戏、微信小游戏、Web casualgame源码😍😍
😍😍试玩地址: https://www.bojiogame.sg😍😍
😍看上哪一款,需要源码的csdn私信我😍

————————————————

​最后我们放松一下眼睛
在这里插入图片描述


http://www.ppmy.cn/embedded/90273.html

相关文章

C# 知识点总结

入门 C#程序在.NET上运行&#xff0c;.NET framework包含两个部分&#xff1a; ①&#xff1a;.NET framework类库 ②&#xff1a;公共语言运行库CLR&#xff08;.NET虚拟机&#xff09; CLS&#xff08;公共语言规范&#xff09; CTS&#xff08;通用类型系统&#xff09; .N…

详解C/C++输入输出

前言 C/C输入输出很多&#xff0c;在不同的情况会用不同的输入输出&#xff0c;有的题目在输入时可能换一种输入输出就能不会TLE&#xff0c;有的输入可能要循环输入&#xff0c;但是可以换一种输入直接就能把所有数据输入进去。C/C有哪些常用的输入输出&#xff0c;在什么时候…

c++数组

数组&#xff1a;相同数据类型的元素组成的集合。 如果说变量是一个盒子&#xff0c;那么数组就是一堆盒子为了区分这些盒子&#xff0c;每个盒子都会依次进行编号。 一维数组&#xff1a;单个变量类似于一个空间&#xff0c;一维数组是指在一排&#xff0c;有多个连续的空间。…

【Vulnhub靶机tomato渗透】

第一步&#xff1a;端口扫描 我使用的是webrobot 访问这个ip&#xff0c;就是它了 第二步&#xff1a;目录扫描 打开kali使用dirb命令扫描http://192.168.189.154下的目录 dirb http://192.168.189.154扫描到目录。 第三步&#xff1a;访问目录地址 看到有几个php的文件 第…

pip‘ 不是内部或外部命令,也不是可运行的程序 或批处理文件。

重新设置一下环境变量。 注意&#xff0c;这里后面没有斜杠 我之前就是因为环境变量中&#xff0c;这两行最后都有斜杠&#xff0c;导致提示pip‘ 不是内部或外部命令,也不是可运行的程序 或批处理文件。

base64 转 pdf

工作中经常会遇到一些签名的pdf传输&#xff0c;一般都是base64编码&#xff0c;这样就需要我们手动转为pdf&#xff0c; 其实根本不需要自己使用pdf的库写入&#xff0c;只是数据的简单写入就行 package mainimport ("encoding/base64""fmt""os&quo…

yield and generator in python

首先&#xff0c;假设大家都对于pytyhon的List comprehension的使用有了一定经验&#xff08;它可以用于list&#xff0c;set&#xff0c;和dict哦&#xff09; 不熟悉的参考介绍&#xff1a; Comprehending Python’s Comprehensions – dbader.org generator generator是哦…

分享c语言中一些实用的函数2

目录 一.头文件 1.sqrt()函数 2.sin&#xff0c;cos&#xff0c;tan函数 附加:宏定义π 3.exp函数 4.fabs函数 5.fmax函数 6.floor函数 7.log函数 附加&#xff1a;求一个数是几为数(运用floor函数和log函数) 8.pow函数 二.头文件 1.abs函数 附加: 一.头文件<…