【RabbitMQ】RabbitMQ 消息的可靠性 —— 生产者和消费者消息的确认，消息的持久化以及消费失败的重试机制

文章目录

  • 前言：消息的可靠性问题
  • 一、生产者消息的确认
    • 1.1 生产者确认机制
    • 1.2 实现生产者消息的确认
    • 1.3 验证生产者消息的确认
  • 二、消息的持久化
    • 2.1 演示消息的丢失
    • 2.2 声明持久化的交换机和队列
    • 2.3 发送持久化的消息
  • 三、消费者消息的确认
    • 3.1 配置消费者消息确认
    • 3.2 演示 none 模式
    • 3.3 演示 auto 模式
  • 四、消息消费失败的重试机制
    • 4.1 本地重试机制
    • 4.2 失败消息的处理策略

前言：消息的可靠性问题

在现代分布式应用程序中，消息队列扮演了至关重要的角色，允许系统中的各个组件之间进行异步通信。这种通信模式提供了高度的灵活性和可伸缩性，但也引入了一系列的挑战，其中最重要的之一是消息的可靠性。

首先让我们来了解一下，在消息队列中，消息从生产者发送到交换机，再到队列，最后到消费者，有哪些情况会导致消息的丢失？

  • 发送时丢失：

    • 生产者发送的消息未送达交换机；
    • 消息到达交换机后未到达队列；

  • MQ 宕机，队列中的消息会丢失；

  • 消费者接收到消息后未消费就宕机了。

确保消息队列的可靠性是分布式系统中不可或缺的一部分，因此我们需要采取措施来应对这些挑战。为了解决上述消息可靠性问题，RabbitMQ提供了一系列的机制和最佳实践，以确保消息在整个传递过程中得到妥善处理和保护。

本文将深入探讨如何应对这些挑战，介绍消息队列中的关键概念，并详细讨论 RabbitMQ 提供的解决方案，包括生产者消息的确认、消息的持久化、消费者消息的确认以及消息消费失败的重试机制。这些措施将有助于确保消息队列在应用程序中的可靠性和稳定性。

一、生产者消息的确认

1.1 生产者确认机制

RabbitMQ 提供了 publisher confirm 机制，这是一种用于解决消息发送过程中可能出现的丢失问题的机制。当消息发送到 RabbitMQ 后，系统会返回一个结果给消息的发送者，以指示消息的处理状态。这个结果有两种可能的值：

  • publisher-confirm，发送者确认：

    • 消息成功投递到交换机，系统返回 ack（确认）。
    • 消息未能成功投递到交换机，系统返回 nack（未确认）。

  • publisher-return，发送者回执：

    • 消息成功投递到交换机，但是没有成功路由到队列，系统返回 ACK，同时提供路由失败的原因。

这个确认机制的目的是确保消息在发送到消息队列后，发送者能够获得有关消息处理状态的明确反馈，从而可以采取适当的措施，例如重发消息或记录失败信息。

需要注意的是，为了实现这一机制，需要为每条消息设置一个全局唯一的标识符，以便区分不同的消息，避免在确认过程中出现冲突。

例如下图所示：
示例图

确保消息生产者能够获得有关消息状态的反馈是确保消息可靠性的关键一步，因为它有助于解决消息可能在发送期间丢失的问题。这是构建可靠的消息队列系统中的重要组成部分。

1.2 实现生产者消息的确认

下面将通过一个 Java 的 Spring Boot 项目来演示如何实现生产者消息的确认。这个项目的结构如下：


这个项目有两个模块，其中 consumer 负责对消息的消费，而 publisher 负责发送消息。下面是在 publisher 模块中实现消息确认的具体步骤：

  1. 在 publisher 服务中的 application.yml 文件中添加如下配置：
spring:
  rabbitmq:
    publisher-confirm-type: correlated
    publisher-returns: true
    template:
      mandatory: true

