Tio Boot DocsTio Boot Docs
Home
  • java-db
  • api-table
  • Enjoy
  • Tio Boot Admin
  • ai_agent
  • translator
  • knowlege_base
  • ai-search
  • 案例
Abount
  • Github
  • Gitee
Home
  • java-db
  • api-table
  • Enjoy
  • Tio Boot Admin
  • ai_agent
  • translator
  • knowlege_base
  • ai-search
  • 案例
Abount
  • Github
  • Gitee
  • 01_tio-boot 简介

    • tio-boot:新一代高性能 Java Web 开发框架
    • tio-boot 入门示例
    • Tio-Boot 配置 : 现代化的配置方案
    • tio-boot 整合 Logback
    • tio-boot 整合 hotswap-classloader 实现热加载
    • 自行编译 tio-boot
    • 最新版本
    • 开发规范
  • 02_部署

    • 使用 Maven Profile 实现分环境打包 tio-boot 项目
    • Maven 项目配置详解:依赖与 Profiles 配置
    • tio-boot 打包成 FastJar
    • 使用 GraalVM 构建 tio-boot Native 程序
    • 使用 Docker 部署 tio-boot
    • 部署到 Fly.io
    • 部署到 AWS Lambda
    • 到阿里云云函数
    • 使用 Deploy 工具部署
    • 胖包与瘦包的打包与部署
    • 使用 Jenkins 部署 Tio-Boot 项目
    • 使用 Nginx 反向代理 Tio-Boot
    • 使用 Supervisor 管理 Java 应用
  • 03_配置

    • 配置参数
    • 服务器监听器
    • 内置缓存系统 AbsCache
    • 使用 Redis 作为内部 Cache
    • 静态文件处理器
    • 基于域名的静态资源隔离
    • DecodeExceptionHandler
  • 04_原理

    • 生命周期
    • 请求处理流程
    • 重要的类
  • 05_json

    • Json
    • 接受 JSON 和响应 JSON
    • 响应实体类
  • 06_web

    • 概述
    • 文件上传
    • 接收请求参数
    • 接收日期参数
    • 接收数组参数
    • 返回字符串
    • 返回文本数据
    • 返回网页
    • 请求和响应字节
    • 文件下载
    • 返回视频文件并支持断点续传
    • http Session
    • Cookie
    • HttpRequest
    • HttpResponse
    • Resps
    • RespBodyVo
    • /zh/06_web/19.html
    • 全局异常处理器
    • 异步
    • 动态 返回 CSS 实现
    • 返回图片
    • Transfer-Encoding: chunked 实时音频播放
    • Server-Sent Events (SSE)
    • 接口访问统计
    • 接口请求和响应数据记录
    • 自定义 Handler 转发请求
    • 使用 HttpForwardHandler 转发所有请求
    • 跨域
    • 添加 Controller
    • 常用工具类
    • HTTP Basic 认证
    • WebJars
    • JProtobuf
  • 07_validate

    • 数据紧校验规范
    • 参数校验
  • 08_websocket

    • 使用 tio-boot 搭建 WebSocket 服务
    • WebSocket 聊天室项目示例
  • 09_java-db

    • java‑db
    • 操作数据库入门示例
    • SQL 模板
    • 数据源配置与使用
    • ActiveRecord
    • Model
    • 生成器与 Model
    • Db 工具类
    • 批量操作
    • 数据库事务处理
    • Cache 缓存
    • Dialect 多数据库支持
    • 表关联操作
    • 复合主键
    • Oracle 支持
    • Enjoy SQL 模板
    • Java-DB 整合 Enjoy 模板最佳实践
    • 多数据源支持
    • 独立使用 ActiveRecord
    • 调用存储过程
    • java-db 整合 Guava 的 Striped 锁优化
    • 生成 SQL
    • 通过实体类操作数据库
    • java-db 读写分离
    • Spring Boot 整合 Java-DB
    • like 查询
    • 常用操作示例
    • Druid 监控集成指南
    • SQL 统计
  • 10_api-table

    • ApiTable 概述
    • 使用 ApiTable 连接 SQLite
    • 使用 ApiTable 连接 Mysql
    • 使用 ApiTable 连接 Postgres
    • 使用 ApiTable 连接 TDEngine
    • 使用 api-table 连接 oracle
    • 使用 api-table 连接 mysql and tdengine 多数据源
    • EasyExcel 导出
    • EasyExcel 导入
    • TQL(Table SQL)前端输入规范
    • ApiTable 实现增删改查
    • 数组类型
    • 单独使用 ApiTable
  • 11_aop

    • JFinal-aop
    • Aop 工具类
    • 配置
    • 配置
    • 独立使用 JFinal Aop
    • @AImport
    • 原理解析
  • 12_cache

    • Caffine
    • Jedis-redis
    • hutool RedisDS
    • Redisson
    • Caffeine and redis
    • CacheUtils 工具类
    • 使用 CacheUtils 整合 caffeine 和 redis 实现的两级缓存
    • 使用 java-db 整合 ehcache
    • 使用 java-db 整合 redis
    • Java DB Redis 相关 Api
    • redis 使用示例
  • 13_认证和权限

    • hutool-JWT
    • FixedTokenInterceptor
    • 使用内置 TokenManager 实现登录
    • 用户系统
    • 重置密码
    • 匿名登录
    • Google 登录
    • 权限校验注解
    • Sa-Token
    • sa-token 登录注册
    • StpUtil.isLogin() 源码解析
    • 短信登录
    • 移动端微信登录实现指南
    • 移动端重置密码
  • 14_i18n

    • i18n
  • 15_enjoy

    • tio-boot 整合 Enjoy 模版引擎文档
    • 引擎配置
    • 表达式
    • 指令
    • 注释
    • 原样输出
    • Shared Method 扩展
    • Shared Object 扩展
    • Extension Method 扩展
    • Spring boot 整合
    • 独立使用 Enjoy
    • tio-boot enjoy 自定义指令 localeDate
    • PromptEngine
    • Enjoy 入门示例-擎渲染大模型请求体
    • Enjoy 使用示例
  • 16_定时任务

    • Quartz 定时任务集成指南
    • 分布式定时任务 xxl-jb
    • cron4j 使用指南
  • 17_tests

    • TioBootTest 类
  • 18_tio

    • TioBootServer
    • tio-core
    • 内置 TCP 处理器
    • 独立启动 UDPServer
    • 使用内置 UDPServer
    • t-io 消息处理流程
    • tio-运行原理详解
    • TioConfig
    • ChannelContext
    • Tio 工具类
    • 业务数据绑定
    • 业务数据解绑
    • 发送数据
    • 关闭连接
    • Packet
    • 监控: 心跳
    • 监控: 客户端的流量数据
    • 监控: 单条 TCP 连接的流量数据
    • 监控: 端口的流量数据
    • 单条通道统计: ChannelStat
    • 所有通道统计: GroupStat
    • 资源共享
    • 成员排序
    • SSL
    • DecodeRunnable
    • 使用 AsynchronousSocketChannel 响应数据
    • 拉黑 IP
    • 深入解析 Tio 源码:构建高性能 Java 网络应用
  • 19_aio

    • ByteBuffer
    • AIO HTTP 服务器
    • 自定义和线程池和池化 ByteBuffer
    • AioHttpServer 应用示例 IP 属地查询
    • 手写 AIO Http 服务器
  • 20_netty

    • Netty TCP Server
    • Netty Web Socket Server
    • 使用 protoc 生成 Java 包文件
    • Netty WebSocket Server 二进制数据传输
    • Netty 组件详解
  • 21_netty-boot

    • Netty-Boot
    • 原理解析
    • 整合 Hot Reload
    • 整合 数据库
    • 整合 Redis
    • 整合 Elasticsearch
    • 整合 Dubbo
    • Listener
    • 文件上传
    • 拦截器
    • Spring Boot 整合 Netty-Boot
    • SSL 配置指南
    • ChannelInitializer
    • Reserve
  • 22_MQ

    • Mica-mqtt
    • EMQX
    • Disruptor
  • 23_tio-utils

    • tio-utils
    • HttpUtils
    • Notification
    • 邮箱
    • JSON
    • 读取文件
    • Base64
    • 上传和下载
    • Http
    • Telegram
    • RsaUtils
    • EnvUtils 使用文档
    • 系统监控
    • 毫秒并发 ID (MCID) 生成方案
  • 24_tio-http-server

    • 使用 Tio-Http-Server 搭建简单的 HTTP 服务
    • tio-boot 添加 HttpRequestHandler
    • 在 Android 上使用 tio-boot 运行 HTTP 服务
    • tio-http-server-native
    • handler 常用操作
  • 25_tio-websocket

    • WebSocket 服务器
    • WebSocket Client
  • 26_tio-im

    • 通讯协议文档
    • ChatPacket.proto 文档
    • java protobuf
    • 数据表设计
    • 创建工程
    • 登录
    • 历史消息
    • 发消息
  • 27_mybatis

    • Tio-Boot 整合 MyBatis
    • 使用配置类方式整合 MyBatis
    • 整合数据源
    • 使用 mybatis-plus 整合 tdengine
    • 整合 mybatis-plus
  • 28_mongodb

    • tio-boot 使用 mongo-java-driver 操作 mongodb
  • 29_elastic-search

    • Elasticsearch
    • JavaDB 整合 ElasticSearch
    • Elastic 工具类使用指南
    • Elastic-search 注意事项
    • ES 课程示例文档
  • 30_magic-script

    • tio-boot 整合 magic-script
  • 31_groovy

    • tio-boot 整合 Groovy
  • 32_firebase

    • 整合 google firebase
    • Firebase Storage
    • Firebase Authentication
    • 使用 Firebase Admin SDK 进行匿名用户管理与自定义状态标记
    • 导出用户
    • 注册回调
    • 登录注册
  • 33_文件存储

    • 文件上传数据表
    • 本地存储
      • 目录
      • 实现本地存储
        • 配置文件
        • 配置类
        • 业务层
        • 接入层
      • 文件上传文档
        • 1. 客户端生成文件的 MD5 值
        • 2. 检查文件是否已上传
        • 3. 上传文件
        • 4. 将文件信息入库
        • 完整流程总结
      • 关键配置说明
        • server.resources.static-locations=pages
        • Path path = Paths.get("pages", bucketName, category);
      • 总结
    • 使用 AWS S3 存储文件并整合到 Tio-Boot 项目中
    • 存储文件到 腾讯 COS
  • 34_spider

    • jsoup
    • 爬取 z-lib.io 数据
    • 整合 WebMagic
    • WebMagic 示例:爬取学校课程数据
    • Playwright
    • Flexmark (Markdown 处理器)
    • tio-boot 整合 Playwright
    • 缓存网页数据
  • 36_integration_thirty_party

    • tio-boot 整合 okhttp
    • 整合 GrpahQL
    • 集成 Mailjet
    • 整合 ip2region
    • 整合 GeoLite 离线库
    • 整合 Lark 机器人指南
    • 集成 Lark Mail 实现邮件发送
    • Thymeleaf
    • Swagger
    • Clerk 验证
  • 37_dubbo

    • 概述
    • dubbo 2.6.0
    • dubbo 2.6.0 调用过程
    • dubbo 3.2.0
  • 38_spring

    • Spring Boot Web 整合 Tio Boot
    • spring-boot-starter-webflux 整合 tio-boot
    • Tio Boot 整合 Spring Boot Starter
    • Tio Boot 整合 Spring Boot Starter Data Redis 指南
  • 39_spring-cloud

    • tio-boot spring-cloud
  • 40_mysql

    • 使用 Docker 运行 MySQL
    • /zh/42_mysql/02.html
  • 41_postgresql

    • PostgreSQL 安装
    • PostgreSQL 主键自增
    • PostgreSQL 日期类型
    • Postgresql 金融类型
    • PostgreSQL 数组类型
    • PostgreSQL 全文检索
    • PostgreSQL 查询优化
    • 获取字段类型
    • PostgreSQL 向量
    • PostgreSQL 优化向量查询
    • PostgreSQL 其他
  • 43_oceanbase

    • 快速体验 OceanBase 社区版
    • 快速上手 OceanBase 数据库单机部署与管理
    • 诊断集群性能
    • 优化 SQL 性能指南
    • /zh/43_oceanbase/05.html
  • 50_media

    • JAVE 提取视频中的声音
    • Jave 提取视频中的图片
    • /zh/50_media/03.html
  • 51_asr

    • Whisper-JNI
  • 54_native-media

    • java-native-media
    • JNI 入门示例
    • mp3 拆分
    • mp4 转 mp3
    • 使用 libmp3lame 实现高质量 MP3 编码
    • Linux 编译
    • macOS 编译
    • 从 JAR 包中加载本地库文件
    • 支持的音频和视频格式
    • 任意格式转为 mp3
    • 通用格式转换
    • 通用格式拆分
    • 视频合并
    • VideoToHLS
    • split_video_to_hls 支持其他语言
    • 持久化 HLS 会话
  • 55_telegram4j

    • 数据库设计
    • /zh/55_telegram4j/02.html
    • 基于 MTProto 协议开发 Telegram 翻译机器人
    • 过滤旧消息
    • 保存机器人消息
    • 定时推送
    • 增加命令菜单
    • 使用 telegram-Client
    • 使用自定义 StoreLayout
    • 延迟测试
    • Reactor 错误处理
    • Telegram4J 常见错误处理指南
  • 56_telegram-bots

    • TelegramBots 入门指南
    • 使用工具库 telegram-bot-base 开发翻译机器人
  • 60_LLM

    • 简介
    • AI 问答
    • /zh/60_LLM/03.html
    • /zh/60_LLM/04.html
    • 增强检索(RAG)
    • 结构化数据检索
    • 搜索+AI
    • 集成第三方 API
    • 后置处理
    • 推荐问题生成
    • 连接代码执行器
    • 避免 GPT 混乱
    • /zh/60_LLM/13.html
  • 61_ai_agent

    • 数据库设计
    • 示例问题管理
    • 会话管理
    • 历史记录
    • 对接 Perplexity API
    • 意图识别与生成提示词
    • 智能问答模块设计与实现
    • 文件上传与解析文档
    • 翻译
    • 名人搜索功能实现
    • Ai studio gemini youbue 问答使用说明
    • 自建 YouTube 字幕问答系统
    • 自建 获取 youtube 字幕服务
    • 通用搜索
    • /zh/61_ai_agent/15.html
    • 16
    • 17
    • 18
    • 在 tio-boot 应用中整合 ai-agent
    • 16
  • 62_translator

    • 简介
  • 63_knowlege_base

    • 数据库设计
    • 用户登录实现
    • 模型管理
    • 知识库管理
    • 文档拆分
    • 片段向量
    • 命中测试
    • 文档管理
    • 片段管理
    • 问题管理
    • 应用管理
    • 向量检索
    • 推理问答
    • 问答模块
    • 统计分析
    • 用户管理
    • api 管理
    • 存储文件到 S3
    • 文档解析优化
    • 片段汇总
    • 段落分块与检索
    • 多文档解析
    • 对话日志
    • 检索性能优化
    • Milvus
    • 文档解析方案和费用对比
    • 离线运行向量模型
  • 64_ai-search

    • ai-search 项目简介
    • ai-search 数据库文档
    • ai-search SearxNG 搜索引擎
    • ai-search Jina Reader API
    • ai-search Jina Search API
    • ai-search 搜索、重排与读取内容
    • ai-search PDF 文件处理
    • ai-search 推理问答
    • Google Custom Search JSON API
    • ai-search 意图识别
    • ai-search 问题重写
    • ai-search 系统 API 接口 WebSocket 版本
    • ai-search 搜索代码实现 WebSocket 版本
    • ai-search 生成建议问
    • ai-search 生成问题标题
    • ai-search 历史记录
    • Discover API
    • 翻译
    • Tavily Search API 文档
    • 对接 Tavily Search
    • 火山引擎 DeepSeek
    • 对接 火山引擎 DeepSeek
    • ai-search 搜索代码实现 SSE 版本
    • jar 包部署
    • Docker 部署
    • 爬取一个静态网站的所有数据
    • 网页数据预处理
    • 网页数据检索与问答流程整合
  • 65_java-linux

    • Java 执行 python 代码
    • 通过大模型执行 Python 代码
    • MCP 协议
    • Cline 提示词
    • Cline 提示词-中文版本
  • 66_manim

    • Teach me anything - 基于大语言的知识点讲解视频生成系统
    • Manim 开发环境搭建
    • 生成场景提示词
    • 生成代码
    • 完整脚本示例
    • 语音合成系统
    • Fish.audio TTS 接口说明文档与 Java 客户端封装
    • 整合 fishaudio 到 java-uni-ai-server 项目
    • 执行 Python (Manim) 代码
    • 使用 SSE 流式传输生成进度的实现文档
    • 整合全流程完整文档
    • HLS 动态推流技术文档
    • manim 分场景生成代码
    • 分场景运行代码及流式播放支持
    • 分场景业务端完整实现流程
    • Maiim布局管理器
    • 仅仅生成场景代码
    • 使用 modal 运行 manim 代码
    • Python 使用 Modal GPU 加速渲染
    • Modal 平台 GPU 环境下运行 Manim
    • Modal Manim OpenGL 安装与使用
    • 优化 GPU 加速
    • 生成视频封面流程
    • Java 调用 manim 命令 执行代码 生成封面
    • Manim 图像生成服务客户端文档
    • manim render help
    • 显示 中文公式
    • manimgl
    • EGL
    • /zh/66_manim/30.html
    • /zh/66_manim/31.html
    • /zh/66_manim/32.html
    • /zh/66_manim/33.html
  • 70_tio-boot-admin

    • 入门指南
    • 初始化数据
    • token 存储
    • 与前端集成
    • 文件上传
    • 网络请求
    • 图片管理
    • /zh/70_tio-boot-admin/08.html
    • Word 管理
    • PDF 管理
    • 文章管理
    • 富文本编辑器
  • 71_tio-boot

    • /zh/71_tio-boot/01.html
    • Swagger 整合到 Tio-Boot 中的指南
    • HTTP/1.1 Pipelining 性能测试报告
  • 80_性能测试

    • 压力测试 - tio-http-serer
    • 压力测试 - tio-boot
    • 压力测试 - tio-boot-native
    • 压力测试 - netty-boot
    • 性能测试对比
    • TechEmpower FrameworkBenchmarks
    • 压力测试 - tio-boot 12 C 32G
  • 99_案例

    • 封装 IP 查询服务
    • tio-boot 案例 - 全局异常捕获与企业微信群通知
    • tio-boot 案例 - 文件上传和下载
    • tio-boot 案例 - 整合 ant design pro 增删改查
    • tio-boot 案例 - 流失响应
    • tio-boot 案例 - 增强检索
    • tio-boot 案例 - 整合 function call
    • tio-boot 案例 - 定时任务 监控 PostgreSQL、Redis 和 Elasticsearch
    • Tio-Boot 案例:使用 SQLite 整合到登录注册系统
    • tio-boot 案例 - 执行 shell 命令

