Warm tip: This article is reproduced from serverfault.com, please click

其他-Akka.Remote F#序列化仅适用于有区别的联合的第一个字段

(其他 - Akka.Remote F# Serialization works only on the first field of a discriminated union)

发布于 2020-12-02 20:48:21

要将区分的并集字段发送到远程角色,我使用Hyperion作为序列化程序,但它似乎仅对第一个字段进行序列化,而未对其余部分进行序列化。示例代码如下:

Server.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

客户端文件

#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()

Message.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

因此,似乎只有第一个字段被序列化为一个有区别的联合。如何克服呢?

Questioner
Rajath Ganesh
Viewed
11
neil danson 2020-12-03 05:29:41

你的演员没有循环播放,因此在第一个消息后终止

添加一个

return! loop()

你的递归循环中。

我认为这个问题有些令人困惑。它指出第一个字段已打印,但所有字段都出现在打印输出中。我想你的意思只是第一句话

c#示例中的Akka不需要循环,但是Akka.fsharp与MailboxProxessor语法匹配,因此需要显式循环。