对这个配置的详细说明：

  • publish-confirm-type：开启 publisher-confirm 功能，这里支持两种类型：
    • simple：同步等待 confirm 结果，直到超时；
    • correlated：异步回调，定义ConfirmCallback，MQ返回结果时会回调这个 ConfirmCallback。
  • publish-returns：开启 publish-return 功能，同样是基于 callback 机制，不过是定义 ReturnCallback；
  • template.mandatory：定义消息路由失败时的策略。true，则调用 ReturnCallback；false，则直接丢弃消息。
  1. 给 RabbitTemplate 配置 ReturnCallback：
@Configuration
@Slf4j
public class CommonConfig implements ApplicationContextAware {

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        // 获取 RabbitTemplate 对象
        RabbitTemplate rabbitTemplate = applicationContext.getBean(RabbitTemplate.class);
        // 配置 ReturnCallBack
        rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {
            // 记录日志
            log.error("消息发送到队列失败，响应码：{}，失败原因：{}，交换机：{}，路由 Key：{}，消息：{}",
                    replyCode, replyText, exchange, routingKey, message.toString());
            // 如果有需要，接下来可以重发消息，或者执行其他通知逻辑
        });
    }
}

由于每个 RabbitTemplate 只能配置一个 ReturnCallback，并且 RabbitTemplate 在Spring 中是一个全局对象，因此需要在项目启动过程中配置。

上述代码就是一个 Spring Boot 的配置类，通常用于在项目启动时配置一些全局的设置。在这个配置类中，实现了 ApplicationContextAware 接口，用于获取 Spring 应用上下文（ApplicationContext）对象。主要作用是配置 RabbitMQ 的 ReturnCallback，以处理消息发送到队列失败的情况。

  1. 发送消息，指定消息的 ID以及消息的 ConfirmCallback
@Test
public void testSendMessage2SimpleQueue() throws InterruptedException {
    String routingKey = "simple.test";
    // 1. 准备消息
    String message = "hello, spring amqp!";
    // 2. 准备 CorrelationDate
    // 2.1.消息ID
    CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
    // 2.2.准备 ConfirmCallback
    correlationData.getFuture().addCallback(confirm -> {
        // 消息发送成功
        // 判断结果
        if(confirm != null && confirm.isAck()){
            // ACK
            log.debug("消息投递到交换机成功！消息 ID: {}", correlationData.getId());
        } else {
            // NACK
            log.error("消息投递到交换机失败！消息 ID: {}", correlationData.getId());
        }
    }, throwable -> {
        // 发送失败
        // 记录日志
        log.error("消息发送失败！", throwable);
        // 重发消息...
    });
    // 3. 发送消息
    rabbitTemplate.convertAndSend("amq.topic", routingKey, message, correlationData);
}

这是一个 Java 测试方法，用于发送消息到 RabbitMQ 队列，并指定消息的 ID 以及 ConfirmCallback（确认回调）。以下是对这段代码的详细解释：

  1. testSendMessage2SimpleQueue: 这是一个测试方法，用于演示如何发送消息到名为 “simple.test” 的 RabbitMQ 队列。

  2. String routingKey = "simple.test";: 定义了消息的路由键，这是用于将消息路由到特定队列的关键。

  3. 准备消息：将要发送的消息内容存储在 message 变量中。

  4. 准备 CorrelationData：

    • CorrelationData 用于关联消息的 ID。
    • 使用 UUID.randomUUID().toString() 生成一个全局唯一的消息 ID。

  5. 准备 ConfirmCallback：

    • CorrelationData.getFuture().addCallback(confirm -> { ... }, throwable -> { ... }) 定义了 ConfirmCallback，该回调会在消息的发送状态发生变化时触发。
    • 在 ConfirmCallback 中，判断了消息是否成功投递到交换机：
      • 如果 confirm 不为 null 且 confirm.isAck() 为 true，则表示消息成功到达交换机，记录一条成功的日志。
      • 否则，如果消息未成功到达交换机，则记录一条失败的日志。
    • 在 throwable 回调中，处理了发送失败的情况，记录了失败的日志，可以在这里添加重发消息或其他失败处理逻辑。

  6. 发送消息：

    • 使用 rabbitTemplate.convertAndSend("amq.topic", routingKey, message, correlationData); 发送消息到 RabbitMQ。
    • 参数包括交换机名称、路由键、消息内容和关联的 CorrelationData。

