最简单文件系统的升级,增加文件创建和读写功能

2024-04-20 17:20

本文主要是介绍最简单文件系统的升级,增加文件创建和读写功能,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

基于前文,我们继续我们的文件系统的开发。在《基于Fuse的最简单的文件系统》一文中我们实现了一个假文件系统。虽然呈现了目录结构,但是不能创建新文件,也不能删除文件,更加不能对文件进行读写。

接下来我们就增加更多的功能,使该文件系统具备创建文件和读写的功能。但是,我们本着循序渐进的原则,这里需要注意的是本文件系统还有诸多限制,具体如下:

  • 目前的文件系统还是基于内存的实现,数据并不会持久化到存储介质上
  • 只支持在根目录创建和删除文件
  • 文件的大小限制在1024字节以内
  • 不支持在根目录创建子目录
  • 只支持一次性读写,不支持指定偏移读写
  • 最大可以创建256个文件

好吧,限制好多! 增加这么多限制的原因很简单,就是为了让降低大家的学习门槛。如果一下子实现一个支持所有功能的文件系统,估计大家就没有学习的兴趣和动力了。所以我们每一个例子会增加一点点功能,逐渐实现一个功能完善的文件系统。至于本系列文章中涉及的技术细节,大家可以参考本人拙著《文件系统技术内幕》一书。
在这里插入图片描述

接下来我们回归正题。虽然本地文件系统的基本原理是将线性的硬盘空间抽象为树型层级结构,但是底层存储并不一定要是线性的地址空间。为了实现简单,本文我们会借助STL的容器实现文件系统的一些基本功能。当然我们最终实现的文件系统肯定是基于硬盘的,目前的设计思路是为了降低学习的门槛和坡度,达到循序渐进的目的。

为了支持256个最大为1KB的内存文件,我们首先需要分配256KB的内存空间(用如下代码中的data_space表示)。同时,为了管理这些空间,也就是记录哪些空间已经被使用,哪些空间还是可用状态,我们通过创建了一个位图类型的变量(data_bitmap)。
image.png

另外,为了记录根目录中文件名称与文件数据的对应关系,我们创建了一个map类型的变量files。通过这个变量,我们可以根据文件名称获取文件的描述信息,比如文件数据的位置和大小等。这里文件的描述信息是通过一个名称为inode的结构体表示的,这也是模仿的Linux文件系统中的概念。

#define DATA_SPACE_LEN (256)
static map<string, inode*> files;
static vector<char*> data_space;
static bitset<DATA_SPACE_LEN> data_bitmap;

如下是结构体inode的具体定义,这里一共包含4项内容,都是最为基本的属性描述。本文我们主要使用了data_index和size两个成员变量,分别表示文件数据的位置和大小。

struct inode
{unsigned int inode_id;unsigned int mode;unsigned short data_index;unsigned short size;
};

如下代码是初始化的代码,本例中我们主要将内存区域清零,并将位图清零。这表示目前我们有一个干净的,没有任何文件的文件系统。后续我们在实现基于硬盘的文件系统时可以在这里实现硬盘格式化的工作。需要注意的是,在init函数中我们调用了syslog函数,该函数用于向系统日志中记录一条日志,方便我们了解程序的运行情况。

/* 初始化的时候被调用 */
void* MemoryFS::init(struct fuse_conn_info *conn, fuse_config*)
{syslog(LOG_NOTICE, "init\n");for (int i = 0; i < DATA_SPACE_LEN; i++) {char* block = new char[1024];memset(block, 0, 1024);data_space.push_back(block);data_bitmap.reset(i);}return 0;
}

然后回到本文的核心内容,实现文件的创建和读写。文件的创建和读写一共涉及4个函数,分别是create、open、write和read。其中create是创建文件时被调用,open是打开文件时被调用,write和read分别数据写读的时候被调用。接下来我们分别看看代码实现。

首先要看的自然是创建文件的实现,也就是create函数的实现,具体代码如下所示。本例实现原理是在创建一个文件的时候将该文件存储在一个map数据结构中,这样后续读写文件的时候就可以找到该文件。在本例中,我们只是创建一个inode实例,并构建文件系统与inode的映射关系。我们这里实现的非常简单,相当于在根目录中增加了一个文件。

