feat: 优化sse接收处理逻辑增加worker逻辑

Author: yangtao

README.md

@@ -1,6 +1,6 @@
 # 🚀 NodePassDash
 
-![Version](https://img.shields.io/badge/version-2.0.0.beta2-blue.svg)
+![Version](https://img.shields.io/badge/version-2.0.0.beta3-blue.svg)
 
 NodePassDash是一个现代化的 NodePass 管理界面，基于 Go 后端 + Next.js 14、HeroUI 和 TypeScript 构建。提供实时隧道监控、流量统计和端点管理功能。
 

cmd/main.go

@@ -29,7 +29,7 @@ type Router struct {
 
 // NewRouter 创建路由器实例
 // 如果外部已创建 sseService / sseManager，则传入以复用，避免出现多个实例导致推流失效
-func NewRouter(db *sql.DB, sharedSSE *sse.Service, sharedManager *sse.Manager) *Router {
+func NewRouter(db *sql.DB, sseService *sse.Service, sseManager *sse.Manager) *Router {
 	// 创建路由器（忽略末尾斜杠差异）
 	router := mux.NewRouter()
 	router.StrictSlash(true)
@@ -39,17 +39,12 @@ func NewRouter(db *sql.DB, sharedSSE *sse.Service, sharedManager *sse.Manager) *
 	endpointService := endpoint.NewService(db)
 	instanceService := instance.NewService(db)
 	tunnelService := tunnel.NewService(db)
-	var sseService *sse.Service
-	var sseManager *sse.Manager
-	if sharedSSE != nil {
-		sseService = sharedSSE
-	} else {
-		sseService = sse.NewService(db)
+
+	if sseService == nil {
+		panic("sseService is nil")
 	}
-	if sharedManager != nil {
-		sseManager = sharedManager
-	} else {
-		sseManager = sse.NewManager(db, sseService)
+	if sseManager == nil {
+		panic("sseManager is nil")
 	}
 	dashboardService := dashboard.NewService(db)
 

internal/api/routes.go

@@ -1,37 +1,41 @@
 package db
 
 import (
-    "database/sql"
-    _ "github.com/mattn/go-sqlite3"
-    "log"
-    "sync"
+	"database/sql"
+	"log"
+	"sync"
+
+	_ "github.com/mattn/go-sqlite3"
 )
 
 var (
-    db   *sql.DB
-    once sync.Once
+	db   *sql.DB
+	once sync.Once
 )
 
 // DB 获取数据库单例
 func DB() *sql.DB {
-    once.Do(func() {
-        var err error
-        db, err = sql.Open("sqlite3", "data.db?_journal_mode=WAL")
-        if err != nil {
-            log.Fatal(err)
-        }
+	once.Do(func() {
+		var err error
+		db, err = sql.Open("sqlite3", "data.db?_journal_mode=WAL&_busy_timeout=3000")
+		if err != nil {
+			log.Fatal(err)
+		}
+
+		// 初始化表结构
+		if err := initSchema(db); err != nil {
+			log.Fatal(err)
+		}
 
-        // 初始化表结构
-        if err := initSchema(db); err != nil {
-            log.Fatal(err)
-        }
-    })
-    return db
+		db.SetMaxOpenConns(1)
+		db.SetMaxIdleConns(1)
+	})
+	return db
 }
 
 // 初始化数据库Schema
 func initSchema(db *sql.DB) error {
-    _, err := db.Exec(`
+	_, err := db.Exec(`
         CREATE TABLE IF NOT EXISTS users (
             id INTEGER PRIMARY KEY AUTOINCREMENT,
             name TEXT NOT NULL,
@@ -40,5 +44,5 @@ func initSchema(db *sql.DB) error {
             updated_at DATETIME DEFAULT CURRENT_TIMESTAMP
         )
     `)
-    return err
-} 
+	return err
+}

internal/db/db.go

@@ -1,6 +1,6 @@
 {
   "name": "NodePassDash",
-  "version": "2.0.0.beta2",
+  "version": "2.0.0.beta3",
   "private": true,
   "scripts": {
     "dev": "next dev",