分享
Go语言daemon启动本身.实现
fyxichen · · 2378 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
package main
import (
"fmt"
"log"
"net/http"
"os"
"os/signal"
"syscall"
)
func main() {
File, err := os.Create("log")
if err != nil {
fmt.Println("创建日志文件错误", err)
return
}
log.SetOutput(File)
ce("pid")
}
func ce(pid string) {
File, err := os.OpenFile(pid, os.O_RDWR|os.O_CREATE, 0644)
if err != nil {
log.Println(err)
return
}
info, _ := File.Stat()
if info.Size() != 0 {
log.Println("pid file is exist")
return
}
if os.Getppid() != 1 {
args := append([]string{os.Args[0]}, os.Args[1:]...)
os.StartProcess(os.Args[0], args, &os.ProcAttr{Files: []*os.File{os.Stdin, os.Stdout, os.Stderr}})
return
}
File.WriteString(fmt.Sprint(os.Getpid()))
c := make(chan os.Signal, 1)
signal.Notify(c, os.Interrupt, syscall.SIGUSR2)
go HttpServer()
for {
s := <-c
switch s {
case syscall.SIGUSR2:
fmt.Println("自定义型号.")
case os.Interrupt:
fmt.Println("安全退出")
Exit(File)
}
}
}
func HttpServer() {
http.HandleFunc("/", route)
http.ListenAndServe(":1789", nil)
}
func route(w http.ResponseWriter, r *http.Request) {
log.Println(r.URL.Path)
fmt.Fprint(w, "Hello World\n")
}
func Exit(F *os.File) {
F.Close()
os.Remove(F.Name())
fmt.Println("bye")
}
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信2378 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
package main
import (
"fmt"
"log"
"net/http"
"os"
"os/signal"
"syscall"
)
func main() {
File, err := os.Create("log")
if err != nil {
fmt.Println("创建日志文件错误", err)
return
}
log.SetOutput(File)
ce("pid")
}
func ce(pid string) {
File, err := os.OpenFile(pid, os.O_RDWR|os.O_CREATE, 0644)
if err != nil {
log.Println(err)
return
}
info, _ := File.Stat()
if info.Size() != 0 {
log.Println("pid file is exist")
return
}
if os.Getppid() != 1 {
args := append([]string{os.Args[0]}, os.Args[1:]...)
os.StartProcess(os.Args[0], args, &os.ProcAttr{Files: []*os.File{os.Stdin, os.Stdout, os.Stderr}})
return
}
File.WriteString(fmt.Sprint(os.Getpid()))
c := make(chan os.Signal, 1)
signal.Notify(c, os.Interrupt, syscall.SIGUSR2)
go HttpServer()
for {
s := <-c
switch s {
case syscall.SIGUSR2:
fmt.Println("自定义型号.")
case os.Interrupt:
fmt.Println("安全退出")
Exit(File)
}
}
}
func HttpServer() {
http.HandleFunc("/", route)
http.ListenAndServe(":1789", nil)
}
func route(w http.ResponseWriter, r *http.Request) {
log.Println(r.URL.Path)
fmt.Fprint(w, "Hello World\n")
}
func Exit(F *os.File) {
F.Close()
os.Remove(F.Name())
fmt.Println("bye")
}