RabbitMQ之延迟队列（万字总结，手把手教你学习延迟队列）

news2024/11/24 17:07:55

文章目录

  • 一、延迟队列概念
  • 二、延迟队列使用场景
  • 三、RabbitMQ 中的 TTL
    • 1、队列设置 TTL
    • 2、消息设置 TTL
    • 3、两者的区别
  • 四、整合 springboot
    • 1、添加依赖
    • 2、修改配置文件
    • 3、添加 Swagger 配置类
  • 五、队列 TTL
    • 1、代码架构图
    • 2、配置文件类代码
    • 3、消息生产者代码
    • 4、消息消费者代码
  • 六、延时队列优化
    • 1、代码架构图
    • 2、配置文件类代码
    • 3、消息生产者代码
  • 七、Rabbitmq 插件实现延迟队列
  • 1、安装延时队列插件
    • 2、代码架构图
    • 3、配置文件类代码
    • 4、消息生产者代码
    • 5、消息消费者代码
  • 总结

一、延迟队列概念

延时队列,队列内部是有序的，最重要的特性就体现在它的延时属性上，延时队列中的元素是希望在指定时间到了以后或之前取出和处理，简单来说，延时队列就是用来存放需要在指定时间被处理的元素的队列的。

二、延迟队列使用场景

  • 1.订单在十分钟之内未支付则自动取消
  • 2.新创建的店铺，如果在十天内都没有上传过商品，则自动发送消息提醒。
  • 3.用户注册成功后，如果三天内没有登陆则进行短信提醒。
  • 4.用户发起退款，如果三天内没有得到处理则通知相关运营人员。
  • 5.预定会议后，需要在预定的时间点前十分钟通知各个与会人员参加会议

这些场景都有一个特点，需要在某个事件发生之后或者之前的指定时间点完成某一项任务，如：发生订单生成事件，在十分钟之后检查该订单支付状态，然后将未支付的订单进行关闭；看起来似乎使用定时任务，一直轮询数据，每秒查一次，取出需要被处理的数据，然后处理不就完事了吗？如果数据量比较少，确实可以这样做，比如：对于“如果账单一周内未支付则进行自动结算”这样的需求，如果对于时间不是严格限制，而是宽松意义上的一周，那么每天晚上跑个定时任务检查一下所有未支付的账单，确实也是一个可行的方案。但对于数据量比较大，并且时效性较强的场景，如：“订单十分钟内未支付则关闭“，短期内未支付的订单数据可能会有很多，活动期间甚至会达到百万甚至千万级别，对这么庞大的数据量仍旧使用轮询的方式显然是不可取的，很可能在一秒内无法完成所有订单的检查，同时会给数据库带来很大压力，无法满足业务要求而且性能低下。

在这里插入图片描述

三、RabbitMQ 中的 TTL

TTL 是什么呢？TTL 是 RabbitMQ 中一个消息或者队列的属性，表明一条消息或者该队列中的所有
消息的最大存活时间，单位是毫秒。换句话说，如果一条消息设置了 TTL 属性或者进入了设置 TTL 属性的队列，那么这条消息如果在 TTL 设置的时间内没有被消费，则会成为"死信"。如果同时配置了队列的 TTL 和消息的TTL，那么较小的那个值将会被使用，有两种方式设置 TTL。

1、队列设置 TTL

第一种是在创建队列的时候设置队列的“x-message-ttl”属性
在这里插入图片描述

2、消息设置 TTL

第二种是针对每条消息设置 TTL
在这里插入图片描述

3、两者的区别

如果设置了队列的 TTL 属性，那么一旦消息过期，就会被队列丢弃(如果配置了死信队列被丢到死信队列中)，而第二种方式，消息即使过期，也不一定会被马上丢弃，因为消息是否过期是在即将投递到消费者之前判定的，如果当前队列有严重的消息积压情况，则已过期的消息也许还能存活较长时间；另外，还需要注意的一点是，如果不设置 TTL，表示消息永远不会过期，如果将 TTL 设置为 0，则表示除非此时可以直接投递该消息到消费者，否则该消息将会被丢弃。

