package src //import ( // "log" // "net" // "os" //) // //// InitSocket 初始化 socket 文件 //func InitSocket() { // log.Println("Start listen command") // // 删除旧的 socket 文件 // if _, err := os.Stat(SocketFile); err == nil { // os.Remove(SocketFile) // } // // listener, err := net.Listen("unix", SocketFile) // if err != nil { // log.Fatalf("Failed to listen on socket: %v", err) // } // defer listener.Close() // // for { // log.Println("Waiting for connections...") // conn, err := listener.Accept() // if err != nil { // log.Printf("Failed to accept connection: %v", err) // continue // } // // go handleConnection(conn) // } //} // ///* //* //处理连接 //*/ //func handleConnection(conn net.Conn) { // defer conn.Close() // // buf := make([]byte, 1024) // n, err := conn.Read(buf) // if err != nil { // log.Printf("Failed to read command: %v", err) // return // } // // command := string(buf[:n]) // log.Printf("Received command: %s", command) // // // 在这里处理接收到的命令 // switch command { // case "stop": // onStop() // default: // onCommand(command) // } //} // ///* //* //收到停止命令 //*/ //func onStop() { // log.Println("Stopping daemon...")// os.Remove(PidFile) // log.Println("Remove PID File...") // os.Remove(SocketFile) // log.Println("Remove Socket File...") // os.Exit(0) //} // ///* //收到命令 //*/ //func onCommand(command string) { // //} // //func onConfig() { // //}