feat: ✨ add SOCKS5 proxy support and enhance configuration

- Introduced SOCKS5 proxy functionality with separate ports for random rotation and lowest latency.
- Updated `.env.example` and `docker-compose.yml` to include SOCKS5 port configurations.
- Enhanced `main.go` to initialize and start SOCKS5 servers alongside existing HTTP proxies.
- Revised README to document new SOCKS5 features, including usage examples and testing scripts.
- Improved proxy selection logic in the storage layer to support SOCKS5 protocol.

Author: isboyjc

.env.example

@@ -2,9 +2,11 @@
 CONTAINER_NAME=goproxy
 
 # 端口配置
-STABLE_PORT=7776    # 最低延迟代理端口
-RANDOM_PORT=7777    # 随机轮换代理端口
-WEBUI_PORT=7778     # WebUI 管理端口
+STABLE_PORT=7776           # HTTP 最低延迟代理端口
+RANDOM_PORT=7777           # HTTP 随机轮换代理端口
+WEBUI_PORT=7778            # WebUI 管理端口
+SOCKS5_RANDOM_PORT=7779    # SOCKS5 随机轮换代理端口
+SOCKS5_STABLE_PORT=7780    # SOCKS5 最低延迟代理端口
 
 # 地理过滤配置
 # 屏蔽指定国家代码的出口代理（逗号分隔，如 CN,RU,KP）

README.md

