完善节点重定向逻辑，添加节点端口配置，更新节点URL获取方法

Author: xingxing2008

Controllers/ContentController.cs

@@ -63,7 +63,21 @@ public async Task<IActionResult> GetFile(string hash)
         if (availableNodes.Any())
         {
             var targetNode = availableNodes.First();
-            return Redirect($"{targetNode.Url}/content/{hash}");
+            if (targetNode?.Url == null)
+            {
+                return StatusCode(500, "Invalid node configuration");
+            }
+
+            if (!Uri.TryCreate(targetNode.Url, UriKind.Absolute, out var uri))
+            {
+                _logger.LogError("Invalid node URL format: {Url}", targetNode.Url);
+                return StatusCode(500, "Invalid node configuration");
+            }
+
+            // 使用配置的主域名，使用 HTTPS，忽略原始端口
+            var redirectUrl = $"https://{uri.Host}.{_config.MainDomain}/content/{hash}";
+            _logger.LogInformation("Redirecting request to: {RedirectUrl}", redirectUrl);
+            return Redirect(redirectUrl);
         }
 
         return NotFound("No available nodes to serve the content");

Models/NodeConfig.cs

@@ -19,5 +19,8 @@ public class NodeConfig
 
     public TimeSpan DirectoryScanInterval { get; set; } = TimeSpan.FromMinutes(10);
 
+    [Required]
+    public int Port { get; set; } = 5000; // 默认端口号为5000
+
     public string StorageDirectory { get; set; } = "Storage";
 }

MultiSourceContentDelivery.csproj

@@ -14,6 +14,7 @@
     <PackageReference Include="Polly" Version="8.6.2" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
     <PackageReference Include="System.Threading.Tasks" Version="4.3.0" />
+    <PackageReference Include="System.Net.NetworkInformation" Version="4.3.0" />
   </ItemGroup>
 
 </Project>

Services/DirectoryScanService.cs

@@ -2,6 +2,8 @@
 using MultiSourceContentDelivery.DbContexts;
 using MultiSourceContentDelivery.Models;
 using System.Net.Http.Json;
+using System.Net.NetworkInformation;
+using System.Net;
 using Polly;
 using Polly.Retry;
 using FileInfo = MultiSourceContentDelivery.Models.FileInfo;
@@ -165,16 +167,17 @@ private async Task ScanDirectoryAndUpdateDatabase(CancellationToken stoppingToke
                             ContentType = GetContentType(file),
                             Size = new IOFileInfo(file).Length,
                             LocalPath = relPath,
-                            AvailableNodes = new List<string> { $"http://{Environment.MachineName}" }
+                            AvailableNodes = new List<string> { GetNodeUrl() }
                         };
                         await context.FileInfos.AddAsync(fileInfo);
                     }
                     else
                     {
                         fileInfo.LocalPath = relPath;
-                        if (!fileInfo.AvailableNodes.Contains($"http://{Environment.MachineName}"))
+                        var nodeUrl = GetNodeUrl();
+                        if (!fileInfo.AvailableNodes.Contains(nodeUrl))
                         {
-                            fileInfo.AvailableNodes.Add($"http://{Environment.MachineName}");
+                            fileInfo.AvailableNodes.Add(nodeUrl);
                         }
                     }
                 }
@@ -206,7 +209,7 @@ private async Task SyncWithOtherNodes(CancellationToken stoppingToken)
             // 更新本节点信息
             var nodeInfo = new NodeInfo
             {
-                Url = $"http://{Environment.MachineName}",
+                Url = GetNodeUrl(),
                 AvailableStorageBytes = await GetAvailableStorageAsync(),
                 CurrentLoad = await GetCurrentLoadAsync(),
                 LastSeen = DateTime.UtcNow
@@ -352,4 +355,27 @@ private string GetContentType(string filePath)
             _ => "application/octet-stream"
         };
     }
+
+    private string GetNodeUrl()
+    {
+        try
+        {
+            // 获取本机所有网络接口的IP地址
+            var ipAddress = System.Net.NetworkInformation.NetworkInterface.GetAllNetworkInterfaces()
+                .Where(n => n.OperationalStatus == System.Net.NetworkInformation.OperationalStatus.Up)
+                .SelectMany(n => n.GetIPProperties().UnicastAddresses)
+                .Where(a => a.Address.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork
+                    && !System.Net.IPAddress.IsLoopback(a.Address))
+                .Select(a => a.Address.ToString())
+                .FirstOrDefault();
+
+            // 如果找不到合适的IP地址，使用localhost
+            return $"http://{ipAddress ?? "localhost"}";
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Error getting node URL, falling back to localhost");
+            return $"http://localhost";
+        }
+    }
 }