脚本之家，脚本语言编程技术及教程分享平台！
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - 一文搞懂Go Exec 僵尸与孤儿进程

一文搞懂Go Exec 僵尸与孤儿进程

2022-09-05 11:32WilburXu Golang

本文主要介绍了Go Exec 僵尸与孤儿进程，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

最近，使用 golang 去管理本地应用的生命周期，期间有几个有趣的点，今天就一起看下。

场景一

我们来看看下面两个脚本会产生什么问题：

创建两个 shell 脚本

  • start.sh
?
1
2
#!/bin/sh
sh sub.sh
  • sub.sh
?
1
2
3
4
5
6
7
8
#!/bin/sh
n=0
while [ $n -le 100 ]
do
  echo $n
  let n++
  sleep 1
done

执行脚本

输出结果

$ ./start.sh 
0
1
2
...

进程关系

查看进程信息

?
1
2
3
4
5
ps -j
 
USER   PID    PPID   PGID   SESS  JOBC  STAT   TT     TIME     COMMAND
root   31758  31346  31758  0     1     S+     s000   0:00.00  /bin/sh ./start.sh
root   31759  31758  31758  0     1     S+     s000   0:00.01  sh sub.sh

  • sub.sh 的 父进程（PPID）为 start.sh 的进程id（PID）

  • sub.sh 和 start.sh 两个进程的 PGID 是同一个，（ 属一个进程组）。

删除 start.sh 的进程

?
1
2
3
4
5
6
7
8
kill -9 31758
 
# 再查看进程组
ps -j
 
## 返回
USER     PID       PPID  PGID     SESS  JOBC   STAT    TT       TIME     COMMAND
root     31759     1     31758    0      0     S       s000     0:00.03  sh sub.sh
  • start.sh 进程不在了
  • sub.sh 进程还在执行
  • sub.sh 进程的 PID 变成了 1

问题1：

那sub.sh 这个进程现在属于什么？

场景二

假设sub.sh 是实际的应用， start.sh 是应用的启动脚本。

那么，golang 是如何管理他们的呢？ 我们继续看看下面 关于golang的场景。

在上面两个脚本的基础上，我们用golang 的 os/exec库去调用 start.sh脚本

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
package main
 
import (
    "context"
    "log"
    "os"
    "os/exec"
    "time"
)
 
func main()  {
    cmd := exec.CommandContext(context.Background(), "./start.sh")
 
  // 将 start.sh 和 sub.sh 移到当前目录下
    cmd.Dir = "/Go/src/go-code/cmd/"
    cmd.Stdout = os.Stdout
    cmd.Stderr = os.Stderr
 
    if err := cmd.Start(); err != nil {
        log.Printf("cmd.Start error %+v \n", err)
    }
 
    for {
        select {
        default:
            log.Println(cmd.Process.Pid)
            time.Sleep(2 * time.Second)
        }
    }
}

执行程序

?
1
go run ./main.go

查看进程

?
1
2
3
4
5
6
ps -j
 
USER   PID    PPID   PGID     SESS  JOBC  STAT   TT      TIME     COMMAND
root   45458  45457  45457    0     0     Ss+    s004    0:00.03  ...___1go_build_go_code_cmd
root   45462  45458  45457    0     0     S+     s004    0:00.01  /bin/sh ./start.sh
root   45463  45462  45457    0     0     S+     s004    0:00.03  sh sub.sh

发现 go 、 start.sh 、sub.sh 三个进程为同一个进程组（同一个 PGID）

父子关系为： main.go -> start.sh -> sub.sh

删除 start.sh 的进程

实际场景，有可能启动程序挂了，导致我们无法监听到执行程序的情况，删除start.sh进程，模拟下场景 ：

?
1
kill -9 45462

再查看进程

?
1
2
3
4
5
6
ps -j
 
USER   PID    PPID   PGID     SESS  JOBC  STAT   TT      TIME     COMMAND
root   45458  45457  45457    0     0     Ss+    s004    0:00.03  ...___1go_build_go_code_cmd
root   45462  1      45457    0     0     S+     s004    0:00.01  (bash)
root   45463  45462  45457    0     0     S+     s004    0:00.03  sh sub.sh
  • 发现没， start.sh 的 PPID 为1
  • 即使 start.sh 的 PPID变成了1 ，log.Println(cmd.Process.Pid) 还持续的输出 .

问题2:

那如果 PPID为1 ，golang程序不就无法管理了吗？ 即使 sub.sh 退出也不知道了，那要如何处理？