本地存储

本篇文章介绍一个实例,演示如何将文件存储到本地文件系统。通过配置和编写相应的代码,实现文件的上传、存储及访问功能。

目录

  1. 实现本地存储
    • 配置文件
    • 配置类
      • 数据库配置类 DbConfig
      • 处理器配置类 HandlerConfiguration
    • 业务层
    • 接入层
  2. 文件上传文档
    • 1. 客户端生成文件的 MD5 值
    • 2. 检查文件是否已上传
    • 3. 上传文件
    • 4. 将文件信息入库
    • 完整流程总结
  3. 关键配置说明
    • server.resources.static-locations=pages
    • Path path = Paths.get("pages", bucketName, category);
  4. 总结

实现本地存储

配置文件

在 app.properties 文件中配置服务器端口、文件上传大小限制、静态资源位置、数据库连接信息以及文件访问前缀 URL。

server.port=8123
http.multipart.max-request-size=73741824
http.multipart.max-file-size=73741824
server.resources.static-locations=pages
DATABASE_DSN=postgresql://postgres:123456@192.168.3.9:5432/static_file
file_prefix_url=http://localhost:8123

配置说明:

  • server.port=8123:指定服务器监听的端口号为 8123。
  • http.multipart.max-request-size=73741824:设置 HTTP 请求的最大大小为 73,741,824 字节(约 70 MB)。
  • http.multipart.max-file-size=73741824:设置单个文件上传的最大大小为 73,741,824 字节(约 70 MB)。
  • server.resources.static-locations=pages:指定静态资源的存储位置为项目根目录下的 pages 文件夹。这样,存储在 pages 目录中的文件可以通过 URL 直接访问。
  • DATABASE_DSN=postgresql://postgres:123456@192.168.3.9:5432/static_file:配置数据库连接字符串,连接到 PostgreSQL 数据库。
  • file_prefix_url=http://localhost:8123:配置文件访问的前缀 URL,用于生成文件的访问链接。

