.NET6 WebApi 大文件上传——分片上传

当前位置：网站建设 > 技术支持

.NET6 WebApi 大文件上传——分片上传

资料来源：网络整理时间：2023/2/14 1:05:36 共计：3638 浏览

本文章向大家介绍.NET6 WebApi 大文件上传——分片上传，主要包括.NET6 WebApi 大文件上传——分片上传使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。

最近遇到大文件上传问题，网上参考后写的小DEMO

WebApi代码

using Microsoft.AspNetCore.Cors;

using Microsoft.AspNetCore.Mvc;

using Microsoft.AspNetCore.WebUtilities;

using Microsoft.Net.Http.Headers;

using Polly;

using UploadFile.Models;

namespace UploadFile.Controllers

{

[ApiController]

[Route("[controller]/[action]")]

public class UploadController : ControllerBase

{

[EnableCors("AllowSpecificOrigin")]

[HttpPost]

public async Task<IActionResult> RuleUploadFile([FromQuery] SliceFileInfo file)

{

try

{

string path = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Upload");

var files = Request.Form.Files;

var buffer = new byte[file.Size];

var fileName = file.Name;

path = path + "//" + fileName + "//";

if (!System.IO.Directory.Exists(path))

{

System.IO.Directory.CreateDirectory(path);

}

string filepath = path + "//" + file.Name + "^" + file.Number;

using (var stream = new FileStream(filepath, FileMode.Append))

{

await files[0].CopyToAsync(stream);

}

var filesList = Directory.GetFiles(Path.GetDirectoryName(path));

//当顺序号等于分片总数量合并文件

if ((file.Number + 1) == file.Count || filesList.Length == file.Count)

{

await MergeFile(file);

}

return this.Ok();

}

catch (Exception ex)

{

return BadRequest(ex.Message);

}

/// <summary>

/// 合并文件

/// </summary>

/// <param name="file"></param>

/// <returns></returns>

private async Task MergeFile(SliceFileInfo file)

{

string path = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Upload");

var fileName = file.Name;

path = path + "//" + fileName + "//";

string baseFileName = path + fileName.Split("~")[0].ToString();

if (!System.IO.Directory.Exists(path))

{

System.IO.Directory.CreateDirectory(path);

}

var filesList = Directory.GetFiles(Path.GetDirectoryName(path));

if (filesList.Length != file.Count)

{

return;

}

List<FileSort> lstFile = new List<FileSort>();

foreach (var item in filesList)

{

lstFile.Add(new FileSort()

{

Name = item,

NumBer = Convert.ToInt32(item.Substring(item.IndexOf('^') + 1))

});

}

lstFile = lstFile.OrderBy(x => x.NumBer).ToList();

using (var fileStream = new FileStream(baseFileName, FileMode.Create))

{

//foreach (var fileSort in filesList)

//{

// using (FileStream fileChunk = new FileStream(fileSort, FileMode.Open))

// {

// await fileChunk.CopyToAsync(fileStream);

// }

//}

await Policy.Handle<IOException>()

.RetryForeverAsync()

.ExecuteAsync(async () =>

{

foreach (var fileSort in lstFile)

{

using (FileStream fileChunk = new FileStream(fileSort.Name, FileMode.Open))

{

await fileChunk.CopyToAsync(fileStream);

}

});

}

//删除分片文件

foreach (var dirfile in filesList)

{

System.IO.File.Delete(dirfile);

}

Program配置跨域

using Microsoft.AspNetCore.Http.Features;

using Microsoft.AspNetCore.Server.Kestrel.Core;

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.

builder.Services.AddControllers();

// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle

builder.Services.AddEndpointsApiExplorer();

builder.Services.AddSwaggerGen();

builder.Services.AddCors(options =>

{

options.AddPolicy("AllowSpecificOrigin", cors =>

{

cors.AllowAnyOrigin();

cors.AllowAnyHeader();

//cors.AllowAnyMethod();

});

builder.Services.Configure<FormOptions>(options =>

{

options.KeyLengthLimit = int.MaxValue;

options.ValueLengthLimit = int.MaxValue;

options.MultipartBodyLengthLimit = int.MaxValue;

options.MultipartHeadersLengthLimit = int.MaxValue;

});

builder.Services.Configure<KestrelServerOptions>(options =>

{

options.Limits.MaxRequestBodySize = int.MaxValue;

options.Limits.MaxRequestBufferSize = int.MaxValue;

});

var app = builder.Build();

// Configure the HTTP request pipeline.

if (app.Environment.IsDevelopment())

{

app.UseSwagger();

app.UseSwaggerUI();

}

app.UseCors("AllowSpecificOrigin");

app.UseAuthorization();

app.MapControllers();

app.Run();

前台VUE

<!DOCTYPE html>

<html>

<head>

</head>

<body>

</div>

var obj = {

data() {

return {

Title: "上传文件",

file: {},

};

methods: {

handleFileChange(e) {

let inputDOM = this.$refs.inputer;

this.file = inputDOM.files[0];// 通过DOM取文件数据

loadfile() {

let size = Math.floor(this.file.size / 1024);//计算文件的大小

let formData = new FormData();//new一个formData事件

formData.append("files", this.file); //将file属性添加到formData里

debugger;

fetch("http://localhost:5128/Upload/RuleUploadFile", {

method: 'post',

body: formData,

headers: {

/*"Content-Type": "multipart/form-data;",*/

}

}).then(r => r.json()).then(r => {

console.log(r);

}).catch(e => {

console.log(e);

})

S4() {

return (((1 + Math.random()) * 0x10000) | 0).toString(16).substring(1);

guid() {

return (this.S4() + this.S4() + "-" + this.S4() + "-" + this.S4() + "-" + this.S4() + "-" + this.S4() + this.S4() + this.S4());

load() {

let size = this.file.size;//文件大小

let maxZrea = 8; //设置每个分区大小 MB

let bufferSize = maxZrea * (1024 * 1024);

let fileStart = 0;

let fileEnd = bufferSize;

let arrFile = [];

while (fileStart < size) {

var fileInfo = {

File: this.file.slice(fileStart, fileEnd),

Start: fileStart,

End: fileEnd

}

arrFile.push(fileInfo);

fileStart = fileEnd;

fileEnd = fileStart + bufferSize;

}

let count = arrFile.length;

let filename = this.file.name + "~" + this.guid();

for (var i = 0; i < count; i++) {

let formData = new FormData();//new一个formData事件

formData.append("file", arrFile[i].File); //将file属性添加到formData里

var url = "http://localhost:5128/Upload/RuleUploadFile?Name=" + filename + "&Number=" + i + "&BufferSize=" + bufferSize + "&Count=" + count + "&Start=" + arrFile[i].Start + "&End=" + arrFile[i].End + "&Size=" + size;

/*var url = "http://192.168.0.166:8080/Upload/RuleUploadFile?Name=" + filename + "&Number=" + i + "&BufferSize=" + bufferSize + "&Count=" + count + "&Start=" + arrFile[i].Start + "&End=" + arrFile[i].End + "&Size=" + size;*/

//fetch(url, {

// method: 'post',

// body: formData,

// headers: {

// /*"Content-Type": "multipart/form-data;",*/

// }

//}).then(r => r.json()).then(r => {

// console.log(r);

//}).catch(e => {

// console.log(e);

//})

axios.post(url, formData, {

headers: {

"Content-Type": "multipart/form-data;",

}

}).then(r => {

console.log(r);

}).catch(e => {

console.log(e);

});

}

};

var vm = Vue.createApp(obj).mount("#app");

</script>

</body>

</html>

实测1G文件本地开发环境上传速度在20秒左右，网络环境没有测试过

原文地址：https://www.cnblogs.com/lyzi/p/16008776.html

版权说明：
本网站凡注明“广州京杭原创”的皆为本站原创文章，如需转载请注明出处！
本网转载皆注明出处，遵循行业规范，如发现作品内容版权或其它问题的，请与我们联系处理！
欢迎扫描右侧微信二维码与我们联系。

·上一条：WebApi接口访问频率控制的实现 | ·下一条：C# WebClient实现文件上传