int MemoryFS::create(const char *name, mode_t mode, struct fuse_file_info *)
{syslog(LOG_NOTICE, "Create: %s\n", name);inode *i = new inode();memset(i, 0, sizeof(inode));files[name] = i;  // 存储到map中return 0;
}

打开文件的函数实现也是非常简单的,我们只需要查询一下map,看看要打开的文件是否存在。如果不存在需要返回ENOENT。

int MemoryFS::open(const char *name, struct fuse_file_info *)
{int status = 0;auto inode = files.find(name);if (inode == files.end()) {status = -ENOENT;}syslog(LOG_NOTICE, "Open: %s %d\n", name, status);return 0;
}

接下来到正题了,也就是文件写数据的功能。首先是写数据的函数原型,可以看出与Linux的write函数类似。不同的地方是Linux API第一个参数是句柄,而本函数是文件名称。当我们在根目录中向某个文件写入数据的时候就会触发给函数。该函数的核心功能是找到前面创建的文件,并且找到一个内存空间用于存储用户要写入的数据。找到具体的信息后,会将数据拷贝到内存空间,并更新inode的记录。

int MemoryFS::write(const char *name, const char *buf, size_t buf_size, off_t offset, struct fuse_file_info *)
{auto inode = files.find(name); // 查找要写入数据的文件char* content = nullptr;short index = 0;int status = 0;if ( inode == files.end() ) {  // 如果没有找到文件,返回相应的错误码status = -ENOENT;goto OUT;}if ( inode->second->size ) {  // 判断文件是否已经有数据index = inode->second->data_index;} else {for (int i = 0; i < DATA_SPACE_LEN; i++) {  // 如果没有数据,根据位图查找一个可用的空间if (!data_bitmap[i]) {index = i;data_bitmap.set(i);break;}}}content = data_space[index]; // 获取空间的地址memcpy(content, buf, buf_size); // 将数据写入内存空间inode->second->data_index = index; // 更新数据的位置inode->second->size = buf_size;       // 更新文件大小OUT:syslog(LOG_NOTICE, "Write: %s %s %d\n", name, buf, buf_size);return buf_size;
}

读数据的实现逻辑与写数据类似,首先我们需要从map中查找到对应的文件。如果该文件存在,则会返回文件对应的inode实例。前文已述,inode中包含着文件数据的位置和大小等信息。根据inode中保存的信息,我们可以将数据拷贝到读数据的缓冲区,这样在调用者就可以看到数据了。

int MemoryFS::read(const char *name, char *buf, size_t buf_size, off_t offset, struct fuse_file_info *)
{auto inode = files.find(name); // 查找文件的inode信息char* content = nullptr;short index = 0;short file_size = 0;int status = 0;if ( inode == files.end() ) {status = -ENOENT;goto OUT;}index = inode->second->data_index; // 根据inode信息确定文件数据的位置和大小file_size = inode->second->size; content = data_space[index];memcpy(buf, content, file_size);  // 将数据拷贝到读缓冲区OUT:syslog(LOG_NOTICE, "Read: %s C %s B %s %d %d %d\n", name, content, buf, index, file_size, buf_size);return file_size;
}

虽然上述函数实现后就可以实现我们的目标功能了。但是如果我们用ls命令查看文件,则需要实现目录遍历的功能,这部分功能我们在前面文章介绍过。首先是需要实现readdir功能,用于遍历目录项。本例中是遍历map类型的变量。

