Machinery —— Go 语言异步任务队列

Machinery 是一个 Go 语言的异步任务队列和作业队列，基于分布式消息传递。类似 Python 的 Celery 框架。

Machinery 中的任务（或者作业）可通过多个 worker 在很多服务器上并发的执行，或者可在单个服务器上利用 Go 的协程运行多个 worker 进程。

任务的定义：

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

任务注册：

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

文章转载自 开源中国社区 [

Machinery 是一个 Go 语言的异步任务队列和作业队列，基于分布式消息传递。类似 Python 的 Celery 框架。 Machinery 中的任务（或者作业）可通过多个 worker 在很多服务器上并发的执行，或者可在单个服务器上利用 Go 的协程运行多个 worker 进程。 https://yqfile.alicdn.com/43afdd81f474151bfe99d8fbbb20a926297217b3.png" > 任务的定义： 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 任务注册： tasks := map[string]machinery.Task{ "add": AddTask{}, "multiply": MultiplyTask{}, } app.RegisterTasks(tasks) 文章转载自 开源中国社区 [