当前位置：首页 > news >正文

4.RabbitMQ - 延迟消息

news 来源：原创 2025/7/6 14:00:33

RabbitMQ延迟消息

文章目录

RabbitMQ延迟消息
一、延迟消息介绍
二、实现
- 2.1 死信交换机
- 2.2 延迟消息插件
- 2.3 取消超时订单

一、延迟消息介绍

延迟消息：生产者发送消息时指定一个时间，消费者不会立刻收到消息，而是在指定时间后才收到消息

用户下单抢购，抢到了但是没有付款，此时其实库存的数量已经扣减了

如果用户迟迟没有付款，超过一定的时间，就会将此订单取消掉，库存的数量也会重新加回来

我们可以定义一个定时任务扫描数据中订单的状态，超过一定时间没有付款的，我们就将订单取消

延迟任务：设置在一定时间之后才执行的任务

当用户下单成功后，立刻向MQ中发送一条延迟消息，设定延迟时间30分钟，30分钟到了之后就可以收到此消息，检查订单状态，如果发现未支付，则订单直接取消。

这样解决了实效性的问题，同时对数据库的压力也很小

二、实现

2.1 死信交换机

当队列满足下列的条件之一时就会称为死信（dead letter）

消费者使用basic.reject或basic.nack声明消费失败，并且消息的requeue参数设置为false

消费者不要这个消息了
消息是一个过期的消息（达到了队列或消息本身设置的过期时间），超时无人消费
要投递的队列消息堆积满了，最早的消息可能成为死信

如果队列通过dead-letter-exchange属性指定了一个交换机，那么该队列中的死信就会投递到这个交换机中。这个交换机称为死信交换机（Dead Letter Exchange，简称DLX）

死信交换机只是一种称呼，和普通的交换机其实是一样的

我们不给simple.queue队列绑定消费者，给dlx.queue绑定一个消费者

因为simple.queue队列没有消费者，所以不会有人来消费，当有人通过simple.direct交换机向simple.queue队列发送一条过期时间为30秒的消息，此消息就会在simple.queue队列卡主

过了30s后，消息就会自动投递到dlx.direct死信交换机，然后进入dlx.queue队列，最终消费者拿到后会进行消费

利用死信交换机、死信队列。过期时间的方式，模拟出了延迟消息的效果

验证一下

在控制台创建simple.direct交换机

将此交换机与simple.queue绑定

注意！simple.queue并没有绑定到消费者，进入到simple.queue队列的消息都会变成死信

创建队列dlx.queue和dlx.direct并将其绑定

创建队列

创建交换机

进行绑定

给simple.queue队列设定死信交换机

注意，这个地方只能是在创建队列的时候进行绑定

在消费者模块代码中定义两个队列simple.queue、dlx.queue

//检查一下，一定不要有simple.queue的消费者
//@RabbitListener(queues = "simple.queue")
//public void listenSimpleQueue(String msg){
//    System.out.println("消费者收到了simple.queue的消息：【" + msg +"】");
//    throw new RuntimeException("抛出异常了");
//}@RabbitListener(queues = "dlx.queue")
public void listenDlxQueue(String msg){log.info("消费者收到了dlx.queue的消息：【" + msg +"】");
}

发送消息

在控制台中下面的这个属性是带过期时间的属性

Java代码中的发送消息如下所示

@Test
void testSendTTLMessage() {Message message = MessageBuilder.withBody("hello".getBytes(StandardCharsets.UTF_8)).setExpiration("10000") //过期时间10s.build();//发送到死信队列rabbitTemplate.convertAndSend("simple.direct", "hi", message);//直接向队列发送消息log.info("消息发送成功！");
}

simple.queue队列中10s内始终存在下面的一条消息

dlx.queue队列的消费者在10s后会接收到消息

2.2 延迟消息插件

这种定时功能，都是有一定的性能损耗的（Redis除外）

MQ或者Spring的定时功能是在程序内部维护一个时钟，比如每隔一秒就往前跳一次，这种时钟的运行过程中CPU就需要不停地计算，定时任务越多，对于CPU的占用越大，定时任务属于一种CPU密集型的任务

采用延迟消息带来的弊端就是给服务器CPU造成的额外压力比较大

使用交换机实现延迟消息非常的繁琐，需要定义很多的交换机和队列，而且死信交换机的目的是为了让我们人工处理死信消息，并不是为了延迟消息而生的

