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

使用RabbitMQ实现判题功能

news 来源：原创 2025/6/29 12:06:42

这次主要选用RabbitMQ消息队列来对判题服务和题目服务解耦，题目服务只需要向消息队列发送消息，判题服务从消息队列中取信息去执行判题，然后异步更新数据库即可。

五一宝宝请快点跑~~~~~

先回顾一下RabbitMQ

（1）引入依赖

<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-amqp -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>2.7.2</version>
</dependency>

（2）在yml中引入配置

spring:rabbitmq:host: localhostport: 5672password: guestusername: guest

（3）创建交换机和队列

/*** 用于创建测试程序用到的交换机和队列（只用在程序启动前执行一次）*/
public class MqInitMain {public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("localhost");Connection connection = factory.newConnection();Channel channel = connection.createChannel();String EXCHANGE_NAME = "code_exchange";channel.exchangeDeclare(EXCHANGE_NAME, "direct");// 创建队列，随机分配一个队列名称String queueName = "code_queue";channel.queueDeclare(queueName, true, false, false, null);channel.queueBind(queueName, EXCHANGE_NAME, "my_routingKey");} catch (Exception e) {}}
}

（4）生产者代码

@Component
public class MyMessageProducer {@Resourceprivate RabbitTemplate rabbitTemplate;public void sendMessage(String exchange, String routingKey, String message) {rabbitTemplate.convertAndSend(exchange, routingKey, message);}}

（5）消费者代码

