子进程接收到只能由父进程处理的 SIGINT,导致子进程突然终止

child process receives SIGINT which should be handled only by parent process, resulting in abrupt termination of child

我正在尝试使用 stdpipes 在 golang 中管理一个应用程序(需要通过特定程序关闭,在本例中是拯救世界)。
这是我要实现的目标的一个简单例子,但我有一个问题,这对我来说非常具体,但对其他人来说也可能很有趣(也许你可以建议如何概括它)。

我还添加了一个名为 interruptListener 的函数,它创建一个 goroutine 并在发送 kill 信号时管理程序的停止

脚本的正常功能:

测试用例(演示问题出在哪里):

您知道为什么会发生这种情况吗?我应该研究什么才能找到解决方案?

我真的迷路了我已经花了 8 个多小时来研究所有可能的代码组合...

package main

import (
    "bufio"
    "fmt"
    "io"
    "os"
    "os/exec"
    "os/signal"
    "strings"
    "sync"
    "syscall"
    "time"
)

var cmd *exec.Cmd

var wg sync.WaitGroup

var stdOut io.ReadCloser
var stdErr io.ReadCloser
var stdIn io.WriteCloser

func main() {
    interruptListener()

    cSplit := strings.Split("java -Xmx1024M -Xms1024M -jar server.jar nogui", " ")
    cmd = exec.Command(cSplit[0], cSplit[1:]...)
    cmd.Dir = "path/to/server/folder"
    stdOut, _ = cmd.StdoutPipe()
    stdErr, _ = cmd.StderrPipe()
    stdIn, _ = cmd.StdinPipe()
    wg.Add(2)
    go printer(stdOut)
    go printer(stdErr)
    err := cmd.Start()
    if err != nil {
        fmt.Println(err)
    }

    // test 1: wait 40 seconds for it to send the stop command and observe the output
    // test 2: in the 40 seconds (after the server has loaded press ctrl+c), there is no output
    time.Sleep(40 * time.Second)
    execute("stop")

    err = cmd.Wait()
    if err != nil {
        fmt.Println(err.Error())
    }
}

func printer(stdP io.ReadCloser) {
    defer func() {
        wg.Done()
        fmt.Println("printer is out")
    }()

    var line string

    scanner := bufio.NewScanner(stdP)

    for scanner.Scan() {
        line = scanner.Text()

        fmt.Println(line)
    }

    fmt.Printf("scanner error: %v\n", scanner.Err())
}

func execute(com string) {
    fmt.Println("sending", com, "to terminal")

    // needs to be added otherwise the virtual "enter" button is not pressed
    com += "\n"

    // write to cmd
    _, err := stdIn.Write([]byte(com))
    if err != nil {
        fmt.Println(err.Error())
    }
}

func interruptListener() {
    c := make(chan os.Signal, 1)
    signal.Notify(c, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)
    go func() {
        select {
        case <-c:
            execute("stop")
            wg.Wait()
            os.Exit(0)
        }
    }()
}

感谢在评论中回答的人,这是一个可以接受的解决方案(如评论中所述,仍然不完美)

在执行之前添加这几行 cmd.Start():

    // launch as new process group so that signals (ex: SIGINT) are not sent also the the child process
    cmd.SysProcAttr = &syscall.SysProcAttr{
        CreationFlags: syscall.CREATE_NEW_PROCESS_GROUP, // windows
        // Setpgid: true, // linux
    }

这里有一个更完整的问题答案 - Killing a child process and all of its children in Go