0

在 Akka.Net 中,我们可以从 Tcp actor 派生 TcpStream actor 吗?

我使用创建了一个 Tcp 演员

Context.System.Tcp().Tell(new IoTcp.Connect(endPoint));

然后我将自己注册为处理程序

Sender.Tell(new IoTcp.Register(Self, true, true));

端点代表一个普通的远程 Tcp 套接字,而不是一个 Tcp 流参与者。

然后我订阅收到的消息

private void OnReceived(IoTcp.Received message)
{
    // pass message.Data to a flow to materialize
}

如何通过定义自定义框架逻辑的 Flow 将 Received 消息作为流使用?

我可以使用创建连接吗

var connection = Context.System.TcpStream().OutgoingConnection("",0);
4

0 回答 0