K8s远程exec终止后容器内命令仍运行，如何同步终止？

问题核心：当主机通过Ctrl+C触发context取消后，K8s的StreamWithContext只会关闭SPDY连接，但不会主动向容器内的进程发送终止信号，导致容器内的HTTP服务器持续运行。以下是两种可行的解决方案：

方案一：启用TTY并传递中断信号（推荐） #

如果你的场景允许使用TTY，这是最直接可靠的方式。通过TTY可以将主机的中断信号（Ctrl+C）传递给容器内的进程，同时在context取消时主动发送信号。

代码修改示例 #

调整remoteExecute函数，通过管道劫持stdin，在context取消时写入Ctrl+C字符（ASCII码\x03），容器内的TTY会自动将其转换为SIGINT信号发送给进程：

remoteExecute(ctx context.Context, pod *k8sCore.Pod, containerName string, cmd []string,
    ioIn io.Reader, ioOut, ioErr io.Writer, tty bool,
) error {
    req := kClientSet.CoreV1().RESTClient().Post().
        Resource("pods").
        Name(pod.GetName()).
        Namespace(pod.GetNamespace()).
        SubResource("exec").
        VersionedParams(&k8sCore.PodExecOptions{
            Container: containerName,
            Command:   cmd,
            Stdin:     ioIn != nil,
            Stdout:    ioOut != nil,
            Stderr:    ioErr != nil,
            TTY:       tty,
        }, scheme.ParameterCodec)

    executor, err := remotecommand.NewSPDYExecutor(s.kRestCfg, "POST", req.URL())
    if err != nil {
        return fmt.Errorf("new spdy executor: %w", err)
    }

    var stdinWriter io.Writer
    stdinReader := ioIn

    // 启用TTY时创建stdin管道，用于发送中断信号
    if tty && ioIn != nil {
        r, w := io.Pipe()
        stdinReader = r
        stdinWriter = w

        // 转发原始stdin输入到管道
        go func() {
            _, _ = io.Copy(w, ioIn)
            _ = w.Close()
        }()
    }

    // 监听context取消事件，主动发送中断信号
    go func() {
        <-ctx.Done()
        if tty && stdinWriter != nil {
            // 写入Ctrl+C字符触发SIGINT
            _, _ = stdinWriter.Write([]byte("\x03"))
            // 关闭管道确保进程收到信号后退出
            if closer, ok := stdinWriter.(io.Closer); ok {
                _ = closer.Close()
            }
        }
    }()

    err = executor.StreamWithContext(ctx, remotecommand.StreamOptions{
        Stdin:  stdinReader,
        Stdout: ioOut,
        Stderr: ioErr,
        Tty:    tty,
    })

    if err != nil {
        return fmt.Errorf("stream with context: %w", err)
    }

    return nil
}

方案二：非TTY场景下主动执行Kill命令 #

如果无法启用TTY，可以在context取消时，通过K8s Exec API额外调用kill命令终止容器内的目标进程。

代码修改示例 #

在remoteExecute函数中添加context取消后的kill逻辑：

remoteExecute(ctx context.Context, pod *k8sCore.Pod, containerName string, cmd []string,
    ioIn io.Reader, ioOut, ioErr io.Writer, tty bool,
) error {
    req := kClientSet.CoreV1().RESTClient().Post().
        Resource("pods").
        Name(pod.GetName()).
        Namespace(pod.GetNamespace()).
        SubResource("exec").
        VersionedParams(&k8sCore.PodExecOptions{
            Container: containerName,
            Command:   cmd,
            Stdin:     ioIn != nil,
            Stdout:    ioOut != nil,
            Stderr:    ioErr != nil,
            TTY:       tty,
        }, scheme.ParameterCodec)

    executor, err := remotecommand.NewSPDYExecutor(s.kRestCfg, "POST", req.URL())
    if err != nil {
        return fmt.Errorf("new spdy executor: %w", err)
    }

    // 监听context取消，执行kill命令终止目标进程
    go func() {
        <-ctx.Done()
        // 替换为你的目标进程名或PID查找逻辑
        killCmd := []string{"sh", "-c", "pkill http-server"}
        killReq := kClientSet.CoreV1().RESTClient().Post().
            Resource("pods").
            Name(pod.GetName()).
            Namespace(pod.GetNamespace()).
            SubResource("exec").
            VersionedParams(&k8sCore.PodExecOptions{
                Container: containerName,
                Command:   killCmd,
                Stdin:     false,
                Stdout:    false,
                Stderr:    false,
                TTY:       false,
            }, scheme.ParameterCodec)

        killExecutor, killErr := remotecommand.NewSPDYExecutor(s.kRestCfg, "POST", killReq.URL())
        if killErr == nil {
            _ = killExecutor.StreamWithContext(context.Background(), remotecommand.StreamOptions{})
        }
    }()

    err = executor.StreamWithContext(ctx, remotecommand.StreamOptions{
        Stdin:  ioIn,
        Stdout: ioOut,
        Stderr: ioErr,
        Tty:    tty,
    })

    if err != nil {
        return fmt.Errorf("stream with context: %w", err)
    }

    return nil
}

注意事项 #

• 方案二需要你的K8s客户端具备执行exec命令的权限
• 进程名或PID的查找逻辑需要根据实际场景调整，避免误杀其他进程

内容的提问来源于stack exchange，提问作者user1929999