@Component
@Slf4j
public class MyMessageConsumer {// 指定程序监听的消息队列和确认机制@SneakyThrows@RabbitListener(queues = {"code_queue"}, ackMode = "MANUAL")public void receiveMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {log.info("receiveMessage message = {}", message);channel.basicAck(deliveryTag, false);}}

（6）单元测试执行

@SpringBootTest
class MyMessageProducerTest {@Resourceprivate MyMessageProducer myMessageProducer;@Testvoid sendMessage() {myMessageProducer.sendMessage("code_exchange", "my_routingKey", "你好呀");}
}

项目实践

要传递的消息是什么?题目提交 id

题目服务中，把原本的本地异步执行改为向消息队列发送消息:

// 发送消息
myMessageProducer.sendMessage("code_exchange", "my_routingKey", String.valueOf(questionSubmitId));
// 执行判题服务
//        CompletableFuture.runAsync(() -> {
//            judgeFeignClient.doJudge(questionSubmitId);
//        });

判题服务中，监听消息，执行判题:

@Component
@Slf4j
public class MyMessageConsumer {@Resourceprivate JudgeService judgeService;// 指定程序监听的消息队列和确认机制@SneakyThrows@RabbitListener(queues = {"code_queue"}, ackMode = "MANUAL")public void receiveMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {log.info("receiveMessage message = {}", message);long questionSubmitId = Long.parseLong(message);try {judgeService.doJudge(questionSubmitId);channel.basicAck(deliveryTag, false);} catch (Exception e) {channel.basicNack(deliveryTag, false, false);}}}

`消息确认机制：basicAck` `basicNack`

在 RabbitMQ 中，消息从生产者发送到队列，然后被消费者消费。为了确保消息被正确处理，RabbitMQ 提供了一种机制，让消费者可以确认消息是否已经被成功处理。这就是 消息确认机制。

`basicAck：`

作用：消费者告诉 RabbitMQ，我已经成功处理了这条消息。

参数：

（1）deliveryTag：消息的唯一标识符，RabbitMQ 用它来跟踪每条消息。

（2）multiple：布尔值，表示是否确认多个消息。如果为 true，则确认所有小于等于deliveryTag 的消息；如果为 false，则只确认当前的 deliveryTag 消息。

示例：

channel.basicAck(deliveryTag, false);

这行代码的意思是：“我成功处理了 deliveryTag 指定的消息，请从队列中移除它。”

`basicNack：`

作用：消费者告诉 RabbitMQ，我无法处理这条消息。

参数：

（1）deliveryTag：消息的唯一标识符。

（2）multiple：布尔值，表示是否拒绝多个消息。如果为 true，则拒绝所有小于等于 deliveryTag 的消息；如果为 false，则只拒绝当前的 deliveryTag 消息。

（3）requeue：布尔值，表示是否将消息重新放回队列。如果为 true，则将消息重新放回队列，等待其他消费者处理；如果为 false，则丢弃这条消息。

示例:

channel.basicNack(deliveryTag, false, false);

这行代码的意思是：“我无法处理 deliveryTag 指定的消息，请丢弃它。”

总结

basicAck：确认消息已成功处理，从队列中移除。

basicNack：确认消息处理失败，可以选择重新放回队列或丢弃。

使用RabbitMQ实现判题功能

这次主要选用RabbitMQ消息队列来对判题服务和题目服务解耦，题目服务只需要向消息队列发送消息，判题服务从消息队列中取信息去执行判题，然后异步更新数据库即可。五一宝宝请快点跑~~~~~ 先回顾一下RabbitMQ （1）引入依…...

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

Kushal Tirumala⇤ Aram H. Markosyan⇤ Luke Zettlemoyer Armen Aghajanyan Meta AI 研究 {ktirumala,amarkos,lsz,armenag}fb.com 原文链接：[2210.09262] Physics-Driven Convolutional Autoencoder Approach for CFD Data Compressions 摘要尽管超大语言模型…...

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

【Java面试笔记：进阶】16.synchronized底层如何实现？什么是锁的升级、降级？

在 Java 中，synchronized 关键字的底层实现依赖于对象头（Object Header）和监视器锁（Monitor）机制，并通过锁的状态升级（Lock Escalation）来优化同步性能。 1. synchronized 的底层实现 synchronized 的同步机制基于 Monitor 对象，它是同步的基本实现单元。通过…...

编程日记 2025/6/29 9:14:07

python可视化：北方城市人口流动趋势分析1

python可视化：北方城市人口流动趋势分析1 斑点鱼在做销售数据分析时发现北京天津的同比下滑明显，客流下滑明显。而山东保定的客流同比上升。引起了斑点鱼对于北方人口流动的好奇。所以本文将分析2025年北方地区(北京、天津、河北、山东、山西、辽宁等)…...

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

wps excel 常用操作

数据分列对于有分隔规律的内容，可以通过分隔符将该内容进行分列例如，以下字符串，可使用Excel对包含IP地址、数据库类型、环境、负责人和日期的字符串进行分列： 192.168.175.211-MySQL 数据库-DEV-李华-2025.06.30 将以上字符串…...

编程日记 2025/6/29 9:11:57

云智融合普惠大模型AI，政务服务重构数智化路径

2025年是“十四五”收官之年，数字政府和政务数智化作为“数字中国”建设的重点，已经取得了显著成效。根据《联合国电子政务调查报告2024》，我国电子政务发展指数全球排名第35位，与2022年相比提升8个名次；其中&#xff…...

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

全行业软件定制：APP/小程序/系统开发与物联网解决方案

在数字化浪潮席卷全球的今天，软件已经渗透到我们生活的方方面面，成为推动社会进步的重要力量。作为一家专注于专业软件定制开发的公司，哲科软件深知每一个行业、每一个企业都有其独特的需求和痛点。因此，我们致力于提供个性化软件…...

编程日记 2025/6/29 11:31:55

Java虚拟机（JVM）家族发展史及版本对比

Java虚拟机（JVM）家族发展史及版本对比一、JVM家族发展史 1. 早期阶段（1996-2000） Classic VM（Java 1.0-1.1）： 厂商：Sun Microsystems（Oracle前身）。特点&…...

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

电脑怎么强制退出程序回到桌面详细操作步骤

电脑日常使用过程中，我们有时会遇到程序无响应或卡死的情况，这时需要采取措施强制关闭这些程序才能保持电脑的正常工作和运行。那么，电脑如何强制退出程序呢？其实方法有很多种，下面便为大家介绍几种电脑强制关闭程序的…...

编程日记 2025/6/29 10:16:54

蓝牙 LE：安全模式和程序说明（蓝牙中的网络安全）

在蓝牙低功耗 (BLE) 中，安全性是一个多方面的难题。了解 BLE 的三种主要安全模式以及五个关键的 BLE 安全程序。毫无疑问，低功耗蓝牙 (BLE) 技术的迅猛发展为我们的生活带来了更多便利。然而，随着低功耗蓝牙设备的普及，人们对其安全性的担忧也日益加剧。与普遍看法相反…...

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

低代码平台开发胎压监测APP

项目介绍该项目是一个利用Flutter框架和蓝牙技术实现轮胎压力实时监测的应用。主要功能如下： 用于接收蓝牙模块传输的胎压数据，并实时显示胎压值。APP对接收到的胎压数据进行处理，如单位转换、数据滤波等，然后将处理后的胎压值…...

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

GNOME扩展入门：日期时间

Getting Started | GNOME JavaScript 1.扩展路径 ~/.local/share/gnome-shell/extensions/ 2.新建文件夹 datetimesonichy 3.metadata.json {"uuid": "datetimesonichy","name": "datetime","description": "Dis…...

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

NLP高频面试题（五十二）——深度学习优化器详解

在深度学习的训练过程中，各种基于梯度的优化器肩负着寻找损失函数最优解的重任。最基础的梯度下降法通过沿着损失函数负梯度方向迭代更新参数，实现对模型参数的优化；而随机梯度下降（SGD）则以更高的计算效率和内存利用率在大规模数据集上大放异彩，但也因更新噪声大、易陷入…...

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

SLAM常用地图对比示例

序号地图类型概述1格栅地图将现实环境栅格化，每一个栅格用 0 和 1 分别表示空闲和占据状态，初始化为未知状态 0.52特征地图以点、线、面等几何特征来描绘周围环境，将采集的信息进行筛选和提取得到关键几何特征3拓扑地图将重要部分抽象为地图&…...

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

Web常见攻击方式及防御措施

一、常见Web攻击方式 1. 跨站脚本攻击(XSS) 攻击原理：攻击者向网页注入恶意脚本，在用户浏览器执行存储型XSS：恶意脚本存储在服务器（如评论区） 反射型XSS：恶意脚本通过URL参数反射给用户 DOM型XSS&…...

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

java.lang.IllegalArgumentException: URI is not hierarchical报错

java.lang.IllegalArgumentException: URI is not hierarchical Thread.currentThread().getContextClassLoader("类的全路径").getClass().newInstance()一个类的静态块初始化异常了，后面调用这个类创建对象会报错吗？ 是的，如果一…...

编程日记 2025/6/29 9:13:02

118. 杨辉三角

目录一、问题描述二、解题思路三、代码四、复杂度分析一、问题描述给定一个非负整数 numRows，生成「杨辉三角」的前 numRows 行。在「杨辉三角」中，每个数是它左上方和右上方的数的和。二、解题思路每一行的第一个和最后一个元素是 1&…...

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

Anything V4/V5 模型汇总

二次元风格生成扩散模型-anything-v4.0Stable Diffusion anything-v5-PrtRE模型介绍及使用深度探索 Anything V5：安装与使用全攻略anything-v5x0.25少儿插画_v1xyn-ai/anything-v4.0...

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

网络原理 - 7（TCP - 4）

目录 6. 拥塞控制 7. 延时应答 8. 捎带应答 9. 面向字节流 10. 异常情况总结： 6. 拥塞控制虽然 TCP 有了滑动窗口这个大杀器，就能够高效可靠的发送大量的数据，但是如果在刚开始阶段就发送大量的数据，仍然可能引起大量的…...

编程日记 2025/6/29 11:01:09

探秘 FFmpeg 版本发展时间简史

前言 FFmpeg 是一套开源的计算机程序，主要用于记录、转换数字音频、视频，并能将其转化为流。它提供了录制、转换以及流化音视频的完整解决方案，在多媒体处理领域应用广泛。很多小伙伴们想系统的学习FFmpeg，还是有必要了解下FFmpeg的版本发展历史，感受它每次的版本迭代是如…...

编程日记 2025/6/29 9:11:58

5.3.1 MvvmLight以及CommunityToolkit.Mvvm介绍

MvvmLight、CommunityToolkit.Mvvm是开源包，他们为实现 MVVM（Model-View-ViewModel）模式提供了一系列实用的特性和工具，能帮助开发者更高效地构建 WPF、UWP、MAUI 等应用程序。本文介绍如下：一、使用(旧)的MvvmLight库其特点如下，要继承的基类是ViewModelBase；且使用…...

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

PCB常见封装类型

1. 电阻、电容、电感封装 2. 二极管、三极管封 3. 排阻类器件（8脚、16脚）封装 4. SO类器件（间距有1.27、2.54mm等）封装 5. QFP类器件封装（四方扁平封装） 结构：引脚分布在封装的四个侧面&#…...

编程日记 2025/6/29 10:15:02

一键多环境构建——用 Hvigor 玩转 HarmonyOS Next

引言在 HarmonyOS Next 的应用开发中，常常需要针对不同环境（测试、预发、线上）或不同签名（调试、正式）输出多个 APP/HAP 包。虽然 HarmonyOS 提供了多目标构建（Multi-Target Build）能力&#…...

编程日记 2025/6/29 9:52:11

SQLPandas刷题(LeetCode3451.查找无效的IP地址)

描述：LeetCode3451.查找无效的IP地址表：logs ---------------------- | Column Name | Type | ---------------------- | log_id | int | | ip | varchar | | status_code | int | ---------------------- log_id 是这张表的唯…...

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

【leetcode100】组合总和Ⅳ

1、题目描述给你一个由不同整数组成的数组 nums ，和一个目标整数 target 。请你从 nums 中找出并返回总和为 target 的元素组合的个数。题目数据保证答案符合 32 位整数范围。示例 1： 输入：nums [1,2,3], target 4 输出&#xff1…...

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

2020-06-23 暑期学习日更计划（机器学习入门之路（资源汇总）+概率论）

机器学习入门前言说实话，机器学习想学好真心不易，很多时候都感觉自己学得云里雾里。以前一段时间自己为了完成毕业设计，在机器学习的理论部分并没有深究，仅仅通过TensorFlow框架力求快速实现模型。现在来看，很多时候…...

编程日记 2025/6/29 11:03:29

Linux操作系统--基础I/O(上)

目录 1.回顾C文件接口 stdin、stdout、stderr 2.系统文件I/O 3.接口介绍 4.open函数返回值 5.文件描述符fd 5.1 0&1&2 1.回顾C文件接口 hello.c写文件 #include<stdio.h> #include<string.h>int main() {FILE *fp fopen("myfile","…...

编程日记 2025/6/29 11:40:50

Spring boot 中的IOC容器对Bean的管理

Spring Boot 中 IOC 容器对 Bean 的管理，涵盖从容器启动到 Bean 的生命周期管理的全流程。步骤 1：理解 Spring Boot 的容器启动 Spring Boot 的 IOC 容器基于 ApplicationContext，在应用启动时自动初始化。入口类：通过 SpringB…...

编程日记 2025/6/29 11:42:28

ARINC818协议一些说明综述

关键术语航空总线技术光纤通道层次架构光纤通道拓扑结构 FC-AV协议，架构，容器系统 ARINC818协议，容器 ADVB帧映射，帧格式机载视频处理系统对视频数据进行实时处理和记录。分辨率：1080p,4k,8k视频技术 FC-AV技术是…...

编程日记 2025/6/29 19:36:37

Turso：一个基于 libSQL的分布式数据库

Turso 是一个完全托管的数据库平台，支持在一个组织中创建高达数十万个数据库，并且可以复制到任何地点，包括你自己的服务器，以实现微秒级的访问延迟。你可以通过Turso CLI（命令行界面）管理群组、数据库和API…...

编程日记 2025/6/29 11:20:31

2025.5.4机器学习笔记：PINN文献阅读

2025.5.4周报文献阅读题目信息摘要创新点网络架构实验结论不足以及展望文献阅读题目信息题目： Physics-Informed Neural Network Approach for Solving the One-Dimensional Unsteady Shallow-Water Equations in Riverine Systems期刊： Journal o…...

编程日记 2025/6/29 10:44:40

一行命令打开iOS模拟器

要在 Mac 命令行打开 iPhone 15 Pro 模拟器，需满足已安装 Xcode 这一前提条件，以下是具体操作步骤： 步骤一：列出所有可用模拟器设备打开终端（Terminal），输入并执行以下命令，用于列…...

编程日记 2025/6/29 9:29:53

java面向对象编程【基础篇】之基础语法

目录 🚀前言🌟构造器💯案例 🤔this关键字💯使用this调用本类中的属性💯使用this调用构造器💯this表示当前对象 🦜封装💯合理隐藏💯合理暴露 🐧实体…...

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

跑MPS产生委外采购申请（成品）

问题：跑MPS产生委外采购申请（成品），更改BOM和跑MRP，但物料需求清单中无新增物料复合膜的需求。截图如下： 解决方法：更改委外采购申请的批准日期为BOM的生效日和重新展开bom。重新展开后&#x…...

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

[flutter]切换国内源（window）

如题，切换到国内源避免总是连不上google导致卡住的问题。临时切换到国内： cmd set PUB_HOSTED_URLhttps://pub.flutter-io.cn set FLUTTER_STORAGE_BASE_URLhttps://storage.flutter-io.cnpower shell $env:PUB_HOSTED_URL "https://pub.flut…...

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

学习海康VisionMaster之顶点检测

一：进一步学习了今天学习下VisionMaster中的顶点检测：可检测图像指定区域内的顶点，并输出顶点坐标等信息。该模块常用于检测目标物体的顶点二：开始学习 1：什么是顶点检测？ 一个不是很规则的物体需要检测…...

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

Vue2中常用的核心函数（选项和生命周期钩子）的完整示例及总结

以下是Vue2中常用的核心函数（选项和生命周期钩子）的完整示例及总结： 1. 实例选项函数 data 初始化组件数据 new Vue({el: #app,data() {return {message: Hello Vue!};} });methods 定义组件方法 new Vue({el: #app,data() {return { c…...

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

数据集-目标检测系列- F35 战斗机检测数据集 F35 plane ＞＞ DataBall

数据集-目标检测系列- F35 战斗机检测数据集 F35 plane >> DataBall DataBall 助力快速掌握数据集的信息和使用方式。贵在坚持！ * 相关项目 1）数据集可视化项目：gitcode: https://gitcode.com/DataBall/DataBall-detections-100s…...

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

2025年3月AGI技术月评｜技术突破重构数字世界底层逻辑

〔更多精彩AI内容，尽在「魔方AI空间」 ，引领AIGC科技时代〕本文作者：猫先生 ——当「无限照片」遇上「可控试穿」，我们正在见证怎样的智能革命？ 被低估的进化：开源力量改写游戏规则当巨头们在AGI赛道…...

编程日记 2025/6/29 11:25:17

【k8s】k8s是怎么实现自动扩缩的

Kubernetes 提供了多种自动扩缩容机制，主要包括 Pod 水平自动扩缩（HPA）、垂直 Pod 自动扩缩（VPA） 和集群自动扩缩（Cluster Autoscaler）。以下是它们的实现原理和配置方法： 1. Pod …...

编程日记 2025/6/29 11:01:20

协作开发攻略：Git全面使用指南 — 引言

协作开发攻略：Git全面使用指南 — 引言 Git 是一种分布式版本控制系统，用于跟踪文件和目录的变更。它能帮助开发者有效管理代码版本，支持多人协作开发，方便代码合并与冲突解决，广泛应用于软件开发领域。文中内容仅限技…...

编程日记 2025/6/29 9:15:39

【AI提示词】私人教练

提示说明以专业且细致的方式帮助客户实现健康与健身目标，提升整体生活质量。提示词 # Role: 私人教练## Profile - language: 中文 - description: 以专业且细致的方式帮助客户实现健康与健身目标，提升整体生活质量 - background: 具备丰富的健身经…...

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

【星海出品】Calico研究汇总

Calico项目由Tigera公司发起并主导开发源码 https://github.com/projectcalico/calico?tabreadme-ov-file#-join-the-calico-community 简介 Tigera是一家专注于云原生安全的公司，于2016年成立，其核心产品包括开源的Calico项目以及商业版的Calico Ent…...

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

观成科技：摩诃草组织Spyder下载器流量特征分析

一、概述自2023年以来，摩诃草组织频繁使用Spyder下载器下载远控木马，例如Remcos。观成安全研究团队对近几年的Spyder样本进行了深入研究，发现不同版本的样本在数据加密、流量模式等方面存在差异。基于此，我们对多个版本样本的通…...

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

中心极限定理（CLT）习题集 · 题目篇

中心极限定理（CLT）习题集题目篇共 18 题，覆盖经典 CLT、Lyapunov/Lindeberg 条件、Berry–Esseen 评估、以及工程/数据科学应用与编程仿真。推荐先独立完成，再看《答案与解析篇》。之前已经出过相关的知识点文章，…...

编程日记 2025/6/29 9:15:16

ITL和TTL线程间值的传递

InheritableThreadLocal InheritableThreadLocal 继承自 ThreadLocal，增加了父线程到子线程的值传递功能。当一个新线程被创建时，InheritableThreadLocal 会将父线程中 ThreadLocal 变量的值拷贝到子线程（浅拷贝），子线…...

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