Bitzsoft.Integrations.CloudDrive.Aliyun 1.0.0-alpha.10

Bitzsoft.Integrations.CloudDrive.Aliyun

阿里云网盘与相册服务（PDS）实现，基于 PDS v2 API。

功能特性

• 基于阿里云网盘与相册服务（PDS）v2 API
• OAuth 2.0 认证：Bearer Token，支持 RefreshToken 自动刷新（提前 5 分钟刷新，401 自动重试）
• 文件操作：上传（含秒传）、下载、删除、移动、复制、获取信息
• 文件夹操作：列表（marker 分页）、创建、删除
• 文件搜索：支持关键词搜索、类型筛选、扩展名筛选
• 分享链接：创建分享链接（支持密码和过期时间）、取消分享链接

安装

.NET CLI

dotnet add package Bitzsoft.Integrations.CloudDrive.Aliyun

PackageReference

<PackageReference Include="Bitzsoft.Integrations.CloudDrive.Aliyun" Version="1.0.0" />

配置

appsettings.json

{
  "CloudDrive": {
    "Aliyun": {
      "AccessToken": "初始访问令牌（可选）",
      "RefreshToken": "刷新令牌（必须）",
      "ClientId": "应用 Client ID",
      "ClientSecret": "应用 Client Secret",
      "DomainId": "PDS 实例域名 ID",
      "DriveId": "默认网盘 ID",
      "BaseUrl": "https://{domainId}.api.aliyunpds.com",
      "HttpClientName": "AliyunCloudDrive",
      "LargeFileThreshold": 104857600,
      "ChunkSize": 104857600
    }
  }
}

注册服务

从 IConfiguration 绑定（推荐）

using Bitzsoft.Integrations.CloudDrive.Aliyun;

builder.Services.AddBitzsoftAliyunCloudDrive(
    builder.Configuration.GetSection("CloudDrive:Aliyun"));

委托配置

builder.Services.AddBitzsoftAliyunCloudDrive(options =>
{
    options.RefreshToken = "your-refresh-token";
    options.ClientId = "your-client-id";
    options.ClientSecret = "your-client-secret";
    options.DomainId = "your-domain-id";
    options.DriveId = "your-drive-id";
});

使用示例

using Bitzsoft.Integrations.CloudDrive.Interfaces;
using Bitzsoft.Integrations.CloudDrive.Models;

public class MyService
{
    private readonly ICloudDriveProvider _drive;

    public MyService(ICloudDriveProvider drive) => _drive = drive;

    public async Task UploadAndListAsync()
    {
        // 上传文件（支持秒传）
        await using var stream = File.OpenRead("report.pdf");
        var upload = await _drive.UploadAsync(new UploadFileRequest
        {
            FolderId = "root",
            FileName = "report.pdf",
            Content = stream,
            ContentType = "application/pdf"
        });

        // 列出文件夹内容（marker 分页）
        var files = await _drive.ListFilesAsync("root");
        foreach (var file in files.Items)
        {
            Console.WriteLine($"{file.Name} ({file.Size} bytes)");
        }

        // 下载文件
        var download = await _drive.DownloadAsync(upload.FileInfo.Id);

        // 搜索文件
        var results = await _drive.SearchAsync(new SearchFilesRequest
        {
            Keyword = "report",
            FileType = DriveFileType.File
        });

        // 创建分享链接（支持密码和过期时间）
        var link = await _drive.CreateShareLinkAsync(new CreateShareLinkRequest
        {
            FileId = upload.FileInfo.Id,
            Password = "1234",
            ExpireTime = DateTime.UtcNow.AddDays(7)
        });
        Console.WriteLine($"分享链接已创建");
    }
}

核心类型一览

上传流程

1. POST /v2/file/create -- 创建文件记录，获取预签名上传 URL 和 upload_id
2. 若 rapid_upload=true，文件已存在（秒传/去重），跳过后续步骤
3. PUT {upload_url} -- 将文件内容上传到预签名 URL
4. POST /v2/file/complete -- 完成上传

实现状态

请求审计

内置 Bitzsoft.Integrations.RequestLogging 出站请求记录管道，默认 NullRequestLogStore 不持久化。

// ① 默认：启用记录管道但不持久化（日志丢弃）
services.AddBitzsoftAliyunCloudDrive(options => { /* ... */ });

// ② 持久化：宿主注册 IRequestLogStore 实现后，所有出站请求自动落库
services.AddRequestLogging<MyRequestLogStore>(opts =>
{
    opts.MaxInMemoryBodyBytes = 64 * 1024; // 仅控制内存/加密临时文件切换，不截断正文
    opts.SensitiveFields.Add("mySecret"); // 额外脱敏字段
});
services.AddBitzsoftAliyunCloudDrive(options => { /* ... */ });

注意事项

• 阿里云 PDS API 所有文件操作均使用 HTTP POST + JSON body
• 文件 ID root 表示根目录
• 令牌过期后自动使用 RefreshToken 刷新，提前 5 分钟刷新避免边界情况
• 401 响应自动触发令牌刷新并重试请求

依赖

相关包

• Bitzsoft.Integrations.CloudDrive -- 抽象层
• Bitzsoft.Integrations.CloudDrive.All -- 聚合包（一键注册全部供应商）
• Bitzsoft.Integrations.CloudDrive.Nutstore -- 坚果云
• Bitzsoft.Integrations.CloudDrive.Microsoft365 -- Microsoft 365 / OneDrive
• Bitzsoft.Integrations.CloudDrive.Gokuai -- 够快云库
• Bitzsoft.Integrations.CloudDrive.AnyShare -- 爱数 AnyShare
• Bitzsoft.Integrations.CloudDrive.Baidu -- 百度网盘
• Bitzsoft.Integrations.Compatibility -- 基础工具库