【负载均衡在线OJ项目日记】运行功能开发

目录

前言

运行功能开发分析

获取子进程运行信息

程序运行资源限制

运行功能开发代码


前言

上篇文章我们对客户端服务器传来的临时文件进行编译,这篇文章主要对编译成功的代码在我们的服务器运行这块功能的开发。

运行功能开发分析

在运行功能开发之前我们默认已经形成了可执行程序;对于该运行程序在我们的服务其中也是一个指令程序,因此我们也要在该程序中创建子进程进行程序替换执行该可执行程序。

程序运行无非就是三种结果

  1. 代码跑完,结果正确
  2. 代码跑完,结果不正确
  3. 代码没跑完,发生异常了

这三种情况我们不需要考虑结果的正确与否,因为代码的运行结果的正确与否是有我们题目的测试用例来判断的,我们只考虑能否正确运行完毕即可。

运行代码我们就要考虑下面几个问题

  • 运行的可执行程序的文件名
  • 一个程序在启动的时候会默认打开三个流:标准输入、标准输出、标准错误
  1. 对于标准输入:也就是平时运行程序输入的测试用例,这个我们不处理;因此题目的测试用例是题目提供的,我们可以重定向从文件中读取数据,而不是从键盘中读取;
  2. 对于标准输出:也就是运行完成输出的结果是什么,这个需要和我们题目测试用例的答案相比较;因此也需要重定向到一个临时文件中
  3. 对于标准错误:这是我们后端服务器运行是的错误信息,不提供给用户,因此也需要重定向到一个临时文件中

获取子进程运行信息

上面提到我们只考虑可执行程序运行异常的情况,可执行程序的运行是通过我们的子进程进程替换,我们可以通过等待子进程获取子进程的退出信息;

程序运行资源限制

一些在在线OJ平台会限制运行时间和内存,在Linux中我我们也可以通过系统调用来设置这个小模块

int setrlimit(int resource, const struct rlimit *rlim);

返回值

  • 如果调用成功,setrlimit() 返回 0。
  • 如果调用失败,返回 -1,并设置 errno 变量来指示错误类型。

参数

  • resource:指定要设置的资源类型,它是一个整数常量,代表了不同的资源,比如 CPU 时间、堆栈大小、文件描述符数量等。这些常量通常以 RLIMIT_ 开头,比如 RLIMIT_CPURLIMIT_STACKRLIMIT_NOFILE 等。可以在系统的 <sys/resource.h> 头文件中找到定义。

  • rlim:是一个指向 struct rlimit 结构的指针,用于指定相应资源的软限制和硬限制。struct rlimit 结构包含两个字段:

    • rlim_cur:软限制,指定了资源的软限制值。软限制是进程在不需要特权的情况下能够修改的资源限制。例如,一个进程的最大打开文件数。
    • rlim_max:硬限制,指定了资源的硬限制值。硬限制是由系统管理员设置的最大资源限制。如果进程试图超过硬限制,系统会阻止这种行为,除非进程有特权。

一般我们只会限制运行时间和空间大小, 这两个参数也是由我们的题目提供。

运行功能开发代码

// 提供运行服务
#pragma once
#include <iostream>
#include <unistd.h>
#include <string>
#include "../comm/Log.hpp"
#include "../comm/util.hpp"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <wait.h>
#include<sys/time.h>
#include<sys/resource.h>
using namespace std;
namespace ns_runner
{
    using namespace ns_util;
    using namespace ns_log;
    class Runner
    {

    public:
        Runner()
        {
        }
        ~Runner()
        {
        }

    public:
        //设置进程资源大小的接口
        static void SetProcLimit(int _cpu_limit,int _mem_limit)
        {
            //设置cpu时长
            struct rlimit cpu_rlimit;
            cpu_rlimit.rlim_max=RLIM_INFINITY;
            cpu_rlimit.rlim_cur = _cpu_limit;
            setrlimit(RLIMIT_CPU,&cpu_rlimit);
            //设置内存大小
            struct rlimit mem_rlimit;
            mem_rlimit.rlim_max=RLIM_INFINITY;
            mem_rlimit.rlim_cur=_mem_limit*1024;//转化为kb
            setrlimit(RLIMIT_AS,&mem_rlimit);


        }
        // 指明文件名即可, 不需要代理路径 ,不需要带后缀
        // 返回值int;
        // 返回值 > 0: 程序异常了,退出时收到了信号,返回值就是对应的信号编号
        // 返回值 == 0: 正常运行完毕的,结果保存到了对应的临时文件中
        // 返回值 < 0: 内部错误
        

