将 SSL 流与异步 System.Net.Sockets 一起使用

Question

我的服务器现在使用异步 System.Net.Sockets 运行，但我想使用 SSL 流。我对使用 SSL 很陌生，所以如果有人可以帮助我，这是我的服务器代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;

    public class Wrapper
    {
        public byte[] buffer;
        public Socket _socket;
        public object connector;
    }

    public class WinSocket
    {
        private Dictionary<string, byte> Connections;
        public event Action<Wrapper> AnnounceNewConnection;//Event Handlers
        public event Action<Wrapper> AnnounceDisconnection;
        public event Action<byte[], Wrapper> AnnounceReceive;
        private Socket _socket;
        public int MAX_USER_CONNECTIONS = 2;//Max User Connections

        public WinSocket(ushort port)
        {
            try
            {
                Connections = new Dictionary<string, byte>();
                _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                _socket.Bind(new IPEndPoint(IPAddress.Any, port));
                _socket.Listen(500);
                _socket.BeginAccept(AcceptConnections, new Wrapper());
            }
            catch (Exception e)
            {
                Console.WriteLine(e);//write an exception
            }
        }

        private void AcceptConnections(IAsyncResult result)
        {
            try
            {
                Wrapper wr = result.AsyncState as Wrapper;
                wr._socket = _socket.EndAccept(result);
                #region Invisible
                string IP = wr._socket.RemoteEndPoint.ToString().Split(':')[0].ToString();//Get user ip
                if (!Connections.ContainsKey(IP))
                    Connections.Add(IP, 1);
                else
                    if (Connections[IP] <= MAX_USER_CONNECTIONS)//Maximum Connections Per IP
                    {
                        byte connections = Connections[IP];
                        Connections.Remove(IP);//Limit exceeded
                        Connections.Add(IP, (byte)(connections + 1));
                    }
                    else
                    {
                        wr._socket.Disconnect(false);
                        _socket.BeginAccept(AcceptConnections, new Wrapper());
                        return;
                    }
                #endregion
                wr.buffer = new byte[65535];
                wr._socket.BeginReceive(wr.buffer, 0, 65535, SocketFlags.None, ReceiveData, wr);
                AnnounceNewConnection.Invoke(wr);
                _socket.BeginAccept(AcceptConnections, new Wrapper());
            }
            catch (Exception e)
            {
                Console.WriteLine(e);//write an exception
            }
        }

        private void ReceiveData(IAsyncResult result)//Receiving Data
        {
            try
            {
                Wrapper wr = result.AsyncState as Wrapper;
                string IP = wr._socket.RemoteEndPoint.ToString().Split(':')[0].ToString();//Get UIP
                if (Connections.ContainsKey(IP))
                {
                    SocketError error = SocketError.Disconnecting;
                    int size = wr._socket.EndReceive(result, out error);
                    if (error == SocketError.Success && size != 0)
                    {
                        byte[] buffer = new byte[size];
                        Buffer.BlockCopy(wr.buffer, 0, buffer, 0, size);
                        AnnounceReceive.Invoke(buffer, wr);//The delegate
                        if (wr._socket.Connected)//Make sure socket is connected
                            wr._socket.BeginReceive(wr.buffer, 0, 65535, SocketFlags.None, ReceiveData, wr);//Start Receiving Data
                    }
                    else
                    {
                        if (wr._socket.Connected)
                        {
                            wr._socket.Disconnect(true);//Disconnect the client
                        }
                        byte connections = Connections[IP];
                        Connections.Remove(IP);
                        Connections.Add(IP, (byte)(connections - 1));
                        try
                        {
                            AnnounceDisconnection.Invoke(wr);
                        }
                        catch { }
                    }
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e);//write an exception
            }
        }
    }

所以我的问题再次明确是：如何使用 SSL Stream 和上面的代码一样的套接字类

Answer 1

将Stream 类替换为System.Net.SslStream 类。除上述代码外，调用AuthenticateAsServer，并在WinSocket构造函数中传递服务器SSL证书。