java - 用于字符串处理的 Akka 分散-聚集

Question

我需要将输入字符串拆分为输出字符串(按一定顺序)通过在输入字符串上应用一组正则表达式。我想实现这个功能与 akka Actor 集群一起使用，我将其分散正则表达式和输入字符串并收集字符串。不过我想知道在收集处理后的字符串时，如何跟踪顺序。我不是确定“分散-聚集”是否是正确的方法，如果还有其他方法可以适合请推荐。

Answer 1

我猜你必须向收集者提供有关如何按顺序组装字符串的提示。您没有提及顺序是如何建立的:初始分割是否可以定义顺序，或者正则表达式处理是否可以定义顺序。

在这两种情况下，您都需要跟踪 3 件事:- 最初的来源，- 每件作品的顺序- 总件数

您可以使用如下消息:

case class StringSegment(id:String, total:Int, seqNr:Int, payload:String)

分散器根据输入生成StringSegment:

def scatter(s:String):List[StringSegment] ...
scatter(input).foreach(msg => processingActor ! msg)

收集者会将它们组装在一起，使用seqNr来了解顺序，使用total来了解所有碎片何时出现。