f# - Akka.Remote F# 序列化仅适用于有区别的联合的第一个字段
问题描述
要将区分联合字段发送到远程参与者,我使用 Hyperion 作为序列化程序,但它似乎只序列化第一个字段,但不序列化联合的其余部分。示例代码如下:
服务器.fsx
#r "nuget: Akka.FSharp"
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"
#r "nuget: Akka.Serialization.Hyperion"
#load "Message.fsx"
open Message
open System
open Akka.FSharp
open Akka.Remote
open Akka.Configuration
open Akka.Serialization
let configuration =
ConfigurationFactory.ParseString(
@"akka {
actor {
provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
debug : {
receive : on
autoreceive : on
lifecycle : on
event-stream : on
unhandled : on
}
serializers {
hyperion = ""Akka.Serialization.HyperionSerializer, Akka.Serialization.Hyperion""
}
serialization-bindings {
""System.Object"" = hyperion
}
}
remote {
helios.tcp {
port = 9002
hostname = 192.168.0.94
}
}
}")
let serversystem = System.create "Server" configuration
let server (mailbox:Actor<_>) =
let rec loop () = actor {
let! message = mailbox.Receive()
match message with
| Message(num, num1, str) -> printfn "Got a number %d %d %s" num num1 str
| CreateDone(num, num1, str) -> printfn "Got a create %d %d %s" num num1 str
}
loop ()
let serveRef = spawn serversystem "server" server
Console.ReadLine() |> ignore
客户端.fsx
#r "nuget: Akka.FSharp"
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"
#r "nuget: Akka.Serialization.Hyperion"
#load "Message.fsx"
open Message
open System
open Akka.FSharp
open Akka.Remote
open Akka.Configuration
open Akka.Serialization
let configuration =
ConfigurationFactory.ParseString(
@"akka {
actor {
provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
serializers {
hyperion = ""Akka.Serialization.HyperionSerializer, Akka.Serialization.Hyperion""
}
serialization-bindings {
""System.Object"" = hyperion
}
}
remote {
helios.tcp {
port = 2552
hostname = localhost
}
}
}")
let clientSystem = System.create "client" configuration
let serveRef = select ("akka.tcp://Server@192.168.0.94:9002/user/server") clientSystem
serveRef <! Message(10L, 20, "Hello")
serveRef <! CreateDone(10L, 20, "Hi")
Console.ReadLine()
消息.fsx
type Message = Message of int64 * int * string
| CreateDone of int64 * int * string
服务器的输出是:
F:\UF\Courses\FALL2020\DOS\Projects\Project4.1>dotnet fsi --langversion:preview serve.fsx
[INFO][12/2/2020 1:42:13 AM][Thread 0001][remoting (akka://Server)] Starting remoting
[INFO][12/2/2020 1:42:13 AM][Thread 0001][remoting (akka://Server)] Remoting started; listening on addresses : [akka.tcp://Server@192.168.0.94:9002]
[INFO][12/2/2020 1:42:13 AM][Thread 0001][remoting (akka://Server)] Remoting now listens on addresses: [akka.tcp://Server@192.168.0.94:9002]
Got a number 10 20 Hello
所以似乎只有第一个字段在有区别的联合中被序列化。如何克服这一点?
解决方案
你的演员没有循环,所以在第一条消息后终止
添加一个
return! loop()
在你的递归循环内。
我认为这个问题有点令人困惑。它声明第一个字段已打印,但所有字段都存在于打印输出中。我假设您的意思只是第一条消息
C# 示例中的 Akka 不需要循环,但 Akka.fsharp 匹配 MailboxProxessor 语法,因此需要显式循环。
推荐阅读
- python - 如何通过优雅的编码更快地将一些逻辑应用于数据框列
- karate - 空手道使用模式匹配验证多个可能的值
- java - 在 jre/bin 目录中找不到 javaws.exe
- amazon-web-services - How to call a grpc service running on ec2 from aws lambda
- python - Python程序不会读取文本文件中的新行
- node.js - 我可以用作 webpack 配置的 es-modules 吗?
- time-complexity - 内循环只运行一次时嵌套循环的时间复杂度?
- java - SendKeys() 仅在我的表单的一个字段中不起作用
- javascript - 嘿,我正在尝试将 2 个条件放在一个 if 语句中。一个在 Javascript 中,一个在 PHP 中
- tensorflow - 使用 GPU 的自组织地图