配置类

配置类负责初始化数据库连接池、ActiveRecord 插件以及注册文件处理器的路由。

数据库配置类 DbConfig

package com.litongjava.file.config;

import com.jfinal.template.Engine;
import com.jfinal.template.source.ClassPathSourceFactory;
import com.litongjava.annotation.AConfiguration;
import com.litongjava.annotation.Initialization;
import com.litongjava.db.activerecord.ActiveRecordPlugin;
import com.litongjava.db.activerecord.OrderedFieldContainerFactory;
import com.litongjava.db.activerecord.dialect.PostgreSqlDialect;
import com.litongjava.db.hikaricp.HikariCpPlugin;
import com.litongjava.model.dsn.JdbcInfo;
import com.litongjava.tio.boot.server.TioBootServer;
import com.litongjava.tio.utils.dsn.DbDSNParser;
import com.litongjava.tio.utils.environment.EnvUtils;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@AConfiguration
public class DbConfig {

  @Initialization
  public void config() {
    // 获取数据库连接信息
    String dsn = EnvUtils.getStr("DATABASE_DSN");
    JdbcInfo jdbc = new DbDSNParser().parse(dsn);

    // 初始化 HikariCP 数据库连接池
    HikariCpPlugin hikariCpPlugin = new HikariCpPlugin(jdbc.getUrl(), jdbc.getUser(), jdbc.getPswd());
    hikariCpPlugin.start();

    // 初始化 ActiveRecordPlugin
    ActiveRecordPlugin arp = new ActiveRecordPlugin(hikariCpPlugin);

    // 开发环境下启用开发模式
    if (EnvUtils.isDev()) {
      arp.setDevMode(true);
    }

    // 是否展示 SQL
    boolean showSql = EnvUtils.getBoolean("jdbc.showSql", false);
    log.info("show sql:{}", showSql);
    arp.setShowSql(showSql);
    arp.setDialect(new PostgreSqlDialect());
    arp.setContainerFactory(new OrderedFieldContainerFactory());

    // 配置模板引擎
    Engine engine = arp.getEngine();
    engine.setSourceFactory(new ClassPathSourceFactory());
    engine.setCompressorOn(' ');
    engine.setCompressorOn('\n');

    // 启动 ActiveRecordPlugin
    arp.start();

    // 在应用销毁时停止数据库连接池
    HookCan.me().addDestroyMethod(() -> {
      arp.stop();
      hikariCpPlugin.stop();
    });
  }
}

