【发布时间】:2017-03-16 10:10:58
【问题描述】:
我有一个 JSON 编码的消息流,我想根据消息中的字段将它们分发给一组演员或演员系统,所以更像是 hash(key)->演员,但是当演员死时我想能够将密钥散列到可用的不同 Actor,但在任何给定的情况下,密钥的散列应该始终转到同一个 Actor。请告诉我如何使用 Akka 实现这一目标?
【问题讨论】:
标签: akka
我有一个 JSON 编码的消息流,我想根据消息中的字段将它们分发给一组演员或演员系统,所以更像是 hash(key)->演员,但是当演员死时我想能够将密钥散列到可用的不同 Actor,但在任何给定的情况下,密钥的散列应该始终转到同一个 Actor。请告诉我如何使用 Akka 实现这一目标?
【问题讨论】:
标签: akka
也许你想试试 ConsistentHashingPool 和 ConsistentHashingGroup 一致哈希池。它使用一致性哈希根据发送的消息选择路由。
【讨论】: