gocron: 定時任務管理器

gocron 是一個簡單易用的定時任務管理器，可以實現輕量級的定時任務管理、分布式任務部署和監控，功能強大且易於上手。在本文中，我們將從多個方面介紹 gocron 的特性和使用方法。

一、gocron使用

gocron 可以輕鬆地創建和管理定時任務，為您節省大量時間和精力。

首先，我們需要使用 go get 命令來安裝 gocron：

go get github.com/go-co-op/gocron

接下來，我們可以使用以下代碼來創建一個簡單的任務：

package main

import (
	"fmt"
	"time"

	"github.com/go-co-op/gocron"
)

func task() {
	fmt.Println("task running...")
}

func main() {
	// 創建一個新的任務
	s := gocron.NewScheduler()
	s.Every(5).Seconds().Do(task)

	// 開始任務
	<-s.StartAsync()
}

在這個例子中，我們使用 gocron.NewScheduler() 方法創建了一個新的調度器，並使用 s.Every(5).Seconds().Do(task) 方法創建了一個每 5 秒鐘執行一次的任務。最後，我們使用 <-s.StartAsync() 方法開始任務。

二、gocron 教程

gocron 不僅可以輕鬆管理單個任務，還可以使用 gocron.Ticker() 方法來創建多個任務。

以下是一個更複雜的示例：

package main

import (
	"fmt"
	"time"

	"github.com/go-co-op/gocron"
)

func task1() {
	fmt.Println("task1 running...")
}

func task2() {
	fmt.Println("task2 running...")
}

func task3() {
	fmt.Println("task3 running...")
}

func main() {
	// 創建一個新的調度器
	s := gocron.NewScheduler()

	// 添加任務
	s.
		Every(5).Seconds().
		Do(task1)

	s.
		Every(10).Seconds().
		Do(task2)

	s.
		Every(15).Seconds().
		Do(task3)

	// 開始任務
	<-s.StartAsync()
}

在這個示例中，我們使用 s.Every(5).Seconds().Do(task1) 方法創建了一個每 5 秒鐘執行一次的任務，並使用 s.Every(10).Seconds().Do(task2) 和 s.Every(15).Seconds().Do(task3) 方法創建了另外兩個任務。最後，我們使用 <-s.StartAsync() 方法開始任務。

三、gocron docker

gocron 還可以集成到 Docker 中，使您可以更輕鬆地使用它。

以下是一個示例 Dockerfile：

FROM golang:alpine

RUN apk update && \
    apk upgrade && \
    apk add --no-cache git

WORKDIR /app

COPY go.mod .

RUN go mod download

COPY . .

RUN go build -o main .

CMD ["./main"]

您可以在容器中運行 gocron，方法如下：

$ docker build -t my-gocron
$ docker run my-gocron

四、gocron時間輪

時間輪是一種用於處理定時任務的數據結構，gocron 也提供了一個時間輪來幫助您管理和執行定時任務。

以下是一個示例代碼：

package main

import (
	"fmt"

	"github.com/go-co-op/gocron"
	"github.com/go-co-op/gocron/internal/timingwheel"
)

func task() {
	fmt.Println("task running...")
}

func main() {
	// 創建一個時間輪
	tw := timingwheel.NewTimingWheel(time.Millisecond, 20)

	// 添加任務
	tw.Schedule(time.Millisecond*100, task)

	// 開始輪詢
	tw.Start()

	// 等待五秒鐘
	time.Sleep(5 * time.Second)

	// 停止任務
	tw.Stop()
}

在這個示例中，我們使用 timingwheel.NewTimingWheel(time.Millisecond, 20) 方法創建了一個新的時間輪，並使用 tw.Schedule(time.Millisecond*100, task) 方法創建了一個每 100 毫秒執行一次的任務。最後，我們使用 tw.Start() 方法開始輪詢，等待五秒鐘後停止任務。

五、gocron 10個任務

gocron 可以管理您的項目中的多個任務，因此讓我們來看一下如何使用 gocron 管理多個任務。

以下是一個示例代碼：

package main

