欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

利用Go語言快速實現(xiàn)一個極簡任務(wù)調(diào)度系統(tǒng)

 更新時間:2022年10月04日 08:37:41   作者:MarvinZhang  
任務(wù)調(diào)度(Task Scheduling)是很多軟件系統(tǒng)中的重要組成部分,字面上的意思是按照一定要求分配運行一些通常時間較長的腳本或程序。本文將利用Go語言快速實現(xiàn)一個極簡任務(wù)調(diào)度系統(tǒng),感興趣的可以了解一下

引子

任務(wù)調(diào)度(Task Scheduling)是很多軟件系統(tǒng)中的重要組成部分,字面上的意思是按照一定要求分配運行一些通常時間較長的腳本或程序。在爬蟲管理平臺 Crawlab 中,任務(wù)調(diào)度是其中的核心模塊,相信不少朋友會好奇如何編寫一個任務(wù)調(diào)度系統(tǒng)。本篇文章會教讀者用 Go 語言編寫一個非常簡單的任務(wù)調(diào)度系統(tǒng)。

思路

我們首先理清一下思路,開發(fā)最小化任務(wù)調(diào)度器需要什么。

  • 交互界面(API)
  • 定時任務(wù)(Cron)
  • 任務(wù)執(zhí)行(Execute Tasks)

整個流程如下:

我們通過 API 創(chuàng)建定時任務(wù),執(zhí)行器根據(jù)定時任務(wù)標(biāo)準(zhǔn)定期執(zhí)行腳本。

實戰(zhàn)

交互界面

首先我們來搭個架子。在項目目錄下創(chuàng)建一個 main.go 文件,并輸入以下內(nèi)容。其中 gin 是非常流行的 Go 語言 API 引擎。

package main
?
import (
  "fmt"
  "github.com/gin-gonic/gin"
  "os"
)
?
func main() {
  // api engine
  app := gin.New()
?
  // api routes
  app.GET("/jobs", GetJobs)
  app.POST("/jobs", AddJob)
  app.DELETE("/jobs", DeleteJob)
?
  // run api on port 9092
  if err := app.Run(":9092"); err != nil {
    _, err = fmt.Fprintln(os.Stderr, err)
    os.Exit(1)
  }
}

然后添加 api.go 文件,輸入以下內(nèi)容,注意,這里沒有任何代碼實現(xiàn),只是加入了占位區(qū)域。

package main
?
import "github.com/gin-gonic/gin"
?
func GetJobs(c *gin.Context) {
  // TODO: implementation here
}
?
func AddJob(c *gin.Context) {
  // TODO: implementation here
}
?
func DeleteJob(c *gin.Context) {
  // TODO: implementation here
}

定時任務(wù)

然后是任務(wù)調(diào)度的核心,定時任務(wù)。這里我們使用 robfig/cron,Go 語言比較流行的定時任務(wù)庫。

現(xiàn)在創(chuàng)建 cron.go 文件,輸入以下內(nèi)容。其中 Cron 就是 robfig/cron 庫中的 Cron 類生成的實例。

package main
?
import "github.com/robfig/cron"
?
func init() {
  // start to run
  Cron.Run()
}
?
// Cron create a new cron.Cron instance
var Cron = cron.New()

現(xiàn)在創(chuàng)建好了主要定時任務(wù)實例,就可以將核心邏輯添加在剛才的 API 占位區(qū)域了。

同樣是 api.go ,將核心代碼添加進來。

package main
?
import (
  "github.com/gin-gonic/gin"
  "github.com/robfig/cron/v3"
  "net/http"
  "strconv"
)
?
func GetJobs(c *gin.Context) {
  // return a list of cron job entries
  var results []map[string]interface{}
  for _, e := range Cron.Entries() {
    results = append(results, map[string]interface{}{
      "id":   e.ID,
      "next": e.Next,
    })
  }
  c.JSON(http.StatusOK, Cron.Entries())
}
?
func AddJob(c *gin.Context) {
  // post JSON payload
  var payload struct {
    Cron string `json:"cron"`
    Exec string `json:"exec"`
  }
  if err := c.ShouldBindJSON(&payload); err != nil {
    c.AbortWithStatus(http.StatusBadRequest)
    return
  }
?
  // add cron job
  eid, err := Cron.AddFunc(payload.Cron, func() {
    // TODO: implementation here
  })
  if err != nil {
    c.AbortWithStatusJSON(http.StatusInternalServerError, map[string]interface{}{
      "error": err.Error(),
    })
    return
  }
?
  c.AbortWithStatusJSON(http.StatusOK, map[string]interface{}{
    "id": eid,
  })
}
?
func DeleteJob(c *gin.Context) {
  // cron job entry id
  id := c.Param("id")
  eid, err := strconv.Atoi(id)
  if err != nil {
    c.AbortWithStatus(http.StatusBadRequest)
    return
  }
?
  // remove cron job
  Cron.Remove(cron.EntryID(eid))
?
  c.AbortWithStatus(http.StatusOK)
}

在這段代碼中,我們實現(xiàn)了大部分邏輯,只在 AddJobCron.AddFunc 中第二個參數(shù)里,剩下最后一部分執(zhí)行任務(wù)的代碼。下面將來實現(xiàn)一下。

任務(wù)執(zhí)行

現(xiàn)在需要添加任務(wù)執(zhí)行的代碼邏輯,咱們創(chuàng)建 exec.go 文件,輸入以下內(nèi)容。這里我們用到了 Go 語言內(nèi)置的 shell 運行管理庫 os/exec,可以執(zhí)行任何 shell 命令。

package main
?
import (
  "fmt"
  "os"
  "os/exec"
  "strings"
)
?
func ExecuteTask(execCmd string) {
  // execute command string parts, delimited by space
  execParts := strings.Split(execCmd, " ")
?
  // executable name
  execName := execParts[0]
?
  // execute command parameters
  execParams := strings.Join(execParts[1:], " ")
?
  // execute command instance
  cmd := exec.Command(execName, execParams)
?
  // run execute command instance
  if err := cmd.Run(); err != nil {
    _, err = fmt.Fprintln(os.Stderr, err)
    fmt.Println(err.Error())
  }
}

好了,現(xiàn)在我們將這部分執(zhí)行代碼邏輯放到之前的占位區(qū)域中。

...
  // add cron job
  eid, _ := Cron.AddFunc(payload.Cron, func() {
    ExecuteTask(payload.Exec)
  })
...

代碼效果

OK,大功告成!現(xiàn)在我們可以試試運行這個極簡的任務(wù)調(diào)度器了。

在命令行中敲入 go run .,API 引擎就啟動起來了。

[GIN-debug] [WARNING] Running in "debug" mode. Switch to "release" mode in production.
 - using env:   export GIN_MODE=release
 - using code:  gin.SetMode(gin.ReleaseMode)
?
[GIN-debug] GET    /jobs                     --> main.GetJobs (1 handlers)
[GIN-debug] POST   /jobs                     --> main.AddJob (1 handlers)
[GIN-debug] DELETE /jobs/:id                 --> main.DeleteJob (1 handlers)
[GIN-debug] [WARNING] You trusted all proxies, this is NOT safe. We recommend you to set a value.
Please check https://pkg.go.dev/github.com/gin-gonic/gin#readme-don-t-trust-all-proxies for details.
[GIN-debug] Listening and serving HTTP on :9092

現(xiàn)在打開另一個命令行窗口,輸入 curl -X POST -d '{"cron":"* * * * *","exec":"touch /tmp/hello.txt"}' http://localhost:9092/jobs,會得到如下返回結(jié)果。表示已經(jīng)生成了相應(yīng)的定時任務(wù),任務(wù) ID 為 1,每分鐘跑一次,會更新一次 /tmp/hello.txt。

{"id":1}

在這個命令行窗口中輸入 curl http://localhost:9092/jobs

