【RabbitMQ】延迟队列之死信交换机

🎉🎉欢迎来到我的CSDN主页!🎉🎉

🏅我是Java方文山,一个在CSDN分享笔记的博主。📚📚

🌟推荐给大家我的专栏《RabbitMQ实战》。🎯🎯

👉点击这里,就可以查看我的主页啦!👇👇

Java方文山的个人主页

🎁如果感觉还不错的话请给我点赞吧!🎁🎁

💖期待你的加入,一起学习,一起进步!💖💖

请添加图片描述

✨前言

了解延迟队列之前我们先了解两个概念TTL和 DXL两个概念:

TTL概念

TTL 顾名思义:指的是消息的存活时间,RabbitMQ可以通过x-message-tt参数来设置指定Queue(队列)和 Message(消息)上消息的存活时间,它的值是一个非负整数,单位为微秒。

RabbitMQ 可以从两种维度设置消息过期时间,分别是队列和消息本身

设置队列过期时间,那么队列中所有消息都具有相同的过期时间。
设置消息过期时间,对队列中的某一条消息设置过期时间,每条消息TTL都可以不同。
如果同时设置队列和队列中消息的TTL,则TTL值以两者中较小的值为准。而队列中的消息存在队列中的时间,一旦超过TTL过期时间则成为Dead Letter(死信)。

 DLX概念

DLX,全称为 Dead-Letter-Exchange,可以称之为死信交换器,也有人称之为死信邮箱。当
消息在一个队列中变成死信(dead message)之后,它能被重新被发送到另一个交换器中,这个
交换器就是 DLX,绑定 DLX 的队列就称之为死信队列或者可以称之为延迟队列。
消息变成死信一般是由于以下几种情况:
🎈 消息被拒绝( Basic.Reject/Basic.Nack ),并且设置 requeue 参数为 false
🎈 消息过期(TTL过期);
🎈队列达到最大长度。
延迟队列存储的对象是对应的延迟消息,所谓“延迟消息”是指当消息被发送以后,并不想让消费者立刻拿到消息,而是等待特定时间后,消费者才能拿到这个消息进行消费。
延迟队列的使用场景有很多,比如:
  • 在订单系统中,一个用户下单之后通常有 30 分钟的时间进行支付,如果 30 分钟之内没有支付成功,那么这个订单将进行异常处理,这时就可以使用延迟队列来处理这些订单了。
  • 用户希望通过手机远程遥控家里的智能设备在指定的时间进行工作。这时候就可以将用户指令发送到延迟队列,当指令设定的时间到了再将指令推送到智能设备。

AMQP 协议中,或者 RabbitMQ 本身没有直接支持延迟队列的功能,但是可以通过前面
所介绍的 DLX TTL 模拟出延迟队列的功能。

🎉死信交换机的使用

1.案例分析

下面我会讲解两种使用死信的方式:

第一种是我们不为正常的交换机设置消费者,为该队列中的消息设置TTL如果消息过期了就会变为死信就会被发送到死信交换机中处理对应的事务

假设我们有一个订单系统,订单有一个待支付状态,如果在30分钟内未支付,则自动变为已取消状态。我们可以通过 RabbitMQ 的 TTL 机制和死信队列来实现这个功能。

具体步骤如下:

  1. 创建一个普通的交换机(例如 orderExchange)和一个普通的队列(例如 orderQueue)。将队列绑定到交换机上。

  2. 创建一个死信交换机(例如 deadLetterExchange)和一个死信队列(例如 deadLetterQueue)。将死信队列绑定到死信交换机上。

  3. 将普通队列设置为有 TTL 的队列,并指定 TTL 的时间为30分钟。这样,如果消息在队列中存活时间超过30分钟,就会变为死信。

  4. 设置普通队列的死信交换机和死信路由键。当消息变为死信时,会被发送到死信交换机,并根据死信路由键路由到对应的死信队列。

  5. 创建一个死信消费者,监听死信队列中的消息。当收到订单消息时,判断订单是否已经支付,如果未支付则将其修改为已取消状态。

这种方式可以灵活地处理订单超时自动取消的需求,并且不需要为每个订单单独创建消费者,降低了系统的复杂性。同时,通过使用 RabbitMQ 的 TTL 机制和死信队列,还可以实现其他类似的延迟任务处理场景。

