RabbitMQ（七）ACK 消息确认机制

目录

    • 一、简介
      • 1.1 背景
      • 1.2 定义
      • 1.3 如何查看确认/未确认的消息数？
    • 二、消息确认机制的分类
      • 2.1 消息发送确认
        • 1）ConfirmCallback方法
        • 2）ReturnCallback方法
        • 3）代码实现方式一：统一配置
          • a.配置类
          • a.生产者
          • c.消费者
          • d.测试结果
        • 4）代码实现方式二：单独配置
      • 2.2 消息接收确认
        • 1）basicAck() 方法
        • 2）basicReject() 方法
        • 3）basicNack() 方法
        • 4）代码实现
          • a.配置方式一：代码配置
          • b.配置方式二：配置文件
          • c.生产者
          • d.消费者
          • e.测试结果

在这里插入图片描述

当我们在项目中引入了新的中间件之后，数据的风险性就要多一层考虑。那么，RabbitMQ 的消息是怎么知道有没有被消费者消费的呢？生产者又怎么确保自己发送成功了呢？这些问题将在文章中进行解答。

一、简介

1.1 背景

在 MQ 中，消费者和生产者并不直接进行通信，生产者只负责把消息发送到队列，消费者只负责从队列获取消息。

  • 消费者从队列 获取到消息后，这条消息就不在队列中了。如果此时消费者所在的信道 因为网络中断没有消费到，那这条消息就 被永远地丢失了。所以，我们希望等待消费者 成功消费掉这条消息之后再删除消息。
  • 生产者向交换机 发送消息后，也 不能保证消息准确发送过去了，消息就像 石沉大海 一样，所以 发送消息也需要进行消息确认。

1.2 定义

为了保证消息从队列可靠地到达消费者，RabbitMQ 提供了 消息确认机制（Message Acknowledgement）。

消费者在订阅队列时，可以指定 autoAck 参数：

  • autoAck=false：RabbitMQ 会 等待消费者显式地回复确认信号 后才从内存（或磁盘）中移除消息（实际上时先打上删除标记，之后再删除）。
  • autoAck=true：RabbitMQ 会 自动把发送出去的消息置为确认，然后内存（或磁盘）中删除，而 不管消费者是否真正地消费到了这些消息。

采用消息确认机制后，只要设置 autoAck 参数为 false，消费者就有足够的时间处理消息（任务），不用担心处理消息过程中消费者进程挂掉后消息丢失的问题，因为 RabbitMQ 会一直等待持有消息知道消费者显式调用 Basic.Ack 命令为止。

对于 RabbitMQ 服务器端而言，当 autoAck 参数为 false 时，队列中的消息分成了两部分：

  • 一部分是 等待投递给消费者的消息；
  • 另一部分是 已经投递给消费者，但是还没有收到消费者确认信号的消息。

在这里插入图片描述

如果 RabbitMQ 服务器端 一直没有收到消费者的确认信息，并且 消费此消息的消费者已经断开连接，则服务器端会安排 该消息重新进入队列，等待投递给下一个消费者（也可能还是原来的那个消费者）。

RabbitMQ 不会为未确认的消息设置过期时间，它 判断此消息是否需要重新投递给消费者的唯一依据是该消息连接是否已经断开，这个设计的原因是 RabbitMQ 允许消费者消费一条消息的时间可以很久很久。

1.3 如何查看确认/未确认的消息数？

RabbitMQ 的 Web 管理平台上可以看到当前队列中的 “Ready” 状态和 “Unacknowledged” 状态的消息数：

  • Read 状态： 等待投递给消费者的消息数。
  • Unacknowledged 状态： 已经投递给消费者但是未收到确认信号的消息树。

在这里插入图片描述

二、消息确认机制的分类

RabbitMQ 消息确认机制分为两大类：

  1. 消息发送确认，又分为：
    • 生产者到交换机的确认；
    • 交换机到队列的确认。
  2. 消息接收确认。

2.1 消息发送确认

RabbitMQ 的消息发送确认有两种实现方式：ConfirmCallback 方法、ReturnCallback 方法。

1）ConfirmCallback方法

ConfirmCallback 是一个回调接口，用于确认消息否是到达交换机中。

配置方式：

spring.rabbitmq.publisher-confirm-type=correlated

