.NET或.NETCoreWebAPi基于tus协议实现断点续传的示例

private DefaultTusConfiguration CreateTusConfiguration(IServiceProvider serviceProvider)
{
  var env = (IWebHostEnvironment)serviceProvider.GetRequiredService(typeof(IWebHostEnvironment));

  //文件上传路径
  var tusFiles = Path.Combine(env.WebRootPath, "tusfiles");

  return new DefaultTusConfiguration
  {
    UrlPath = "/files",
    //文件存储路径
    Store = new TusDiskStore(tusFiles),
    //元数据是否允许空值
    MetadataParsingStrategy = MetadataParsingStrategy.AllowEmptyValues,
    //文件过期后不再更新
    Expiration = new AbsoluteExpiration(TimeSpan.FromMinutes(5)),
    //事件处理（各种事件，满足你所需）
    Events = new Events
    {
      //上传完成事件回调
      OnFileCompleteAsync= async ctx =>
      {
        //获取上传文件
        var file = await ctx.GetFileAsync();

        //获取上传文件元数据
        var metadatas = await file.GetMetadataAsync(ctx.CancellationToken);
        
        //获取上述文件元数据中的目标文件名称
        var fileNameMetadata = metadatas["name"];

        //目标文件名以base64编码，所以这里需要解码
        var fileName = fileNameMetadata.GetString(Encoding.UTF8);

        var extensiOnName= Path.GetExtension(fileName);

        //将上传文件转换为实际目标文件
        File.Move(Path.Combine(tusFiles, ctx.FileId), Path.Combine(tusFiles, $"{ctx.FileId}{extensionName}"));
      }
    }
  };
}

app.UseTus(httpCOntext=> Task.FromResult(httpContext.RequestServices.GetService()));

endpoints.MapGet("/files/{fileId}", DownloadFileEndpoint.HandleRoute);

public static class DownloadFileEndpoint
{
  public static async Task HandleRoute(HttpContext context)
  {
    var cOnfig= context.RequestServices.GetRequiredService();

    if (!(config.Store is ITusReadableStore store))
    {
      return;
    }

    var fileId = (string)context.Request.RouteValues["fileId"];
    var file = await store.GetFileAsync(fileId, context.RequestAborted);

    if (file == null)
    {
      context.Response.StatusCode = 404;
      await context.Response.WriteAsync($"File with id {fileId} was not found.", context.RequestAborted);
      return;
    }

    var fileStream = await file.GetContentAsync(context.RequestAborted);
    var metadata = await file.GetMetadataAsync(context.RequestAborted);

    context.Response.COntentType= GetContentTypeOrDefault(metadata);
    context.Response.COntentLength= fileStream.Length;

    if (metadata.TryGetValue("name", out var nameMeta))
    {
      context.Response.Headers.Add("Content-Disposition",
        new[] { $"attachment; filename=\"{nameMeta.GetString(Encoding.UTF8)}\"" });
    }

    using (fileStream)
    {
      await fileStream.CopyToAsync(context.Response.Body, 81920, context.RequestAborted);
    }
  }

  private static string GetContentTypeOrDefault(Dictionary metadata)
  {
    if (metadata.TryGetValue("contentType", out var contentType))
    {
      return contentType.GetString(Encoding.UTF8);
    }

    return "application/octet-stream";
  }
}

 
  
   //若不配置，默认是28.6兆
   
  
 

services.Configure(optiOns=>
 {
   options.MaxRequestBodySize = int.MaxValue;
 });

services.Configure(optiOns=>
{
   //若不配置，默认是30兆（没记错的话）
   options.Limits.MaxRequestBodySize = int.MaxValue; 
});

services.Configure(x =>
{
   x.ValueLengthLimit = int.MaxValue;
  //如果不配置，默认是128兆（没记错的话）
   x.MultipartBodyLengthLimit = int.MaxValue; 
   x.MultipartHeadersLengthLimit = int.MaxValue;
});