第二种则是为正常队列创建一个消费者但是开启手动确认,什么意思呢,我们的RabbitMQ中的消费者都是自动消费的,所以我们可以设置为手动确认消费,我接收到你这个消息了,但我还未处理,而是由消费者主动发送确认信号(ACK)给 RabbitMQ,告知消息已经成功处理,这条消息才算是被消费了。

以下情况会使用这种方式:

  1. 并发处理:当多个消费者同时消费同一个队列中的消息时,为了保证消息不被重复消费或丢失,可以使用手动签收。消费者在处理完消息后,手动发送 ACK 确认消息处理完成,这样 RabbitMQ 就知道该消息已经被正确处理,可以将其标记为已消费。

  2. 消息处理失败:如果消费者在处理消息时发生了异常或错误,可以选择不发送 ACK,即不确认消息的消费完成。这样 RabbitMQ 就会重新将该消息发送给其他消费者进行处理,确保消息不会丢失。

  3. 消息处理耗时较长:某些消息的处理可能需要较长的时间,为了防止 RabbitMQ 认为该消息处理超时而重新发送给其他消费者,可以使用手动签收。消费者在开始处理消息时,发送 ACK 告知 RabbitMQ 接收到消息并开始处理,然后在处理完成后再发送 ACK 确认消息处理完成。

2.案例1实践

创建交换机、队列以及它们的绑定关系
package org.example.produce.config;import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.HashMap;
import java.util.Map;@Configuration
@SuppressWarnings("all")
public class RabbitConfig {/*** 定义正常队列* @return*/@Beanpublic Queue QueueA(){Map<String, Object> config = new HashMap<>();config.put("x-message-ttl", 10000);//message在该队列queue的存活时间最大为10秒config.put("x-dead-letter-exchange", "deadExchange"); //x-dead-letter-exchange参数是设置该队列的死信交换器(DLX)config.put("x-dead-letter-routing-key", "bb");//x-dead-letter-routing-key参数是给这个DLX指定路由键return new Queue("QueueA", true, true, false, config);}/*** 定义死信队列* @return*/@Beanpublic Queue QueueB(){return new Queue("QueueB");}/*** 自定义直连交换机* @return*/@Beanpublic DirectExchange directExchangeA(){return new DirectExchange("direct-exchangeA",true,false);}/*** 自定义死信交换机* @return*/@Beanpublic DirectExchange directExchangeB(){return new DirectExchange("direct-exchangeB",true,false);}/*** 将正常队列与直连交换机进行绑定,并设置路由键与死信交换机以及队列* @return*/@Beanpublic Binding bindingExchangeA(){return BindingBuilder.bind(QueueA()).to(directExchangeA()).with("aa");}/*** 将死信队列与死信交换机进行绑定,并设置路由键* @return*/@Beanpublic Binding bindingExchangeB(){return BindingBuilder.bind(QueueB()).to(directExchangeB()).with("bb");}}
  1. x-message-ttl 参数是设置消息在队列中的存活时间,单位为毫秒。在这个例子中,设置了 10000 毫秒,即 10 秒钟。如果一个消息在该队列中未被消费者接收并确认处理,那么该消息就会被自动移除出队列,避免消息的过期占用队列资源。

  2. x-dead-letter-exchange 参数是设置该队列的死信交换器(DLX),表示当一个消息变成死信时,会被发送到指定的 DLX 中。在这个例子中,设置的死信交换器为 "direct-exchangeB",即将死信消息发送到名为 "direct-exchangeB" 的交换器。

  3. x-dead-letter-routing-key 参数是给该 DLX 指定一个路由键。当消息变成死信时,会根据该路由键将它发送到绑定该路由键的队列中。在这个例子中,设置的路由键为 "bb",即将死信消息发送到名为 "QueueB" 的队列中。

 创建消息的生产者
package org.example.produce.controller;import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.HashMap;
import java.util.Map;@RestController
public class Sender {@Autowiredprivate AmqpTemplate rabbitTemplate;@RequestMapping("/send")public String send() {Map<String,Object> data=new HashMap<>();data.put("msg","订单ID:121452623345");rabbitTemplate.convertAndSend("direct-exchangeA","aa", data);return "😎";}
}
创建死信队列的消费者 
package org.example.produce.controller;import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;import java.util.Map;@Component
@RabbitListener(queues = {"QueueB"})
public class BReceiver {@RabbitHandlerpublic void handler(Map<String,Object> json){System.out.println(json);}
}

效果展示: 

