Update.

Author: xOS

db/badger.go

@@ -35,20 +35,20 @@ func getOptimalCacheConfig() CacheConfig {
 	currentHeapMB := int(m.HeapAlloc / (1024 * 1024))
 
 	// 根据内存使用情况动态调整
-	// 目标：BadgerDB缓存控制在50-100MB之间
+	// 目标：BadgerDB缓存控制在30-60MB之间，减少内存压力
 	var totalCacheMB int
-	if currentHeapMB < 100 {
-		totalCacheMB = 80 // 系统内存充足时
-	} else if currentHeapMB < 200 {
-		totalCacheMB = 60 // 内存适中时
+	if currentHeapMB < 80 {
+		totalCacheMB = 50 // 系统内存充足时
+	} else if currentHeapMB < 150 {
+		totalCacheMB = 35 // 内存适中时
 	} else {
-		totalCacheMB = 40 // 内存紧张时
+		totalCacheMB = 25 // 内存紧张时，进一步减少缓存
 	}
 
-	// 智能分配缓存
+	// 智能分配缓存，优化性能和内存使用平衡
 	return CacheConfig{
-		BlockCache: totalCacheMB * 50 / 100, // 50%给块缓存（最重要）
-		IndexCache: totalCacheMB * 30 / 100, // 30%给索引缓存
+		BlockCache: totalCacheMB * 45 / 100, // 45%给块缓存
+		IndexCache: totalCacheMB * 35 / 100, // 35%给索引缓存
 		MemTable:   totalCacheMB * 20 / 100, // 20%给内存表
 	}
 }

service/singleton/servicesentinel.go

@@ -1255,35 +1255,37 @@ func (ss *ServiceSentinel) getTaskPriority(taskType string) int {
 func (ss *ServiceSentinel) getTaskTimeout(taskType string) time.Duration {
 	switch taskType {
 	case "badger_save_tcp_ping", "badger_save_service":
-		return 30 * time.Second // 增加数据库操作超时时间
+		return 60 * time.Second // 数据库操作超时时间
 	case "traffic_save":
-		return 3 * time.Minute  // 流量保存任务需要更长时间，增加到3分钟
+		return 5 * time.Minute // 流量保存任务超时时间
 	case "full_data_save":
-		return 5 * time.Minute  // 全量数据保存需要更长时间，增加到5分钟
-	case "scheduled_cleanup", "hourly_cleanup":
-		return 10 * time.Minute // 清理任务可能需要很长时间
+		return 8 * time.Minute // 全量数据保存超时时间
+	case "scheduled_cleanup":
+		return 15 * time.Minute // 定期清理任务超时时间
+	case "hourly_cleanup":
+		return 12 * time.Minute // 每小时清理任务超时时间
 	case "notification":
-		return 30 * time.Second // 通知可能较慢
+		return 60 * time.Second // 通知超时时间
 	default:
-		return 30 * time.Second // 增加默认超时时间
+		return 60 * time.Second // 默认超时时间
 	}
 }
 
 // getMaxRetries 获取最大重试次数
 func (ss *ServiceSentinel) getMaxRetries(taskType string) int {
 	switch taskType {
 	case "badger_save_tcp_ping", "badger_save_service":
-		return 2 // 数据保存减少重试次数，避免重复超时
+		return 1 // 数据保存减少重试次数，避免重复超时
 	case "traffic_save":
-		return 3 // 流量保存任务重试3次
+		return 2 // 流量保存任务重试2次
 	case "full_data_save":
-		return 2 // 全量保存减少重试次数
+		return 1 // 全量保存减少重试次数
 	case "scheduled_cleanup", "hourly_cleanup":
-		return 1 // 清理任务只重试1次
+		return 0 // 清理任务不重试，避免重复执行
 	case "notification":
 		return 1 // 通知重试1次
 	default:
-		return 2
+		return 1
 	}
 }
 

service/singleton/singleton.go

@@ -35,7 +35,7 @@ var (
 
 	// 服务器状态缓存，减少数据库访问
 	serverStatusCache *cache.Cache
-	
+
 	// BadgerDB 数据保存任务互斥锁，防止并发冲突
 	badgerDBSaveMutex sync.Mutex
 )
@@ -355,8 +355,8 @@ func LoadSingleton() {
 		log.Printf("添加监控历史记录一致性检查任务失败: %v", err)
 	}
 
-	// 添加定时清理任务，每6小时执行一次 - 通过ServiceSentinel Worker池执行，减少频率以避免超时
-	Cron.AddFunc("0 0 */6 * * *", func() {
+	// 添加定时清理任务，每12小时执行一次 - 进一步减少频率以避免超时
+	Cron.AddFunc("0 0 */12 * * *", func() {
 		if ServiceSentinelShared != nil {
 			ServiceSentinelShared.SubmitOptimizedTask("scheduled_cleanup", nil, func() error {
 				CleanMonitorHistory()
@@ -403,8 +403,8 @@ func LoadSingleton() {
 		}
 	})
 
-	// 定期清理任务，每小时执行一次 - 通过ServiceSentinel Worker池执行
-	Cron.AddFunc("0 0 * * * *", func() {
+	// 定期清理任务，每2小时执行一次 - 减少频率以避免超时
+	Cron.AddFunc("0 0 */2 * * *", func() {
 		if ServiceSentinelShared != nil {
 			ServiceSentinelShared.SubmitOptimizedTask("hourly_cleanup", nil, func() error {
 				performHourlyCleanup()
@@ -1267,7 +1267,7 @@ func SaveAllTrafficToBadgerDB() {
 	// 使用互斥锁防止多个数据保存任务同时执行
 	badgerDBSaveMutex.Lock()
 	defer badgerDBSaveMutex.Unlock()
-	
+
 	// 使用读锁获取服务器列表
 	ServerLock.RLock()
 	serverData := make(map[uint64]*model.Server)
@@ -1297,7 +1297,7 @@ func SaveAllTrafficToBadgerDB() {
 		start := time.Now()
 		err := serverOps.UpdateServerTraffic(serverID, server.CumulativeNetInTransfer, server.CumulativeNetOutTransfer)
 		elapsed := time.Since(start)
-		
+
 		if err != nil {
 			log.Printf("保存服务器 %s (ID:%d) 累计流量失败: %v (耗时: %v)", server.Name, serverID, err, elapsed)
 		} else {
@@ -2086,7 +2086,7 @@ func OptimizeDatabase() {
 					if err := DB.WithContext(vacCtx).Exec("VACUUM").Error; err != nil {
 						log.Printf("VACUUM操作失败: %v", err)
 					} else {
-											log.Println("VACUUM操作完成")
+						log.Println("VACUUM操作完成")
 					}
 				}
 				return nil