延迟消息的插件能自动实现延迟效果

RabbitMQ官方也推出了一个插件，原生支持延迟消息功能。

该插件的原理是设计了一种支持延迟消息功能的交换机，当消息投递到交换机后可以暂存一定时间，到期后再投递到队列。

暂存的时间取决于发消息时配置的时间（也就是延迟时间）

在Java代码中配置延迟交换机的两种方式

在声明交换机的时候，需要多添加一个参数delayed=“true”

注解的方式

在消费者模块声明交换机、队列

@RabbitListener(bindings = @QueueBinding(//队列value = @Queue(name = "delay.queue", durable = "true"),//交换机exchange = @Exchange(name = "hmall.direct", delayed = "true"),//Routing keykey = "delay"
))
public void listenDelayMessage(String msg) {log.info("接收到delay.queue的延迟消息【" + msg + "】");
}

注入Bean的方式

这种方式只声明了交换机

@Bean
public DirectExchange delayExchange(){return ExchangeBuilder.directExchange("delay.direct").delayed() //设置delay的属性为true 主要是这个.durable(true) //持久化.build();
}

发送延迟消息的Java代码

    @Testvoid testSendDelayMessage() {
//        Message message = MessageBuilder
//                .withBody("hello".getBytes(StandardCharsets.UTF_8))
//                .setExpiration("10000") //过期时间10s
//                .build();
//        //发送到死信队列rabbitTemplate.convertAndSend("dela.direct", "hi", "hello", new MessagePostProcessor() {@Overridepublic Message postProcessMessage(Message message) throws AmqpException {message.getMessageProperties().setExpiration("10000");//延迟十秒return message;}});//直接向队列发送消息log.info("消息发送成功！");}

2.3 取消超时订单

设置三十分钟后检测订单支付状态，存在两个问题

如果并发比较高，30分钟可能堆积消息过多，对MQ的压力很大
大多数订单在下单后1分钟内就会支付，但是却需要再MQ内等待30分钟，浪费资源

30分钟太长，可以缩短为10s，10s后立刻来检查有没有支付

假如10s后没有支付，可以再发一个10s的延迟消息，直到成功后不再发送延迟消息

这样的话MQ的压力会减少很多

处理如下所示：

查询支付状态的时候，需要先查询本地，之后再查询支付服务，查完之后判断支付状态

定义延时消息时间数组

package com.hmall.common.domain;import com.hmall.common.utils.CollUtils;
import lombok.Data;import java.util.List;@Data
public class MultiDelayMessage<T> {/*** 消息体*/private T data;/*** 记录延迟时间的集合*/private List<Long> delayMillis;public MultiDelayMessage(T data, List<Long> delayMillis) {this.data = data;this.delayMillis = delayMillis;}public static <T> MultiDelayMessage<T> of(T data, Long ... delayMillis){return new MultiDelayMessage<>(data, CollUtils.newArrayList(delayMillis));}/*** 获取并移除下一个延迟时间* @return 队列中的第一个延迟时间*/public Long removeNextDelay(){return delayMillis.remove(0);}/*** 是否还有下一个延迟时间*/public boolean hasNextDelay(){return !delayMillis.isEmpty();}
}

定义好对应的交换机和队列

@Component
@RequiredArgsConstructor
public class PayStatusListener {private final IOrderService orderService;@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "mark.order.pay.queue", durable = "true"),exchange = @Exchange(name = "pay.topic", type = ExchangeTypes.TOPIC),key = "pay.success"))public void listenOrderPay(Long orderId) {/* // 1.查询订单Order order = orderService.getById(orderId);// 2.判断订单状态是否为未支付if(order == null || order.getStatus() != 1){// 订单不存在，或者状态异常return;}// 3.如果未支付，标记订单状态为已支付orderService.markOrderPaySuccess(orderId);*/// update order set status = 2 where id = ? AND status = 1orderService.lambdaUpdate().set(Order::getStatus, 2).set(Order::getPayTime, LocalDateTime.now()).eq(Order::getId, orderId).eq(Order::getStatus, 1).update();}
}