这段代码演示了如何发送消息并在消息状态变化时使用 ConfirmCallback 处理消息的确认情况。通过关联消息 ID 和 ConfirmCallback，可以确保消息的可靠性，根据确认情况采取适当的措施。

1.3 验证生产者消息的确认

下面通过可以运行上述测试代码来查看生产者的消息确认情况：

  1. 正常发送消息

直接执行测试方法，可以发现消息成功投递到交换机：

  1. 发送消息失败

此时，将交换机的名称改成一个错误不存在的：
然后再次执行测试方法：

发现此时消息投递到交换机失败，说明此时返回的是 NACK，并且提示了错误的原因是找不到名为 aamq.topic的交换机。

  1. 成功发送消息，但是路由失败

此时将交换机的名称修改回来，但是将路由 Key 修改成错误的：


然后执行测试方法：

通过输出的日志可以发现，消息成功投递到了交换机，但是由于路由 Key 不正确，导致路由不到 simple,queue，从而触发调用了上文配置的ReturnCallback。

二、消息的持久化

在通过上文的生产者消息确认机制之后，确保了消息能够正确的发送到队列中，但是这并不意味着消息就安全了。因为 RabbitMQ 默认是内存储存的，如果出现了 RabbitMQ 宕机的情况，那么此时队列中的消息还是会丢失。要确保消息能够真正的安全，我们还需要实现消息的持久化。

2.1 演示消息的丢失

例如，现在 simple.queue 中存在 3 条消息：

这些消息是通过 RabbitMQ 自带的交换机 amp.topic 进行转发的：

然后我们重启一下 RabbitMQ 服务，看一看队列中的消息是否还存在：


此时我们重新服务 RabbitMQ 的控制台，发现连 simple.queue 都消失了：

但是RabbitMQ自带的 amp.topic 交换机还存在：

说明，这个交换机是持久化储存的，如果仔细观察可以发现，这些所有的交换机的 Features 都带有一个 D ，即持久化 Durable。

因此要让我们自己创建的队列或者交换机也能持久存在，就可以否选上 Durable 这个选项：

2.2 声明持久化的交换机和队列

通过上文我们知道了可以在 RabbitMQ 的控制台创建交换机和队列的时候可以勾选 Durable 来达到持久化的目的，但是如果使用代码来创建持久化的交换机和队列呢？下面我将使用 Java 代码来演示这个过程：

由于消费者comsumer在启动的时候可以帮我们创建交换机和队列，因此将交换机和队列的声明交给 consumer 来完成。

  1. 声明持久化的交换机
@Configuration
public class CommonConfig {
    @Bean
    public DirectExchange simpleDirect(){
        // DirectExchange的构造方法有三个参数：交换机名称、是否持久化、当没有 queue 与其绑定时是否自动删除
        return new DirectExchange("simple.direct", true, false);
    }
}
  1. 声明持久化的队列持久化
@Configuration
public class CommonConfig {

		// ...
		
    @Bean
    public Queue simpleQueue(){
        // 使用QueueBuilder构建队列，其中使用 durable 方法就是持久化的
        return QueueBuilder.durable("simple.queue").build();
    }
}

当完成了上面两步之后，我们可以启动 consumer 服务：

在这里插入图片描述
此时，我们发现成功创建了simple.direct交换机和 simple.queue 队列，并且它们都是持久的。然后停止consumer 服务，在 RabbitMQ 的控制台中向 simple.queue 添加一条消息：


