go语言 robfig/cron包 实现定时 调用

woquNOKIA · · 5004 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
package main


import (
    "github.com/robfig/cron"
    "time"
    "fmt"
    "os"

    log "github.com/cihub/seelog"
)

var (
    ttt int
)

const (
    logFilePath = "hard/log/test/test.log"
)

func init() {
    logLevel := os.Getenv("LOG_LEVEL")
    if logLevel == "" {
        logLevel = "error"
    }

    logger, err := log.LoggerFromConfigAsString(`
    <seelog minlevel="` + logLevel + `" maxlevel="critical">
        <outputs formatid="common">
            <console />
            <rollingfile formatid="common" type="date" datepattern="2006-01-02"  filename="` + logFilePath + `" maxrolls="7"/>
        </outputs>
    
        <formats>
            <format id="common" format="%Date %Time %LEVEL (%File:%Line) - %Msg%n"/>
        </formats>
    </seelog>
    `)

    if err != nil {
        _ = log.Errorf("load seelog config failed! message: %s", err)
    }

    err = log.ReplaceLogger(logger)
    if err != nil {
        _ = log.Error(err)
    }
}

func test(){
    
    fmt.Printf("test=%d\n",ttt)
    ttt++
}

func main() {
    fmt.Println(os.Getenv("GOPATH"))
    ttt=1
    c := cron.New()
    c.AddFunc("0/5 * * * * ?", func() { log.Info("Every hour on the half hour") })
    c.AddFunc("0/5 * * * * ?", test)//5秒执行一次,12×5=60,所以一共执行12次
    c.Start()
    //log.Info("Every hour on the half hour")
    time.Sleep(time.Minute)    //一分钟后主线程退出
    fmt.Println("aaa")
}
----------------------------------------
package main
import (
    "github.com/robfig/cron"
//    "time"
    "fmt"
    "os"
    log "github.com/cihub/seelog"
)
var (
    ttt int
)
const (
    logFilePath = "D:\\hard/log/test/test.log"
)
func init() {
    logLevel := os.Getenv("LOG_LEVEL")
    if logLevel == "" {
        logLevel = "error"
    }
    logger, err := log.LoggerFromConfigAsString(`
    <seelog minlevel="` + logLevel + `" maxlevel="critical">
        <outputs formatid="common">
            <console />
            <rollingfile formatid="common" type="date" datepattern="2006-01-02"  filename="` + logFilePath + `" maxrolls="7"/>
        </outputs>
    
        <formats>
            <format id="common" format="%Date %Time %LEVEL (%File:%Line) - %Msg%n"/>
        </formats>
    </seelog>
    `)
    if err != nil {
        _ = log.Errorf("load seelog config failed! message: %s", err)
    }
    err = log.ReplaceLogger(logger)
    if err != nil {
        _ = log.Error(err)
    }
}
func test(){
    
    fmt.Printf("test=%d\n",ttt)
    ttt++
}
func main() {
    fmt.Println(os.Getenv("GOPATH"))
    ttt=1
    c := cron.New()
    c.AddFunc("0 33 * * * * ", func() { log.Info("Every hour on the half hour") }) //每小时的第33分钟调用
    c.AddFunc("0 33 * * * * ", test)
    c.Start()
    //log.Info("Every hour on the half hour")
    select{}
    
}
-------------
func test(){
    log.Error("test")
}
func main() {
    c := cron.New()
    c.AddFunc("@daily", func() { log.Error("Every hour on the half hour") })//每天调用一次
    c.AddFunc("@midnight", test)//每天调用一次(和daily一样)
    c.Start()    
    log.Info("Every hour on the half hour")
    time.Sleep(time.Minute)
    fmt.Println("aaa")
    select{} //阻塞主线程不退出
}



						

有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:woquNOKIA

查看原文:go语言 robfig/cron包 实现定时 调用

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

5004 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传