在 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);