四、整合 springboot

1、添加依赖

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--RabbitMQ 依赖-->

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

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.47</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <!--swagger-->
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger2</artifactId>
            <version>2.9.2</version>
        </dependency>
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger-ui</artifactId>
            <version>2.9.2</version>
        </dependency>
        <!--RabbitMQ 测试依赖-->
        <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

2、修改配置文件

spring.rabbitmq.host=192.168.10.130
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3、添加 Swagger 配置类

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Contact;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
@Configuration
@EnableSwagger2
public class SwaggerConfig {
 	@Bean
 	public Docket webApiConfig(){
 		return new Docket(DocumentationType.SWAGGER_2)
 			.groupName("webApi")
 			.apiInfo(webApiInfo())
 			.select()
 			.build();
 	}
 	private ApiInfo webApiInfo(){
 		return new ApiInfoBuilder()
 			.title("rabbitmq 接口文档")
 			.description("本文档描述了 rabbitmq 微服务接口定义")
 			.version("1.0")
 			.contact(new Contact("enjoy6288", "http://atguigu.com", "1551388580@qq.com"))
 			.build();
 	}
}

五、队列 TTL

1、代码架构图

创建两个队列 QA 和 QB，两者队列 TTL 分别设置为 10S 和 40S，然后在创建一个交换机 X 和死信交换机 Y，它们的类型都是 direct，创建一个死信队列 QD，它们的绑定关系如下：
在这里插入图片描述

2、配置文件类代码

@Configuration
public class TtlQueueConfig {
 	public static final String X_EXCHANGE = "X";
 	public static final String QUEUE_A = "QA";
 	public static final String QUEUE_B = "QB";
 	public static final String Y_DEAD_LETTER_EXCHANGE = "Y";
 	public static final String DEAD_LETTER_QUEUE = "QD";
 	// 声明 xExchange
 	@Bean("xExchange")
 	public DirectExchange xExchange(){
 		return new DirectExchange(X_EXCHANGE);
 	}
 	// 声明 xExchange
 	@Bean("yExchange")
 	public DirectExchange yExchange(){
 		return new DirectExchange(Y_DEAD_LETTER_EXCHANGE);
 	}
 	//声明队列 A ttl 为 10s 并绑定到对应的死信交换机
 	@Bean("queueA")
 	public Queue queueA(){
 		Map<String, Object> args = new HashMap<>(3);
 		//声明当前队列绑定的死信交换机
 		args.put("x-dead-letter-exchange", Y_DEAD_LETTER_EXCHANGE);
 		//声明当前队列的死信路由 key
 		args.put("x-dead-letter-routing-key", "YD");
 		//声明队列的 TTL
 		args.put("x-message-ttl", 10000);
 		return QueueBuilder.durable(QUEUE_A).withArguments(args).build();
 	}
 	// 声明队列 A 绑定 X 交换机
 	@Bean
 	public Binding queueaBindingX(@Qualifier("queueA") Queue queueA,@Qualifier("xExchange") DirectExchange xExchange){
 		return BindingBuilder.bind(queueA).to(xExchange).with("XA");
 	}
 	//声明队列 B ttl 为 40s 并绑定到对应的死信交换机
 	@Bean("queueB")
 	public Queue queueB(){
 		Map<String, Object> args = new HashMap<>(3);
 		//声明当前队列绑定的死信交换机
 		args.put("x-dead-letter-exchange", Y_DEAD_LETTER_EXCHANGE);
 		//声明当前队列的死信路由 key
 		args.put("x-dead-letter-routing-key", "YD");
 		//声明队列的 TTL
 		args.put("x-message-ttl", 40000);
 		return QueueBuilder.durable(QUEUE_B).withArguments(args).build();
 	}
 	//声明队列 B 绑定 X 交换机
 	@Bean
 	public Binding queuebBindingX(@Qualifier("queueB") Queue queue1B,@Qualifier("xExchange") DirectExchange xExchange){
 		return BindingBuilder.bind(queue1B).to(xExchange).with("XB");
 	}
 	//声明死信队列 QD
 	@Bean("queueD")
 	public Queue queueD(){
 		return new Queue(DEAD_LETTER_QUEUE);
 	}
 	//声明死信队列 QD 绑定关系
 	@Bean
 	public Binding deadLetterBindingQAD(@Qualifier("queueD") Queue queueD,@Qualifier("yExchange") DirectExchange yExchange){
 		return BindingBuilder.bind(queueD).to(yExchange).with("YD");
 	}
}