int MemoryFS::readdir(const char *path, void *buf, fuse_fill_dir_t filler,off_t, struct fuse_file_info *, enum fuse_readdir_flags)
{syslog(LOG_NOTICE, "readdir: %s\n", path);filler(buf, ".", NULL, 0, FUSE_FILL_DIR_PLUS);filler(buf, "..", NULL, 0, FUSE_FILL_DIR_PLUS);for (const auto& [key, value] : files) { // 实现目录项的遍历filler(buf, key.c_str() + 1, NULL, 0, FUSE_FILL_DIR_PLUS);}return 0;
}

然后是实现getattr,该函数用于获取每个文件/目录的详细属性。这里我们也是偷懒了,很多属性是写死的。这个函数的实现并不复杂,大家可以自行阅读一下相关代码。

int MemoryFS::getattr(const char *path, struct stat *stbuf, struct fuse_file_info *)
{int res = 0;memset(stbuf, 0, sizeof(struct stat));if (path == root_path) {stbuf->st_mode = S_IFDIR | 0755;stbuf->st_nlink = 2;} else if (files.find(path) != files.end()) {auto inode = files.find(path);stbuf->st_mode = S_IFREG | 0755; // 我们这里模式是写死的,stbuf->st_nlink = 1;stbuf->st_size = inode->second->size;syslog(LOG_NOTICE, "getattr file: %s %d\n", path);} else {res = -ENOENT;syslog(LOG_NOTICE, "getattr error: %s\n", path);}syslog(LOG_NOTICE, "getattr: %s %d\n", path, res);return res;
}

至此,我们完成了所有函数的介绍。相关代码已经更新到作者的github空间,大家可以自行下载编译实验一下。接下来我们将进一步丰富功能,实现一个可以持久化的文件系统。

注: 本文配套的源代码可以在github的SunnyZhang-IT/fs-from-zero库中找到。

这篇关于最简单文件系统的升级,增加文件创建和读写功能的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/920865

相关文章

将Mybatis升级为Mybatis-Plus的详细过程

《将Mybatis升级为Mybatis-Plus的详细过程》本文详细介绍了在若依管理系统(v3.8.8)中将MyBatis升级为MyBatis-Plus的过程,旨在提升开发效率,通过本文,开发者可实现... 目录说明流程增加依赖修改配置文件注释掉MyBATisConfig里面的Bean代码生成使用IDEA生

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一:基于AbstractRoutingDataSource实现动态

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件(图片)的预览和下载 @ApiOperation("访问文件") @GetMapping("

Mysql表的简单操作(基本技能)

《Mysql表的简单操作(基本技能)》在数据库中,表的操作主要包括表的创建、查看、修改、删除等,了解如何操作这些表是数据库管理和开发的基本技能,本文给大家介绍Mysql表的简单操作,感兴趣的朋友一起看... 目录3.1 创建表 3.2 查看表结构3.3 修改表3.4 实践案例:修改表在数据库中,表的操作主要

SpringKafka消息发布之KafkaTemplate与事务支持功能

《SpringKafka消息发布之KafkaTemplate与事务支持功能》通过本文介绍的基本用法、序列化选项、事务支持、错误处理和性能优化技术,开发者可以构建高效可靠的Kafka消息发布系统,事务支... 目录引言一、KafkaTemplate基础二、消息序列化三、事务支持机制四、错误处理与重试五、性能优

SpringIntegration消息路由之Router的条件路由与过滤功能

《SpringIntegration消息路由之Router的条件路由与过滤功能》本文详细介绍了Router的基础概念、条件路由实现、基于消息头的路由、动态路由与路由表、消息过滤与选择性路由以及错误处理... 目录引言一、Router基础概念二、条件路由实现三、基于消息头的路由四、动态路由与路由表五、消息过滤

Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

《SpringBoot3.4.3基于SpringWebFlux实现SSE功能(代码示例)》SpringBoot3.4.3结合SpringWebFlux实现SSE功能,为实时数据推送提供... 目录1. SSE 简介1.1 什么是 SSE?1.2 SSE 的优点1.3 适用场景2. Spring WebFlu

基于SpringBoot实现文件秒传功能

《基于SpringBoot实现文件秒传功能》在开发Web应用时,文件上传是一个常见需求,然而,当用户需要上传大文件或相同文件多次时,会造成带宽浪费和服务器存储冗余,此时可以使用文件秒传技术通过识别重复... 目录前言文件秒传原理代码实现1. 创建项目基础结构2. 创建上传存储代码3. 创建Result类4.

Python+PyQt5实现多屏幕协同播放功能

《Python+PyQt5实现多屏幕协同播放功能》在现代会议展示、数字广告、展览展示等场景中,多屏幕协同播放已成为刚需,下面我们就来看看如何利用Python和PyQt5开发一套功能强大的跨屏播控系统吧... 目录一、项目概述:突破传统播放限制二、核心技术解析2.1 多屏管理机制2.2 播放引擎设计2.3 专

一文详解SpringBoot响应压缩功能的配置与优化

《一文详解SpringBoot响应压缩功能的配置与优化》SpringBoot的响应压缩功能基于智能协商机制,需同时满足很多条件,本文主要为大家详细介绍了SpringBoot响应压缩功能的配置与优化,需... 目录一、核心工作机制1.1 自动协商触发条件1.2 压缩处理流程二、配置方案详解2.1 基础YAML