它有三个值：

  • none：禁用发布确认模式，默认值。
  • correlated：发布消息成功到交换机后触发回调方法。
  • simple：经测试有两种效果：一是和 correlated 一样会触发回调方法；二是在发布消息成功后使用 rabbitTemplate 调用 waitForConfirm 或 waitForConfirmsOrDie方法等待 broker 节点返回发送结果，根据返回结果来判定下一步的逻辑。要注意的是 waitForConfirmsOrDie 方法如果返回 false 则会关闭 channel，则接下来无法发送消息到 broker。
2）ReturnCallback方法

ReturnCallback 也是一个回调接口，用于确认消息是否在交换机中路由到了队列。

（该方法可以不使用，因为交换机和队列是在代码里面绑定的，如果消息成功投递到 Broker 后几乎不存在绑定队列失败，除非代码写错了。）

配置方式：

spring.rabbitmq.publisher-returns=true
3）代码实现方式一：统一配置
a.配置类

RabbitDirectConfig.java

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** <p> @Title RabbitDirectConfig* <p> @Description 直连交换机配置* Direct Exchange是RabbitMQ默认的交换机模式，也是最简单的模式，根据key全文匹配去寻找队列。** @author ACGkaka* @date 2023/1/12 15:09*/
@Slf4j
@Configuration
public class RabbitDirectConfig {public static final String DIRECT_EXCHANGE_NAME = "TEST_DIRECT_EXCHANGE";public static final String DIRECT_ROUTING_NAME = "TEST_DIRECT_ROUTING";public static final String DIRECT_QUEUE_NAME = "TEST_DIRECT_QUEUE";@Beanpublic RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {RabbitTemplate rabbitTemplate = new RabbitTemplate();rabbitTemplate.setConnectionFactory(connectionFactory);// 设置开启Mandatory,才能触发回调函数,无论消息推送结果怎么样都强制调用回调函数rabbitTemplate.setMandatory(true);//设置message序列化方法rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());// 设置消息发送到交换机(Exchange)回调rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {if (ack) {log.info(">>>>>>>>>>【INFO】消息发送到交换机(Exchange)成功, 相关数据: {}", correlationData);} else {log.error(">>>>>>>>>>【ERROR】消息发送到交换机(Exchange)失败, 错误原因: {}, 相关数据: {}", cause, correlationData);}});// 设置消息发送到队列(Queue)回调（经测试，只有失败才会调用）rabbitTemplate.setReturnsCallback((returnedMessage) -> {log.error(">>>>>>>>>>【ERROR】消息发送到队列(Queue)失败：响应码: {}, 响应信息: {}, 交换机: {}, 路由键: {}, 消息内容: {}",returnedMessage.getReplyCode(), returnedMessage.getReplyText(), returnedMessage.getExchange(), returnedMessage.getRoutingKey(), returnedMessage.getMessage());});return rabbitTemplate;}/*** 消息监听-反序列化*/@Beanpublic RabbitListenerContainerFactory<?> rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();factory.setConnectionFactory(connectionFactory);factory.setMessageConverter(new Jackson2JsonMessageConverter());return factory;}/*** 队列，命名：testDirectQueue** @return 队列*/@Beanpublic Queue testDirectQueue() {// durable:是否持久化，默认是false，持久化队列：会被存储在磁盘上，当消息代理重启时仍然存在，暂存队列：当前连接有效// exclusive:默认false，只能被当前创建的连接使用，而且当连接关闭后队列即被删除。此参考优先级高于durable。// autoDelete:是否自动删除，当没有生产者或消费者使用此队列，该队列会自动删除。// 一般设置一下队列的持久化就好，其余两个默认falsereturn new Queue(DIRECT_QUEUE_NAME, true);}/*** Direct交换机，命名：testDirectExchange* @return Direct交换机*/@BeanDirectExchange testDirectExchange() {return new DirectExchange(DIRECT_EXCHANGE_NAME, true, false);}/*** 绑定 将队列和交换机绑定，并设置用于匹配键：testDirectRouting* @return 绑定*/@BeanBinding bindingDirect() {return BindingBuilder.bind(testDirectQueue()).to(testDirectExchange()).with(DIRECT_ROUTING_NAME);}
}
a.生产者

SendMessageController.java

import com.demo.config.RabbitDirectConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;/*** <p> @Title SendMessageController* <p> @Description 推送消息接口** @author ACGkaka* @date 2023/1/12 15:23*/
@Slf4j
@RestController
public class SendMessageController {/*** 使用 RabbitTemplate，这提供了接收/发送等方法。*/@Autowiredprivate RabbitTemplate rabbitTemplate;@GetMapping("/sendDirectMessage")public String sendDirectMessage() {String messageId = String.valueOf(UUID.randomUUID());String messageData = "Hello world.";String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));Map<String, Object> map = new HashMap<>();map.put("messageId", messageId);map.put("messageData", messageData);map.put("createTime", createTime);// 将消息携带绑定键值：TEST_DIRECT_ROUTING，发送到交换机：TEST_DIRECT_EXCHANGErabbitTemplate.convertAndSend(RabbitDirectConfig.DIRECT_EXCHANGE_NAME, RabbitDirectConfig.DIRECT_ROUTING_NAME, map);return "OK";}}
c.消费者

DirectReceiver.java

import com.demo.config.RabbitDirectConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;import java.util.Map;/*** <p> @Title DirectReceiver* <p> @Description 直连交换机监听类** @author ACGkaka* @date 2023/1/12 15:59*/
@Slf4j
@Component
public class DirectReceiver {@RabbitListener(queues = RabbitDirectConfig.DIRECT_QUEUE_NAME)public void process(Map<String, Object> testMessage) {System.out.println("DirectReceiver消费者收到消息：" + testMessage.toString());}}
d.测试结果

成功发送时，执行结果：

在这里插入图片描述

交换机错误时，执行结果：

在这里插入图片描述

路由键错误时，执行结果：

在这里插入图片描述

4）代码实现方式二：单独配置

除了在配置类里面统一设置回调方法外，还可以在每次推送消息到队列时，手动使用 CorrelationData 指定回调方法。

@GetMapping("/sendDirectMessage2")
public String sendDirectMessage2() {String messageId = String.valueOf(UUID.randomUUID());String messageData = "Hello world.";String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));Map<String, Object> map = new HashMap<>();map.put("messageId", messageId);map.put("messageData", messageData);map.put("createTime", createTime);//生成唯一标识CorrelationData correlationData = new CorrelationData(messageId);//不管成功失败都会调用confirm或者throwable,这是异步调用correlationData.getFuture().addCallback(confirm -> {// 设置消息发送到交换机(Exchange)回调if (confirm != null && confirm.isAck()) {log.info(">>>>>>>>>>【INFO】发送成功ACK，msgId: {}, message: {}", correlationData.getId(), map);} else {log.error(">>>>>>>>>>【ERROR】发送失败NACK，msgId: {}, message: {}", correlationData.getId(), map);}},throwable -> {//发生错误，链接mq异常，mq未打开等...报错回调System.out.println("发送失败throwable = " + throwable + ",  id:" + correlationData.getId());});// 将消息携带绑定键值：TEST_DIRECT_ROUTING，发送到交换机：TEST_DIRECT_EXCHANGErabbitTemplate.convertAndSend(RabbitDirectConfig.DIRECT_EXCHANGE_NAME, RabbitDirectConfig.DIRECT_ROUTING_NAME, map, correlationData);return "OK";
}

