Go 言語で書かれたマイクロサービス タスク スケジューラ

Go 言語で書かれたマイクロサービス タスク スケジューラ

はじめに:
マイクロサービス アーキテクチャの人気に伴い、タスク スケジューラはさまざまなシステムの不可欠な部分となっています。必須コンポーネントです。タスクスケジューラを介して、タスクのスケジュール実行、タスクの依存関係の処理、タスクの実行結果の監視などの機能を実装できます。この記事では、Go 言語で書かれたマイクロサービス タスク スケジューラの実装方法を紹介し、コード例を通して説明します。

1. タスク スケジューリング モデルの設計

1. タスク モデル
   タスク スケジューラの中核はタスク スケジューリングであるため、最初にタスク モデルを定義する必要があります。タスクには次の属性を含めることができます。
2. ID: タスクを一意に識別するために使用される、タスクの一意の識別子。
3. 名前: タスクの名前。タスクを説明するために使用されます。
4. Cron: タスクのスケジュール期間。固定時間、間隔、または式にすることができます。
5. 依存関係: タスクの依存関係。タスクの先行タスクを示します。
6. ハンドラー: 特定のタスク ロジックを実行するために使用されるタスク処理関数。

次のコードを通じてタスク モデルを定義できます:

type Task struct {

ID           string
Name         string
Cron         string
Dependencies []string
Handler      func() error

}

2. タスク スケジューラ モデル
   タスクスケジューラには、タスクの追加、タスクの削除、タスクの実行、タスクの依存関係処理などの機能が必要です。タスク スケジューラのモデルは、次のコードを通じて定義できます。

type Scheduler struct {

m sync.Mutex
tasks map[string]*Task
dependencies map[string][]string

}

3. タスク スケジューラ メソッドの実装
   Connection 次に、タスク スケジューラ メソッドを実装する必要があります。次のコードを使用して、タスクの追加、タスクの削除、タスクの実行、タスクの依存関係の処理、およびその他の関数をタスク スケジューラに実行できます。

func (s Scheduler) AddTask(task Task) ) {

s.m.Lock()
defer s.m.Unlock()

s.tasks[task.ID] = task
// 处理任务依赖关系
for _, dependency := range task.Dependencies {
    s.dependencies[dependency] = append(s.dependencies[dependency], task.ID)
}

}

func (s *Scheduler) RemoveTask(タスクID 文字列) {

s.m.Lock()
defer s.m.Unlock()

task, ok := s.tasks[taskID]
if ok {
    delete(s.tasks, taskID)
    // 清理任务依赖关系
    for _, dependent := range s.dependencies[taskID] {
        dependentTask, ok := s.tasks[dependent]
        if ok {
            dependentTask.Dependencies = remove(dependentTask.Dependencies, taskID)
        }
    }
    delete(s.dependencies, taskID)
}

}

func (s *Scheduler) RunTask( taskID string) {

s.m.Lock()
defer s.m.Unlock()

task, ok := s.tasks[taskID]
if ok {
    err := task.Handler()
    if err != nil {
        fmt.Printf("Task %s failed to execute: %s

", taskID, err.Error())

    }
}

}

func (s *Scheduler) handleDependency(taskID string) {

dependentTasks, ok := s.dependencies[taskID]
if ok {
    for _, dependent := range dependentTasks {
        s.RunTask(dependent)
    }
}

}

func (s *Scheduler) RunAllTask​​s() {

s.m.Lock()
defer s.m.Unlock()

for _, task := range s.tasks {
    s.RunTask(task.ID)
}

}

コード分析:

• AddTask メソッドタスクをタスクに追加するために使用されます。 タスクをスケジューラに追加し、タスクの依存関係を処理します。
• RemoveTask メソッドは、タスク スケジューラからタスクを削除し、タスクの依存関係をクリーンアップするために使用されます。
• RunTask メソッドは、使用されますタスクを実行し、タスクの実行が失敗したことを示すエラー メッセージを出力します。
• handleDependency メソッドは、タスクの依存関係を処理する、つまり、指定されたタスクに依存するすべてのタスクを実行するために使用されます。
RunAllTask​​s メソッドは、実行スケジューラのすべてのタスクで使用されます。

2. 使用例

次は、マイクロサービス タスク スケジューラの使用方法を示す簡単な例です。

func main() {

scheduler := &Scheduler{
    tasks:        make(map[string]*Task),
    dependencies: make(map[string][]string),
}

// 初始化任务
task1 := &Task{
    ID:   "1",
    Name: "Task 1",
    Cron: "* * * * *", // 每分钟执行一次
    Handler: func() error {
        fmt.Println("Task 1 Executed")
        return nil
    },
}
task2 := &Task{
    ID:           "2",
    Name:         "Task 2",
    Cron:         "* * * * *", // 每分钟执行一次
    Dependencies: []string{"1"},
    Handler: func() error {
        fmt.Println("Task 2 Executed")
        return nil
    },
}

// 添加任务到任务调度器中
scheduler.AddTask(task1)
scheduler.AddTask(task2)

// 执行任务
scheduler.RunAllTasks()

// 删除任务
scheduler.RemoveTask("2")

// 再次执行任务
scheduler.RunAllTasks()

}

コード分析:

まず、タスク スケジューラ インスタンスを作成し、タスク スケジューラを初期化します。
• 次に、2 つのタスクを作成し、スケジューリング サイクル、タスクの依存関係、および処理機能を設定します。
• 次に、タスクをタスク スケジューラに追加します。
• 次に、タスク スケジューラのすべてのタスクを実行します。
• 最後に、タスクを削除し、タスク スケジューラのすべてのタスクを再度実行します。

概要:

この記事では、次の内容を紹介します。 Go言語で書かれたマイクロプロセッサ サービスタスクスケジューラの実装方法をコード例を用いて説明します タスクスケジューラを通じて、タスクのスケジュール実行、タスクの依存関係の処理、タスクの実行結果の監視などの機能を実装することができ、システムのマイクロサービス アーキテクチャ。強力なタスク スケジューリングのサポートを提供します。

以上がGo 言語で書かれたマイクロサービス タスク スケジューラの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。