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

OSS修改
continuous-integration/drone/push Build is running Details

Test_HIR_Net8
he 2026-05-27 12:15:22 +08:00
parent 4f83944a30
commit a7c462210c
1 changed files with 20 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,4 +1,4 @@
using AlibabaCloud.SDK.Sts20150401;
using AlibabaCloud.SDK.Sts20150401;
using Aliyun.OSS;
using Aliyun.OSS.Common;
using Amazon;
@ -529,40 +529,35 @@ public class OSSService : IOSSService
{
var minIOConfig = ObjectStoreServiceOptions.MinIO;
var httpClientHandler = new HttpClientHandler
{
ServerCertificateCustomValidationCallback = HttpClientHandler.DangerousAcceptAnyServerCertificateValidator
};
var minioClient = new MinioClient()
.WithEndpoint($"{minIOConfig.EndPoint}:{minIOConfig.Port}")
.WithCredentials(minIOConfig.AccessKeyId, minIOConfig.SecretAccessKey)
.WithSSL(minIOConfig.UseSSL)
.WithHttpClient(new HttpClient(httpClientHandler))
.Build();
var pipe = new System.IO.Pipelines.Pipe();
var args = new GetObjectArgs()
.WithBucket(minIOConfig.BucketName)
.WithObject(ossRelativePath)
.WithCallbackStream(async stream => // ✅ 使用异步回调
_ = Task.Run(async () =>
{
try
{
try
{
var pipeStream = pipe.Writer.AsStream();
await stream.CopyToAsync(pipeStream); // ✅ 使用异步CopyTo
await pipe.Writer.CompleteAsync();
}
catch (Exception ex)
{
Log.Error($"minio 获取流错误：{ex.Message}");
await pipe.Writer.CompleteAsync(ex);
}
});
var args = new GetObjectArgs()
.WithBucket(minIOConfig.BucketName)
.WithObject(ossRelativePath)
.WithCallbackStream(stream =>
{
stream.CopyTo(pipe.Writer.AsStream());
});
await minioClient.GetObjectAsync(args);
await pipe.Writer.CompleteAsync();
}
catch (Exception ex)
{
await pipe.Writer.CompleteAsync(ex);
}
});
await minioClient.GetObjectAsync(args);
return pipe.Reader.AsStream();
#region 废弃2