然后再次重启 RabbitMQ 服务，发现刚才创建的交换机和队列都还在，但是消息却没有了：
因为我刚才添加的是非持久化的消息：

2.3 发送持久化的消息

同样，在控制台添加消息的时候可以设置消息的持久化和非持久化，下面让我来演示然后在使用 Java 代码发送持久化的消息：

@Test
public void testDurableMessage() {
    // 1. 准备消息
    Message message = MessageBuilder.withBody("hello, simple.queue".getBytes(StandardCharsets.UTF_8))
            .setDeliveryMode(MessageDeliveryMode.PERSISTENT)
            .build();
    // 2. 发送消息
    rabbitTemplate.convertAndSend("simple.queue", message);
}

在发送持久化的消息需要使用MessageBuilder来构建消息，其中withBody用于指定消息体；setDeliveryMode用来设置消息的发送类型，可以是持久化的，也可以是非持久化的；build 与构建消息。

完成上述代码之后，我们可以执行这个测试方法：

查看 RabbitMQ 的控制台，发现成功发送了消息，并且其中的 delivery_mode 为 2，代表的就是持久化：

再次重启 RabbitMQ 服务：

此时发现刚才的消息并没有丢失，至此我们就完成了持久化消息的发送，进一步确保了消息的可靠性。另外，其实在使用 Spring AMQP 创建的交换机，队列和发送的消息都是持久化的。

三、消费者消息的确认

3.1 配置消费者消息确认

RabbitMQ 同样也支持消费者确认机制，即当消费者处理消息后可以向 MQ 发送 ack 回执，当 MQ 收到 ack 回执后才会删除该消息。而Spring AMQP 则允许配置三种确认模式：

  • manual：在代码中手动 ack，需要在业务代码结束后，调用Spring AMQP 提供的 API 发送 ack，但是这种情况存在代码侵入的问题。
  • auto：基于 AOP 自动发送 ack，由 Spring 监测 listener 代码是否出现异常，没有异常则返回 ack；抛出异常则返回 nack；
  • none：关闭 ack，MQ 假定消费者获取消息后会成功处理，因此消息投递后立即被删除。

实现消费者的确认机制的方式就是是修改application.yml文件，添加下面配置：

spring:
  rabbitmq:
    listener:
      simple:
        prefetch: 1
        acknowledge-mode: auto # none，关闭ack；manual，手动ack；auto：自动 ack

3.2 演示 none 模式

此时，我们将消费者的确认模式改为 none：


消息处理逻辑：

@Slf4j
@Component
public class SpringRabbitListener {
    @RabbitListener(queues = "simple.queue")
    public void listenSimpleQueue(String msg) {
        System.out.println("消费者接收到simple.queue的消息：【" + msg + "】");
        // 模拟异常
        System.out.println(1/0);
        log.info("消费者处理消息成功！");
    }
}

在这里，使用 System.out.println(1/0)来模拟异常的产生。

此时，在 simple.queue 中存在一条消息：

然后，我们将断点设置到如下位置：
调试运行，可以发现，在 none 模式下，只有消费者接收到了消息，RabbitMQ 就会立即删除队列中的消息。

在这种none模式下，队列中的消息并不可靠，当消费者消费消息失败的时候不应该理解删除，而是应该重新发送或者采取其他措施来保证消息的可靠性。

3.3 演示 auto 模式

接下来让我们演示一下 auto 模式：

同样在simple.queue中准备一条消息：

然后调试运行刚才的代码：

此时发现consumer成功接收到了消息：
并且，此时 simple.queue 中消息的状态变成了 Unacked：

如果，此时放行代码，发现消费者还是会继续接收到这条消息：


此时，如果取消断点，并放开代码，会发现此时的消费者就会一直死循环的接收到这条消息。

