Azure Storage 系列（二） .NET Core Web 项目中操作 Blob 存储

 1 [Route("Blobs")]
 2     public class BlobExplorerController : Controller
 3     {
 4         private readonly IBlobSergvice _blobService;
 5 
 6         public BlobExplorerController(IBlobSergvice blobService)
 7         {
 8             this._blobService = blobService;
 9         }
10 
11         [HttpGet("{BlobName}")]
12         public async Task GetBlob(string blobName)
13         {
14             var data = await _blobService.GetBlobAsync(blobName);
15             return File(data.Content, data.ContentType);
16         }
17 
18         [HttpGet("BlobsName")]
19         public async Task ListBlobsName()
20         {
21             return Ok(await _blobService.ListBlobsNameAsync());
22         }
23 
24         [HttpPost("UploadFile")]
25         public async Task UpLoadFile([FromBody] UploadFileRequest request)
26         {
27             await _blobService.UploadFileBlobAsync(request.FilePath, request.FileName);
28             return Ok();
29         }
30 
31         [HttpPost("UploadContent")]
32         public async Task UploadContent([FromBody] UpLoadContentRequest request)
33         {
34             await _blobService.UploadContentBlobAsync(request.Content, request.FileName);
35             return Ok();
36         }
37 
38         [HttpDelete("{BlobName}")]
39         public async Task DaleteFile(string blobName)
40         {
41             await _blobService.DeleteBlobAsync(blobName);
42             return Ok();
43         }
44     }

public interface IBlobSergvice
    {
        Task GetBlobAsync(string name);

        Taskstring>> ListBlobsNameAsync();

        Task UploadFileBlobAsync(string filePath, string filename);

        Task UploadContentBlobAsync(string content, string filename);

        Task DeleteBlobAsync(string blobName);

    }

 1 public class BlobService : IBlobSergvice
 2     {
 3         private readonly BlobServiceClient _blobServiceClient;
 4 
 5         public BlobService(BlobServiceClient blobServiceClient)
 6         {
 7             this._blobServiceClient = blobServiceClient;
 8         }
 9 
10         #region 01，获取Blob,根据blob名称+async Task GetBlobAsync(string name)
11         /// 

12         /// 获取Blob,根据blob名称
13         /// 
14         /// blob名称
15         /// 
16         public async Task GetBlobAsync(string name)
17         {
18             var containerClient = _blobServiceClient.GetBlobContainerClient("picturecontainer");
19 
20             var blobClient = containerClient.GetBlobClient(name);
21             var blobDownLoadInfo = await blobClient.DownloadAsync();
22             return new Azure.Storage.Models.BlobInfo(blobDownLoadInfo.Value.Content, blobDownLoadInfo.Value.ContentType);
23         }
24         #endregion
25 
26         #region 02，获取所有Blob名称+async Task> ListBlobsNameAsync()
27         /// 

28         /// 获取所有Blob名称
29         /// 
30         /// 
31         public async Taskstring>> ListBlobsNameAsync()
32         {
33             var containerClient = _blobServiceClient.GetBlobContainerClient("picturecontainer");
34             var items = new Liststring>();
35 
36             await foreach (var blobItem in containerClient.GetBlobsAsync())
37             {
38                 items.Add(blobItem.Name);
39             }
40             return items;
41         }
42         #endregion
43 
44         #region 03，上传图片流，根据文件路径和文件名称+async Task UploadFileBlobAsync(string filePath, string filename)
45         /// 

46         /// 上传图片流，根据文件路径和文件名称
47         /// 
48         /// 文件路径
49         /// 文件名称
50         /// 
51         public async Task UploadFileBlobAsync(string filePath, string filename)
52         {
53             var containerClient = _blobServiceClient.GetBlobContainerClient("picturecontainer");
54             var blobClient = containerClient.GetBlobClient(filename);
55             await blobClient.UploadAsync(filePath, new BlobHttpHeaders { ContentType = filePath.GetContentType() });
56         }
57         #endregion
58 
59         #region 04，上传文件流，根据文件内容和文件名称+async Task UploadContentBlobAsync(string content, string filename)
60         /// 

61         /// 上传文件流，根据文件内容和文件名称
62         /// 
63         /// 文件内容
64         /// 文件名称
65         /// 
66         public async Task UploadContentBlobAsync(string content, string filename)
67         {
68             var containerClient = _blobServiceClient.GetBlobContainerClient("picturecontainer");
69             var blobClient = containerClient.GetBlobClient(filename);
70             var bytes = Encoding.UTF8.GetBytes(content);
71             await using var memoryStream = new MemoryStream(bytes);
72             await blobClient.UploadAsync(memoryStream, new BlobHttpHeaders() { ContentType = filename.GetContentType() });
73         }
74         #endregion
75 
76         #region 05，删除Blob+async Task DeleteBlobAsync(string blobName)
77         /// 

78         /// 删除Blob
79         /// 
80         /// blob名称
81         /// 
82         public async Task DeleteBlobAsync(string blobName)
83         {
84             var containerClient = _blobServiceClient.GetBlobContainerClient("picturecontainer");
85             var blobClient = containerClient.GetBlobClient(blobName);
86             await blobClient.DeleteIfExistsAsync();
87         } 
88         #endregion
89     }

 1 public class UpLoadContentRequest
 2     {
 3         /// 

 4         /// 文件内容
 5         /// 
 6         public string Content { get; set; }
 7 
 8         /// 

 9         /// 文件名称
10         /// 
11         public string FileName { get; set; }
12     }

 1 public class UploadFileRequest
 2     {
 3         /// 

 4         /// 文件路径
 5         /// 
 6         public string FilePath { get; set; }
 7 
 8         /// 

 9         /// 文件名称
10         /// 
11         public string FileName { get; set; }
12     }

 1 public static class FileExtensions
 2     {
 3         private static readonly FileExtensionContentTypeProvider provider = new FileExtensionContentTypeProvider();
 4 
 5         public static string GetContentType(this string fileName)
 6         {
 7             if (!provider.TryGetContentType(fileName, out var contentType))
 8             {
 9                 contentType = "application/octet-stream";
10             }
11             return contentType;
12         }
13     }