Akka.NET实现周期发数TCP服务器的死信及EventStream使用问题求助

问题1：Tcp.Bound消息进入DeadLetters排查 #

你能正常收到Tcp.Connected消息说明ProcessingServer本身运行正常、端口绑定成功，出现DeadLetters的常见原因如下：

1. 消息处理逻辑未正确注册：部分旧版本的Akka.NET中，ReceiveActor.Receive方法的重载如果直接传入私有方法，可能出现方法匹配失败的问题，导致你以为注册了Tcp.Bound的处理逻辑，实际并未生效。Actor收到未匹配处理规则的消息时，会将其标记为未处理，最终进入DeadLetters。
   修复方式建议直接用lambda表达式注册处理逻辑，避免方法匹配问题：

public ProcessingServer()
{ 
    Receive<Tcp.Bound>(bound => 
    {
        Console.WriteLine("Listening on {0}", bound.LocalAddress);
    });
    Receive<Tcp.Connected>(connected => 
    {
        var tcpConnection = Sender; 
        var connectionHandler = Context.ActorOf(SensorReader.CreateReader(tcpConnection));
        tcpConnection.Tell(new Tcp.Register(connectionHandler));
    });
}

2. API参数匹配错误：你可以为Tcp.Bind的参数加上显式参数名，避免不同版本API参数顺序变化导致的传值错误：

tcpManager.Tell(new Tcp.Bind(
    handler: server, 
    localAddress: new IPEndPoint(IPAddress.Any, 10002)));

如果需要进一步排查，可以开启Akka的调试日志，查看消息流转的具体情况：

var config = ConfigurationFactory.ParseString(@"
akka {
    loglevel = DEBUG
    io.tcp.log-received-messages = on
}");
_sys = ActorSystem.Create("tcp-processing", config);

问题2：EventStream Publish未生效原因 #

你的使用方式存在两处明显错误：

1. 消息类型不匹配：SensorReader中注册的接收消息类型是SensorDataReceived，但你调用Publish发送的是SensorData类型，两者类型不一致，Actor自然无法匹配到处理逻辑。
2. 未显式订阅EventStream：Akka的EventStream是显式订阅模式，仅在Actor中定义接收逻辑不会自动收到EventStream的消息，你需要手动订阅对应类型的消息。

修复代码： #

首先统一两边的消息类型，我们以发送和接收都用SensorData为例，修改SensorReader的代码：

internal class SensorReader : ReceiveActor
{
    private readonly IActorRef _tcpConnection;

    public SensorReader(IActorRef tcpConnection)
    {
        _tcpConnection = tcpConnection;
        // 启动时订阅EventStream的SensorData消息
        Context.System.EventStream.Subscribe(Self, typeof(SensorData));
        Receive<SensorData>(TcpWriteSensorData);
    }

    internal static Props CreateReader(IActorRef connectionHandler)
    {
        return Props.Create(() => new SensorReader(connectionHandler));
    }

    // 重写停止方法，取消订阅避免内存泄漏
    protected override void PostStop()
    {
        Context.System.EventStream.Unsubscribe(Self);
        base.PostStop();
    }

    private void TcpWriteSensorData(SensorData receivedData)
    {
        _tcpConnection.Tell(Tcp.Write.Create(ByteString.FromString(receivedData.SensorData + "\n")));
    }
}

修改后每个客户端连接时创建的SensorReader都会自动收到EventStream推送的SensorData消息，并转发给对应TCP客户端，符合你的需求。

内容的提问来源于stack exchange，提问作者Romesh D. Niriella