通过上面的演示可以发现，尽管在 auto 模式下保证了消息的不丢失，但是此时如果消费者出现了异常，就会死循环的接收并尝试处理同一条消息。面对这个问题，还需要采取其他措施来进行处理，例如下文消费者消费失败的重试机制。

四、消息消费失败的重试机制

4.1 本地重试机制

当消费者出现异常后，消息会不断 requeue（重新入队）到队列，再重新发送给消费者，然后再次异常，再次 requeue，无限循环，导致 MQ的消息处理的压力大大提高，给 MQ 服务器带来不必要的压力：

我们可以利用 Spring 的 retry 机制，在消费者出现异常时利用本地重试，而不是无限制的 requeue 到 MQ 队列，使用这个重试机制需要在 application.yml 添加如下配置：

spring:
  rabbitmq:
    listener:
      simple:
        retry:
          enabled: true # 开启消费者失败重试
          initial-interval: 1000 # 初识的失败等待时长为1秒
          multiplier: 1 # 失败的等待时长倍数，下次等待时长 = multiplier * last-interval
          max-attempts: 3 # 最大重试次数
          stateless: true # true无状态；false 有状态。如果业务中包含事务，这里改为 false

完成了上面的配置之后，再次重启 consumer ：

发现，消费者在本地重试了三次，最终还是失败，然后就放弃重试，并且simple.queue 中的消息也删除了。

4.2 失败消息的处理策略

在开启重试模式后，重试次数耗尽，如果消息依然失败，则需要有 MessageRecoverer 接口来处理，它包含三种不同的实现：

  • RejectAndDontRequeueRecoverer：重试次数耗尽后，直接 reject，丢弃消息，这是默认采取的方式；
  • ImmediateRequeueMessageRecoverer：重试次数耗尽后，返回 nack，消息重新入队；
  • RepublishMessageRecoverer：重试耗尽后，将失败消息投递到指定的交换机。

下面演示一下 RepublishMessageRecoverer 处理模式：

  1. 首先，定义接收失败消息的交换机、队列及其绑定关系：
@Bean
public DirectExchange errorMessageExchange() {
    return new DirectExchange("error.direct");
}

@Bean
public Queue errorQueue() {
    return new Queue("error.queue", true);
}

@Bean
public Binding errorBinding() {
    return BindingBuilder.bind(errorQueue()).to(errorMessageExchange()).with("error");
}
  1. 然后，定义RepublishMessageRecoverer：
@Bean
public MessageRecoverer republishMessageRecoverer(RabbitTemplate rabbitTemplate) {
    return new RepublishMessageRecoverer(rabbitTemplate, "error.direct", "error");
}

当我们注册了 RepublishMessageRecoverer Bean 对象之后，就会自动覆盖 Spring 提供的默认的 RejectAndDontRequeueRecoverer 的 Bean 对象。

当完成了上述的所有配置之后，首先在 simple.queue 中准备一条消息，然后再启动 consumer：

最终发现，处理失败的消息最终转发到了 error.queue 队列了。

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

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

相关文章

系统设计中的缓存技术：完整指南

系统设计中的缓存技术：完整指南

Image.png 缓存是软件工程中用于提高系统性能和用户体验的基本技术。它通过临时存储频繁访问的数据在缓存中，缓存比数据的原始来源更容易访问。 作为一名软件工程师，了解缓存以及它在不同类型的系统中的工作方式是至关重要的。在本文中，我们将…
阅读更多...
基于AOSP源码Android-10.0.0_r41分支编译，framework开发，修改系统默认字体大小

基于AOSP源码Android-10.0.0_r41分支编译，framework开发，修改系统默认字体大小

文章目录 基于AOSP源码Android-10.0.0_r41分支编译，framework开发，修改系统默认字体大小 基于AOSP源码Android-10.0.0_r41分支编译，framework开发，修改系统默认字体大小 主要修改一个地方就行 代码源码路径 frameworks/base/co…
阅读更多...
旅游业为什么要选择VR全景，VR全景在景区旅游上有哪些应用

