Go MachineryGo 異步任務(wù)隊(duì)列

Machinery 是一個(gè) Go 語(yǔ)言的異步任務(wù)隊(duì)列和作業(yè)隊(duì)列，基于分布式消息傳遞。類似 Python 的 Celery 框架。

Machinery 中的任務(wù)（或者作業(yè)）可通過(guò)多個(gè) worker 在很多服務(wù)器上并發(fā)的執(zhí)行，或者可在單個(gè)服務(wù)器上利用 Go 的協(xié)程運(yùn)行多個(gè) worker 進(jìn)程。

任務(wù)的定義：

type AddTask struct{}

func (t AddTask) Run(args []interface{}) (interface{}, error) {
    parsedArgs, err := machinery.ParseNumberArgs(args)
    if err != nil {
        return nil, err
    }

    add := func(args []float64) float64 {
        sum := 0.0
        for _, arg := range args {
            sum += arg
        }
        return sum
    }

    return add(parsedArgs), nil
}

type MultiplyTask struct{}

func (t MultiplyTask) Run(args []interface{}) (interface{}, error) {
    parsedArgs, err := machinery.ParseNumberArgs(args)
    if err != nil {
        return nil, err
    }

    multiply := func(args []float64) float64 {
        sum := 1.0
        for _, arg := range args {
            sum *= arg
        }
        return sum
    }

    return multiply(parsedArgs), nil
}

// ... more tasks

任務(wù)注冊(cè)：

tasks := map[string]machinery.Task{
    "add":      AddTask{},
    "multiply": MultiplyTask{},
}
app.RegisterTasks(tasks)