.NET CORE Aws S3 使用

1.安装指定的包

　Install-Package AWSSDK.S3 -Version 3.3.104.10

2.使用帮助类

using System;
using System.Collections.Generic;
using System.Text;
using Amazon;
using Amazon.Runtime;
using Amazon.S3;
using Amazon.S3.Model;
using System.IO;
using System.Threading.Tasks;namespace xx.xx.xx.Helper
{public class AwsS3Helper{/// <summary>/// 地区是亚太香港/// </summary>readonly RegionEndpoint bucketRegion = RegionEndpoint.GetBySystemName("xx");/// <summary>/// 要向 Amazon S3 上传数据(照片、视频、文档等)，/// 您必须首先在其中一个 AWS 区域中创建 S3 存储桶, 比如：在亚太香港地址，创建了一个gfbk桶/// 然后，您可以将任何数量的对象上传到该存储桶。/// 每个 AWS 账户中创建多达 100 个存储桶，一个存储桶中可以存储任意数量的对象。/// 资料：https://docs.aws.amazon.com/zh_cn/AmazonS3/latest/dev/UsingBucket.html/// </summary>readonly string bucketName = Appsettings.GetNode("AwsBucketName");/// <summary>/// 请求S3的凭据/// </summary>readonly AWSCredentials awsCredentials = new BasicAWSCredentials(Appsettings.GetNode("AwsAccessKey"), Appsettings.GetNode("AwsSecretKey"));/// <summary>/// 请求客户端/// </summary>AmazonS3Client client = null;/// <summary>/// 上传资源类型/// </summary>ResourceType _resourceType;public AwsS3Helper(ResourceType resourceType){_resourceType = resourceType;client = new AmazonS3Client(awsCredentials, bucketRegion);}/// <summary>///创建一个桶/// </summary>/// <returns></returns>public async Task CreateBucket(){var putBucketRequest = new PutBucketRequest{BucketName = bucketName,UseClientRegion = true};PutBucketResponse putBucketResponse = await client.PutBucketAsync(putBucketRequest);string bucketLocation = await FindBucketLocationAsync(client);}/// <summary>/// 查找桶所在的地区/// </summary>/// <param name="client"></param>/// <returns></returns>private async Task<string> FindBucketLocationAsync(IAmazonS3 client){string bucketLocation;var request = new GetBucketLocationRequest(){BucketName = bucketName};GetBucketLocationResponse response = await client.GetBucketLocationAsync(request);bucketLocation = response.Location.ToString();return bucketLocation;}/// <summary>/// 上传文件/// </summary>/// <param name="uploadFilePath">上传的文件地址如:E:\test.jpg</param>/// <returns></returns>public async Task<bool> WritingAnObjectAsync(string uploadFilePath){try{string filename = uploadFilePath.Substring(uploadFilePath.LastIndexOf('\\') + 1);string key = string.Format("resource/img/{0}/{1}", _resourceType.ToString().Replace("Img", ""), filename);var putRequest2 = new PutObjectRequest{BucketName = bucketName,//获取和设置键属性。此键用于标识S3中的对象,上传到s3的路径+文件名，//S3上没有文件夹可以创建一个，参考https://www.cnblogs.com/web424/p/6840207.htmlKey = key,//所有者获得完全控制权，匿名主体被授予读访问权。如果//此策略用于对象，它可以从浏览器中读取，无需验证CannedACL = S3CannedACL.PublicRead,//上传的文件路径FilePath = uploadFilePath,//为对象设置的标记。标记集必须编码为URL查询参数TagSet = new List<Tag>{new Tag { Key = "Test", Value = "S3Test"} }//ContentType = "image/png"};putRequest2.Metadata.Add("x-amz-meta-title", "AwsS3Net");PutObjectResponse response2 = await client.PutObjectAsync(putRequest2);return true;}catch (AmazonS3Exception e){throw new Exception(string.Format("Error encountered ***. Message:'{0}' when writing an object", e.Message));}catch (Exception e){throw new Exception(string.Format("Unknown encountered on server. Message:'{0}' when writing an object", e.Message));}}/// <summary>/// 上传文件 (未经测试)/// </summary>/// <param name="inputStream">以流的形式</param>/// <returns></returns>public async Task<bool> WritingAnObjectByStreamAsync(Stream inputStream, string key, string contenttype){//string key = string.Format("resource/img/{0}/{1}", _resourceType.ToString().Replace("Img", ""), filename);try{var putRequest1 = new PutObjectRequest{BucketName = bucketName,//创建对象时，要指定键名，它在存储桶中唯一地标识该对象Key = key,CannedACL = S3CannedACL.PublicRead,//放开存储InputStream = inputStream,ContentType = contenttype};PutObjectResponse response1 = await client.PutObjectAsync(putRequest1);return true;}catch (AmazonS3Exception e){throw new Exception(string.Format("Error encountered ***. Message:'{0}' when writing an object", e.Message));}catch (Exception e){throw new Exception(string.Format("Unknown encountered on server. Message:'{0}' when writing an object", e.Message));}}/// <summary>/// 删除一个对象/// </summary>/// <param name="key">删除的对象的键如:resource/img/basketballnews/test1.jpg</param>/// <returns></returns>public async Task<bool> DeleteAnObjectAsync(string key){try{// 1. Delete object-specify only key name for the object.var deleteRequest1 = new DeleteObjectRequest{BucketName = bucketName,Key = key};DeleteObjectResponse response1 = await client.DeleteObjectAsync(deleteRequest1);return true;}catch (AmazonS3Exception e){throw new Exception(string.Format("Error encountered ***. Message:'{0}' when writing an object", e.Message));}catch (Exception e){throw new Exception(string.Format("Unknown encountered on server. Message:'{0}' when writing an object", e.Message));}}/// <summary>/// 获取/// </summary>/// <param name="prefix">限制对以指定前缀开头的键的响应</param>/// <returns></returns>public async Task<List<S3Object>> ListObjectsAsync(string prefix = ""){try{var list = new ListObjectsRequest{BucketName = bucketName,Prefix = prefix};ListObjectsResponse response1 = await client.ListObjectsAsync(list);return response1.S3Objects;}catch (AmazonS3Exception e){throw new Exception(string.Format("Error encountered ***. Message:'{0}' when writing an object", e.Message));}catch (Exception e){throw new Exception(string.Format("Unknown encountered on server. Message:'{0}' when writing an object", e.Message));}}}public enum ResourceType{xx,xx,xx,xx,xx,xx,xx,xx}
}

3.接口请求

 [HttpPost][Route("uploadfils")]public async Task<ActionResult<Result>> UploadFiles(List<IFormFile> files, [FromQuery] int type, string filetype){var rtype = new ResourceType();AwsS3Helper awss3 = new AwsS3Helper(rtype);try{if (files == null && files.Count == 0){return ApiResultHelper.renderError("未选择上传的文件！");}foreach (var file in files){if (file.Length > 0){using (var stream = file.OpenReadStream()){var fileName = ContentDispositionHeaderValue.Parse(file.ContentDisposition).FileName.Trim('"');//拼接地址string key = string.Format("resource/{0}/{1}/{2}", filetype, "xx", fileName);var result = await awss3.WritingAnObjectByStreamAsync(stream, key, file.ContentType);}}}return ApiResultHelper.renderSuccess();}catch (Exception e){return ApiResultHelper.renderError();}}/// <summary>/// 删除aws s3数据/// </summary>/// <param name="key"></param>/// <returns></returns>[HttpPost][Route("deletefiles")]public async Task<ActionResult<Result>> DeleteFiles(string key){var rtype = new ResourceType();AwsS3Helper awss3 = new AwsS3Helper(rtype);try{if (!string.IsNullOrEmpty(key)){var result = await awss3.DeleteAnObjectAsync(key);if (result){return ApiResultHelper.renderSuccess(true);}}return ApiResultHelper.renderError();}catch (Exception e){return ApiResultHelper.renderError();}}