旅游业为什么要选择VR全景，VR全景在景区旅游上有哪些应用

引言： VR全景技术的引入为旅游业带来了一场变革。这项先进技术不仅提供了前所未有的互动体验，还为景区旅游文化注入了新的生机。 一．VR全景技术：革新旅游体验 1.什么是VR全景技术？ VR全景技术是一种虚拟现实技术&am…
阅读更多...
【C++初阶（四）aoto关键字与基于范围的for循环】

【C++初阶（四）aoto关键字与基于范围的for循环】

本专栏内容为：C学习专栏，分为初阶和进阶两部分。 通过本专栏的深入学习，你可以了解并掌握C。 💓博主csdn个人主页：小小unicorn ⏩专栏分类：C 🚚代码仓库：小小unicorn的代码仓库&…
阅读更多...
python实现MC协议（SLMP 3E帧）的TCP服务端（篇二）

python实现MC协议（SLMP 3E帧）的TCP服务端（篇二）

python实现MC协议（SLMP 3E帧）的TCP服务端是一件稍微麻烦点的事情。它不像modbusTCP那样，可以使用现成的pymodbus模块去实现。但是，我们可以根据协议帧进行组包，自己去实现帧的格式，而这一切可以基于socket模…
阅读更多...
Kotlin 进阶函数式编程技巧

Kotlin 进阶函数式编程技巧

Kotlin 进阶函数式编程技巧 Kotlin 简介 软件开发环境不断变化，要求开发人员不仅适应，更要进化。Kotlin 以其简洁的语法和强大的功能迅速成为许多人进化过程中的信赖伙伴。虽然 Kotlin 的初始吸引力可能是它的简洁语法和与 Java 的互操作性&#xff0c…
阅读更多...
每天一点python——day61

每天一点python——day61

#第61天 #字符串的驻留机制字符串：python中基本数据类型，是一个不可变的序列【目前我们学了两个：元组、字符串】 可以使用单引号，双引号，三引号来定义#定义字符串 apython#用单引号，双引号，三引…
阅读更多...
Redis原理到常用语法基础图文讲解

Redis原理到常用语法基础图文讲解

在初期，已经讲述了Redis安装问题。现在正式进入Redis的入门阶段 系统架构的演进 传统单机架构 一台机器运行应用程序、数据库服务器 现在大部分公司的产品都是这种单机架构。因为现在计算机硬件发展速度很快，哪怕只有一台主机，性能也很高…
阅读更多...
智慧城市排水系统，管网水位监测仪怎么监测

智慧城市排水系统，管网水位监测仪怎么监测

地下排水管网应用于城市的多个环境之中，比如排放雨水，污水或者是地表水等，总之是在维护城市的安全运行，并且保护城市地下生命线处于正常状态。但是一旦排水系统面对各种极端天气，便有可能会突发安全事故，导…
阅读更多...
如何再kali中下载iwebsec靶场

如何再kali中下载iwebsec靶场

这个靶场有三种搭建方法： 第一种是在线靶场：http://www.iwebsec.com:81/ 第二种是虚拟机版本的，直接下载到本地搭建 官网地址下载：http://www.iwebsec.com/ 而第三种就是利用docker搭建这个靶场，我这里是用kali进行…
阅读更多...
部署kubevirt教程

部署kubevirt教程

前提条件 已安装：kubernetes集群、kubectl、docker apt install -y qemu-kvm libvirt virt-install bridge-utils 【所有节点全部安装】 virt-host-validate qemu部署kubevirt 下载kubevirt-cr.yaml和kubevirt-operator.yaml 先执行： Kubectl apply …
阅读更多...
网络安全（黑客）-0基础小白自学

网络安全（黑客）-0基础小白自学