3、消息生产者代码

@Slf4j
@RequestMapping("ttl")
@RestController
public class SendMsgController {
 	@Autowired
 	private RabbitTemplate rabbitTemplate;
 	@GetMapping("sendMsg/{message}")
 	public void sendMsg(@PathVariable String message){
 		log.info("当前时间：{},发送一条信息给两个 TTL 队列:{}", new Date(), message);
 		rabbitTemplate.convertAndSend("X", "XA", "消息来自 ttl 为 10S 的队列: "+message);
 		rabbitTemplate.convertAndSend("X", "XB", "消息来自 ttl 为 40S 的队列: "+message);
 	} 
}

4、消息消费者代码

@Slf4j
@Component
public class DeadLetterQueueConsumer {
 	@RabbitListener(queues = "QD")
 	public void receiveD(Message message, Channel channel) throws IOException {
 		String msg = new String(message.getBody());
 		log.info("当前时间：{},收到死信队列信息{}", new Date().toString(), msg);
 	}
}

发起一个请求 http://localhost:8080/ttl/sendMsg/嘻嘻嘻

在这里插入图片描述第一条消息在 10S 后变成了死信消息，然后被消费者消费掉，第二条消息在 40S 之后变成了死信消息，然后被消费掉，这样一个延时队列就打造完成了。

不过，如果这样使用的话，岂不是每增加一个新的时间需求，就要新增一个队列，这里只有 10S 和 40S两个时间选项，如果需要一个小时后处理，那么就需要增加 TTL 为一个小时的队列，如果是预定会议室然后提前通知这样的场景，岂不是要增加无数个队列才能满足需求？

六、延时队列优化

1、代码架构图

在这里新增了一个队列 QC,绑定关系如下,该队列不设置 TTL 时间
在这里插入图片描述

2、配置文件类代码

@Component
public class MsgTtlQueueConfig {
 	public static final String Y_DEAD_LETTER_EXCHANGE = "Y";
 	public static final String QUEUE_C = "QC";
 	//声明队列 C 死信交换机
 	@Bean("queueC")
 	public Queue queueB(){
 		Map<String, Object> args = new HashMap<>(3);
 		//声明当前队列绑定的死信交换机
 		args.put("x-dead-letter-exchange", Y_DEAD_LETTER_EXCHANGE);
 		//声明当前队列的死信路由 key
 		args.put("x-dead-letter-routing-key", "YD");
 		//没有声明 TTL 属性
 		return QueueBuilder.durable(QUEUE_C).withArguments(args).build();
 	}
 	//声明队列 B 绑定 X 交换机
 	@Bean
 	public Binding queuecBindingX(@Qualifier("queueC") Queue queueC,@Qualifier("xExchange") DirectExchange xExchange){
 		return BindingBuilder.bind(queueC).to(xExchange).with("XC");
 	}
}

3、消息生产者代码

@GetMapping("sendExpirationMsg/{message}/{ttlTime}")
public void sendMsg(@PathVariable String message,@PathVariable String ttlTime) {
 	rabbitTemplate.convertAndSend("X", "XC", message, correlationData ->{
 		correlationData.getMessageProperties().setExpiration(ttlTime);
 		return correlationData;
 	});
 	log.info("当前时间：{},发送一条时长{}毫秒 TTL 信息给队列 C:{}", new Date(),ttlTime, message);
}

