Go Machinery 介绍
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)
Go Machinery 官网
https://github.com/RichardKnop/machinery
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
