在机器（go）中路由任务的最佳方式是什么？

在使用机器（Go）作为分布式任务队列时，可以为不同任务组部署单独的工作人员。通过在任务签名中设置 routingkey 字段并使用 taskserver.newcustomqueueworker 获取队列特定的工作对象，可以将任务路由到特定队列。然后，工作人员可以从特定队列中消费任务，从而实现任务组隔离。

我正在尝试使用机器作为分布式任务队列，并希望为不同的任务组部署单独的工作人员。例如。在数据库服务器旁边有一个工作线程运行数据库相关任务，并且在不同服务器上有多个工作线程运行 cpu/内存密集型任务。只是文档并不清楚如何做到这一点。

我最初尝试运行工作人员而不向其注册不需要的任务，但这导致工作人员重复使用未注册的任务并使用以下消息将其重新排队：

INFO: 2022/01/27 08:33:13 redis.go:342 Task not registered with this worker. Requeuing message: {"UUID":"task_7026263a-d085-4492-8fa8-e4b83b2c8d59","Name":"add","RoutingKey":"","ETA":null,"GroupUUID":"","GroupTaskCount":0,"Args":[{"Name":"","Type":"int32","Value":2},{"Name":"","Type":"int32","Value":4}],"Headers":{},"Priority":0,"Immutable":false,"RetryCount":0,"RetryTimeout":0,"OnSuccess":null,"OnError":null,"ChordCallback":null,"BrokerMessageGroupId":"","SQSReceiptHandle":"","StopTaskDeletionOnError":false,"IgnoreWhenTaskNotRegistered":false}

我怀疑可以通过将 ignorewhentasknotregistered 设置为 true 来解决此问题，但这似乎不是一个非常优雅的解决方案。

任务签名还具有 routingkey 字段，但文档中没有有关如何将工作线程配置为仅使用特定路由键中的任务的信息。

此外，另一种解决方案是拥有单独的机器任务服务器，但这会剥夺在工作人员之间使用工作流程和编排任务的能力。

正确答案

通过一些尝试和错误找到了解决方案。

将 ignorewhentasknotregistered 设置为 true 不是正确的解决方案，因为与我最初的想法不同，工作线程仍然消耗未注册的任务，然后丢弃它而不是重新排队。

路由任务的正确方法是将任务签名中的 routingkey 设置为所需队列的名称，并使用 taskserver.newcustomqueueworker 来获取队列特定的工作对象，而不是 taskserver.newworker

将任务发送到特定队列：

task := tasks.signature{
    name: "<taskname>",
    routingkey: "<queue>",
    args: []tasks.arg{
        // args...
    },
}

res, err := taskserver.sendtask(&task)
if err != nil {
    // handle error
}

并启动工作人员从特定队列中进行消费：

worker := taskserver.NewCustomQueueWorker("<WORKERNAME>", concurrency, "<QUEUE>")
if err := worker.Launch(); err != nil {
    // handle error
}

仍然不太确定如何告诉工作人员从一组队列中使用，因为 newcustomqueueworker 只接受单个字符串作为队列名称，但这是一个相对较小的细节。

到这里，我们也就讲完了《在机器（go）中路由任务的最佳方式是什么？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！