1.网络安全是什么 网络安全可以基于攻击和防御视角来分类，我们经常听到的 “红队”、“渗透测试” 等就是研究攻击技术，而“蓝队”、“安全运营”、“安全运维”则研究防御技术。 2.网络安全市场 一、是市场需求量高； 二、则是发展相对成熟…
阅读更多...
Go Gin中间件

Go Gin中间件

Gin是一个用Go语言编写的Web框架，它提供了一种简单的方式来创建HTTP路由和处理HTTP请求。中间件是Gin框架中的一个重要概念，它可以用来处理HTTP请求和响应，或者在处理请求之前和之后执行一些操作。 以下是关于Gin中间件开发的一些基本信息&am…
阅读更多...
数据库系统原理与实践 笔记 #7

数据库系统原理与实践 笔记 #7

文章目录 数据库系统原理与实践 笔记 #7数据库设计和E-R模型(续)转换为关系模式具有简单属性的实体集的表示复合属性多值属性联系集的表示模式的冗余—合并 实体-联系设计问题设计问题联系属性的布局 扩展的E-R特性特化概化属性继承特化/概化的设计约束聚集E-R图表示方法总结E-…
阅读更多...
聚会娱乐喝酒游戏小程序源码系统 可开流量主 带完整的搭建教程

聚会娱乐喝酒游戏小程序源码系统 可开流量主 带完整的搭建教程

今天罗峰来给大家分享一款聚会娱乐喝酒游戏小程序源码系统 。在聚会娱乐活动中，喝酒游戏是一种非常受欢迎的活动方式。但是，往往由于缺乏有效的组织和规则，导致游戏的进行不够顺畅，甚至出现混乱的情况。因此，开发一款能…
阅读更多...
Java-Hbase介绍

Java-Hbase介绍

1.1. 概念 base 是分布式、面向列的开源数据库（其实准确的说是面向列族）。HDFS 为 Hbase 提供可靠的 底层数据存储服务，MapReduce 为 Hbase 提供高性能的计算能力，Zookeeper 为 Hbase 提供 稳定服务和 Failover 机制&#xff0c…
阅读更多...
云计算实战项目之---学之思在线考试系统

云计算实战项目之---学之思在线考试系统

简介： 学之思开源考试系统是一款 java vue 的前后端分离的考试系统。主要优点是开发、部署简单快捷、界面设计友好、代码结构清晰。支持web端和微信小程序，能覆盖到pc机和手机等设备。 支持多种部署方式：集成部署、前后端分离部署、docker部…
阅读更多...
一文深入了解 CPU 的型号、代际架构与微架构

一文深入了解 CPU 的型号、代际架构与微架构

在 10 月 16 号的时候，Intel 正式发布了第 14 代的酷睿处理器。但还有很多同学看不懂这种发布会上发布的各种 CPU 参数。借着这个时机，给大家深入地讲讲 CPU 的型号规则、代际架构与微架构方面的知识。 CPU 在整个计算机硬件中、技术体系中都算是最最重…
阅读更多...
Wpf 使用 Prism 实战开发Day04

Wpf 使用 Prism 实战开发Day04

一.菜单导航实现 1.首先创建出所有的页面(View)及对应的页面逻辑处理类(ViewModel) IndexView(首页)-----------------IndexViewModelToDoView(待办事项)------------ToDoViewModelMemoView(忘备录)--------------MemoViewModelSettingsView(设置)--------------SettingsViewMo…
阅读更多...
防逆流系统中防逆流电表的正确安装位置-安科瑞黄安南

防逆流系统中防逆流电表的正确安装位置-安科瑞黄安南

随着光伏行业的发展，部分地区村级变压器及工业用电变压器容量与光伏项目的装机容量处于饱和。电网公司要求对后建的光伏并网系统为不可逆流发电系统，指光伏并网系统所发生的电由本地负载消耗，多余的电不允许通过低压配电变压器向上级电网逆向…
阅读更多...
最新文章

Copyright @ 2022~2023