 访问一下http://localhost:8081/send

访问一下http://118.178.124.148:15672

可以看到已经有我们的队列了,现在我们开启消费者服务查看一下

也是可以拿到原先队列中的消息的,说明我们的死信交换机和死信队列生效了

RabbitMQ死信队列优化

如果我们想要第一条消息在6s后变成了死信消息,然后被消费者消费掉,第二条消息在60s之后变成了死信消息,然后被消费掉,这样,岂不是每增加一个新的时间需求,就要新增一个队列,这里只有6s和60s两个时间选项,如果需要一个小时后处理,那么就需要增加TTL为一个小时的队列,如果是预定会议室然后提前通知这样的场景,岂不是要增加无数个队列才能满足需求??

其实我们可以增加一个延时队列,用于接收设置为任意延时时长的消息,增加一个相应的死信队列和routingkey

创建交换机、队列以及它们的绑定关系

package org.example.produce.config;import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.HashMap;
import java.util.Map;@Configuration
@SuppressWarnings("all")
public class RabbitConfig {/*** 定义正常队列* @return*/@Beanpublic Queue QueueA(){Map<String, Object> config = new HashMap<>();config.put("x-message-ttl", 10000);//message在该队列queue的存活时间最大为10秒config.put("x-dead-letter-exchange", "direct-exchangeB"); //x-dead-letter-exchange参数是设置该队列的死信交换器(DLX)config.put("x-dead-letter-routing-key", "bb");//x-dead-letter-routing-key参数是给这个DLX指定路由键return new Queue("QueueA", true, true, false, config);}/*** 定义死信队列* @return*/@Beanpublic Queue QueueB(){return new Queue("QueueB");}// 声明延时队列C 不设置TTL@Beanpublic Queue QueueC(){Map<String, Object> config = new HashMap<>();// x-dead-letter-exchange    这里声明当前队列绑定的正常交换机config.put("x-dead-letter-exchange","direct-exchangeA");// x-dead-letter-routing-key  这里声明当前队列的死信路由keyconfig.put("x-dead-letter-routing-key", "aa");return new Queue("QueueC", true, true, false, config);}/*** 自定义直连交换机* @return*/@Beanpublic DirectExchange directExchangeA(){return new DirectExchange("direct-exchangeA",true,false);}/*** 自定义死信交换机* @return*/@Beanpublic DirectExchange directExchangeB(){return new DirectExchange("direct-exchangeB",true,false);}/*** 自定义延迟交换机* @return*/@Beanpublic DirectExchange directExchangeC(){return new DirectExchange("direct-exchangeC",true,false);}/*** 将正常队列与直连交换机进行绑定,并设置路由键与死信交换机以及队列* @return*/@Beanpublic Binding bindingExchangeA(){return BindingBuilder.bind(QueueA()).to(directExchangeA()).with("aa");}/*** 将死信队列与死信交换机进行绑定,并设置路由键* @return*/@Beanpublic Binding bindingExchangeB(){return BindingBuilder.bind(QueueB()).to(directExchangeB()).with("bb");}/*** 将正常队列与直连交换机进行绑定,并设置路由键与死信交换机以及队列* @return*/@Beanpublic Binding bindingExchangeC(){return BindingBuilder.bind(QueueC()).to(directExchangeC()).with("cc");}/}

