XCKJ
/
irc-netcore-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改流式返回
continuous-integration/drone/push Build is passing Details

Test_HIR_Net8
hang 2025-12-18 13:26:16 +08:00
parent a1b5d960ff
commit ee3133adee
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
IRaCIS.Core.Application/Helper/OSSService.cs
View File

@ -518,11 +518,12 @@ public class OSSService : IOSSService
var result = _ossClient.GetObject(aliConfig.BucketName, ossRelativePath); var result = _ossClient.GetObject(aliConfig.BucketName, ossRelativePath);
// 将OSS返回的流复制到内存流中并返回 return result.Content;
var memoryStream = new MemoryStream(); //// 将OSS返回的流复制到内存流中并返回
await result.Content.CopyToAsync(memoryStream); //var memoryStream = new MemoryStream();
memoryStream.Position = 0; // 重置位置以便读取 //await result.Content.CopyToAsync(memoryStream);
return memoryStream; //memoryStream.Position = 0; // 重置位置以便读取
//return memoryStream;
} }
else if (ObjectStoreServiceOptions.ObjectStoreUse == "MinIO") else if (ObjectStoreServiceOptions.ObjectStoreUse == "MinIO")
{ {
@ -608,10 +609,13 @@ public class OSSService : IOSSService
var response = await amazonS3Client.GetObjectAsync(getObjectRequest); var response = await amazonS3Client.GetObjectAsync(getObjectRequest);
var memoryStream = new MemoryStream(); // ⭐ 直接返回流
await response.ResponseStream.CopyToAsync(memoryStream); return response.ResponseStream;
memoryStream.Position = 0;
return memoryStream; //var memoryStream = new MemoryStream();
//await response.ResponseStream.CopyToAsync(memoryStream);
//memoryStream.Position = 0;
//return memoryStream;
} }
else else
{ {