我可以从System.Net.Security.SslStream获得什么级别的线程安全性？

Question

我有一个应用程序,用于SslStream发送和接收具有自己的固定长度框架的数据.通过包装NetworkStream返回来创建流,TcpClient.GetStream()如下所示:

var client = new TcpClient();
client.Connect(host, port);
var sslStream = new SslStream(client.GetStream(), false, callback, null);
sslStream.AuthenticateAsClient(hostname);

因为协议是完全异步的(框架"消息"在任意时间到达并允许客户端在任意时间发送它们),我通常会生成一个负责阻塞的线程,NetworkStream.Read()并确保NetworkStream.Write(...)在任何时候只有一个线程调用一度.

该备注的部分NetworkStream说:

可以在NetworkStream类的实例上同时执行读写操作,而无需同步.只要有一个用于写操作的唯一线程和一个用于读操作的唯一线程,读写线程之间就不会存在交叉干扰,也不需要同步.

但是,MSDN文档 "线程安全"部分SslStream说:

此类型的任何公共静态(在Visual Basic中为Shared)成员都是线程安全的.任何实例成员都不保证是线程安全的.

因为SslStream并且NetworkStream不在同一个类层次结构中,所以我假设(可能不正确)该备注NetworkStream不适用于SslStream.

线程安全的最佳方法是简单地用这样的东西包装SslStream.BeginRead/ SslStream.EndRead和SslStream.BeginWrite/ SslStream.EndWrite吗？

internal sealed class StateObject
{
    private readonly ManualResetEvent _done = new ManualResetEvent(false);

    public int BytesRead { get; set; }
    public ManualResetEvent Done { get { return _done; } }
}

internal sealed class SafeSslStream
{
    private readonly object _streamLock = new object();
    private readonly SslStream _stream;

    public SafeSslStream(SslStream stream)
    {
        _stream = stream;
    }

    public int Read(byte[] buffer, int offset, int count)
    {
        var state = new StateObject();
        lock (_streamLock)
        {
             _stream.BeginRead(buffer, offset, count, ReadCallback, state);
        }
        state.Done.WaitOne();
        return state.BytesRead;
    }

    public void Write(byte[] buffer, int offset, int count)
    {
        var state = new StateObject();
        lock (_streamLock)
        {
            _stream.BeginWrite(buffer, offset, count, WriteCallback, state);
        }
        state.Done.WaitOne();
    }

    private void ReadCallback(IAsyncResult ar)
    {
        var state = (StateObject)ar.AsyncState;
        lock (_streamLock)
        {
            state.BytesRead = _stream.EndRead(ar);
        }
        state.Done.Set();
    }

    private void WriteCallback(IAsyncResult ar)
    {
        var state = (StateObject)ar.AsyncState;
        lock (_streamLock)
        {
            _stream.EndWrite(ar);
        }
        state.Done.Set();
    }
}

Answer 1

您从 MSDN 文档中提取的短语是大多数类文档中的包罗万象的内容。如果成员的文档明确声明了线程安全（确实如此NetworkStream），那么您可以信赖它。

但是，他们所说的是您可以同时执行一次读取和一次写入，而不是两次读取或两次写入。因此，您需要单独同步或排队读取和写入。您的代码看起来足以执行此操作。