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

minio 获取流调整

Test_IRC_Net8
hang 2026-06-05 17:50:32 +08:00
parent 2969306d1e
commit dc1f95c75e
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1186,14 +1186,21 @@ public class OSSService(IOptionsMonitor<ObjectStoreServiceOptions> options,
} }
else if (ObjectStoreServiceOptions.ObjectStoreUse == "MinIO") else if (ObjectStoreServiceOptions.ObjectStoreUse == "MinIO")
{ {
var httpClientHandler = new HttpClientHandler
{
ServerCertificateCustomValidationCallback = HttpClientHandler.DangerousAcceptAnyServerCertificateValidator
};
var minIOConfig = ObjectStoreServiceOptions.MinIO; var minIOConfig = ObjectStoreServiceOptions.MinIO;
var minioClient = new MinioClient() var minioClient = new MinioClient()
.WithEndpoint($"{minIOConfig.EndPoint}:{minIOConfig.Port}") .WithEndpoint($"{minIOConfig.EndPoint}:{minIOConfig.Port}")
.WithCredentials(minIOConfig.AccessKeyId, minIOConfig.SecretAccessKey) .WithCredentials(minIOConfig.AccessKeyId, minIOConfig.SecretAccessKey)
.WithSSL(minIOConfig.UseSSL) .WithSSL(minIOConfig.UseSSL)
.WithHttpClient(new HttpClient(httpClientHandler))
.Build(); .Build();
var pipe = new System.IO.Pipelines.Pipe(); var pipe = new System.IO.Pipelines.Pipe();
_ = Task.Run(async () => _ = Task.Run(async () =>
@ -1206,6 +1213,7 @@ public class OSSService(IOptionsMonitor<ObjectStoreServiceOptions> options,
.WithCallbackStream(stream => .WithCallbackStream(stream =>
{ {
stream.CopyTo(pipe.Writer.AsStream()); stream.CopyTo(pipe.Writer.AsStream());
pipe.Writer.FlushAsync();
}); });
await minioClient.GetObjectAsync(args); await minioClient.GetObjectAsync(args);
@ -1213,6 +1221,7 @@ public class OSSService(IOptionsMonitor<ObjectStoreServiceOptions> options,
} }
catch (Exception ex) catch (Exception ex)
{ {
Log.Error($"minio 获取流错误：{ex.Message}");
await pipe.Writer.CompleteAsync(ex); await pipe.Writer.CompleteAsync(ex);
} }
}); });