问题分析

  • 两个场景中， 都有一个共同的点，就是 PPID 为1，这妥妥的成为没人要的娃了——孤儿进程

  • 场景二中，如果 cmd的没有进程没有被回收，go程序也无法管理，那么start.sh就成为了占着茅坑不拉屎的子进程——僵尸进程

那究竟什么是孤儿进程 和 僵尸进程？

孤儿进程

在类 UNIX 操作系统中，孤儿进程（Orphan Process）指：是在其父进程执行完成或被终止后仍继续运行的一类进程。

为避免孤儿进程退出时无法释放所占用的资源而僵死，任何孤儿进程产生时都会立即为系统进程 init 或 systemd 自动接收为子进程，这一过程也被称为收养。在此需注意，虽然事实上该进程已有init作为其父进程，但由于创建该进程的进程已不存在，所以仍应称之为孤儿进程。孤儿进程会浪费服务器的资源，甚至有耗尽资源的潜在危险。

解决&预防

  • 终止机制：强制杀死孤儿进程（最常用的手段）；

  • 再生机制：服务器在指定时间内查找调用的客户端，若找不到则直接杀死孤儿进程；

  • 超时机制：给每个进程指定一个确定的运行时间，若超时仍未完成则强制终止之。若有需要，亦可让进程在指定时间耗尽之前申请延时。

  • 进程组：因为父进程终止或崩溃都会导致对应子进程成为孤儿进程，所以也无法预料一个子进程执行期间是否会被“遗弃”。有鉴于此，多数类UNIX系统都引入了进程组以防止产生孤儿进程。

僵尸进程

在类 UNIX 操作系统中，僵尸进程（zombie process）指：完成执行（通过exit系统调用，或运行时发生致命错误或收到终止信号所致），但在操作系统的进程表中仍然存在其进程控制块，处于"终止状态"的进程。
正常情况下，进程直接被其父进程 wait 并由系统回收。而僵尸进程与正常进程不同，kill 命令对僵尸进程无效，并且无法回收，从而导致资源泄漏。

解决&预防

收割僵尸进程的方法是通过 kill 命令手工向其父进程发送SIGCHLD信号。如果其父进程仍然拒绝收割僵尸进程，则终止父进程，使得 init 进程收养僵尸进程。init 进程周期执行 wait 系统调用收割其收养的所有僵尸进程。

查看进程详情

?
1
2
# 列出进程
ps -l
  • USER：进程的所属用户
  • PID：进程的进程ID号
  • RSS：进程占用的固定的内存量 (Kbytes)
  • S：查看进程状态
  • CMD：进程对应的实际程序

进程状态（S）

  • R：运行 Runnable (on run queue) 正在运行或在运行队列中等待
  • S：睡眠 Sleeping 休眠中，受阻，在等待某个条件的形成或接受到信号
  • I：空闲 Idle
  • Z：僵死 Zombie（a defunct process) 进程已终止，但进程描述符存在， 直到父进程调用wait4()系统调用后释放
  • D：不可中断 Uninterruptible sleep (ususally IO) 收到信号不唤醒和不可运行， 进程必须等待直到有中断发生
  • T：终止 Terminate 进程收到SIGSTOP、SIGSTP、 SIGTIN、SIGTOU信号后停止运行运行
  • P：等待交换页
  • W：无驻留页 has no resident pages 没有足够的记忆体分页可分配
  • X：死掉的进程

Go解决方案

采用 杀掉进程组（kill process group，而不是只 kill 父进程，在 Linux 里面使用的是 kill -- -PID） 与 进程wait方案，结果如下：

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package main
 
import (
    "context"
    "log"
    "os"
    "os/exec"
    "syscall"
    "time"
)
 
func main() {
 
    ctx := context.Background()
    cmd := exec.CommandContext(ctx, "./start.sh")
  
        // 设置进程组
    cmd.SysProcAttr = &syscall.SysProcAttr{
        Setpgid: true,
    }
 
    cmd.Dir = "/Users/Wilbur/Project/Go/src/go-code/cmd/"
    cmd.Stdout = os.Stdout
    cmd.Stderr = os.Stderr
 
    if err := cmd.Start(); err != nil {
        log.Printf("cmd.Start error %+v \n", err)
    }
 
        // 监听进程wait
    errCmdCh := make(chan error, 1)
    go func() {
        errCmdCh <- cmd.Wait()
    }()
 
    for {
        select {
        case <-ctx.Done():
            log.Println("ctx.done")
            pid := cmd.Process.Pid
            if err := syscall.Kill(-1*pid, syscall.SIGKILL); err != nil {
                return
            }
        case err := <-errCmdCh:
            log.Printf("errCmdCh error %+v \n", err)
            return
        default:
            log.Println(cmd.Process.Pid)
            time.Sleep(2 * time.Second)
        }
    }
}