import (
	"fmt"
	"time"

	"github.com/go-co-op/gocron"
)

func task1() {
	fmt.Println("task1 running...")
}

func task2() {
	fmt.Println("task2 running...")
}

func task3() {
	fmt.Println("task3 running...")
}

func task4() {
	fmt.Println("task4 running...")
}

func task5() {
	fmt.Println("task5 running...")
}

func task6() {
	fmt.Println("task6 running...")
}

func task7() {
	fmt.Println("task7 running...")
}

func task8() {
	fmt.Println("task8 running...")
}

func task9() {
	fmt.Println("task9 running...")
}

func task10() {
	fmt.Println("task10 running...")
}

func main() {
	// 創建一個新的調度器
	s := gocron.NewScheduler()

	// 添加任務
	s.
		Every(5).Seconds().
		Do(task1)

	s.
		Every(10).Seconds().
		Do(task2)

	s.
		Every(15).Seconds().
		Do(task3)

	s.
		Every(20).Seconds().
		Do(task4)

	s.
		Every(25).Seconds().
		Do(task5)

	s.
		Every(30).Seconds().
		Do(task6)

	s.
		Every(35).Seconds().
		Do(task7)

	s.
		Every(40).Seconds().
		Do(task8)

	s.
		Every(45).Seconds().
		Do(task9)

	s.
		Every(50).Seconds().
		Do(task10)

	// 開始任務
	<-s.StartAsync()
}

在這個示例中，我們使用 gocron.NewScheduler() 方法創建一個新的調度器，並使用 s.Every() 方法創建了多個任務。

六、gocron如何判斷已生成表

gocron 可以自動創建並管理定時任務表。如果您想檢查是否已經創建了表，請使用以下代碼：

package main

import (
	"database/sql"
	"fmt"

	"github.com/go-co-op/gocron"
	_ "github.com/mattn/go-sqlite3"
)

func main() {
	db, _ := sql.Open("sqlite3", "./test.db")
	defer db.Close()

	_, err := db.Exec(gocron.CreateTaskTable)
	if err != nil {
		fmt.Println("table already exists")
	} else {
		fmt.Println("table created")
	}
}

在這個示例中，我們使用 gocron.CreateTaskTable 常量來創建一個新表。

七、gocron分布式任務管理

gocron 還提供了分布式任務管理的功能，讓您可以更輕鬆地管理您的任務。

以下是一個示例代碼：

package main

import (
	"fmt"
	"time"

	"github.com/go-co-op/gocron"
	"github.com/go-co-op/gocron/leader"
)

func task() {
	fmt.Println("task running...")
}

func main() {
	// 創建一個新的調度器
	s := gocron.NewScheduler()

	// 添加任務
	s.Every(1).Minute().Do(task)

	// 加入分布式鎖
	lock, err := leader.NewElection("/my-lock", 30*time.Second)
	if err != nil {
		panic(err)
	}

	// 開始任務
	<-s.Start()
}

在這個示例中，我們使用 leader.NewElection(“/my-lock”, 30*time.Second) 方法為我們的任務添加了分布式鎖。

八、gocron webhook

gocron 還支持 webhook，讓您可以根據特定事件發送通知和執行其他操作。

以下是一個示例代碼：

package main

import (
	"fmt"
	"net/http"

	"github.com/go-co-op/gocron"
)

func task() {
	fmt.Println("task running...")
}

func handleWebhook(w http.ResponseWriter, r *http.Request) {
	s := gocron.NewScheduler()
	s.Every(10).Seconds().Do(task)
	<-s.StartAsync()

	fmt.Fprintf(w, "task started")
}

func main() {
	http.HandleFunc("/webhook", handleWebhook)
	http.ListenAndServe(":8080", nil)
}

在這個示例中，我們使用 gocron.NewScheduler() 和 s.Every(10).Seconds().Do(task) 方法來創建和啟動一個新的任務，並使用 http.HandleFunc(“/webhook”, handleWebhook) 方法來處理 webhook。

以上是 gocron 的一些特點和用法，希望本文對您有所幫助。