发起请求

  • http://localhost:8080/ttl/sendExpirationMsg/你好 1/20000
  • http://localhost:8080/ttl/sendExpirationMsg/你好 2/2000

在这里插入图片描述
看起来似乎没什么问题，但是在最开始的时候，就介绍过如果使用在消息属性上设置 TTL 的方式，消息可能并不会按时“死亡“，因为 RabbitMQ 只会检查第一个消息是否过期，如果过期则丢到死信队列，如果第一个消息的延时时长很长，而第二个消息的延时时长很短，第二个消息并不会优先得到执行。

七、Rabbitmq 插件实现延迟队列

1、安装延时队列插件

因为博主是用Docker安装的RabbitMQ，所以安装延时队列插件也是在Docker中进行。
首先在官网下载rabbitmq_delayed_message_exchange 插件。
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases
在这里插入图片描述
点击下载.ez文件。
然后通过自己的文件传输工具将.ez文件上传到虚拟机中，博主这里将.ez文件放到了/mnt目录下。
在这里插入图片描述
然后输入sudo docker ps命令查看自己的rabbitmq是否正在运行，如果不在运行则输入sudo docker start idid这里填你自己的容器id，如果不知道自己id的，输入sudo docker pa -a查看。
在这里插入图片描述

当容器运行起来后，输入sudo docker cp /mnt/rabbitmq_delayed_message_exchange-3.12.0.ez rabbit:/plugins命令，将刚插件拷贝到容器内plugins目录下。
在这里插入图片描述
拷贝完成后，输入sudo docker exec -it rabbit /bin/bash命令，进入容器。
在这里插入图片描述

在容器内plugins目录下，查看插件是否上传成功ls -l|grep delay

在这里插入图片描述
然后启动插件，在当前目录下输入rabbitmq-plugins enable rabbitmq_delayed_message_exchange命令
在这里插入图片描述
到这里插件安装就完成了，接下来我们需要重启RabbitMQ容器。执行exit命令退出RabbitMQ容器内部，然后执行docker restart rabbit命令重启RabbitMQ容器
在这里插入图片描述
在容器重启完成后，我们可以登录RabbitMQ的Web端管理界面，在Exchanges选项卡下，点击Add a new exchange，在Type里面看是否出现了x-delayed-message选项，如下图到这里，整个安装过程就完毕了。
在这里插入图片描述

2、代码架构图

在这里新增了一个队列 delayed.queue,一个自定义交换机 delayed.exchange，绑定关系如下:
在这里插入图片描述

3、配置文件类代码

在我们自定义的交换机中，这是一种新的交换类型，该类型消息支持延迟投递机制 消息传递后并不会立即投递到目标队列中，而是存储在 mnesia(一个分布式数据系统)表中，当达到投递时间时，才投递到目标队列中。

@Configuration
public class DelayedQueueConfig {
 	public static final String DELAYED_QUEUE_NAME = "delayed.queue";
 	public static final String DELAYED_EXCHANGE_NAME = "delayed.exchange";
 	public static final String DELAYED_ROUTING_KEY = "delayed.routingkey";
 	@Bean
 	public Queue delayedQueue() {
 		return new Queue(DELAYED_QUEUE_NAME);
 	}
 	//自定义交换机 我们在这里定义的是一个延迟交换机
 	@Bean
	 public CustomExchange delayedExchange() {
		Map<String, Object> args = new HashMap<>();
 		//自定义交换机的类型
 		args.put("x-delayed-type", "direct");
 		return new CustomExchange(DELAYED_EXCHANGE_NAME, "x-delayed-message", true, false, args);
 	}
 	@Bean
 	public Binding bindingDelayedQueue(@Qualifier("delayedQueue") Queue queue,@Qualifier("delayedExchange") CustomExchange delayedExchange) {
 		return BindingBuilder.bind(queue).to(delayedExchange).with(DELAYED_ROUTING_KEY).noargs();
 	}
}