关键点说明:

  • 数据库连接初始化:通过 DATABASE_DSN 获取数据库连接信息,并使用 HikariCpPlugin 初始化数据库连接池。
  • ActiveRecordPlugin 配置:设置开发模式、SQL 显示选项、方言(PostgreSQL)、容器工厂等,并启动插件。
  • 模板引擎配置:配置 JFinal 模板引擎的源工厂和压缩选项。
  • 资源回收:注册应用销毁时的回调方法,确保数据库连接池和 ActiveRecordPlugin 正确关闭,释放资源。

处理器配置类 HandlerConfiguration

package com.litongjava.file.config;

import com.litongjava.annotation.AConfiguration;
import com.litongjava.annotation.Initialization;
import com.litongjava.file.handler.SystemFileHandler;
import com.litongjava.jfinal.aop.Aop;
import com.litongjava.tio.boot.server.TioBootServer;
import com.litongjava.tio.http.server.router.HttpRequestRouter;

@AConfiguration
public class HandlerConfiguration {
  @Initialization
  public void config() {
    HttpRequestRouter router = TioBootServer.me().getRequestRouter();
    if (router == null) {
      return;
    }
    // 获取文件处理器实例并注册路由
    SystemFileHandler fileHandler = Aop.get(SystemFileHandler.class);
    router.add("/api/system/file/upload", fileHandler::upload);
    router.add("/api/system/file/url", fileHandler::getUrl);
  }
}