[{"id":1,"next":"2022-10-03T12:46:00+08:00"}]

這表示下一次執(zhí)行是 1 分鐘之后。

等待一分鐘,執(zhí)行 ls -l /tmp/hello.txt,得到如下結(jié)果。

-rw-r--r--  1 marvzhang  wheel     0B Oct  3 12:46 /tmp/hello.txt

也就是說,執(zhí)行成功了,大功告成!

總結(jié)

本篇文章通過將 Go 語言幾個庫簡單組合,就開發(fā)出了一個極簡的任務(wù)調(diào)度系統(tǒng)。所用到的核心庫:

整個代碼示例倉庫在 GitHub 上: https://github.com/tikazyq/codao-code/tree/main/2022-10/go-task-scheduler

到此這篇關(guān)于利用Go語言快速實現(xiàn)一個極簡任務(wù)調(diào)度系統(tǒng)的文章就介紹到這了,更多相關(guān)Go語言實現(xiàn)任務(wù)調(diào)度系統(tǒng)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Go語言Gin處理響應(yīng)方式詳解

    Go語言Gin處理響應(yīng)方式詳解

    gin框架封裝了常用的數(shù)據(jù)格式方法響應(yīng)于客戶端,下面這篇文章主要給大家介紹了關(guān)于Go語言Gin處理響應(yīng)方式的相關(guān)資料,文中通過圖文介紹的非常詳細,需要的朋友可以參考下
    2023-01-01
  • Go語言實現(xiàn)漢諾塔算法

    Go語言實現(xiàn)漢諾塔算法

    之前的文章,我們給大家分享了不少漢諾塔算法的實現(xiàn)語言,包括C、c++、java、python等,今天我們就來使用go語言來實現(xiàn)一下,需要的小伙伴來參考下吧。
    2015-03-03
  • 線上golang grpc服務(wù)資源泄露問題排查

    線上golang grpc服務(wù)資源泄露問題排查

    這篇文章主要介紹了線上golang grpc服務(wù)資源泄露問題排查,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-12-12
  • web項目中g(shù)olang性能監(jiān)控解析

    web項目中g(shù)olang性能監(jiān)控解析

    這篇文章主要為大家介紹了web項目中g(shù)olang性能監(jiān)控詳細的解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步早日升職加薪
    2022-04-04
  • Go語言實現(xiàn)請求超時處理的方法總結(jié)

    Go語言實現(xiàn)請求超時處理的方法總結(jié)

    這篇文章主要為大家詳細介紹了Go語言中實現(xiàn)請求的超時控制的方法,主要是通過timer和timerCtx來實現(xiàn)請求的超時控制,希望對大家有所幫助
    2023-05-05
  • Go語言狀態(tài)機的實現(xiàn)

    Go語言狀態(tài)機的實現(xiàn)

    本文主要介紹了Go語言狀態(tài)機的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-03-03
  • golang?http請求未釋放造成的錯誤問題

    golang?http請求未釋放造成的錯誤問題

    這篇文章主要介紹了golang?http請求未釋放造成的錯誤問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-01-01
  • golang配置管理神器Viper使用教程

    golang配置管理神器Viper使用教程

    這篇文章主要為大家介紹了golang配置管理神器Viper使用教程,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步早日升職加薪
    2022-04-04
  • Go Uber靜態(tài)分析工具NilAway使用初體驗

    Go Uber靜態(tài)分析工具NilAway使用初體驗

    這篇文章主要介紹了Go Uber靜態(tài)分析工具NilAway使用詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2024-01-01
  • GoLang編程必備:GoFrame?GoLand插件介紹

    GoLang編程必備:GoFrame?GoLand插件介紹

    掌握GoLang編程必備工具,我們來深入了解GoFrame?GoLand插件,這個小巧但強大的插件將極大提升你的開發(fā)效率,讓代碼流暢如行云流水,一起跟隨本指南,解鎖更智能的編程之旅!
    2023-12-12

最新評論