Go 异步任务队列:Go Machinery

pjp 4年前

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

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

Go 异步任务队列:Go Machinery

任务的定义:

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)

项目主页:http://www.open-open.com/lib/view/home/1431304478747