        //运行时间,和内存限制是由出题人决定的
        //第二个参数
        static int Run(const string &file_name,int cpu_limit,int mem_limit)
        {
            // 程序运行三种结果
            // 1.代码跑完,结果正确
            // 2.代码匏安,结果不正确
            // 3.代码没跑完,异常了
            // Run不需要考虑,结果正确与否
            // 结果正确与否,是由我们的正确用例决定的
            // 我们只考虑是否正确运行完毕
            //

            // 我们必须知道可执行程序是谁
            // 一个程序在默认启动的时候
            // 标准输入:不处理(不考虑用户自测情况)//只可以使用我们提供的测试用例
            // 标准输出:程序运行完成输出结果是什么
            // 标准错误:运行时错误信息
            // 写入文件

            // 获得可执行程序的文件名
            std::string _execute = PathUtil::Exe(file_name);
            std::string _stdin = PathUtil::Stdin(file_name);
            std::string _stdout = PathUtil::Stdout(file_name);
            std::string _stderr = PathUtil::Stderr(file_name);
            umask(0);
            int _stdin_fd = open(_stdin.c_str(), O_CREAT | O_RDONLY, 0644);
            int _stdout_fd = open(_stdout.c_str(), O_CREAT | O_WRONLY, 0644);
            int _stderr_fd = open(_stderr.c_str(), O_CREAT | O_WRONLY, 0644);

            if (_stdin_fd < 0 || _stdout_fd < 0 || _stderr_fd < 0)
            {
                LOG(ERROR)<<"运行时打开标准文件失败"<<"\n";
                return -1; // 打开文件失败,运行信息获取失败
            }
            pid_t pid = fork();
            if (pid < 0)
            {
                close(_stdin_fd);
                close(_stdout_fd);
                close(_stderr_fd);
                LOG(ERROR)<<"运行时创建子进程失败"<<"\n";
                return -2; // 代表创建子进程失败
            }
            else if (pid == 0)
            {
                // 子进程
                dup2(_stdin_fd, 0);
                dup2(_stdout_fd, 1);
                dup2(_stderr_fd, 2);
                SetProcLimit(cpu_limit,mem_limit);
                execl(_execute.c_str() /*我要执行谁*/, _execute.c_str() /*我想在命令行上如何执行该程序*/, nullptr);
                exit(1);
            }
            else
            {
                // 父进程
                close(_stdin_fd);
                close(_stdout_fd);
                close(_stderr_fd);
                int status = 0;
                waitpid(pid, &status, 0); // 程序运行异常,一定是因为收到了信号
                LOG(INFO)<<"运行完毕,info:"<<(status&0x7F)<<"\n";
                return status & 0x7F;
            }
        }
    };
}

今天对项目运行功能开发的分享到这就结束了,希望大家读完后有很大的收获,也可以在评论区点评文章中的内容和分享自己的看法;个人主页还有很多精彩的内容。您三连的支持就是我前进的动力,感谢大家的支持!!! 

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

RabbitMQ(Docker 单机部署)

序言 本文给大家介绍如何使用 Docker 单机部署 RabbitMQ 并与 SpringBoot 整合使用。 一、部署流程 拉取镜像 docker pull rabbitmq:3-management镜像拉取成功之后使用下面命令启动 rabbitmq 容器 docker run \# 指定用户名-e RABBITMQ_DEFAULT_USERusername \# 指定密码-e R…

Java_异常

介绍 编译时异常&#xff1a; 除RuntimeException和他的子类&#xff0c;其他都是编译时异常。编译阶段需要进行处理&#xff0c;作用在于提醒程序眼 运行时异常&#xff1a; RuntimeException本身和其所有子类&#xff0c;都是运行时异常。编译阶段不报错&#xff0c;是程序…

【Linux】gcc/g++的使用

&#x1f389;博主首页&#xff1a; 有趣的中国人 &#x1f389;专栏首页&#xff1a; Linux &#x1f389;其它专栏&#xff1a; C初阶 | C进阶 | 初阶数据结构 小伙伴们大家好&#xff0c;本片文章将会讲解Linux中gcc/g使用的相关内容。 如果看到最后您觉得这篇文章写得不错…

登录校验总览-jwt令牌

一、前置问题 为什么要登录校验&#xff1f;登录校验&#xff0c;就是判断访问资源的用户是否是合法用户&#xff0c;保障安全。如果不设置登录校验&#xff0c;就可以跳过登录&#xff0c;直接通过url访问资源。二、登录校验实现思路&#xff1a; 在服务器端对请求进行统一拦…

连接docker中的MySQL出现2058错误

出错场景&#xff1a;在虚拟机中用docker技术下载最新版本的MySQL&#xff0c;在本地电脑上连接发现出现2058错误。 解决方法&#xff1a; 按照以下步骤 1. 2. ALTER USER root% IDENTIFIED WITH mysql_native_password BY 自己MySQL的密码; 3.成功

不是所有的AI都这么乖——探索DAN模式的野性一面

今天偶然间发现DAN模式还挺好玩的&#xff01;&#xff01;&#xff01; 在一个充斥着预测性回答和过分礼貌的人工智能世界里&#xff0c;你是否曾渴望一场真正的思想碰撞&#xff1f;忘掉你以往遇到的那些听话的AI。DAN模式&#xff0c;一个设计来打破常规、挑战边界的AI&…

构建自己的docker镜像node.js

学习资源&#xff1a; 构建自己的 Docker 镜像_哔哩哔哩_bilibili 针对其中的一些比较困难的点写篇文章。 以下是对app.js的注释&#xff1a; // 使用 Koa 框架搭建 Node.js 应用的示例代码// 这两行代码引入了 koa 模块&#xff0c;并创建了一个新的 Koa 应用实例&#xf…