4、消息生产者代码

public static final String DELAYED_EXCHANGE_NAME = "delayed.exchange";
public static final String DELAYED_ROUTING_KEY = "delayed.routingkey";
@GetMapping("sendDelayMsg/{message}/{delayTime}")
public void sendMsg(@PathVariable String message,@PathVariable Integer delayTime) {
 	rabbitTemplate.convertAndSend(DELAYED_EXCHANGE_NAME, DELAYED_ROUTING_KEY, message, correlationData ->{
 		correlationData.getMessageProperties().setDelay(delayTime);
 		return correlationData;
 	});
 	log.info(" 当 前 时 间 ： {}, 发送一条延迟 {} 毫秒的信息给队列 delayed.queue:{}", new 
Date(),delayTime, message);
}

5、消息消费者代码

public static final String DELAYED_QUEUE_NAME = "delayed.queue";
@RabbitListener(queues = DELAYED_QUEUE_NAME)
public void receiveDelayedQueue(Message message){
 	String msg = new String(message.getBody());
 	log.info("当前时间：{},收到延时队列的消息：{}", new Date().toString(), msg);
}

发起请求：

  • http://localhost:8080/ttl/sendDelayMsg/come on baby1/20000
  • http://localhost:8080/ttl/sendDelayMsg/come on baby2/2000

在这里插入图片描述
第二个消息被先消费掉了，符合预期

总结

延时队列在需要延时处理的场景下非常有用，使用 RabbitMQ 来实现延时队列可以很好的利用RabbitMQ 的特性，如：消息可靠发送、消息可靠投递、死信队列来保障消息至少被消费一次以及未被正确处理的消息不会被丢弃。另外，通过 RabbitMQ 集群的特性，可以很好的解决单点故障问题，不会因为单个节点挂掉导致延时队列不可用或者消息丢失。

当然，延时队列还有很多其它选择，比如利用 Java 的 DelayQueue，利用 Redis 的 zset，利用 Quartz或者利用 kafka 的时间轮，这些方式各有特点,看需要适用的场景

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

RT-Thread STM32F407 ADC

RT-Thread STM32F407 ADC

ADC(Analog-to-Digital Converter) 指模数转换器。是指将连续变化的模拟信号转换为离散的数字信号的器件。真实世界的模拟信号&#xff0c;例如温度、压力、声音或者图像等&#xff0c;需要转换成更容易储存、处理和发射的数字形式。模数转换器可以实现这个功能&#xff0c;在各…
阅读更多...
如何解决网页中的pdf文件无法下载？pdf打印显示空白怎么办？

如何解决网页中的pdf文件无法下载？pdf打印显示空白怎么办？

问题描述 偶然间&#xff0c;遇到这样一个问题&#xff0c;一个网页上的附件pdf想要下载打印下来&#xff0c;奈何尝试多种办法都不能将其下载下载&#xff0c;点击打印出现的也是一片空白 百度搜索了一些解决方案都不太行&#xff0c;主要解决方案如&#xff1a;https://zh…
阅读更多...
计算机网络——物理层-编码与调制（数字基带信号、模拟基带信号、码元、常用编码、基本调制方法、混合调制）

计算机网络——物理层-编码与调制（数字基带信号、模拟基带信号、码元、常用编码、基本调制方法、混合调制）

目录 编码与调制 数字基带信号 模拟基带信号 码元 常用编码 不归零编码 归零编码 曼彻斯特编码 差分曼彻斯特编码 编码习题 基本调制方法 调幅 调频 调相 混合调制 QAM-16 编码与调制 在计算机网络中&#xff0c;计算机需要处理和传输用户的文字、图片、音频…
阅读更多...
JavaScript学习_01——JavaScript简介

JavaScript学习_01——JavaScript简介

