哪些网站是用python做的网站的发展趋势

哪些网站是用python做的,网站的发展趋势,自己做公众号和小说网站推广,酷炫网站首页RabbitMQ 作为一款高性能的开源消息队列#xff0c;基于 AMQP#xff08;高级消息队列协议#xff09;实现#xff0c;凭借其轻量级、高可用、易扩展的特性#xff0c;被广泛应用于分布式系统的解耦、异步通信、流量削峰等场景。RabbitMQ 的核心能力体现在多种消息投递模式…RabbitMQ 作为一款高性能的开源消息队列基于 AMQP高级消息队列协议实现凭借其轻量级、高可用、易扩展的特性被广泛应用于分布式系统的解耦、异步通信、流量削峰等场景。RabbitMQ 的核心能力体现在多种消息投递模式上本文作为系列第一篇将深入解析简单模式Simple Mode和工作队列模式Work Queue Mode结合代码实现与场景分析让你彻底掌握这两种基础模式的使用。一、前置知识RabbitMQ 核心概念在正式讲解模式之前先快速回顾 RabbitMQ 的几个核心概念为后续理解铺路生产者Producer发送消息的应用程序。消费者Consumer接收并处理消息的应用程序。队列Queue消息的存储容器RabbitMQ 的消息只能存储在队列中生产者向队列发消息消费者从队列取消息。交换机Exchange在高级模式中负责消息路由简单模式和工作队列模式中会默认使用内置的默认交换机。绑定Binding将交换机与队列关联起来的规则决定消息如何从交换机路由到队列。二、简单模式Simple Mode一对一的消息通信2.1 模式原理简单模式是 RabbitMQ 最基础的模式也被称为点对点模式其核心架构是一个生产者、一个队列、一个消费者消息从生产者直接发送到队列再由唯一的消费者消费。核心特点生产者通过默认交换机名称为空字符串将消息发送到指定队列默认交换机是直连交换机会根据消息的routing key匹配队列名称进行路由。队列是消息的载体生产者发送的消息会先存储在队列中消费者主动从队列拉取消息或队列推送消息给消费者。一个队列仅对应一个消费者消费者消费完消息后消息会从队列中被移除。简单模式的架构图如下生产者Producer→ 队列Queue→ 消费者Consumer2.2 代码实现基于 Java Spring AMQP本文采用 Spring Boot 整合 Spring AMQP 的方式实现相比原生的 RabbitMQ ClientSpring AMQP 提供了更简洁的 API 和自动配置开发效率更高。步骤 1引入依赖在pom.xml中添加 Spring Boot 与 RabbitMQ 的整合依赖dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-amqp/artifactId /dependency步骤 2配置 RabbitMQ 连接在application.yml中配置 RabbitMQ 的连接信息spring: rabbitmq: host: localhost # RabbitMQ服务地址 port: 5672 # 默认端口 username: guest # 默认用户名 password: guest # 默认密码 virtual-host: / # 默认虚拟主机步骤 3声明队列创建配置类声明简单模式使用的队列队列名称为simple.queueimport org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; Configuration public class RabbitMQConfig { /** * 声明简单模式的队列 * 队列特点持久化、非排他、非自动删除 */ Bean public Queue simpleQueue() { return new Queue(simple.queue, true, false, false); } }步骤 4实现生产者发送消息创建生产者类通过RabbitTemplate发送消息到队列import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.stereotype.Component; import javax.annotation.Resource; Component public class SimpleProducer { Resource private RabbitTemplate rabbitTemplate; /** * 发送消息到简单队列 * param message 消息内容 */ public void sendMessage(String message) { rabbitTemplate.convertAndSend(simple.queue, message); System.out.println(简单模式生产者发送消息 message); } }步骤 5实现消费者接收消息创建消费者类监听队列并处理消息import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; Component public class SimpleConsumer { /** * 监听简单队列消费消息 * param message 消息内容 */ RabbitListener(queues simple.queue) public void consumeMessage(String message) { System.out.println(简单模式消费者接收消息 message); // 这里可以添加消息处理逻辑比如业务逻辑调用、数据存储等 } }步骤 6测试代码创建测试类调用生产者发送消息import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; SpringBootTest public class SimpleModeTest { Resource private SimpleProducer simpleProducer; Test public void testSendMessage() { simpleProducer.sendMessage(Hello, RabbitMQ Simple Mode!); // 休眠1秒确保消费者有时间处理消息 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }运行测试后控制台会输出生产者发送的消息和消费者接收的消息说明简单模式的消息通信成功。2.3 场景分析简单模式适用于一对一的消息通信场景典型应用场景包括简单的异步通知比如用户注册后发送一封激活邮件生产者发送注册用户信息到队列消费者接收后调用邮件发送接口。单一任务的处理比如后台系统接收到一个数据导入请求生产者将请求参数发送到队列消费者接收后执行数据导入操作。日志收集简单场景比如小型应用的日志收集生产者将日志消息发送到队列消费者接收后将日志写入文件。注意简单模式的局限性在于当消费者处理能力不足时消息会在队列中堆积无法通过横向扩展消费者来提高处理效率这时候就需要用到工作队列模式。三、工作队列模式Work Queue Mode一对多的消息分发3.1 模式原理工作队列模式也被称为任务队列模式Task Queue其核心架构是一个生产者、一个队列、多个消费者消息从生产者发送到队列后由多个消费者竞争消费每个消息只会被其中一个消费者处理。核心特点生产者依然通过默认交换机将消息发送到指定队列队列存储消息。多个消费者监听同一个队列RabbitMQ 默认采用轮询Round-Robin策略分发消息即依次将消息分发给不同的消费者。支持消息确认ACK机制确保消息被消费者处理完成后才从队列中移除避免消息丢失。可以通过设置消费者的prefetchCount预取数量控制消费者一次获取的消息数量实现负载均衡。工作队列模式的架构图如下生产者Producer→ 队列Queue→ 消费者1Consumer1 ↓ → 消费者2Consumer2 ↓ → 消费者3Consumer33.2 代码实现基于 Java Spring AMQP工作队列模式的代码在简单模式的基础上主要增加多个消费者并可配置消息确认和预取数量。步骤 1复用队列声明同简单模式工作队列模式使用的队列可以复用之前的simple.queue也可以新建队列比如work.queue这里我们新建一个工作队列Configuration public class RabbitMQConfig { // 简单模式队列复用 Bean public Queue simpleQueue() { return new Queue(simple.queue, true, false, false); } /** * 声明工作队列 */ Bean public Queue workQueue() { return new Queue(work.queue, true, false, false); } }步骤 2实现生产者发送消息生产者代码与简单模式类似只是发送到工作队列import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.stereotype.Component; import javax.annotation.Resource; Component public class WorkProducer { Resource private RabbitTemplate rabbitTemplate; /** * 发送消息到工作队列 * param message 消息内容 */ public void sendMessage(String message) { rabbitTemplate.convertAndSend(work.queue, message); System.out.println(工作队列模式生产者发送消息 message); } /** * 批量发送消息用于测试多个消费者的分发效果 * param count 消息数量 */ public void sendBatchMessage(int count) { for (int i 1; i count; i) { String message Work Queue Message i; rabbitTemplate.convertAndSend(work.queue, message); System.out.println(工作队列模式生产者发送消息 message); } } }步骤 3实现多个消费者接收消息创建两个消费者监听同一个工作队列并模拟不同的处理耗时体现负载均衡的需求消费者 1import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; Component public class WorkConsumer1 { /** * 监听工作队列消费消息处理耗时较短 * param message 消息内容 */ RabbitListener(queues work.queue) public void consumeMessage(String message) { System.out.println(工作队列消费者1接收消息 message); // 模拟处理耗时100毫秒 try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(工作队列消费者1处理完成 message); } }消费者 2import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; Component public class WorkConsumer2 { /** * 监听工作队列消费消息处理耗时较长 * param message 消息内容 */ RabbitListener(queues work.queue) public void consumeMessage(String message) { System.out.println(工作队列消费者2接收消息 message); // 模拟处理耗时500毫秒 try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(工作队列消费者2处理完成 message); } }步骤 4配置消息确认和预取数量优化负载均衡默认的轮询策略会忽略消费者的处理能力导致处理慢的消费者堆积大量消息。我们可以通过配置prefetchCount预取数量让消费者一次只获取指定数量的消息处理完再获取下一批实现更合理的负载均衡。在application.yml中添加配置spring: rabbitmq: host: localhost port: 5672 username: guest password: guest virtual-host: / listener: simple: acknowledge-mode: manual # 手动确认消息默认是auto自动确认 prefetch: 1 # 预取数量为1即消费者一次只能处理一条消息处理完再取修改消费者代码添加手动确认消息的逻辑以消费者 1 为例消费者 2 同理import com.rabbitmq.client.Channel; import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; import java.io.IOException; Component public class WorkConsumer1 { /** * 监听工作队列消费消息手动确认 * param message 消息内容 * param channel 信道 * param msg AMQP消息对象 */ RabbitListener(queues work.queue) public void consumeMessage(String message, Channel channel, Message msg) throws IOException { try { System.out.println(工作队列消费者1接收消息 message); // 模拟处理耗时100毫秒 Thread.sleep(100); System.out.println(工作队列消费者1处理完成 message); // 手动确认消息第二个参数表示是否批量确认 channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); } catch (InterruptedException e) { e.printStackTrace(); // 处理失败时拒绝消息并重新入队根据业务需求调整 channel.basicNack(msg.getMessageProperties().getDeliveryTag(), false, true); } } }步骤 5测试代码创建测试类批量发送消息观察多个消费者的消费情况import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; SpringBootTest public class WorkModeTest { Resource private WorkProducer workProducer; Test public void testSendBatchMessage() { // 批量发送10条消息 workProducer.sendBatchMessage(10); // 休眠10秒确保消费者有时间处理所有消息 try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } } }运行测试后会发现消费者 1处理快会消费更多的消息而消费者 2处理慢消费较少的消息实现了基于处理能力的负载均衡。3.3 场景分析工作队列模式适用于单个队列有大量消息需要处理且希望通过多个消费者提高处理效率的场景典型应用场景包括任务分发比如电商平台的订单处理生产者将订单消息发送到队列多个消费者同时处理订单如库存扣减、支付确认、物流通知等。图片处理用户上传图片后需要对图片进行压缩、裁剪、水印等处理生产者将图片信息发送到队列多个消费者并行处理图片。数据计算大数据场景下的简单计算任务生产者将计算任务发送到队列多个消费者分布式计算提高计算效率。流量削峰比如秒杀活动中大量的下单请求发送到队列多个消费者慢慢处理避免系统被瞬间高流量冲垮。关键优化点消息持久化队列和消息都设置为持久化避免 RabbitMQ 重启后消息丢失。手动消息确认确保消费者处理完消息后再确认避免消息丢失。预取数量配置根据消费者的处理能力设置prefetchCount实现负载均衡。消费者限流通过prefetchCount限制消费者的并发处理数量防止消费者过载。四、简单模式 vs 工作队列模式为了更清晰地对比两种模式的差异我们整理了如下表格特性简单模式工作队列模式消费者数量一个多个消息分发策略单一消费者独占所有消息轮询 / 基于预取的负载均衡处理效率低单消费者高多消费者并行处理适用场景一对一简单通信高并发任务处理、负载均衡扩展性差无法横向扩展消费者好可动态增加消费者五、总结本文详细讲解了 RabbitMQ 的两种基础模式简单模式和工作队列模式。简单模式是一对一的消息通信适用于简单的异步场景工作队列模式是一对多的消息分发通过多个消费者并行处理消息适用于高并发任务处理场景。在实际开发中需要根据业务场景选择合适的模式如果是简单的异步通知使用简单模式即可如果是大量任务需要处理建议使用工作队列模式并结合消息持久化、手动确认、预取数量配置等优化手段确保消息处理的可靠性和效率。下一篇文章我们将继续讲解 RabbitMQ 的另外三种核心模式发布 / 订阅模式、路由模式和主题模式敬请期待