如何启动多个Machinery worker？

Question

我是golang Machinery的新手，下面是doc上启动workers的代码machinery workers

worker := server.NewWorker("worker_name", 10)
err := worker.Launch()
if err != nil {
  // do something with the error
}

我的第一个问题是，server.NewWorker("worker_name", 10) 是否启动 10 个工人？或者它意味着其他东西，如果不是，我如何在需要时启动 10 个工人，运行 go run example/machinery.go worker 10 次？

我的第二个问题是关于第一个参数consumerTag，请问哪里可以找到使用的地方标签？

谢谢

Answer 1

不，这一行：

worker := server.NewWorker("worker_name", 10)

开始一个新的工人。您需要 运行 多个实例来启动新工作程序。 10 是特定 worker 将 运行ning 的并发 goroutines 的数量。如果队列中有 10 个任务，它们可以同时 运行。

对于标签，您需要检查代码库中每个代理的具体实现。