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



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

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

脚本的正常功能:

  • 启动minecraft服务器
  • 等待40秒,然后通过stdIn发出"stop";命令
    (在本例中,它按预期工作,打印有关保存过程的所有日志)

测试用例(说明问题在哪里):

  • 启动minecraft服务器
  • 在脚本发出停止命令之前,用户发送ctrl+c
    (在这种情况下,它应该完成打印关于保存过程的日志,然后退出,但它没有…似乎在接收到kill信号后,scanner.Scan()返回false,因此它只是退出)

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

我真的迷路了,我已经花了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: %vn", 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
}

对于您的问题,这里有一个更完整的答案-在Go中杀死子进程及其所有子进程

最新更新