关键点说明:

  • 路由注册:通过 HttpRequestRouter 注册文件上传和获取 URL 的 API 路径,分别对应 upload 和 getUrl 方法。
  • 依赖注入:使用 AOP 获取 SystemFileHandler 实例,确保处理器能够被正确管理和注入。

业务层

业务层负责处理文件的上传、存储和查询逻辑。

package com.litongjava.file.service;

import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

import com.litongjava.db.activerecord.Row;
import com.litongjava.file.dao.SystemUploadFileDao;
import com.litongjava.file.model.UploadResultVo;
import com.litongjava.jfinal.aop.Aop;
import com.litongjava.tio.http.common.UploadFile;
import com.litongjava.tio.utils.crypto.Md5Utils;
import com.litongjava.tio.utils.environment.EnvUtils;
import com.litongjava.tio.utils.hutool.FileUtil;
import com.litongjava.tio.utils.hutool.FilenameUtils;
import com.litongjava.tio.utils.snowflake.SnowflakeIdUtils;

public class SystemFileService {

  /**
   * 上传文件并存储到本地文件系统
   *
   * @param uploadFile  上传的文件
   * @param bucketName  存储桶名称
   * @param category    文件分类
   * @return UploadResultVo 文件上传结果
   */
  public UploadResultVo upload(UploadFile uploadFile, String bucketName, String category) {
    if (uploadFile != null) {
      byte[] fileData = uploadFile.getData();
      String digestHex = Md5Utils.digestHex(fileData);
      SystemUploadFileDao systemUploadFileDao = Aop.get(SystemUploadFileDao.class);
      Row row = systemUploadFileDao.getFileBasicInfoByMd5(bucketName, digestHex);

      // 如果文件已存在,返回已有文件信息
      if (row != null) {
        Long id = row.getLong("id");
        String filename = row.getStr("filename");
        String targetName = row.getStr("target_name");
        String url = getUrl(bucketName, targetName);
        return new UploadResultVo(id, filename, url, digestHex);
      }

      // 生成新的文件名和路径
      String originFilename = uploadFile.getName();
      String suffix = FilenameUtils.getSuffix(originFilename);
      long id = SnowflakeIdUtils.id();
      String filename = id + "." + suffix;
      Path path = Paths.get("pages", bucketName, category);

      // 创建目录(如果不存在)
      try {
        Files.createDirectories(path);
      } catch (IOException e) {
        e.printStackTrace();
        return null;
      }

      // 完整文件路径
      Path filePath = path.resolve(filename);
      File file = filePath.toFile();

      // 将文件数据写入指定路径
      FileUtil.writeBytes(fileData, file);

      String targetName = category + "/" + filename;
      String url = getUrl(bucketName, targetName);
      systemUploadFileDao.save(id, digestHex, originFilename, fileData.length, "local", bucketName, targetName);
      return new UploadResultVo(id, originFilename, url, digestHex);
    }
    return null;
  }