2.2 消息接收确认

消费者确认发生在 监听队列的消费者处理业务失败，如：发生了异常、不符合要求的数据等。这些场景就 需要我们手动处理消息，比如：重新发送消息或者丢弃消息。

RabbitMQ 的 消息确认机制（ACK） 默认是自动确认的。自动确认会 在消息发送给消费者后立即确认，但 存在丢失消息的可能。如果消费端消费逻辑抛出了异常，假如我们使用了事务的回滚，也只是保证了数据的一致性，消息还是丢失了。也就是消费端没有处理成功这条消息，那么就相当于丢失了消息。

消息的确认模式有三种：

  1. AcknowledgeMode.NONE：自动确认。（默认）
  2. AcknowledgeMode.AUTO：根据情况确认。
  3. AcknowledgeMode.MANUAL：手动确认。（推荐）

消费者收到消息后，手动调用 Channel 的 basicAck()/basicReject()/basicNack() 方法后，RabbitMQ 收到消息后，才认为本次投递完成。

  1. basicAck()：用于确认当前消息。
  2. basicReject()：用于拒绝当前消息，可以自定义是否重回队列。
  3. basicNack()：用于批量拒绝消息（这是 AMPQ 0-9-1 的 RabbitMQ 扩展）。
1）basicAck() 方法

