swagger

Author: trueai-org

README.md

@@ -94,6 +94,7 @@ d. 启动方式2: chmod +x run_app_osx.sh && ./run_app_osx.sh
 - `Timeout`：请求超时时间，单位为毫秒，默认值为 `30000`（30秒）。
 - `MemoryLimit`：内存限制，单位为MB，默认值为 `128`（128MB）。
 - `BufferSize`：缓冲区大小，单位为字节，默认值为 `8192`（8KB）。
+- `Concurrent`：并发下载数，默认值为 `4`。
 - `Username`：Docker Hub 用户名，默认值为空，采用登录方式可提升拉取速度。
 - `Password`：Docker Hub 密码，默认值为空，采用登录方式可提升拉取速度。
 
@@ -104,6 +105,7 @@ d. 启动方式2: chmod +x run_app_osx.sh && ./run_app_osx.sh
     "Timeout": 30000,
     "MemoryLimit": 128,
     "BufferSize": 8192,
+    "Concurrent": 4,
     "Username": "",
     "Password": ""
 }

scripts/docker-upgrade.sh

@@ -50,8 +50,21 @@ fi
 
 # 运行新的容器
 echo "启动新的容器 ${CONTAINER_NAME}..."
+
+mkdir -p ./logs
+mkdir -p ./cache
+mkdir -p ./cache/manifests
+mkdir -p ./cache/blobs
+
+# 添加权限修改
+chmod -R 777 ./cache
+chmod -R 777 ./logs
+
 docker run --name ${CONTAINER_NAME} -d --restart=always \
  -p 8080:8080 \
+ -v ./logs:/app/logs:rw \
+ -v ./cache:/app/cache:rw \
+ -v ./appsettings.json:/app/appsettings.json:ro \
  -e TZ=Asia/Shanghai \
  ${IMAGE_NAME}
 if [ $? -ne 0 ]; then

src/DockerProxy/AppConfig.cs

@@ -5,6 +5,11 @@
     /// </summary>
     public class AppConfig
     {
+        /// <summary>
+        /// 演示环境
+        /// </summary>
+        public bool IsDemo { get; set; } = false;
+
         /// <summary>
         /// 缓存目录
         /// </summary>
@@ -30,6 +35,11 @@ public class AppConfig
         /// </summary>
         public int BufferSize { get; set; } = 8192; // 8 KB
 
+        /// <summary>
+        /// 并发下载数量
+        /// </summary>
+        public int Concurrent { get; set; } = 4;
+
         /// <summary>
         /// Optional credentials for Docker Hub (for higher rate limits)
         /// </summary>

src/DockerProxy/Controllers/RegistryController.cs

@@ -7,6 +7,7 @@
 namespace DockerProxy.Controllers
 {
     /// <summary>
+    /// Docker Registry API v2
     /// https://docker-docs.uclv.cu/registry/spec/api/
     /// </summary>
     [ApiController]
@@ -20,13 +21,21 @@ public class RegistryController : ControllerBase
         private readonly TokenService _tokenService;
         private readonly IHttpClientFactory _httpClientFactory;
 
-        public RegistryController(TokenService tokenService, IHttpClientFactory httpClientFactory,
-            DockerRegistryService registryService, IOptions<AppConfig> config)
+        public RegistryController(
+            TokenService tokenService,
+            IHttpClientFactory httpClientFactory,
+            DockerRegistryService registryService,
+            IOptions<AppConfig> config)
         {
             _tokenService = tokenService;
             _httpClientFactory = httpClientFactory;
             _registryService = registryService;
             _config = config.Value;
+
+            var ip = Request.GetIP();
+            var url = Request.GetUrl();
+
+            Log.Information("Received request: {Method} {Url} from {IP}", Request.Method, url, ip);
         }
 
         /// <summary>
@@ -43,7 +52,7 @@ public IActionResult GetStatus()
             var status = new
             {
                 status = "ok",
-                version = "1.2.4",
+                version = "1.3.0",
                 timestamp = DateTime.UtcNow,
                 uptime = (int)(DateTime.UtcNow - _startTime).TotalSeconds + " s",
                 memoryLimit = $"{_config.MemoryLimit} MB",
@@ -74,6 +83,7 @@ public IActionResult HandleV2Root()
         [HttpGet("v2/{name}/tags/list")]
         public async Task<IActionResult> ListTags(string name)
         {
+            var ip = Request.GetIP();
             Log.Information("Listing tags for repository: {Repository}", name);
 
             // Format repository name
@@ -145,8 +155,6 @@ public async Task<IActionResult> HandleV2Request(string path)
             var url = Request.GetUrl();
             var ip = Request.GetIP();
 
-            Log.Information("Received request: {Method} {Url} from {IP}", Request.Method, url, ip);
-
             // Handle manifest requests
             var manifestMatch = Regex.Match(path, @"^([^/]+(?:/[^/]+)?)/manifests/(.+)$");
             if (manifestMatch.Success)

src/DockerProxy/DockerRegistryMirror.cs

@@ -19,7 +19,11 @@ public DockerRegistryService(TokenService tokenService, IHttpClientFactory httpC
             _tokenService = tokenService;
             _httpClientFactory = httpClientFactory;
             _config = config.Value;
-            _concurrencySemaphore = new SemaphoreSlim(4, 4); // Allow 4 concurrent requests
+
+            // Allow 4 concurrent requests
+            var core = Math.Max(1, _config.Concurrent);
+
+            _concurrencySemaphore = new SemaphoreSlim(core, core);
         }
 
         public async Task<RegistryResponse> GetManifestAsync(string repository, string reference)

src/DockerProxy/Program.cs

@@ -90,7 +90,7 @@ public static void Main(string[] args)
                 app.UseSerilogRequestLogging();
 
                 // Configure the HTTP request pipeline.
-                if (app.Environment.IsDevelopment())
+                if (app.Environment.IsDevelopment() || config.IsDemo)
                 {
                     app.UseSwagger();
                     app.UseSwaggerUI();

src/DockerProxy/appsettings.json

@@ -32,11 +32,13 @@
     },
     "urls": "http://*:8080",
     "Registry": {
+        "IsDemo": false,
         "CacheDir": "./cache",
         "CacheTTL": 604800,
         "Timeout": 30000,
         "MemoryLimit": 128,
         "BufferSize": 8192,
+        "Concurrent": 4,
         "Username": "",
         "Password": ""
     }