将 Kubernetes 容器中的 Go 语言设置 POSIX 消息队列 RLIMIT_MSGQUEUE 为无限制

本篇文章给大家分享《将 Kubernetes 容器中的 Go 语言设置 POSIX 消息队列 RLIMIT_MSGQUEUE 为无限制》，覆盖了Golang的常见基础知识，其实一个语言的全部知识点一篇文章是不可能说完的，但希望通过这些问题，让读者对自己的掌握程度有一定的认识(B 数)，从而弥补自己的不足，更好的掌握它。

我们有一个库，它使用 posix 消息队列在进程之间传递数据，并要求将 msgqueue 内核参数设置为 unlimited，否则进程将返回错误 too much open files。通常我们使用 ulimit -q 和 ulimit -q unlimited 来查看/设置它，但对于某些 kubernetes 容器，我们希望能够通过 go 代码直接设置它。

我们已经确认 pod 规范允许更改 mqueue 设置（通过 kubernetes 1.14+ 的 securitycontext），并且特定容器可以调整资源设置：

...
kind: Deployment
...
spec:
  template:
    spec:
      securityContext:
        sysctls:
        - name: fs.mqueue.msg_max
          value: "10000"
        - name: fs.mqueue.msgsize_max
          value: "102400"
      containers:
      - name: testing
        securityContext:
          capabilities:
            add:
            - SYS_RESOURCE
...

如果没有这些设置，即使 ulimit -q unlimited 也会出现错误：

bash: ulimit: posix 消息队列: 无法修改限制: 不允许操作

但是我们如何使用 syscall.setrlimit 来调整代码中的限制值？

解决方案

看起来系统调用包在没有 rlimit_msgqueue = 0xc 常量的情况下被冻结，并且它还定义了 syscall.rlim_infinity = -0x1 ，这会在尝试使用该值时导致错误：

因此您必须手动定义常量

const rlimit_msgqueue int = 0xc
const rlim_infinity uint64 = 0xffffffffffffffff // https://github.com/golang/go/issues/22731
err = syscall.setrlimit(rlimit_msgqueue, &syscall.rlimit{rlim_infinity,rlim_infinity}))

或者切换到使用https://godoc.org/golang.org/x/sys/unix中的方法：

err = unix.setrlimit(unix.rlimit_msgqueue, &unix.rlimit{cur: unix.rlim_infinity, max: unix.rlim_infinity})

另请注意，仅为该进程及其子进程设置限制值，因此要确认您必须检查 /proc//limits 或从代码中调用 getrlimit/ulimit：

var rLimit syscall.Rlimit
err := syscall.Getrlimit(0xC, &rLimit)
if err != nil {
    fmt.Println("Error Getting Rlimit ", err)
}
fmt.Println(rLimit)

// construct bash command
cmd := &exec.Cmd {
    Path: "/bin/bash",
    Args: []string{ "/bin/bash", "-c", "ulimit -q"},
    Stdout: os.Stdout,
    Stderr: os.Stdout,
}

// run `cmd` in background and wait for it to finish
cmd.Start()
cmd.Wait()

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~