MoneyTree.Storage 文件存储

📋 概述

MoneyTree.Storage 提供统一的文件存储抽象层，屏蔽底层云服务商差异。开发者通过 IFileStorage 接口操作文件，支持本地磁盘、MinIO、阿里云 OSS、腾讯云 COS 和七牛云等多种后端，切换提供者只需改配置无需改代码。

📦 包体系结构

MoneyTree.Storage                            ← 核心包：IFileStorage 接口 + 本地存储
    ├── MoneyTree.Storage.Minio              ← 扩展包：MinIO 对象存储
    ├── MoneyTree.Storage.AliyunOss          ← 扩展包：阿里云 OSS
    ├── MoneyTree.Storage.TencentCos         ← 扩展包：腾讯云 COS
    └── MoneyTree.Storage.Qiniu              ← 扩展包：七牛云存储

🏗️ 项目文件结构

MoneyTree.Storage/
├── MoneyTree.Storage.csproj
├── GlobalUsings.cs
├── Abstractions/
│   └── IFileStorage.cs                     # 统一文件存储接口
├── Core/
│   ├── FileStorageOptions.cs               # 全局配置选项
│   └── FileMetadata.cs                     # 文件元数据模型
├── Providers/
│   └── LocalFileStorage.cs                 # 本地磁盘存储
└── Extensions/
    ├── StorageBuilder.cs                   # 流畅配置构造器
    └── StorageExtensions.cs                # DI 注册扩展

🎯 设计原则

🚀 快速开始

本地存储（开发环境）

// Program.cs
using MoneyTree.Storage.Extensions;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddMoneyTreeStorage(s => s.UseLocal("./uploads"));

MinIO 存储

builder.Services.AddMoneyTreeStorage(s =>
{
    s.UseMinio(
        endpoint: "minio.example.com:9000",
        accessKey: "your-key",
        secretKey: "your-secret",
        bucketName: "myapp",
        useSsl: true);
});

阿里云 OSS

builder.Services.AddMoneyTreeStorage(s =>
{
    s.UseAliyunOss(
        endpoint: "oss-cn-hangzhou.aliyuncs.com",
        accessKeyId: "your-ak",
        accessKeySecret: "your-sk",
        bucketName: "my-bucket");
});

腾讯云 COS

builder.Services.AddMoneyTreeStorage(s =>
{
    s.UseTencentCos(
        region: "ap-guangzhou",
        secretId: "your-secret-id",
        secretKey: "your-secret-key",
        bucketName: "my-bucket");
});

七牛云

builder.Services.AddMoneyTreeStorage(s =>
{
    s.UseQiniu(
        accessKey: "your-ak",
        secretKey: "your-sk",
        bucketName: "my-bucket",
        baseUrl: "https://cdn.example.com");
});

📖 使用示例

文件上传

public class AvatarService
{
    private readonly IFileStorage _storage;

    public AvatarService(IFileStorage storage)
    {
        _storage = storage;
    }

    public async Task<string> UploadAvatarAsync(string userId, Stream image)
    {
        var key = $"avatars/{userId}.jpg";
        var metadata = await _storage.UploadAsync(key, image, "image/jpeg");
        return await _storage.GetPublicUrlAsync(key);
    }
}

文件下载终结点

app.MapGet("/api/files/{**key}", async (string key, IFileStorage storage) =>
{
    var stream = await storage.DownloadAsync(key);
    if (stream is null) return Results.NotFound();

    var metadata = await storage.GetMetadataAsync(key);
    return Results.File(stream, metadata?.ContentType ?? "application/octet-stream");
});

文件删除和列表

// 删除文件
await _storage.DeleteAsync("avatars/user-001.jpg");

// 列出目录下的所有文件
var files = await _storage.ListAsync("avatars/");

// 获取文件元数据
var metadata = await _storage.GetMetadataAsync("reports/monthly.xlsx");

📋 IFileStorage 接口说明

📊 FileMetadata 元数据模型

🔌 存储后端对比