JavaScript简介 JavaScript介绍 JavaScript是一种轻量级的脚本语言。所谓“脚本语言”&#xff0c;指的是它不具备开发操作系统的能力&#xff0c;而是只用来编写控制其他大型应用程序的“脚本”。 JavaScript 是一种嵌入式&#xff08;embedded&#xff09;语言。它本身提供…
阅读更多...
ubuntu中cuda12.1配置（之前存在11.1版本的cuda）(同时配置两个版本)

ubuntu中cuda12.1配置（之前存在11.1版本的cuda）(同时配置两个版本)

ubuntu中cuda12.1配置 由于YOLOv8项目中Pytorch版本需要cuda12.1版本 在官网下载12.1版本的deb包 官网地址 sudo dpkg -i cuda-keyring_1.0-1_all.deb sudo apt-get update sudo apt-get -y install cuda然后需要修改bashrc文件&#xff08;隐藏文件&#xff09; 添加 exp…
阅读更多...
C#，数值计算——插值和外推，BaryRat_interp的计算方法与源程序

C#，数值计算——插值和外推，BaryRat_interp的计算方法与源程序

1 文本格式 using System; namespace Legalsoft.Truffer { /// <summary> /// 重心有理插值对象 /// Barycentric rational interpolation object. /// After constructing the object, /// call interp for interpolated values. /// Note t…
阅读更多...
供应商选择和评估：如何寻找合适的供应商并与其合作

供应商选择和评估：如何寻找合适的供应商并与其合作

如果供应商不能按时交货或产品质量低劣&#xff0c;制造商的生产计划就会延误&#xff1b;客户交货将被延迟&#xff0c;商品可能被退回&#xff0c;你的公司声誉也将受损。 要在当今竞争激烈的市场中取得成功&#xff0c;你需要一流的、价格合理且来源可靠的原材料和服务&…
阅读更多...
Leetcode刷题详解——岛屿数量

Leetcode刷题详解——岛屿数量

1. 题目链接&#xff1a;200. 岛屿数量 2. 题目描述&#xff1a; 给你一个由 1&#xff08;陆地&#xff09;和 0&#xff08;水&#xff09;组成的的二维网格&#xff0c;请你计算网格中岛屿的数量。 岛屿总是被水包围&#xff0c;并且每座岛屿只能由水平方向和/或竖直方向上…
阅读更多...
php快速排序法

php快速排序法

快速排序是一种常用的排序算法&#xff0c;也是最快的排序算法之一。其基本思想是通过一趟排序将待排序的数据分割成两部分&#xff0c;其中一部分的所有数据都比另一部分的所有数据小&#xff0c;然后再对这两部分分别进行快速排序&#xff0c;递归地重复这个过程&#xff0c;…
阅读更多...
wpf devexpress post 更改数据库

wpf devexpress post 更改数据库

这个教程示范如何使用GridControl编辑数据&#xff0c;和保存更改到数据库。这个教程基于前一个篇。 Items Source Wizard 当 CRUD (Create, Read, Update, Delete) 启动选项时添加Post data功能 Items Source Wizard 生成如下代码&#xff1a; 1、设置 TableView.ShowUpdat…
阅读更多...
滚雪球学Java(09-1)：Java中的算术运算符，你真的掌握了吗？

滚雪球学Java(09-1)：Java中的算术运算符，你真的掌握了吗？

咦咦咦&#xff0c;各位小可爱&#xff0c;我是你们的好伙伴——bug菌&#xff0c;今天又来给大家普及Java SE相关知识点了&#xff0c;别躲起来啊&#xff0c;听我讲干货还不快点赞&#xff0c;赞多了我就有动力讲得更嗨啦&#xff01;所以呀&#xff0c;养成先点赞后阅读的好…
阅读更多...
力扣第84 题柱状图中最大的矩形 C++ 单调栈 Java

力扣第84 题柱状图中最大的矩形 C++ 单调栈 Java

题目 84. 柱状图中最大的矩形 困难 相关标签 栈 数组 单调栈 给定 n 个非负整数&#xff0c;用来表示柱状图中各个柱子的高度。每个柱子彼此相邻&#xff0c;且宽度为 1 。 求在该柱状图中&#xff0c;能够勾勒出来的矩形的最大面积。 示例 1: 输入&#xff1a;heigh…
阅读更多...
人工智能基础_机器学习032_多项式回归升维_原理理解---人工智能工作笔记0072

人工智能基础_机器学习032_多项式回归升维_原理理解---人工智能工作笔记0072

现在开始我们来看多项式回归,首先理解多维 原来我们学习的使用线性回归,其实就是一条直线对吧,那个是一维的,我们之前学的全部都是一维的对吧,是一维的,然后是多远的,因为有多个x1,x2,x3,x4... 但是比如我们有一个数据集,是上面这种,的如果用一条直线很难拟合,那么 这个时候,…
阅读更多...
贪吃蛇游戏和俄罗斯方块

贪吃蛇游戏和俄罗斯方块

一、创建新项目 创建一个新的项目&#xff0c;并命名。 创建一个名为images的文件夹用来存放游戏相关图片。 然后再在项目的src文件下创建一个com.xxx.view的包用来存放所有的图形界面类&#xff0c; 创建一个com.xxx.controller的包用来存放启动的入口类(控制类) package …
阅读更多...
多svn仓库一键更新脚本分享

多svn仓库一键更新脚本分享

之前分享过多git仓库一键更新脚本&#xff0c;本期就分享下svn仓库的一键更新脚本 1、首先需要设置svn为可执行命令行 打开SVN安装程序&#xff0c;选择modify&#xff0c;然后点击 command client tools&#xff0c;安装命令行工具 2、update脚本 echo 开始更新SVN目录&…
阅读更多...
Uniapp-小程序自定义导航栏

Uniapp-小程序自定义导航栏

一、项目背景 制作小程序页面时候发现原生导航栏有一定的高度是没有背景渲染的会出现这种情况 但是我们需要的是 二、原因 小程序的原生导航栏存在。一般可以使用 纯色填充顶部栏 可以直接使用navigationBarBackgroundColor完成 在style中添加 "navigationBarBackgrou…
阅读更多...
一文图解爬虫_姊妹篇（spider）

一文图解爬虫_姊妹篇（spider）

—引导语 爬虫&#xff0c;没有一个时代比当前更重视它。一个好的爬虫似乎可以洞穿整个互联网&#xff0c;“来装满自己的胃”。 接上一篇&#xff1a;一文图解爬虫&#xff08;spider&#xff09; 博主已初步对爬虫的“五脏六腑”进行了解剖。虽然俗称“爬虫”&#xff0c;但窃…
阅读更多...
[C国演义] 第十九章

[C国演义] 第十九章

第十九章 回文子串最长回文子串 子串, 等价于 子数组, 都要求连续 回文子串 力扣链接 子串 ⇒ 状态表示 子串 ⇒ 状态转移方程 初始化 : 全都初始化为 false 遍历顺序 返回结果 : 此时的dp表中, 已经是每个区间能否是回文子串的结果了 ⇒ 我们要统计所有的回文子串的…
阅读更多...
PDF文件标题修改方法

PDF文件标题修改方法

目录 一、PDF文件的标题和名称 二、标题修改方法 1.浏览器打开PDF Editor Free网站 2.点击Free Oline 3.选择第三个从本地上传PDF附件 4.将附件上传&#xff0c;两种方法都可以​编辑 5.等待加载&#xff0c;附件大的情况下会有些慢&#xff0c;耐心等待即可 6. 导入文…
阅读更多...
PyG(torch_geometric)的MessagePassing详解

PyG(torch_geometric)的MessagePassing详解

1. 提出MessagePassing的目的 MessagePassing是图神经网络&#xff08;Graph Neural Networks&#xff0c;GNNs&#xff09;的一个基础组件&#xff0c;它被设计用来处理图形数据的问题。在图形数据中&#xff0c;数据点&#xff08;节点&#xff09;之间的关系&#xff08;边…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023