cron秒级调度

cron

配置文件格式：

1
*/5, *, *, *, *, *#echo `date` >> /tmp/fortest

代码

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
package main
import (
    "fmt"
    "os"
    "bufio"
    "io"
    "strings"
    "os/exec"
    "github.com/robfig/cron"
)
func main() {
    c := cron.New()
    f, err := os.Open("/root/bitcron")
    if err != nil {
        panic(err)
    }
    defer f.Close()
    rd := bufio.NewReader(f)
    for {
        line, err := rd.ReadString('\n') 
        
	arr := strings.Split(line,"#")
        if err != nil || io.EOF == err {
            break
        }
 c.AddFunc(arr[0], func() {
	exec.Command("/bin/bash", "-c", arr[1]).Output()	
	})
        }  
    c.Start()
    select {}
}