在方法中发送延迟检查订单状态的消息

    @Override@GlobalTransactionalpublic Long createOrder(OrderFormDTO orderFormDTO) {// 1.订单数据Order order = new Order();// 1.1.查询商品List<OrderDetailDTO> detailDTOS = orderFormDTO.getDetails();// 1.2.获取商品id和数量的MapMap<Long, Integer> itemNumMap = detailDTOS.stream().collect(Collectors.toMap(OrderDetailDTO::getItemId, OrderDetailDTO::getNum));Set<Long> itemIds = itemNumMap.keySet();// 1.3.查询商品List<ItemDTO> items = itemClient.queryItemByIds(itemIds);if (items == null || items.size() < itemIds.size()) {throw new BadRequestException("商品不存在");}// 1.4.基于商品价格、购买数量计算商品总价：totalFeeint total = 0;for (ItemDTO item : items) {total += item.getPrice() * itemNumMap.get(item.getId());}order.setTotalFee(total);// 1.5.其它属性order.setPaymentType(orderFormDTO.getPaymentType());order.setUserId(UserContext.getUser());order.setStatus(1);// 1.6.将Order写入数据库order表中save(order);// 2.保存订单详情List<OrderDetail> details = buildDetails(order.getId(), items, itemNumMap);detailService.saveBatch(details);// 3.扣减库存try {itemClient.deductStock(detailDTOS);} catch (Exception e) {throw new RuntimeException("库存不足！");}// 4.清理购物车商品// cartClient.deleteCartItemByIds(itemIds);try {rabbitTemplate.convertAndSend(MqConstants.TRADE_EXCHANGE_NAME, MqConstants.ORDER_CREATE_KEY,itemIds/*,new RelyUserInfoMessageProcessor()*/);} catch (AmqpException e) {log.error("清理购物车的消息发送异常", e);}// 5.延迟检测订单状态消息try {MultiDelayMessage<Long> msg = MultiDelayMessage.of(order.getId(), 10000L, 10000L, 10000L, 15000L, 15000L, 30000L, 30000L);rabbitTemplate.convertAndSend(MqConstants.DELAY_EXCHANGE, MqConstants.DELAY_ORDER_ROUTING_KEY, msg,new DelayMessageProcessor(msg.removeNextDelay().intValue()));} catch (AmqpException e) {log.error("延迟消息发送异常！", e);}return order.getId();}

将MessagePostProcessMessage对象提取出来了，不用每次都new了

@RequiredArgsConstructor
public class DelayMessageProcessor implements MessagePostProcessor {private final int delay;@Overridepublic Message postProcessMessage(Message message) throws AmqpException {message.getMessageProperties().setDelay(delay);return message;}
}

或者是使用下面视频里面的代码

但是下面的代码每次都要使用一个内部类

4.RabbitMQ - 延迟消息

RabbitMQ延迟消息文章目录 RabbitMQ延迟消息一、延迟消息介绍二、实现2.1 死信交换机2.2 延迟消息插件2.3 取消超时订单一、延迟消息介绍延迟消息：生产者发送消息时指定一个时间，消费者不会立刻收到消息，而是在指定时间后才收到消息用户…...

编程日记 2025/7/6 14:00:33

C++学习：六个月从基础到就业——STL算法（一）基础与查找算法

C学习：六个月从基础到就业——STL算法（一） 基础与查找算法本文是我C学习之旅系列的第二十五篇技术文章，也是第二阶段"C进阶特性"的第三篇，主要介绍C STL算法库的基础知识与查找类算法。查看完整系列目录了解…...

编程日记 2025/7/6 12:23:17

springboot+vue 支付宝支付（沙箱方式，测试环境使用）

准备工作： 1 支付宝沙箱环境的公钥，私钥配置，查询等使用，如果是用自定义的方式，需要下生成公钥，私钥的工具，否则不需要登录 - 支付宝小程序文档 - 支付宝文档中心 2 本地测试时&…...

编程日记 2025/7/6 13:53:32

安装win11自带linux是报错：WslRegisterDistribution failed with error: 0x800701bcErr

确保系统设置中的“打开win11的子系统”已打钩管理员身份运行cmd，并输入如下然后再重启ubantu...

编程日记 2025/7/6 12:09:13

面试经历（一）雪花算法

uid生成方面 1：为什么用雪花算法分布式ID的唯一性需要保证，同时需要做到 1：单调递增 2：确保安全，一个是要能体现出递增的单号，二一个不能轻易的被恶意爬出订单数量 3：含有时间戳 4&#…...

编程日记 2025/7/6 13:11:21

docker底层原理简述

前言平时用docker很多，今天深入了解下docker原理层面的实现，包括docker核心概念，文件系统，资源隔离，网络通信等参考文章： Docker底层原理（图解秒懂史上最全） - 疯狂创客圈 - 博…...

编程日记 2025/7/6 13:22:54

【6D位姿估计】Foundation Pose复现

主要参考项目仓库README站内其他博文注意事项容器化部署不难，主要是部署docker本身会存在一些环境问题，重点关注访问外网的端口需要手动调整至与魔法相同，可以参考： docker部署在启动容器镜像后，需要注意镜像当前…...

编程日记 2025/7/6 12:45:11

TDengine 数据订阅设计

简介数据订阅作为 TDengine 的一个核心功能，为用户提供了灵活获取所需数据的能力。通过深入了解其内部原理，用户可以更加有效地利用这一功能，满足各种实时数据处理和监控需求。基本概念主题与 Kafka 一样，使用 TDengine 数…...

编程日记 2025/7/6 12:51:17

VMware Fusion Pro 13 Mac版虚拟机安装Win11系统教程

Mac分享吧文章目录 Win11安装完成，软件打开效果一、VMware安装Windows11虚拟机1️⃣：准备镜像2️⃣：创建虚拟机3️⃣：虚拟机设置4️⃣：安装虚拟机5️⃣：解决连不上网问题安装完成！&#xff0…...

编程日记 2025/7/6 2:55:41

高并发下单库存扣减异常？飞算 JavaAI 自动化生成分布式事务解决方案

在电商、旅游等行业业务量激增，高并发下单场景中，传统库存扣减方式弊端尽显。超卖问题因缺乏有效并发控制机制频发，多个订单同时访问库存数据，导致同一商品多次售出，订单无法履约引发客户投诉；同时&#xf…...

编程日记 2025/7/6 13:27:39

crictl 遇到报错 /run/containerd/containerd.sock: connect: permission denied

报错内容 crictl --runtime-endpoint unix:///run/containerd/containerd.sock logs CONTAINERID FATA[0000] validate service connection: validate CRI v1 runtime API for endpoint "unix:///run/containerd/containerd.sock": rpc error: code Unavailable de…...

编程日记 2025/7/6 13:12:18

CSS外边距合并现象

外边距合并（Margin Collapsing）是指在文档流中，两个或多个相邻元素的外边距（margin）会合并为一个外边距，其大小会取其中最大的外边距值当两个相邻的兄弟元素之间没有其他内容（如边框、内边距、…...

编程日记 2025/7/6 11:54:05

《深度神经网络之数据增强、模型保存、模型调用、学习率调整》

文章目录前言一、数据增强1、什么是数据增强？2、数据增强的实现方法（1）几何变换翻转:旋转：平移： （2）颜色变换亮度调整：对比度调整：色彩抖动： （3&…...

编程日记 2025/7/6 13:56:43

【Java学习笔记】random的使用

random使用方法使用说明：返回的是(0<n<1)这个范围中的任意带正号的double值代码实例 public class helloworld{public static void main(String[] args){System.out.println(Math.random());} }生成0-100中的任意数代码示例 public class Main {public …...

编程日记 2025/7/6 12:46:13

Redis的string类型使用

第一步：添加缓存以若依岗位代码为例一：首先从redis中查询岗位信息，如果查询到了则直接返回。二：如果redis中没有数据，则直接从数据库中查询。查询后放到redis并返回 package com.ruoyi.system.service.impl;imp…...

编程日记 2025/7/6 12:29:32

AIGC架构与原理

AIGC（AI Generated Content，人工智能生成内容）的架构与原理 AIGC通过整合数据采集、模型训练、推理服务等模块，结合深度学习与生成对抗网络（GAN）等技术，实现从数据到内容的自动化生成。一、AIG…...

编程日记 2025/7/6 12:25:52

安全复健|windows常见取证工具

写在前面： 此博客仅用于记录个人学习内容，学识浅薄，若有错误观点欢迎评论区指出。欢迎各位前来交流。（部分材料来源网络，若有侵权，立即删除） 取证 01系统运行数据使用工具：Live-F…...

编程日记 2025/7/6 12:54:34

Oracle EBS R12.2 汉化

一、前言在使用oracle ebs时，使用中文会更好的理解整个ebs流程，以下介绍oracle r12中文补丁的方式如果你的系统除了支持英语外，还支持其他语言，比如中文，那你在下载补丁的时候除了下载Generic Platform版本外&#…...

编程日记 2025/7/6 12:42:20

【Java面试笔记：基础】12.Java有几种文件拷贝方式？哪一种最高效？

在 Java 中，文件拷贝可以通过多种方式实现，不同方式的性能和适用场景有所差异。 1. Java 文件拷贝方式传统 IO 方式使用 FileInputStream 和 FileOutputStream，通过循环读取和写入数据实现文件拷贝。示例代码： try (InputStream is = new FileInputStream("sou…...

编程日记 2025/7/6 12:44:12

互联网大厂Java面试：RocketMQ、RabbitMQ与Kafka的深度解析

互联网大厂Java面试：RocketMQ、RabbitMQ与Kafka的深度解析面试场景面试官：马架构，您好！欢迎参加我们的面试。今天我们将围绕消息中间件展开讨论，尤其是RocketMQ、RabbitMQ和Kafka。您有十年的Java研发和架构设计经…...

编程日记 2025/7/6 13:56:44

kali安装切换jdk1.8.0_451java8详细教程

kali安装切换jdk1.8.0_451java8详细教程下载链接： jdk-8u451-linux-i586.tar.gz 链接: https://pan.baidu.com/s/1lpgI0JMfHpZ__RxsF8UoBw?pwdx3z2 提取码: x3z2 解压jdk 首先将下载好的压缩包放在kali虚拟机中，一般是直接拖到桌面然后cd到压缩包…...

编程日记 2025/6/29 9:24:45

众趣科技X世界读书日丨数字孪生技术赋能图书馆空间智慧化运营

4月23日，是第30个“世界读书日”，不仅是庆祝阅读的日子，更是思考知识传播未来的契机。图书馆作为主要传播图书的场所，在科技的发展中，图书馆正面临前所未有的挑战，联合国数据显示，全球近30%的…...

编程日记 2025/6/29 9:24:59

Python内置函数-aiter()

Python内置函数 aiter() 用于获取异步可迭代对象的异步迭代器，是异步编程中的核心工具之一。 1. 基本概念异步可迭代对象：实现了 __aiter__() 和 __anext__() 方法的对象，支持 async for 循环。异步迭代器：通过 aiter() 获取的…...

编程日记 2025/7/5 14:04:25

Java 实现单链表翻转（附详细注释）

1. 引言单链表（Singly Linked List）是一种常见的数据结构，在算法和数据结构的学习中占有重要地位。翻转单链表是一道经典的面试题，本文将介绍几种常见的 Java 实现方法，并详细讲解关键步骤的含义。 2. 单链表定义 …...

编程日记 2025/6/29 11:45:05

基于HPC的气候模拟GPU加速实践全流程解析

基于HPC的气候模拟GPU加速实践全流程解析关键词：气候模型、GPU加速、CUDA编程、性能优化、分布式训练摘要： 本文针对全球气候模拟中10^12级网格点实时计算需求，提出基于CUDA的并行计算架构。通过改进WRF模式的分块矩阵乘法算法&#xff0c…...

编程日记 2025/6/29 9:41:23

【初级】前端开发工程师面试100题（一）

本题库共计包含100题，考察html，css，js，以及react，vue，webpack等基础知识掌握情况。 HTML基础篇说说你对HTML语义化的理解？语义化就是用合适的标签表达合适的内容，比如<header>表示页眉，<nav>表示导航。这样不仅代码更清晰，对SEO也友好，屏幕阅读器也能…...

编程日记 2025/6/29 11:13:46

大模型框架技术演进与全栈实践指南

‌一、大模型框架概述 ‌大模型框架‌是支撑大规模语言模型（LLM）训练、推理和应用开发的核心技术体系，涵盖分布式训练、高效推理、应用编排等全流程。从AlphaGo到GPT-4，大模型框架的进化推动AI从实验室走向工业化落地。据IDC预测…...

编程日记 2025/6/29 12:29:20

【Bug】 [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed

当你在进行深度学习相关操作时，若因缺少本地的 CA 证书而无法下载资源，下面为你介绍几种解决办法： 方法一：更新 CA 证书在大多数 Linux 发行版中，你可以使用包管理器来更新 CA 证书。例如，在基于 Debian…...

编程日记 2025/6/29 10:50:33

第七章：Workspace Security

Chapter 7: Workspace Security 从变形金刚到安全防护罩：如何为代理设置权限边界？ 在上一章多后端配置，我们学会了让代理像变形金刚一样切换不同环境。但就像超级英雄需要遵守法律一样，代理也需要一个“安全防护罩”来限制它的操…...

编程日记 2025/6/29 10:31:42

【论文阅读】Hierarchical Group-Level Emotion Recognition

【论文阅读】Hierarchical Group-Level Emotion Recognition 摘要1.介绍2.相关工作3.方法4.实验5.分析摘要本篇博客参考IEEE于2021年收录的论文Hierarchical Group-Level Emotion Recognition，对其主要内容进行总结，以便加深理解和记忆 1.介绍 1&am…...

编程日记 2025/6/29 10:50:53

（2025最新版）CUDA安装及环境配置

CUDA安装文章目录 CUDA安装检查本地环境下载CUDA安装包CUDA安装检查是否安装成功学习深度学习的小伙伴在配置环境的时候必不可少的一件事就是安装CUDA，在这个过程中也是容易踩很多坑，所以这里写一篇教程来帮助新入门的小伙伴快速安装CUDA，减…...

编程日记 2025/6/29 11:35:48

ODC 4.3.4 发布：三大核心功能升级，打造更好的数据开发体验

ODC 是OceanBase提供的企业级数据库协同开发平台，提供了团队协作开发的基础框架，和14种工单任务类型。此次升级的 ODC 4.3.4版本，重点优化了30余项功能，主要聚焦快速上手、配置管理和核心功能中的改进，来为用户打造更高…...

编程日记 2025/7/5 1:35:59

JavaFX 第一篇 Hello World

1、简介 JavaFX 是一个用于构建客户端应用程序的 Java 库，作为 Java 标准库的一部分（JDK 8 到 10），从 JDK 11 开始，JavaFX 将以独立模块发布，将不再包含在 JDK标准库中，他是 Java 应用程序开发的…...

编程日记 2025/6/29 9:24:41

es的range失效

es的range失效的解决方法问题描述当我们es使用keyword类型存储数字时，当我们使用range时我们发现range失效的问题，例如以下的用例： 我们创建一个test1的索引test1： 使用_bulk进行批量导入数据： 进行查询我们发现我…...

编程日记 2025/6/29 10:28:38

gem5-gpu教程03 当前的gem5-gpu软件架构（因为涉及太多专业名词不知道该如何翻译所以没有汉化）

Current gem5-gpu Software Architecture 这是当前gem5-gpu软件架构的示意图。 CudaCore (src/gpu/gpgpu-sim/cuda_core.*, src/gpu/gpgpu-sim/CudaCore.py) Wrapper for GPGPU-Sim shader_core_ctx (gpgpu-sim/gpgpu-sim/shader.h) Sends instruction, global and const m…...

编程日记 2025/6/29 9:25:12

【C++】vector扩容缩容

vector扩容缩容 1 扩容一般来说，主要是重新分配内存 2 缩容 resize 缩小后，vector 的容量（capacity()）可能保持不变，需要显式调用 shrink_to_fit() 来释放内存。验证代码： #include <vector>…...

编程日记 2025/6/29 11:26:45

【鸿蒙HarmonyOS】深入理解router与Navigation

5. 路由 1.页面路由(router模式） 1.概述页面路由指的是在应用程序中实现不同页面之间的跳转，以及数据传递。我们先明确自定义组件和页面的关系： 自定义组件：Component 装饰的UI单元，页面：即应用的UI…...

编程日记 2025/6/29 10:37:42

手机端touch实现DOM拖拉功能

touch实现DOM拖拉功能 1、面板交互流程图 [ 用户触摸拖动手柄 ]↓ [ 记录起始位置、偏移量 ]↓ [ 实时更新面板 translateY ]↓ [ 手指松开 → 判断释放位置 ]↓ [ 达到恢复条件？ → 复位 ]2、详细实现步骤 2.1 初始面板位置 const initialPosition () > tr…...

编程日记 2025/6/29 9:44:56

Discuz!与DeepSeek的AI融合：打造智能网址导航新体验——以“虎跃办公”为例

在数字化办公需求日益增长的今天，高效获取优质资源成为职场人士的核心痛点。传统网址导航网站往往面临信息过载、个性化不足、交互体验单一等问题，难以满足用户精准触达目标资源的需求。本文将深入剖析“虎跃办公”这一基于Discuz!系统构建的网址导航网站…...

编程日记 2025/6/29 10:43:03

【AI】Windows环境安装SPAR3D单图三维重建心得

效果一览左图为原始单个图像，右图为通过SPAR3D重建后的三维建模，可以看出效果还是不错的。本地环境配置系统：Windows 11 专业版CPU：i5-13400F内存：32GBGPU：RTX3060 12GBcuda：11.8conda&…...

编程日记 2025/6/29 11:47:10

关于Agent的简单构建和分享

前言：Agent 具备自主性、环境感知能力和决策执行能力，能够根据环境的变化自动调整行为，以实现特定的目标。一、Agent 的原理 Agent(智能体)被提出时，具有四大能力感知、分析、决策和执行。是一种能够在特定环境中自主行动、感…...

编程日记 2025/7/1 21:36:13

【C/S通信仿真】

文章目录一、实验背景与目的二、实验设计与实现思路1. 设计思想2. 核心代码实现总结一、实验背景与目的在网络编程中，TCP 协议是实现可靠通信的核心。本次实验基于 Windows 平台，使用 WinSock2 库实现客户端与服务器的双向数据传递，模拟…...

编程日记 2025/6/29 10:52:41

Tomcat 8 启动闪退解决方案：版本差异与调试技巧详解

在使用 Tomcat 8 时，启动闪退是常见问题，核心原因多与 JAVA_HOME 环境变量配置、版本特性及启动脚本逻辑相关。本文结合官方文档与专家实践，提供分版本解决方案及调试技巧，适用于开发与运维场景。一、核心问题：JAVA_…...

编程日记 2025/6/29 11:30:12

【Project】基于spark-App端口懂车帝数据采集与可视化

文章目录 hadoop完全分布式部署hdfs-site.xmlcore-site.xmlmarpred-site.xmlyarn-site.xml spark集群部署spark-env.sh mongodb分片模式部署config 服务器初始化config 副本集 shard 服务器初始化shard 副本集 mongos服务器添加shard设置chunk大小启动分片为集合 user 创建索引…...

编程日记 2025/6/29 9:55:38

基于ARM+FPGA+DSP的储能协调控制器解决方案，支持国产化

储能协调控制器的作用与设计方案一、‌核心作用‌ ‌实时监测与协调控制‌ 实时采集储能系统电压、电流、温度等参数，监测电池电量状态及充放电功率，动态调整储能与电网、负载的功率交互，保障能源供需平衡15。支持一次调频（AGC&a…...

编程日记 2025/6/29 11:34:21

将天气查询API封装为MCP服务

下面我将展示如何将一个天气查询API封装为符合MCP协议的服务。我们将使用Python实现，包括服务端和客户端。 ## 1. 服务端实现 python # weather_mcp_server.py from fastapi import FastAPI, HTTPException from pydantic import BaseModel from typing import Di…...

编程日记 2025/6/29 12:29:12

JSON实现动态按钮管理的Python应用

在开发桌面应用程序时，动态生成用户界面元素并根据配置文件灵活管理是一项常见需求。本文将介绍如何使用Python的wxPython库结合JSON配置文件，开发一个支持动态按钮创建、文件执行和配置管理的桌面应用程序。该应用允许用户通过设置界面配置按钮名称和关…...

编程日记 2025/6/29 11:24:51

基于GA遗传优化TCN-BiGRU注意力机制网络模型的时间序列预测算法matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 5.算法完整程序工程 1.算法运行效果图预览 (完整程序运行后无水印) 2.算法运行软件版本 matlab2024b（提供软件版本下载） 3.部分核心程序 （完整版代码包…...

编程日记 2025/6/29 11:41:08

MongoDB（docker版）备份还原

docker启动MongoDB docker run -d -p 27017:27017 --name my-mongo -v /mongodb/db:/data/db mongo备份MongoDB 使用mongodump备份数据库时，默认会将备份数据保存在当前工作目录下的dump文件夹中。 docker容器中默认备份在当前工作目录，所以此处指定当…...

编程日记 2025/6/29 10:17:43

[蓝桥杯 2025 省 Python B] 异或和

暴力（O(n^2)）： def xor_sum(n, arr):total 0for i in range(n):for j in range(i 1, n):total (arr[i] ^ arr[j]) * (j - i)return total# 主函数 if __name__ "__main__":n int(input())arr list(map(int, input().split()…...

编程日记 2025/6/29 11:06:12