就使用 Service Fabric 编写批处理器而言，最好的方法是什么？

Question

我们需要能够处理存储过程的结果记录集。每条记录的处理都是相同的，我们希望有多线程并且不会遇到任何锁定。你会在这里推荐演员还是有状态的？

Answer 1

没有更多信息的粗略回答：

创建一个有状态服务来接收处理记录集的请求（包括要处理的记录集，或获取记录集的过程，或将其存储在某个地方以便可以调用它）。然后，在有状态服务内部，遍历记录集，将处理解析到各个参与者。如果您不关心有多少参与者，您可以生成随机 ID，或者您可以将处理限制为有限集。如果选择前者，则必须考虑规模——多少个处理器可以安全地同时运行而无需横向扩展？如果您使用后者，您需要在 Actor 中进行某种队列处理或发布/订阅基础设施，以便您可以分担工作并确保一切都完成。