basicAck() 方法 用于确认当前消息，Channel 类中的方法定义如下：

void basicAck(long deliveryTag, boolean multiple) throws IOException;

参数说明：

  • long deliveryTag： 当一个消费者向 RabbitMQ 注册后，会建立起一个 Channel。RabbitMQ 会用 basic.deliver 方法向消费者推送消息，这个方法携带了一个 deliveryTag，它代表了 RabbitMQ 向该 Channel 投递的这条消息的唯一标识ID，是一个单调递增的正整数，deliveryTag 的范围仅限于当前 Channel。
  • boolean multiple： 是否批处理，一般为 false，当该参数为 true 时，则可以一次性确认 deliveryTag 小于等于传入值的所有消息。
2）basicReject() 方法

basicReject() 方法 用于明确拒绝当前的消息。RabbitMQ 在 2.0.0 版本开始引入，Channel 类中的方法定义如下：

void basicReject(long deliveryTag, boolean requeue) throws IOException;

参数说明：

  • long deliveryTag： 当一个消费者向 RabbitMQ 注册后，会建立起一个 Channel。RabbitMQ 会用 basic.deliver 方法向消费者推送消息，这个方法携带了一个 deliveryTag，它代表了 RabbitMQ 向该 Channel 投递的这条消息的唯一标识ID，是一个单调递增的正整数，deliveryTag 的范围仅限于当前 Channel。
  • boolean requeue： 是否重新放回队列。
    • 如果参数为 true，则 RabbitMQ 会重新将这条消息存入队列，以便发送给下一个订阅的消费者。
    • 如果参数为 false，则 RabbitMQ 会立即把消息从队列中移除，不会把它发送给新的消费者。
3）basicNack() 方法

basicNack() 方法 用于批量拒绝消息。由于 basicReject() 方法一次只能拒绝一条消息，如果想批量拒绝消息，则可以使用 basicNack() 方法。Channel 类中的方法定义如下：

参数说明：

  • long deliveryTag： 当一个消费者向 RabbitMQ 注册后，会建立起一个 Channel。RabbitMQ 会用 basic.deliver 方法向消费者推送消息，这个方法携带了一个 deliveryTag，它代表了 RabbitMQ 向该 Channel 投递的这条消息的唯一标识ID，是一个单调递增的正整数，deliveryTag 的范围仅限于当前 Channel。
  • boolean multiple： 是否批处理，一般为 false，当该参数为 true 时，则可以一次性确认 deliveryTag 小于等于传入值的所有消息。
  • boolean requeue： 是否重新放回队列。
    • 如果参数为 true，则 RabbitMQ 会重新将这条消息存入队列，以便发送给下一个订阅的消费者。
    • 如果参数为 false，则 RabbitMQ 会立即把消息从队列中移除，不会把它发送给新的消费者。
4）代码实现
a.配置方式一：代码配置

如果我们之前配置了 Jackson2JsonMessageConverter.java 的序列化方式，那么我们可以接着指定消费方的消息确认模式为 AcknowledgeMode.MANUL。

/*** 消息监听配置*/
@Bean
public RabbitListenerContainerFactory<?> rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();// 设置连接工厂factory.setConnectionFactory(connectionFactory);// 设置消息确认模式factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);// 设置反序列化factory.setMessageConverter(new Jackson2JsonMessageConverter());return factory;
}
b.配置方式二：配置文件

我们可以直接在 application.yml 中进行如下配置：

# 确认模式，默认auto，自动确认；manual：手动确认
spring.rabbitmq.listener.simple.acknowledge-mode=manual

注意： yaml中指定的是消费端容器的默认配置，如果我们在代码中有自定义注入 RabbitListenerContainerFactory 示例之后，还需要使用默认配置，需要在代码中进行设置，如下所示：

@Autowired
private SimpleRabbitListenerContainerFactoryConfigurer configurer;/*** 消息监听配置*/
@Bean
public RabbitListenerContainerFactory<?> rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();// 设置连接工厂factory.setConnectionFactory(connectionFactory);// 采用yaml中的配置configurer.configure(factory, connectionFactory);// 设置反序列化factory.setMessageConverter(new Jackson2JsonMessageConverter());return factory;
}
c.生产者

