f# - 使用 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

有三种指定散列键的方法。我最喜欢的是从属性中实现IConsistentHashable并返回键（基于消息的某些属性）ConsistentHashKey。

我的 Consistent Hashing 文章的示例摘录（在 C# 中；抱歉我不知道 F#）：

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

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

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