剖析 cmd.Wait() 源码

在 os/exec_unix下：

?
1
2
3
4
5
6
7
8
9
10
11
12
13
var (
    status syscall.WaitStatus
    rusage syscall.Rusage
    pid1   int
    e      error
)
 
for {
    pid1, e = syscall.Wait4(p.Pid, &status, 0, &rusage)
    if e != syscall.EINTR {
        break
    }
}

进行了 syscall.Wait4对系统监听，正如"僵死 Zombie（a defunct process) 进程已终止，但进程描述符存在， 直到父进程调用wait4()系统调用后释放"，所说一致。

总结

严格地来说，僵尸进程并不是问题的根源，罪魁祸首是产生出大量僵尸进程的那个父进程。

因此，当我们寻求如何消灭系统中大量的僵尸进程时，更应该是在实际的开发过程中，思考如何避免僵尸进程的产生。

参考：

https://pkg.go.dev/syscall

https://cs.opensource.google/go/go/+/refs/tags/go1.17.7:src/syscall/syscall_linux.go;l=279

https://pkg.go.dev/os/exec

到此这篇关于一文搞懂Go Exec 僵尸与孤儿进程 的文章就介绍到这了,更多相关Go Exec 僵尸与孤儿进程内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！

原文链接：https://www.cnblogs.com/wilburxu/p/15941020.html

  • Go
  • 僵尸进程
  • exec
  • 孤儿进程

    • 延伸 · 阅读

    精彩推荐
    • GolangGo语言使用字符串的几个技巧分享

      Go语言使用字符串的几个技巧分享

      这篇文章中小编将给出一些Go语言在处理字符串方面的技巧，对大家学习Go语言具有一定的参考借鉴价值，下面一起看看吧。 ...

      daisy3772020-05-01
    • Golang使用go求幂的几种方法小结

      使用go求幂的几种方法小结

      这篇文章主要介绍了使用go求幂的几种方法小结，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...

      autuan_liu13652021-03-03
    • Golang基于Go语言实现的简易api网关的示例代码

      基于Go语言实现的简易api网关的示例代码

      本文主要介绍了基于Go语言实现的简易api网关，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...

      董洪臣4092022-01-19
    • GolangGo语言中并发的工作原理

      Go语言中并发的工作原理

      本文详细讲解了Go语言中并发的工作原理，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...

      奋斗的大橙子8902022-07-16
    • GolangGo Excelize API源码解析GetSheetFormatPr使用示例

      Go Excelize API源码解析GetSheetFormatPr使用示例

      这篇文章主要为大家介绍了Go Excelize API源码解析GetSheetFormatPr使用示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职...

      丘山子8952022-08-17
    • Golang解决Go gorm踩过的坑

      解决Go gorm踩过的坑

      这篇文章主要介绍了解决Go gorm踩过的坑，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...

      持之以恒201613252021-06-11
    • Golang详解golang中bufio包的实现原理

      详解golang中bufio包的实现原理

      这篇文章主要介绍了详解golang中bufio包的实现原理，通过分析golang中bufio包的源码，来了解为什么bufio能够提高文件读写的效率和速度 ...

      liangwt5272020-05-13
    • Golang深入理解Golang的单元测试和性能测试

      深入理解Golang的单元测试和性能测试

      Go语言提供了强大的测试工具，下面这篇文章主要给大家介绍了关于Golang单元测试和性能测试的相关资料，文中通过示例代码给大家详细介绍了单元测试和...

      shenlanzifa5322020-05-08
    最近更新
    编辑推荐
    阅读排行
    热门标签
    树形图 　 指针类型 　 new() 　 make() 　 并发模型 　 切片 　 静态WEB服务器 　 端口扫描器 　 Go语言入门教程 　 基础语 　 Slices 　 Maps 　 Golang编程 　 panic 　 接受者类型 　 嵌入类型 　 Slice 　 Golang教程 　 Golang项目 　 内存模型 　 开发环境搭建 　 大小端判断 　 代码组织结构 　 复合类型 　 GOPATH 　 工作目录 　 实例 　 struct类型 　 并发技术 　 buffered 　
    © 2019-2022 脚本之家 | 服务器之家(www.tuohang.net)旗下站点 版权所有关于我们联系我们版权申明网站地图