其他-如何在Akka中使用元组发送消息。使用F＃进行远程处理？

(其他 - How to send a message with tuples in Akka.Remote with F#?)

发布于 2020-12-01 02:52:05

我正在尝试使用F＃中的remote发送消息，但是我一直遇到这个问题，即永远不会发送带有类型的消息。当我使用下面给出的代码时：

Server.fsx

#r "nuget: Akka.FSharp" 
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"



open System
open Akka.FSharp
open Akka.Remote
open Akka.Configuration

let configuration = 
    ConfigurationFactory.ParseString(
        @"akka {
            actor {
                provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
                debug : {
                    receive : on
                    autoreceive : on
                    lifecycle : on
                    event-stream : on
                    unhandled : on
                }
            }
            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()
        printfn "%s" message
    }
    loop ()

let serveRef = spawn serversystem "server" server
Console.ReadLine() |> ignore

客户端文件

#r "nuget: Akka.FSharp" 
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"

open System
open Akka.FSharp
open Akka.Remote
open Akka.Configuration

let configuration = 
    ConfigurationFactory.ParseString(
        @"akka {
            actor {
                provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
                
            }
            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 <! "Register"
Console.ReadLine()

消息已发送，我可以在服务器终端上看到“注册”字样。但是，当我尝试使用要发送的特定类型的消息时，就会出现问题。
服务器终端上的输出：

[INFO][12/1/2020 2:37:43 AM][Thread 0001][remoting (akka://Server)] Starting remoting
[INFO][12/1/2020 2:37:43 AM][Thread 0001][remoting (akka://Server)] Remoting started; listening on addresses : [akka.tcp://Server@192.168.0.94:9002]
[INFO][12/1/2020 2:37:43 AM][Thread 0001][remoting (akka://Server)] Remoting now listens on addresses: [akka.tcp://Server@192.168.0.94:9002]
Register

现在的代码是

Server.fsx

#r "nuget: Akka.FSharp" 
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"
#load "Message.fsx"

open Message
open System
open Akka.FSharp
open Akka.Remote
open Akka.Configuration

let configuration = 
    ConfigurationFactory.ParseString(
        @"akka {
            actor {
                provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
                debug : {
                    receive : on
                    autoreceive : on
                    lifecycle : on
                    event-stream : on
                    unhandled : on
                }
            }
            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) -> printfn "Got a number %d" num
    }
    loop ()

let serveRef = spawn serversystem "server" server
Console.ReadLine() |> ignore

客户端文件

#r "nuget: Akka.FSharp" 
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"
#load "Message.fsx"

open Message
open System
open Akka.FSharp
open Akka.Remote
open Akka.Configuration

let configuration = 
    ConfigurationFactory.ParseString(
        @"akka {
            actor {
                provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
                
            }
            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(10)
Console.ReadLine()

Message.fsx

type Message = 
              | Message of int

在这种情况下，该消息永远不会被打印。在发送之前，我们需要对消息进行序列化吗？如果是，那该怎么办呢？否则，我在做什么错？任何帮助表示赞赏。

Questioner

Rajath Ganesh

Viewed

Original

English

#load "Message.fsx" open Message open System open Akkling let configuration = Configuration.parse @"akka { actor { provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote"" debug : { receive : on autoreceive : on lifecycle : on event-stream : on unhandled : on } } remote { helios.tcp { port = 9002 hostname = localhost } } }" let serversystem = System.create "Server" configuration let rec server = function | Message(num) -> printfn "Got a number %d" num become server let serveRef = spawn serversystem "server" <| props(actorOf server) Console.ReadLine() |> ignore

#load "Message.fsx" open Message open System open Akkling let configuration = Configuration.parse @"akka { actor { provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote"" } remote { helios.tcp { port = 2552 hostname = localhost } } }" let clientSystem = System.create "client" configuration let serveRef = select clientSystem "akka.tcp://Server@localhost:9002/user/server" serveRef <! Message(10) Console.ReadLine()

其他-如何在Akka中使用元组发送消息。使用F＃进行远程处理？

(其他 - How to send a message with tuples in Akka.Remote with F#?)

热门帖子

热门github