@@ -34,10 +34,17 @@ type Config struct {
 	// 稳定代理端口（最低延迟模式）
 	StableProxyPort string
 
+	// SOCKS5 服务端口（随机轮换模式）
+	SOCKS5Port string
+
+	// 稳定 SOCKS5 端口（最低延迟模式）
+	StableSOCKS5Port string
+
 	// 代理服务认证配置
 	ProxyAuthEnabled      bool   // 是否启用代理认证（默认 false）
 	ProxyAuthUsername     string // 代理认证用户名（默认 "proxy"）
-	ProxyAuthPasswordHash string // 代理认证密码 SHA256 哈希
+	ProxyAuthPassword     string // 代理认证密码明文（用于 SOCKS5）
+	ProxyAuthPasswordHash string // 代理认证密码 SHA256 哈希（用于 HTTP）
 
 	// 地理过滤配置
 	BlockedCountries []string // 屏蔽的国家代码列表（如 ["CN", "RU"]，默认 ["CN"]）
@@ -139,11 +146,14 @@ func DefaultConfig() *Config {
 		WebUIPasswordHash: passwordHash(password),
 		ProxyPort:         ":7777",
 		StableProxyPort:   ":7776",
+		SOCKS5Port:        ":7779",
+		StableSOCKS5Port:  ":7780",
 		DBPath:            dataDir() + "proxy.db",
 
 		// 代理认证配置
 		ProxyAuthEnabled:      proxyAuthEnabled,
 		ProxyAuthUsername:     proxyAuthUsername,
+		ProxyAuthPassword:     proxyAuthPassword,
 		ProxyAuthPasswordHash: proxyAuthHash,
 
 		// 地理过滤配置

config/config.go

@@ -10,9 +10,11 @@ services:
     container_name: ${CONTAINER_NAME:-goproxy}
     restart: unless-stopped
     ports:
-      - "${STABLE_PORT:-7776}:7776"   # 稳定代理（最低延迟）
-      - "${RANDOM_PORT:-7777}:7777"   # 随机轮换
-      - "${WEBUI_PORT:-7778}:7778"      # WebUI（有登录认证）
+      - "${STABLE_PORT:-7776}:7776"          # HTTP 最低延迟
+      - "${RANDOM_PORT:-7777}:7777"          # HTTP 随机轮换
+      - "${WEBUI_PORT:-7778}:7778"           # WebUI（有登录认证）
+      - "${SOCKS5_RANDOM_PORT:-7779}:7779"   # SOCKS5 随机轮换
+      - "${SOCKS5_STABLE_PORT:-7780}:7780"   # SOCKS5 最低延迟
     volumes:
       - goproxy-data:/app/data
     environment:

docker-compose.yml

@@ -71,13 +71,13 @@ func (f *Fetcher) FetchSmart(mode string, preferredProtocol string) ([]storage.P
 
 	switch mode {
 	case "emergency":
-		// 紧急模式：使用所有可用源
-		sources = f.filterAvailableSources(allSources, preferredProtocol)
-		log.Printf("[fetch] 🚨 紧急模式: 使用 %d 个源", len(sources))
+		// 紧急模式：忽略断路器，强制使用所有源（包括被禁用的）
+		sources = f.filterAvailableSources(allSources, preferredProtocol, true)
+		log.Printf("[fetch] 🚨 紧急模式: 使用 %d 个源（忽略断路器）", len(sources))
 
 	case "refill":
 		// 补充模式：使用快更新源
-		sources = f.filterAvailableSources(fastUpdateSources, preferredProtocol)
+		sources = f.filterAvailableSources(fastUpdateSources, preferredProtocol, false)
 		log.Printf("[fetch] 🔄 补充模式: 使用 %d 个快更新源", len(sources))
 
 	case "optimize":
@@ -86,7 +86,7 @@ func (f *Fetcher) FetchSmart(mode string, preferredProtocol string) ([]storage.P
 		log.Printf("[fetch] ⚡ 优化模式: 使用 %d 个源", len(sources))
 
 	default:
-		sources = f.filterAvailableSources(fastUpdateSources, preferredProtocol)
+		sources = f.filterAvailableSources(fastUpdateSources, preferredProtocol, false)
 	}
 
 	if len(sources) == 0 {
@@ -97,11 +97,12 @@ func (f *Fetcher) FetchSmart(mode string, preferredProtocol string) ([]storage.P
 }
 
 // filterAvailableSources 过滤可用的源（通过断路器）
-func (f *Fetcher) filterAvailableSources(sources []Source, preferredProtocol string) []Source {
+// ignoreCircuitBreaker: 是否忽略断路器（Emergency 模式下使用）
+func (f *Fetcher) filterAvailableSources(sources []Source, preferredProtocol string, ignoreCircuitBreaker bool) []Source {
 	var available []Source
 	for _, src := range sources {
-		// 检查断路器
-		if f.sourceManager != nil && !f.sourceManager.CanUseSource(src.URL) {
+		// 检查断路器（紧急模式下忽略）
+		if !ignoreCircuitBreaker && f.sourceManager != nil && !f.sourceManager.CanUseSource(src.URL) {
 			continue
 		}
 		// 如果指定了协议偏好，优先该协议的源
@@ -115,7 +116,7 @@ func (f *Fetcher) filterAvailableSources(sources []Source, preferredProtocol str
 
 // selectRandomSources 随机选择N个源
 func (f *Fetcher) selectRandomSources(sources []Source, count int, preferredProtocol string) []Source {
-	available := f.filterAvailableSources(sources, preferredProtocol)
+	available := f.filterAvailableSources(sources, preferredProtocol, false)
 	if len(available) <= count {
 		return available
 	}

fetcher/fetcher.go

@@ -70,9 +70,13 @@ func main() {
 		totalDeleted += int(deleted)
 	}
 
-	// 创建两个代理服务器：随机轮换 + 最低延迟
+	// 创建 HTTP 代理服务器：随机轮换 + 最低延迟
 	randomServer := proxy.New(store, cfg, "random", cfg.ProxyPort)
 	stableServer := proxy.New(store, cfg, "lowest-latency", cfg.StableProxyPort)
+	
+	// 创建 SOCKS5 代理服务器：随机轮换 + 最低延迟
+	socks5RandomServer := proxy.NewSOCKS5(store, cfg, "random", cfg.SOCKS5Port)
+	socks5StableServer := proxy.NewSOCKS5(store, cfg, "lowest-latency", cfg.StableSOCKS5Port)
 
 	// 配置变更通知 channel
 	configChanged := make(chan struct{}, 1)
@@ -105,16 +109,30 @@ func main() {
 	// 监听配置变更
 	go watchConfigChanges(configChanged, poolMgr)
 
-	// 启动稳定代理服务（最低延迟模式）
+	// 启动 HTTP 稳定代理服务（最低延迟模式）
 	go func() {
 		if err := stableServer.Start(); err != nil {
-			log.Fatalf("stable proxy server: %v", err)
+			log.Fatalf("stable http proxy server: %v", err)
+		}
+	}()
+
+	// 启动 SOCKS5 稳定代理服务（最低延迟模式）
+	go func() {
+		if err := socks5StableServer.Start(); err != nil {
+			log.Fatalf("stable socks5 proxy server: %v", err)
+		}
+	}()
+
+	// 启动 SOCKS5 随机代理服务
+	go func() {
+		if err := socks5RandomServer.Start(); err != nil {
+			log.Fatalf("random socks5 proxy server: %v", err)
 		}
 	}()
 
-	// 启动随机代理服务（阻塞）
+	// 启动 HTTP 随机代理服务（阻塞）
 	if err := randomServer.Start(); err != nil {
-		log.Fatalf("random proxy server: %v", err)
+		log.Fatalf("random http proxy server: %v", err)
 	}
 }