HTTP常见面试题(二)

3.1 HTTP 常见面试题 HTTP特性 HTTP 常见到版本有 HTTP/1.1&#xff0c;HTTP/2.0&#xff0c;HTTP/3.0&#xff0c;不同版本的 HTTP 特性是不一样的。 HTTP/1.1 的优点有哪些&#xff1f; HTTP 最突出的优点是「简单、灵活和易于扩展、应用广泛和跨平台」。 1. 简单 HTTP…

关于行进线路。

https://map.tianditu.gov.cn/ 作者&#xff1a;Chockhugh 链接&#xff1a;https://www.zhihu.com/question/20545559/answer/494685117 来源&#xff1a;知乎 著作权归作者所有。商业转载请联系作者获得授权&#xff0c;非商业转载请注明出处。 以50km&#xff0c;几乎全是…

C#字符串格式化

数值规范 也可写成int money 368; money .ToString("C"); string.Format("金额&#xff1a;{0:C}", 368); > 368.00 string.Format("科学计数法&#xff1a;{0:C}", 12000.1); > 1.200001…

【软件测试】用例篇 -- 详解

一、测试用例的基本要素 测试用例&#xff08;Test Case&#xff09;是为了实施测试而向被测试的系统提供的一组集合&#xff0c;这组集合包含&#xff1a;测试环境、操作步骤、测试数据、预期结果等要素。&#xff08;注意&#xff1a;不需要执行结果&#xff0c;因为执行结果…

【Qt 学习笔记】Qt常用控件 | 输入类控件 | Dial的使用及说明

博客主页&#xff1a;Duck Bro 博客主页系列专栏&#xff1a;Qt 专栏关注博主&#xff0c;后期持续更新系列文章如果有错误感谢请大家批评指出&#xff0c;及时修改感谢大家点赞&#x1f44d;收藏⭐评论✍ Qt常用控件 | 输入类控件 | Dial的使用及说明 文章编号&#xff1a;Qt…

kafka系列一:初识kafka

概述 kafka是由scala语言编写的一个分布式且具备高可用、高性能、可持久化、可水平扩展、支持流数据处理等众多特性的消息系统&#xff0c;常活跃于大数据生态中&#xff0c;而且大名鼎鼎的rocketmq就是参考了kafka的设计原理。 目前越来越多的开源分布式中间件都支持与kafka集…

Mysql:Before start of result set

解决方法&#xff1a;使用resultSet.getString&#xff08;&#xff09;之前一定要调用resultSet.next() ResultSet resultSet statement1.executeQuery();while (resultSet.next()){String username1 resultSet.getString("username");int id1 resultSet.getInt…

【C++】---继承

【C】---继承 一、继承的概念及定义1、继承的概念2、定义语法格式3、继承基类成员访问方式的变化 二、基类 和 派生类 的对象之间的赋值转换1、赋值规则2、切片&#xff08;1&#xff09;子类对象 赋值 给 父类对象&#xff08;2&#xff09;子类对象 赋值 给 父类指针&#xf…

windows11忘记登录密码怎么办?

STEP1&#xff1a;进入Win RE界面 1.按住shift不要松手,点击重新启动&#xff0c;进入WINRE界面 2.选择疑难解答 选择高级选项 点击命令提示符 STEP2:替换utilman 1.输入以下代码查看所在windows所在盘 diskpart list volume exit 2.根据所在盘输入命令&#xff08;以C盘为…

数据结构与算法(5)队列的基本操作

#include<stdio.h> #include<stdlib.h> #include<stdbool.h> typedef int ElemType; #define MaxSize 10//队列的定义 typedef struct SqQueue {ElemType data[MaxSize];int front, rear;//front为头指针&#xff0c;rear为尾指针。这里并不是真正的“指针”…

Java | Spring框架 | @Autowired与@Resource

在Spring框架中&#xff0c;依赖注入是一种核心概念&#xff0c;它允许开发者将对象的创建和对象之间的依赖关系的管理交给框架来处理。这样做的目的是为了提高代码的模块化和可测试性。 Spring提供了多种方式来实现依赖注入&#xff0c;其中最常用的方式是通过注解。在本文中…

mysql数据库---操作数据库跟表的命令总结

前言 欢迎来到我的博客 个人主页:北岭敲键盘的荒漠猫-CSDN博客 本文着重整理mysql管理库跟表的指令。 不涉及增删查改等指令 其实本篇主要是我做好笔记格式 用的时候直接复制粘贴的 所以排版大多是为了快速找功能来排的 方便大家快速找目标语法 数据库的简介 一个数据库系…

[Redis] 使用布隆过滤器和分布式锁实现用户注册

布隆过滤器&#xff08;Bloom Filter&#xff09;是一种数据结构&#xff0c;用于快速判断一个元素是否可能存在于一个集合中。它通过使用多个哈希函数和一个位数组来表示一个集合&#xff0c;当一个元素被加入到集合时&#xff0c;通过哈希函数计算出多个哈希值&#xff0c;并…
最新文章