App.xaml.cs

@@ -40,12 +40,8 @@ namespace HeBianGu.App.Disk
             if (File.Exists("./settings.xml"))
             {
                 var setting = xmlSerializerService.Load<SystemSetting>("./settings.xml");
-                if (!string.IsNullOrEmpty(setting.SyncDir))
+                if (!string.IsNullOrEmpty(setting.SyncDir) && setting.TaskCount != null)
                 {
-                    if (setting.TaskCount  == 0 )
-                    {
-                        setting.TaskCount = 3;
-                    }
                     minioService.MirrorAsync1(bucketName, setting.SyncDir, setting.TaskCount);
                     minioService.RealTimeListen(bucketName, setting.SyncDir);
                 }

Hopetry.csproj

@@ -87,9 +87,7 @@
 
   <ItemGroup>
     <None Remove="global.json" />
-    <Content Include="global.json">
+    <EditorConfigFiles Include="global.json" />
-      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
-    </Content>
   </ItemGroup>
 
 </Project>

Services/MinioService.cs

@@ -98,13 +98,13 @@ namespace Hopetry.Services
         /// <param name="maxParallel"></param>
         public async Task MirrorAsync1(string bucket, string localDir, int maxParallel = 5)
         {
-            Channel<(string ObjectName, string ETag)> SyncChannel = Channel.CreateBounded<(string, string)>(
+            
-                new BoundedChannelOptions(10000)
+          Channel<(string ObjectName, string ETag)>  SyncChannel  = Channel.CreateBounded<(string, string)>(new BoundedChannelOptions(10000)
-                {
+            {
-                    SingleWriter = false,
+                SingleWriter = false,
-                    SingleReader = false,
+                SingleReader = false,
-                    FullMode = BoundedChannelFullMode.Wait
+                FullMode = BoundedChannelFullMode.Wait
-                });
+            });
             var count = 0;
             var producerTasks = new List<Task>();
             var listArgs = new ListObjectsArgs()
@@ -314,24 +314,10 @@ namespace Hopetry.Services
         // 实时监听方法
         public async Task RealTimeListen(string bucketName, string localDir, string prefix = "", string suffix = "")
         {
-            var downloadQueue =
-                Channel.CreateBounded<(string bucketName, string objectKey, string localDir, string objectETag)>(
-                    new BoundedChannelOptions(1000)
-                    {
-                        FullMode = BoundedChannelFullMode.Wait
-                    });
-            Task.Run(async () =>
-            {
-                await Parallel.ForEachAsync(downloadQueue.Reader.ReadAllAsync(),
-                    new ParallelOptions { MaxDegreeOfParallelism = 5 },
-                    async (item, _) =>
-                    {
-                        await DownLoadObject(item.bucketName, item.objectKey, item.localDir, item.objectETag);
-                    });
-            });
             try
             {
                 var events = new List<EventType> { EventType.ObjectCreatedAll };
+
                 ListenBucketNotificationsArgs args = new ListenBucketNotificationsArgs()
                     .WithBucket(bucketName)
                     .WithEvents(events);
@@ -347,9 +333,8 @@ namespace Hopetry.Services
                         var objectSize = obj["Records"]?[0]?["s3"]?["object"]?["size"]?.Value<long>();
                         var objectKey = obj["Records"]?[0]?["s3"]?["object"]?["key"]?.Value<string>();
                         var objectETag = obj["Records"]?[0]?["s3"]?["object"]?["eTag"]?.Value<string>();
-                        Console.WriteLine("将要下载的Key:" + objectKey);
+
-                        downloadQueue.Writer.TryWrite((bucketName, objectKey, localDir, objectETag));
+                        await DownLoadObject(bucketName, objectKey, localDir, objectETag);
-                        //await DownLoadObject(bucketName, objectKey, localDir, objectETag);
                     },
                     ex => Console.WriteLine($"OnError: {ex}"),
                     () => Console.WriteLine($"Stopped listening for bucket notifications\n"));

global.json

@@ -1,4 +1,3 @@
-/*
 {
   "Minio": {
     "Endpoint": "123.132.248.154:9107",
@@ -6,12 +5,4 @@
     "SecretKey": "66GYn0x1XAEInSa9wdCutzvUWKfhH1EhqxPJ6a9u",
     "BucketName": "demo"
   }
-}*/
-{
-  "Minio": {
-    "Endpoint": "192.168.10.163:9016",
-    "AccessKey": "I2c35jD6ayApaneyQZyC",
-    "SecretKey": "XHlrNeCHK0xf8y2Fo0K5OKyDeaI2ItfEsFbzQPFk",
-    "BucketName": "demo"
-  }
 }