c# - 如何在 C# 中获取异步 TCP 对象流？

Question

我对序列化很陌生，所以请多多包涵。

我希望我的应用程序的两个实例通过 Internet 相互通信。我已经成功地建立了 TCP 客户端/服务器关系，并使用二进制格式化程序让双方交换一对消息。这是客户端...

using (TcpClient clientSocket = new TcpClient(ipAddress, currentPort))
{
    using (NetworkStream stream = clientSocket.GetStream())
    {
        // send
        bformatter.Serialize(stream, new Message());

        // recv
        return (Message)bformatter.Deserialize(stream);
    }
}

这很酷，但对于需要发送消息以响应用户事件的应用程序来说不是很有用。所以我需要能够异步发送和接收。

我基本上想要一个行为如下的界面:

class BidirectionalObjectStream
{
    public BidirectionalObjectStream(TcpClient client)
    {
        //...
    }

    // objects go in here
    public void SendObject(object o)
    {
        //...
    }

    // objects come out here
    public event Action<object> ObjectReceived;
}

.NET 中是否有这样的类？如果没有，我应该如何实现接收事件？也许一个专用线程反复调用 bformatter.Deserialize()...？

感谢任何帮助。

Answer 1

这个问题有点宽泛。

我可以想到两种选择:

• 使用异步套接字。 Using an Asynchronous Client Socket
• 为接收和发送创建单独的线程。有很多方法可以实现它，原始线程、ThreadPool、delegate.Invoke、新的 TPL 功能，如 Task 和 Parallel。