使用Hocon时如何指定HashMapping

Question

鉴于下面的 HOCON consitent-hashing-pool 路由器，我该如何指定 hashMapping。

    akka {
      actor {
        serializers {
          wire = "Akka.Serialization.WireSerializer, Akka.Serialization.Wire"
        }
        serialization-bindings {
          "System.Object" = wire
        }
        deployment {
          /data-collector {
            router = consistent-hashing-pool
            nr-of-instances = 10
          }
        }
      }
      loggers = ["Akka.Logger.NLog.NLogLogger,Akka.Logger.NLog"]
    }

给定

let config = Configuration.load()
let systemName = config.GetString("app-config.actorsystem", "my-system")
let system = System.create systemName config
let collectorRouter = 
  let hashMapping (msg:obj) =
    match msg with
    | :? Message as msg ->
        match msg with
        | Parse (_, req) -> req.uniqueId |> box
    | _ -> "-" |> box
  ConsistentHashingPool (10, ConsistentHashMapping hashMapping)
let dataCollectorProps = 
  { props (dataCollector settings.collector) with
      Router = Some (collectorRouter :> RouterConfig)} //(FromConfig.Instance.WithFallback collectorRouter)
let test = spawn system "data-collector" <| dataCollectorProps

Router = Some (collectorRouter :> RouterConfig) 工作

Router = Some (FromConfig.Instance.WithFallback collectorRouter) 没有

指定 hashMapping 函数的正确方法是什么？

编辑 1 来自控制台的警告是

Akka.Routing.ConsistentHashingRoutingLogic|Message [Message] must be handled by hashMapping, or implement [IConsistentHashable] or be wrapped in [ConsistentHashableEnvelope]

Answer 1

有three ways of specifying the hash key个。我最喜欢的是实现 IConsistentHashable 和 return 来自 ConsistentHashKey 属性.

的密钥（基于消息的某些属性）

摘自 my Consistent Hashing article 的示例（在 C# 中；抱歉，我不懂 F#）：

public class CurrencyPriceChangeMessage : IConsistentHashable
{
    public string CurrencyPair { get; }
    public decimal Price { get; }

    public object ConsistentHashKey
    {
        get
        {
            return this.CurrencyPair;
        }
    }

哈希键将用于将具有相同键的消息始终路由到相同的路由。

使用Hocon时如何指定HashMapping

How to specify HashMapping when using Hocon

f#

akka.net

hocon