  /**
   * 根据存储桶和目标名称生成文件访问 URL
   *
   * @param bucketName 存储桶名称
   * @param targetName 目标名称
   * @return 文件访问 URL
   */
  public String getUrl(String bucketName, String targetName) {
    String prefixUrl = EnvUtils.getStr("file_prefix_url");
    return prefixUrl + "/" + bucketName + "/" + targetName;
  }

  /**
   * 根据文件 ID 获取文件 URL
   *
   * @param id 文件 ID
   * @return UploadResultVo 文件上传结果
   */
  public UploadResultVo getUrlById(Long id) {
    SystemUploadFileDao systemUploadFileDao = Aop.get(SystemUploadFileDao.class);
    Row row = systemUploadFileDao.getFileBasicInfoById(id);
    String md5 = row.getStr("md5");
    String filename = row.getStr("filename");
    String bucketName = row.getStr("bucket_name");
    String targetName = row.getStr("target_name");
    String url = getUrl(bucketName, targetName);
    return new UploadResultVo(id, filename, url, md5);
  }

  /**
   * 根据文件 MD5 获取文件 URL
   *
   * @param bucketName 存储桶名称
   * @param md5        文件 MD5 值
   * @return UploadResultVo 文件上传结果
   */
  public UploadResultVo getUrlByMd5(String bucketName, String md5) {
    SystemUploadFileDao systemUploadFileDao = Aop.get(SystemUploadFileDao.class);
    Row row = systemUploadFileDao.getFileBasicInfoByMd5(bucketName, md5);
    Long id = row.getLong("id");
    String filename = row.getStr("filename");
    String targetName = row.getStr("target_name");
    String url = getUrl(bucketName, targetName);
    return new UploadResultVo(id, filename, url, md5);
  }
}

功能说明:

  • 文件上传:

    • MD5 校验:通过文件数据生成 MD5 值,检查文件是否已存在,以避免重复上传。
    • 文件存储:生成唯一文件名,创建存储路径(pages/{bucketName}/{category}),将文件数据写入本地文件系统。
    • 数据库记录:将文件的基本信息(如 ID、MD5、文件名、存储路径等)保存到数据库中。
  • URL 生成:根据存储桶名称和目标文件名生成文件的访问 URL。

  • 文件查询:

    • 按 ID 查询:根据文件 ID 获取文件的 URL 和其他信息。
    • 按 MD5 查询:根据文件的 MD5 值和存储桶名称获取文件的 URL 和其他信息。

接入层

接入层负责处理 HTTP 请求,调用业务层的相关方法,并返回响应结果。

package com.litongjava.file.handler;

import com.jfinal.kit.StrKit;
import com.litongjava.file.model.UploadResultVo;
import com.litongjava.file.service.SystemFileService;
import com.litongjava.jfinal.aop.Aop;
import com.litongjava.model.body.RespBodyVo;
import com.litongjava.tio.boot.http.TioRequestContext;
import com.litongjava.tio.http.common.HttpRequest;
import com.litongjava.tio.http.common.HttpResponse;
import com.litongjava.tio.http.common.UploadFile;
import com.litongjava.tio.http.server.model.HttpCors;
import com.litongjava.tio.http.server.util.CORSUtils;
import com.litongjava.tio.http.server.util.Resps;

public class SystemFileHandler {

  /**
   * 处理文件上传请求
   *
   * @param request HTTP 请求
   * @return HttpResponse 响应
   */
  public HttpResponse upload(HttpRequest request) {
    HttpResponse httpResponse = TioRequestContext.getResponse();
    CORSUtils.enableCORS(httpResponse, new HttpCors());

    UploadFile uploadFile = request.getUploadFile("file");
    String bucket = request.getParam("bucket");
    String category = request.getParam("category");
    if (uploadFile == null) {
      return httpResponse.fail(RespBodyVo.fail("请求体中未找到文件"));
    }
    if (bucket == null) {
      return httpResponse.fail(RespBodyVo.fail("存储桶名称不能为空"));
    }
    if (category == null) {
      return httpResponse.fail(RespBodyVo.fail("文件分类不能为空"));
    }
    SystemFileService systemFileService = Aop.get(SystemFileService.class);
    UploadResultVo vo = systemFileService.upload(uploadFile, bucket, category);
    return httpResponse.setJson(vo);
  }

  /**
   * 处理获取文件 URL 的请求
   *
   * @param request HTTP 请求
   * @return HttpResponse 响应
   * @throws Exception 异常
   */
  public HttpResponse getUrl(HttpRequest request) throws Exception {
    HttpResponse httpResponse = TioRequestContext.getResponse();
    CORSUtils.enableCORS(httpResponse, new HttpCors());

    SystemFileService systemFileService = Aop.get(SystemFileService.class);

    RespBodyVo respBodyVo = null;
    Long id = request.getLong("id");
    String md5 = request.getParam("md5");
    String bucket = request.getParam("bucket");
    if (id != null && id > 0) {
      // 根据 ID 获取文件信息
      UploadResultVo uploadResultVo = systemFileService.getUrlById(id);
      if (uploadResultVo == null) {
        respBodyVo = RespBodyVo.fail();
      } else {
        respBodyVo = RespBodyVo.ok(uploadResultVo);
      }

    } else if (StrKit.notBlank(md5)) {
      // 根据 MD5 获取文件信息
      UploadResultVo uploadResultVo = systemFileService.getUrlByMd5(bucket, md5);
      if (uploadResultVo == null) {
        respBodyVo = RespBodyVo.fail();
      } else {
        respBodyVo = RespBodyVo.ok(uploadResultVo);
      }
    } else {
      respBodyVo = RespBodyVo.fail("id 或 md5 不能为空");
    }

    return Resps.json(httpResponse, respBodyVo);
  }

}

功能说明:

  • 文件上传接口 (/api/system/file/upload):
    • CORS 支持:启用跨域资源共享(CORS)。
    • 参数校验:检查请求中是否包含文件、存储桶名称和文件分类。
    • 调用业务层:调用 SystemFileService 的 upload 方法处理文件上传。
    • 响应结果:返回文件上传结果的 JSON 数据。
  • 获取文件 URL 接口 (/api/system/file/url):
    • CORS 支持:启用跨域资源共享(CORS)。
    • 参数校验:根据请求参数 id 或 md5 获取文件信息。
    • 调用业务层:调用 SystemFileService 的 getUrlById 或 getUrlByMd5 方法获取文件的 URL。
    • 响应结果:返回文件信息的 JSON 数据。

文件上传文档

1. 客户端生成文件的 MD5 值

在文件上传之前,客户端需要生成文件的 MD5 值。该值用于识别文件是否已经上传,以避免重复上传。

2. 检查文件是否已上传

通过以下 API 接口,客户端可以根据文件的 MD5 值查询文件是否已经存在于系统中:

  • 请求方式: GET
  • URL: http://localhost:8123/api/system/file/url?md5=76b503588b76c3236f5741a053f1e6bb&bucket=channel_001

示例响应:

{
  "data": {
    "id": "439681354499067904",
    "md5": "76b503588b76c3236f5741a053f1e6bb",
    "filename": "200-dpi.png",
    "url": "http://localhost:8123/channel_001/images/439681354499067904.png"
  },
  "ok": true,
  "msg": null,
  "code": 1
}
  • 说明: 如果文件已存在,响应会包含文件的 id、url、filename 等信息,客户端即可使用该文件的链接,无需重新上传。

3. 上传文件

如果文件不存在,客户端需执行上传操作,将文件发送至服务器。

  • 请求方式: POST
  • URL: http://localhost:8123/api/system/file/upload

请求参数:

--form 'file=@"C:\\Users\\Administrator\\Pictures\\200-dpi.png"' \
--form 'bucket="channel_001"' \
--form 'category="images"'

示例响应:

{
  "id": "439679344561782784",
  "url": "http://localhost:8123/channel_001/images/439679344561782784.png",
  "filename": "200-dpi.png",
  "md5": "76b503588b76c3236f5741a053f1e6bb"
}
  • 说明: 成功上传后,系统返回该文件的 id、url、filename 及 MD5 值等信息。

4. 将文件信息入库

文件上传成功后,客户端应将以下信息存入数据库,以便于后续管理和查询:

  • id: 文件的唯一标识符
  • md5: 文件的 MD5 值
  • bucket: 文件所在的存储分区(例如 channel_001)
  • category: 文件的分类(例如 images)
  • filename: 文件名

完整流程总结

  1. 生成文件 MD5 值 - 客户端生成文件的 MD5 值。
  2. 检查文件是否存在 - 调用检查接口,通过 MD5 值判断文件是否已上传。
  3. 上传文件 - 若文件不存在,则调用上传接口上传文件。
  4. 文件信息入库 - 上传成功后,客户端将文件的详细信息入库。

关键配置说明

server.resources.static-locations=pages

该配置项指定了服务器静态资源的存储位置为项目根目录下的 pages 文件夹。

作用与优势:

  • 静态资源服务:通过配置 server.resources.static-locations=pages,服务器能够自动将 pages 目录下的文件作为静态资源进行服务。这样,存储在 pages 目录中的文件(如图片、CSS、JavaScript 文件等)可以通过 URL 直接访问,无需额外的处理。

  • 组织结构清晰:将静态文件统一存储在 pages 目录下,有助于项目结构的清晰与管理。

  • 简化访问路径:用户可以通过简单的 URL 直接访问静态资源,例如 http://localhost:8123/channel_001/images/439679344561782784.png。

注意事项:

  • 确保 pages 目录具有适当的读写权限,服务器进程能够访问和修改该目录中的文件。
  • 根据实际需求,可以调整 static-locations 的值,以适应不同的项目结构和部署环境。

Path path = Paths.get("pages", bucketName, category);

该代码行用于生成文件存储的路径,确保文件按照存储桶名称和分类进行组织。

作用与优势:

  • 动态路径生成:通过 Paths.get("pages", bucketName, category),根据传入的 bucketName 和 category 动态生成文件存储路径。例如,对于 bucketName 为 channel_001,category 为 images,生成的路径为 pages/channel_001/images。

  • 组织有序:将文件按照存储桶和分类进行组织,有助于文件的管理和检索。不同存储桶可以代表不同的业务模块或用户群体,分类则可以进一步细分文件类型或用途。

  • 避免命名冲突:通过将文件存储在不同的目录下,可以有效避免文件名冲突。例如,不同存储桶下可以存在相同文件名的文件,而不会互相覆盖。

注意事项:

  • 目录创建:在上传文件前,需确保目标目录存在。代码中已使用 Files.createDirectories(path) 创建必要的目录结构,如果目录已存在,该方法不会抛出异常。
  • 路径安全:确保 bucketName 和 category 的值经过验证,避免路径遍历等安全风险。

总结

通过以上步骤,您可以在 Tio-boot 应用中成功实现本地文件存储功能。这不仅包括文件的上传和存储,还涵盖了文件的查询和访问。关键配置如 server.resources.static-locations=pages 确保了静态资源的正确服务,而 Path path = Paths.get("pages", bucketName, category); 则提供了灵活且有序的文件存储路径生成机制。

建议:

  • 安全性:确保文件上传功能具备必要的安全措施,如文件类型验证、大小限制、防止恶意文件上传等。
  • 性能优化:对于大文件或高并发上传场景,考虑使用异步处理或分片上传技术,以提升系统性能和用户体验。
  • 备份与恢复:定期备份存储的文件,确保在意外情况下能够快速恢复数据。
  • 监控与日志:监控文件上传和访问的日志,及时发现和处理异常情况,保障系统的稳定运行。

通过合理的配置和优化,本地存储功能将为您的 Tio-boot 应用提供强大的文件管理支持,提升系统的整体功能性和用户体验。

Edit this page
Last Updated: 5/31/2025, 5:46:12 AM
Contributors: Tong Li
Prev
文件上传数据表
Next
使用 AWS S3 存储文件并整合到 Tio-Boot 项目中