gs

http_service/service.go

@@ -4,9 +4,9 @@ import (
 	"context"
 	"fmt"
 	"net/http"
-	"os"
-	"os/signal"
-	"syscall"
+	// "os"
+	// "os/signal"
+	// "syscall"
 
 	"github.com/Brandon-lz/myopcua/http_service/routers"
 	webhookrouters "github.com/Brandon-lz/myopcua/http_service/routers/webhook_routers"
@@ -67,12 +67,12 @@ func Start(ctx context.Context) {
 
 	// Wait for interrupt signal to gracefully shutdown the server with
 	// a timeout of 5 seconds.
-	quit := make(chan os.Signal)
+	// quit := make(chan os.Signal)
 	// kill (no param) default send syscanll.SIGTERM
 	// kill -2 is syscall.SIGINT
 	// kill -9 is syscall. SIGKILL but can"t be catch, so don't need add it
-	signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
-	<-quit
+	// signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
+	// <-quit
 	slog.Info("Shutdown Server ...")
 
 	if err := srv.Shutdown(ctx); err != nil {

main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"log/slog"
 
 	"github.com/Brandon-lz/myopcua/config"
@@ -33,7 +34,8 @@ func main() {
 	db.InitDB()
 	query.SetDefault(db.DB) // init gen model, for decouple with db
 	globaldata.InitSystemVars()
-	go opcservices.Start()
-	go httpservice.Start()
+	ctx := context.Background()
+	go opcservices.Start(ctx)
+	go httpservice.Start(ctx)
 	select {}
 }