 创建消息的生产者

package org.example.produce.controller;import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.Date;
import java.util.HashMap;
import java.util.Map;@RestController
@Slf4j
public class Sender {@Autowiredprivate AmqpTemplate rabbitTemplate;@RequestMapping("send02")public void sendMsg( Integer delay) {Map<String,Object> data=new HashMap<>();data.put("msg","延迟队列");rabbitTemplate.convertAndSend("direct-exchangeC", "cc",data , message -> {// 设置延迟毫秒值message.getMessageProperties().setExpiration(String.valueOf(delay * 1000));return message;});}
}


 

3.案例2实践

  • 消息通过 ACK 确认是否被正确接收,每个 Message 都要被确认(acknowledged),可以手动去 ACK 或自动 ACK

  • 自动确认会在消息发送给消费者后立即确认,但存在丢失消息的可能,如果消费端消费逻辑抛出异常,也就是消费端没有处理成功这条消息,那么就相当于丢失了消息

  • 如果消息已经被处理,但后续代码抛出异常,使用 Spring 进行管理的话消费端业务逻辑会进行回滚,这也同样造成了实际意义的消息丢失

  • 如果手动确认则当消费者调用 ack、nack、reject 几种方法进行确认,手动确认可以在业务失败后进行一些操作,如果消息未被 ACK 则会发送到下一个消费者

  • 如果某个服务忘记 ACK 了,则 RabbitMQ 不会再发送数据给它,因为 RabbitMQ 认为该服务的处理能力有限

  • ACK 机制还可以起到限流作用,比如在接收到某条消息时休眠几秒钟

  • 消息确认模式有:

    • AcknowledgeMode.NONE:自动确认

    • AcknowledgeMode.AUTO:根据情况确认

    • AcknowledgeMode.MANUAL:手动确认

配置yml文件关闭自动确认
server:port: 9999
spring:application:name: consumerabbitmq:host: localhostusername: weiweipassword: 123456port: 5672virtual-host: my_vhostlistener:simple:acknowledge-mode: manual
为QueueA创建一个消费者并且手动确认

在刚刚上一个案例中我们不是没有为正常队列创建消费者吗,现在我们创建一个

package org.example.produce.controller;import com.rabbitmq.client.Channel;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;import java.io.IOException;
import java.util.Map;@Component
@RabbitListener(queues = {"QueueA"})
public class AReceiver {@RabbitHandlerpublic void handler(Map<String,Object> json, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws Exception {System.out.println("QA接到消息"+json); // 打印接收到的消息channel.basicAck(tag,true); // 确认消息已被消费}
}

需要注意的 basicAck 方法需要传递两个参数

  • deliveryTag(唯一标识 ID):当一个消费者向 RabbitMQ 注册后,会建立起一个 Channel ,RabbitMQ 会用 basic.deliver 方法向消费者推送消息,这个方法携带了一个 delivery tag, 它代表了 RabbitMQ 向该 Channel 投递的这条消息的唯一标识 ID,是一个单调递增的正整数,delivery tag 的范围仅限于 Channel

  • multiple:为了减少网络流量,手动确认可以被批处理,当该参数为 true 时,则可以一次性确认 delivery_tag 小于等于传入值的所有消息

 现在我们看一下我们的消息是否会是怎么样的

2024-01-25 19:55:27.744  INFO 13668 --- [nio-8081-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
2024-01-25 19:55:27.744  INFO 13668 --- [nio-8081-exec-1] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
2024-01-25 19:55:27.745  INFO 13668 --- [nio-8081-exec-1] o.s.web.servlet.DispatcherServlet        : Completed initialization in 1 ms
QA接到消息{msg=订单ID:121452623345}
QA接到消息{msg=订单ID:121452623345}

直接被QA接收消费,那么如果我拒绝呢?

消费者拒绝消息
package org.example.produce.controller;import com.rabbitmq.client.Channel;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;import java.util.Map;@Component
@RabbitListener(queues = {"QueueA"})
public class AReceiver {@RabbitHandlerpublic void handler(Map<String,Object> json, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws Exception {System.out.println("拒绝"+json);channel.basicReject(tag,false);  // 拒绝消息Thread.sleep(1000);}
}

basicReject(tag,false)是用于拒绝消息并可选择是否将消息重新放回队列的方法。

具体来说,basicReject() 方法用于告知 RabbitMQ 服务器拒绝处理特定的消息,并可以选择将消息重新放回队列中等待重新投递。这样可以用于处理无法处理的消息或者避免消息丢失。

  • 参数 tag 表示消息的标签(delivery tag),它是一个唯一的标识符,用于表示消息在通道中的位置。每个消息都会被分配一个单独的标签。通过将正确的标签传递给 basicReject() 方法,可以告诉 RabbitMQ 服务器要拒绝哪个具体的消息。
  • 第二个参数 false 表示不将消息重新放回队列,即将消息丢弃。如果将其设置为 true,则表示将消息重新放回队列中等待重新投递。

 

被拒绝就会变成死信消息转到我们的死信交换机然后发送给死信队列

但是我们的死信也没有进行消费 ,只是消息保存在了队列中,那是因为我们开启了全局的手动消息确认,也就是上面所编写的配置,我们只需要像刚刚那样手动确认即可
 

package org.example.produce.controller;import com.rabbitmq.client.Channel;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;import java.util.Map;@Component
@RabbitListener(queues = {"QueueB"})
public class BReceiver {@RabbitHandlerpublic void handler(Map<String,Object> json, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws Exception {System.out.println("QB接到消息"+json); // 打印接收到的消息channel.basicAck(tag,true); // 确认消息已被消费}
}

 可以看到在消息被拒后消息就会跑到死信队列中做处理

2024-01-25 20:00:53.759  INFO 13444 --- [  restartedMain] org.example.produce.ProduceApplication   : Started ProduceApplication in 3.916 seconds (JVM running for 4.403)
2024-01-25 20:01:16.094  INFO 13444 --- [nio-8081-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
2024-01-25 20:01:16.095  INFO 13444 --- [nio-8081-exec-1] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
2024-01-25 20:01:16.095  INFO 13444 --- [nio-8081-exec-1] o.s.web.servlet.DispatcherServlet        : Completed initialization in 0 ms
拒绝{msg=订单ID:121452623345}
QB接到消息{msg=订单ID:121452623345}

请添加图片描述

到这里我的分享就结束了,欢迎到评论区探讨交流!!

💖如果觉得有用的话还请点个赞吧 💖

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

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

相关文章

==与equals

在Java中&#xff0c; 和 equals() 是两种不同的比较方式&#xff0c;用于比较对象或基本数据类型&#xff0c;但它们在比较时的行为是不同的。 操作符&#xff1a; 当用于比较基本数据类型&#xff08;如 int, char, boolean 等&#xff09;时&#xff0c; 比较的是它…

前端学习生产环境、开发环境、测试环境

1、路径 定义是什么环境 NODE_ENVdevelopment 开发环境 2、.env 端口号 3、.env.development 开发环境 4、.env.production 生产环境 5、.env.test 测试环境 6、如何访问&#xff0c;通过process.env进行访问 学习中.......

简化java代码:mapstruct + 策略模式

目录 目的 准备 注意 相同类型-属性名不同 实体类 映射 使用 验证-查看实现类 测试 不同类型(策略模式) 实体类 映射 工具类 使用&#xff1a;对象拷贝 验证-查看实现类 测试 使用&#xff1a;集合拷贝 测试 策略模式说明 准备-依赖 目的 简化 BeanUtils.…

【RL】(task4)DDPG算法、TD3算法

note 文章目录 note一、DDPG算法二、TD3算法时间安排Reference 一、DDPG算法 DDPG&#xff08;Deep Deterministic Policy Gradient&#xff09;算法 DDPG算法是一种结合了深度学习和确定性策略梯度的算法。它主要解决的是在连续动作空间中&#xff0c;智能体&#xff08;age…

Axios取消请求:AbortController

AbortController AbortController() 构造函数创建了一个新的 AbortController 实例。MDN官网给出了一个利用AbortController取消下载视频的例子。 核心逻辑是&#xff1a;利用AbortController接口的只读属性signal标记fetch请求&#xff1b;然后在需要取消请求的时候&#xff0…

python算法与数据结构---单调栈与实践

单调栈 单调栈是一个栈&#xff0c;里面的元素的大小按照它们所在栈的位置&#xff0c;满足一定的单调性&#xff1b; 性质&#xff1a; 单调递减栈能找到左边第一个比当前元素大的元素&#xff1b;单调递增栈能找到左边第一个比当前元素小的元素&#xff1b; 应用场景 一般用…

Ubuntu22.04安装4090显卡驱动

1、安装完Ubuntu系统&#xff0c;打完所有补丁后再进行后续操作 2、下载系统所需要的版本的NV显卡驱动&#xff0c;本次由于使用CUDA12.1&#xff0c;故选用的驱动版本为NVIDIA-Linux-x86_64-530.41.03.run 3、卸载NV驱动&#xff08;只是保险起见&#xff0c;并不是一定会卸…

微信小程序登录获取手机号教程(超详细)

1. 背景介绍&#xff1a; 在我们开发微信小程序时&#xff0c;登录时&#xff0c;需要获取用户手机号作为唯一标识&#xff0c;下面我介绍一下获取手机号的教程。 本篇文章介绍后端获取方法&#xff1a; 前端工作 后端工作 前端 新建Page页面&#xff0c;在xxx.wxml中加入…

Shell脚本④循环语句for、while、until

目录 一.for 1. 九九乘法表 2.求1到10奇数和 3.累计加到100 &#xff08;1&#xff09;方法一 &#xff08;2&#xff09;方法2 二.while 1.猜价格小游戏 2.累加到100的方法三 三.until循环 1.累加到100方法四 四.嵌套循环 五.循环语句中break、exit和continue 1…

如何把标书制作精美

标书&#xff0c;作为一种正式的文件&#xff0c;其制作需要我们花费心思。精美、专业的标书不仅能准确传达信息&#xff0c;还能给阅读者留下深刻印象。那么&#xff0c;如何才能制作出精美的标书呢&#xff1f;接下来&#xff0c;我会从五个方面为您详细解析。 一、内容至上 …

RabbitMQ简单模式和工作模式

RabbitMQ 是一个消息队列中间件&#xff0c;用于在分布式系统中进行消息传递。在 RabbitMQ 中&#xff0c;有几种工作模式&#xff0c;其中简单模式和工作模式是其中两种基本的模式之一。 简单模式&#xff08;Simple Mode&#xff09;&#xff1a; 在简单模式中&#xff0c;有…

前端 - 视觉呈现技术

前言 不知道大家有没有在微信中看见过&#xff0c;那种特别炫酷的h5&#xff0c;从事前端工作的伙伴看着这么炫酷的效果&#xff0c;又不知如何实现。本文就带你走进前端高阶视觉特效。 特效 视觉呈现做的最熟的&#xff0c;我觉得应是视频了&#xff0c;每个视频工具都能根…

使用封装函数判断素数

#include<stdio.h> int judgeprime(int n) //判断是不是素数 { int i 0; int j 1; //默认素数&#xff0c;判断之后若不是素数&#xff0c;返回j0&#xff0c;否则返回j1 for (i 2; i < n; i) {if (n%i 0) //有其他共因数&#xff0c;不为素数{j 0;break;} }…

26.删除排序数组中的重复项(力扣LeetCode)

26.删除排序数组中的重复项 题目描述 给你一个 非严格递增排列 的数组 nums &#xff0c;请你 原地 删除重复出现的元素&#xff0c;使每个元素 只出现一次 &#xff0c;返回删除后数组的新长度。元素的 相对顺序 应该保持 一致 。然后返回 nums 中唯一元素的个数。 考虑 nu…

v-if 导致 elementui 表单校验失效问题解决

问题 在使用 elementui 表单的过程中&#xff0c;某些表单项需要通过 v-if 来判断是否展示&#xff0c;但是这些表单项出现了检验失效的问题。 解决方法 1、给需要 v-if 判断的表单项添加 key 值 <el-form ref"form" :model"form"><el-form-i…

【Unity学习笔记】创建人物控制器

人物左右移动 1 导入模型&#xff0c;如果没有模型&#xff0c;则在 窗口-资产商店-free sample 找到人物模型 2 在 窗口-包管理中 导入自己的模型 3 在自己的资产文件夹中找到Prefabs Base HighQuality MaleFree1模型&#xff0c;导入到场景中 4 Assets中创建C#项目 写入如下…

四、MySQL之DML DQL

有关数据表的DML操作 INSERT 针对于数据的插入DELETE 针对于数据的删除UPDATE 针对于数据的修改 4.1 INSERT语句 INSERT INTO 表名 [(列名1,列名2,....)] VALUES (值1&#xff0c;值2&#xff0c;...); 默认情况下&#xff0c;一条插入命令只针对一行进行影响INSERT INTO 表…

Leetcode:二分搜索树层次遍历

题目&#xff1a; 给你二叉树的根节点 root &#xff0c;返回其节点值的 层序遍历 。 &#xff08;即逐层地&#xff0c;从左到右访问所有节点&#xff09;。 示例&#xff1a; 示例 1&#xff1a; 输入&#xff1a;root [3,9,20,null,null,15,7] 输出&#xff1a;[[3],[9,…

使用阿里云的oss对象存储服务实现图片上传(前端vue后端java详解)

一&#xff1a;前期准备&#xff1a; 1.1&#xff1a;注册阿里云账号&#xff0c;开启对象存储oss功能&#xff0c;创建一个bucket&#xff08;百度教程多的是&#xff0c;跟着创建一个就行&#xff0c;创建时注意存储类型是标准存储&#xff0c;读写权限是公共读&#xff09;…

《吐血整理》高级系列教程-吃透Fiddler抓包教程(24)-Fiddler如何优雅地在正式和测试环境之间来回切换-中篇

1.简介 在开发或者测试的过程中&#xff0c;由于项目环境比较多&#xff0c;往往需要来来回回地反复切换&#xff0c;那么如何优雅地切换呢&#xff1f;宏哥今天介绍几种方法供小伙伴或者童鞋们进行参考。 2.实际工作场景 2.1问题场景 &#xff08;1&#xff09;已发布线上…