diff --git a/CMakeLists.txt b/CMakeLists.txt index a8cc1f9..af5f7c6 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -60,6 +60,12 @@ FetchContent_Declare( URL ${CMAKE_SOURCE_DIR}/deps/spdlog-v1.13.0-mirror.zip ) FetchContent_MakeAvailable(spdlog) +FetchContent_Declare( + sockpp + URL_HASH SHA256=d144b3dcc7e9f031a9205395deb334b0b9681e1e7db61c066cca22ec2650a77b + URL ${CMAKE_SOURCE_DIR}/deps/sockpp-v1.0.0-mirror.zip +) +FetchContent_MakeAvailable(sockpp) include_directories(${CMAKE_SOURCE_DIR}/bpt/include) include_directories(${CMAKE_SOURCE_DIR}/stlite) enable_testing() diff --git a/deps/sockpp-v1.0.0-mirror.zip b/deps/sockpp-v1.0.0-mirror.zip new file mode 100644 index 0000000..eb082f1 Binary files /dev/null and b/deps/sockpp-v1.0.0-mirror.zip differ diff --git a/design.md b/design.md index 7109030..f723493 100644 --- a/design.md +++ b/design.md @@ -1,11 +1,14 @@ # 规划的Bonus实现方式 - 缓存:LRU - 空间回收 -- 快照:不内置于数据库系统,而是直接针对整个数据文件夹打快照(类似于git,在火车票系统后端处于非活动状态时操作,比对工作文件夹和版本库中的最后一次commit,然后打一个新的commit进去),额外消耗空间为压缩后的 当前文件实际大小+变化量,使用zstd算法压缩。交互方式:`./core-cli snapshot [options]` +- 快照:贯通于数据库系统和火车票系统整体,而是直接针对整个数据文件夹打快照(类似于git,在火车票系统后端处于非活动状态时操作,比对工作文件夹和版本库中的最后一次commit,然后打一个新的commit进去),额外消耗空间为压缩后的 当前文件实际大小+变化量,使用zstd算法压缩。交互方式:`./core-cli snapshot [options]` - 并发:内置于数据库系统,基于`std::shared_mutex`的简单并发。(但火车票系统会直接在整个业务层面上读写锁,因此不会直接使用数据库系统的并发安全)。 -- 容错:不内置于数据库系统,由火车票系统针对实际业务逻辑记录日志。在文件系统层级上修复完损伤后,运行`./core-cli fsck`检查是否有可能有损坏,借助快照工具修复可能的损伤。 +- 容错:不内置于数据库系统,由火车票系统针对实际业务逻辑记录日志。在文件系统层级上修复完损伤后,运行`./core-cli fsck`检查是否有可能有损坏,借助快照系统修复可能的损伤。 - 前端:一个使用正经框架写的简洁美观的UI,无响应式设计。 +## 快照系统 +一个仿照git的直接针对文件的快照库,有Work Tree、Stage、Commit等概念。虽然快照系统直接集成于数据库系统,但对用户开放的操作是以整个火车票系统为单位的。火车票系统会每隔数秒或数千比交易执行一次暂存,此时数据库系统会把缓存写回磁盘,记录数据操作日志,以及在快照系统中执行Stash;打快照时,会依次把缓存写回磁盘、记录日志(以单笔业务为最小单位)、stage工作目录、创建commit。 + 因为详细的数据库相关知识没学,所以正经并发和更细粒度的容错就不打算自己瞎搓了。 # 内核设计 @@ -13,8 +16,16 @@ - bpt:原始B+树以及相关简单封装,和其他一些涉及具体磁盘存储的东西 - 一个火车票系统执行引擎 - 一个直接的命令行交互系统,用于OJ测试/单会话模式/快照管理/数据错误检查 -- C Extensions封装,用于对接服务端 +- 一个Socket服务端,用于对接服务端 # UI设计 - 语言:Python -- 与内核的交互:C Extensions -- Web框架:FastAPI + socket.IO + (React?) + BootStrap \ No newline at end of file +- 与内核的交互:Socket +- Web框架:FastAPI + socket.IO + (React?) + BootStrap + +___ +# 使用到的第三方库 +均为在不涉及核心功能的情况下为了让程序更优雅而使用: +- argparse:提供优雅的命令行参数解析 +- googletest:调试用 +- spdlog:运行日志,调试用(不是数据库系统日志) +- sockpp:服务器模式下与Python交互用 \ No newline at end of file diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt index d69736f..717caae 100644 --- a/src/CMakeLists.txt +++ b/src/CMakeLists.txt @@ -6,4 +6,5 @@ endif() add_executable(${BACKEND_EXETUABLE_NAME} main.cpp) target_link_libraries(${BACKEND_EXETUABLE_NAME} argparse) target_link_libraries(${BACKEND_EXETUABLE_NAME} spdlog::spdlog) +target_link_libraries(${BACKEND_EXETUABLE_NAME} sockpp) set_target_properties(${BACKEND_EXETUABLE_NAME} PROPERTIES RUNTIME_OUTPUT_DIRECTORY ${CMAKE_BINARY_DIR}) \ No newline at end of file diff --git a/src/main.cpp b/src/main.cpp index 345234a..1edaad5 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -1,3 +1,4 @@ +#include #include "basic_defs.h" const std::string main_version = "0.0.1"; const std::string build_version = GIT_COMMIT_HASH; @@ -17,6 +18,14 @@ int main(int argc, char *argv[]) { argparse::ArgumentParser fsck_command("fsck"); fsck_command.add_description("Check and fix data"); program.add_subparser(fsck_command); + argparse::ArgumentParser server_command("server"); + server_command.add_description("Start a socket server"); + server_command.add_argument("-p", "--port").help("Port to listen").default_value(8085).nargs(1, 1).scan<'i', int>(); + server_command.add_argument("-a", "--address") + .help("Address to bind") + .default_value(std::string("127.0.0.1")) + .nargs(1, 1); + program.add_subparser(server_command); program.add_argument("-d", "--directory").help("Directory to serve").default_value(std::string(".")).nargs(1, 1); auto &group = program.add_mutually_exclusive_group(); group.add_argument("-c", "--consolelog").help("Enable console log").default_value(false).implicit_value(true); @@ -62,5 +71,20 @@ int main(int argc, char *argv[]) { LOG->info("Starting backend"); LOG->info("Compile optimization enabled: {}", optimize_enabled); LOG->info("Data directory: {}", data_directory); + bool is_server = program.is_subcommand_used("server"); + LOG->info("Server mode: {}", is_server); + if (is_server) { + auto port = server_command.get("--port"); + auto address = server_command.get("--address"); + LOG->info("Server port: {}", port); + LOG->info("Server address: {}", address); + LOG->info("Starting server"); + sockpp::tcp_acceptor acceptor(sockpp::inet_address(address, port)); + if (!acceptor) { + LOG->error("Error creating acceptor: {}", acceptor.last_error_str()); + return 1; + } else + LOG->info("successfully bind to address {} port {}", address, port); + } return 0; } \ No newline at end of file