SendMessageController.java

import com.demo.config.RabbitDirectConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;/*** <p> @Title SendMessageController* <p> @Description 推送消息接口** @author ACGkaka* @date 2023/1/12 15:23*/
@Slf4j
@RestController
public class SendMessageController {/*** 使用 RabbitTemplate，这提供了接收/发送等方法。*/@Autowiredprivate RabbitTemplate rabbitTemplate;@GetMapping("/sendDirectMessage")public String sendDirectMessage() {String messageId = String.valueOf(UUID.randomUUID());String messageData = "Hello world.";String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));Map<String, Object> map = new HashMap<>();map.put("messageId", messageId);map.put("messageData", messageData);map.put("createTime", createTime);// 将消息携带绑定键值：TEST_DIRECT_ROUTING，发送到交换机：TEST_DIRECT_EXCHANGErabbitTemplate.convertAndSend(RabbitDirectConfig.DIRECT_EXCHANGE_NAME, RabbitDirectConfig.DIRECT_ROUTING_NAME, map);return "OK";}}
d.消费者

DirectReceiver.java

import com.demo.config.RabbitDirectConfig;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;import java.io.IOException;
import java.util.Map;/*** <p> @Title DirectReceiver* <p> @Description 直连交换机监听类** @author ACGkaka* @date 2023/1/12 15:59*/
@Slf4j
@Component
public class DirectReceiver {@RabbitListener(queues = RabbitDirectConfig.DIRECT_QUEUE_NAME)public void process(Map<String, Object> testMessage, Message message, Channel channel) throws IOException {try {log.info("DirectReceiver消费者收到消息: {}", testMessage.toString());// 手动答应消费完成，从队列中删除该消息channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);} catch (Exception e) {log.error("DirectReceiver消费者消费失败，原因: {}", e.getMessage(), e);// 手动答应消费完成，从队列中删除该消息（不重回队列）channel.basicReject(message.getMessageProperties().getDeliveryTag(),false);}}}
e.测试结果

场景一：消费者进行手动确认，生产者推送2条消息：

可以看到，生产者推送2条消息后立马被消费了。

在这里插入图片描述

场景二：消费者不进行手动确认，生产者推送2条消息：

虽然消费者消费完毕，但是由于没有进行手动确认，所以2条消息会一直处于 Unacked 状态，直到消费者下线。

在这里插入图片描述

关闭 SpringBoot 程序，消费者下线后，消息由 Unacked 状态转为 Ready 状态，等待下一个消费者上线后重新进行消费。

在这里插入图片描述

整理完毕，完结撒花~ 🌻





参考地址：

1.RabbitMQ(4):消息确认机制详解，https://juejin.cn/post/7029232312197840904

2.RabbitMQ消息确认机制（ACK），https://blog.csdn.net/pan_junbiao/article/details/112956537

3.RabbitMQ高级，https://blog.csdn.net/hnhroot/article/details/125921527

4.关于rabbitMQ在yml配置手动ack不生效，重复答应的问题，https://blog.csdn.net/love_Saber_Archer/article/details/109111088

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

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

相关文章

淘宝京东1688商品详情API接口，搜索商品列表接口

淘宝京东1688商品详情API接口，搜索商品列表接口

前言 在实际工作中&#xff0c;我们需要经常跟第三方平台打交道&#xff0c;可能会对接第三方平台API接口&#xff0c;或者提供API接口给第三方平台调用。 那么问题来了&#xff0c;如果设计一个优雅的API接口&#xff0c;能够满足&#xff1a;安全性、可重复调用、稳定性、好…
阅读更多...
嵌入式-C语言-ASCII码（字符）转换二进制和十六进制

嵌入式-C语言-ASCII码（字符）转换二进制和十六进制

一&#xff1a;ASCII码是什么&#xff1f; 问&#xff1a;ASCII码是什么&#xff1f; 答&#xff1a;ASCII码&#xff08;American Standard Code for Information Interchange&#xff0c;美国信息交换标准代码&#xff09;是一种用于表示字符的标准编码系统。它使用7位或8位…
阅读更多...
科普小米手机、华为手机、红米手机、oppo手机、vivo手机、荣耀手机、一加手机、realme手机如何设置充电提示音

科普小米手机、华为手机、红米手机、oppo手机、vivo手机、荣耀手机、一加手机、realme手机如何设置充电提示音

用空空鱼就可以设置&#xff0c;上面还有很多提示音素材还可以设置满电和低电提醒
阅读更多...
poium测试库之JavaScript API封装原理

poium测试库之JavaScript API封装原理

为什么要封装JavaScript的API&#xff1f; 因为有些场景下Selenium提供的API并不能满足我们需求。比如&#xff0c;滑动浏览滚动条&#xff0c;控制元素的显示/隐藏&#xff0c;日历控件的操作等&#xff0c;都可以通过JavaScrip实现&#xff0c;而且Selenium为我们提供了 exe…
阅读更多...
C#之反编译之路(一)

C#之反编译之路(一)

本文将介绍微软反编译神器dnSpy的使用方法 c#反编译之路(一) dnSpy.exe区分64位和32位,所以32位的程序,就用32位的反编译工具打开,64位的程序,就用64位的反编译工具打开(个人觉得32位的程序偏多,如果不知道是32位还是64位,就先用32位的打开试试) 目前只接触到wpf和winform的桌…
阅读更多...
leetcode——杨辉三角

leetcode——杨辉三角

https://leetcode.cn/problems/pascals-triangle/ 杨辉三角&#xff1a; 给定一个非负整数 numRows&#xff0c;生成「杨辉三角」的前 numRows 行。 在「杨辉三角」中&#xff0c;每个数是它左上方和右上方的数的和。 核心思想&#xff1a;找出杨辉三角的规律&#xff0c;发…
阅读更多...
实验笔记之——服务器链接

实验笔记之——服务器链接

最近需要做NeRF相关的开发，需要用到GPU，本博文记录本人配置服务器远程链接的过程，本博文仅供本人学习记录用~ 连上服务器 首先先确保环境是HKU的网络环境（HKU AnyConnect也可）。伙伴已经帮忙创建好用户（第一次登录会提示重新设置密码）。用cmd ssh链接ssh -p 60001 <u…
阅读更多...
window服务器thinkphp队列监听服务

window服务器thinkphp队列监听服务

经常使用linux的同学们应该对使用宝塔来做队列监听一定非常熟悉&#xff0c;但对于windows系统下&#xff0c;如何去做队列的监听&#xff1f;是一个很麻烦的事情。 本文将通过windows系统的服务来实现队列的监听。 对于thinkphp6 queue如何使用&#xff0c;不再赘述。其它系…
阅读更多...
【总线接口】1.以Xilinx开发板为例，直观的认识硬件板卡和接口

【总线接口】1.以Xilinx开发板为例，直观的认识硬件板卡和接口

初接触硬件&#xff0c;五花八门的总线、接口一定会让你有些疑惑&#xff0c;我尝试用一系列文章来解开你的疑惑 系列文章 【总线接口】1.以Xilinx开发板为例&#xff0c;直观的认识硬件接口 【总线接口】2.学习硬件这些年接触过的硬件接口、总线 大汇总 【总线接口】…
阅读更多...
uniapp：签字版、绘画板 插件l-signature

uniapp：签字版、绘画板 插件l-signature

官方网站&#xff1a;LimeUi - 多端uniapp组件库 使用步骤&#xff1a; 1、首先从插件市场将代码下载到项目 海报画板 - DCloud 插件市场 2、下载后&#xff0c;在项目中的uni_modules目录&#xff08;uni_modules优点&#xff1a;不需要import引入&#xff0c;还可以快捷更新…
阅读更多...
论文阅读：基于MCMC的能量模型最大似然学习剖析

论文阅读：基于MCMC的能量模型最大似然学习剖析

On the Anatomy of MCMC-Based Maximum Likelihood Learning of Energy-Based Models 相关代码&#xff1a;点击 本文只介绍关于MCMC训练的部分&#xff0c;由此可知&#xff0c;MCMC常常被用于训练EBM。最后一张图源于Implicit Generation and Modeling with Energy-Based Mod…
阅读更多...
小红书 X WSDM 2024「对话式多文档问答挑战赛」火热开赛！

小红书 X WSDM 2024「对话式多文档问答挑战赛」火热开赛！

基于大语言模型&#xff08;LLM&#xff09;的对话问答机器人&#xff0c;已经成为当前人工智能领域学术界和工业界共同关注的的热门研究方向之一。在对话过程中&#xff0c;为大模型引入搜索结果&#xff0c;进行检索增强的生成&#xff08;Retrieval Augmented Generation&am…
阅读更多...
MyBatis-Plus框架学习笔记

MyBatis-Plus框架学习笔记

先赞后看&#xff0c;养成习惯&#xff01;&#xff01;&#xff01;❤️ ❤️ ❤️ 文章码字不易&#xff0c;如果喜欢可以关注我哦&#xff01; ​如果本篇内容对你有所启发&#xff0c;欢迎访问我的个人博客了解更多内容&#xff1a;链接地址 MyBatisPlus &#xff08;简称…
阅读更多...
接口测试用例编写与模板

接口测试用例编写与模板

一、简介 接口测试区别于传统意义上的系统测试&#xff0c;下面介绍接口测试用例和接口测试报告。 二、接口测试用例模板 功能测试用例最重要的两个因素是测试步骤和预期结果&#xff0c;接口测试属于功能测试&#xff0c;所以同理。接口测试的步骤中&#xff0c;最重要的是…
阅读更多...
嵌入式硬件电路原理图之跟随电路

嵌入式硬件电路原理图之跟随电路

描述 电压跟随电路 电压跟随器是共集电极电路&#xff0c;信号从基极输入&#xff0c;射极输出&#xff0c;故又称射极输出器。基极电压与集电极电压相位相同&#xff0c;即输入电压与输出电压同相。这一电路的主要特点是&#xff1a;高输入电阻、低输出电阻、电压增益近似为…
阅读更多...
【单片机】延迟程序＆延迟子程序的设计（入门）

【单片机】延迟程序＆延迟子程序的设计（入门）

前言 大家好吖&#xff0c;欢迎来到 YY 滴小小知识点系列 &#xff0c;热烈欢迎&#xff01; 本章主要内容面向接触过单片机知识点的老铁 主要内容含&#xff1a; 欢迎订阅 YY滴C专栏&#xff01;更多干货持续更新&#xff01;以下是传送门&#xff01; YY的《C》专栏YY的《C1…
阅读更多...
动态规划(不同路径1，不同路径2，整数拆分)

动态规划(不同路径1，不同路径2，整数拆分)

62.不同路径 力扣题目链接(opens new window) 一个机器人位于一个 m x n 网格的左上角 &#xff08;起始点在下图中标记为 “Start” &#xff09;。 机器人每次只能向下或者向右移动一步。机器人试图达到网格的右下角&#xff08;在下图中标记为 “Finish” &#xff09;。…
阅读更多...
Linux操作系统——进程控制（一） 进程创建和进程终止

Linux操作系统——进程控制（一） 进程创建和进程终止

进程创建 fork函数 在linux中fork函数时非常重要的函数&#xff0c;它从已存在进程中创建一个新进程。新进程为子进程&#xff0c;而原进程为父进程。 #include <unistd.h> pid_t fork(void); 返回值&#xff1a;自进程中返回0&#xff0c;父进程返回子进程id&#xff…
阅读更多...
数据结构和算法-交换排序中的冒泡排序（过程 代码实现 算法效率 稳定性 适用链表？）

数据结构和算法-交换排序中的冒泡排序（过程 代码实现 算法效率 稳定性 适用链表？）

文章目录 总览冒泡排序冒泡&#xff1f;啥是冒泡排序冒泡排序过程算法实现算法性能分析稳定性冒泡排序是否适用于链表 小结 总览 冒泡排序 冒泡&#xff1f; 自然界的冒泡 啥是冒泡排序 冒泡排序过程 此时序列要求递增的 首先比较27和49&#xff0c;发现符号递增序列&…
阅读更多...
【Linux Shell】6. echo 命令

【Linux Shell】6. echo 命令

文章目录 【 1. 显示普通字符串 】【 2. 显示转义字符 】【 3. 显示变量 】【 4. 显示换行 】【 5. 显示不换行 】【 6. 显示命令执行结果 】 Shell 的 echo 指令用于字符串的输出。命令格式&#xff1a; echo string【 1. 显示普通字符串 】 #!/bin/bashecho "It is a …
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023