c# - Socket.DuplicateAndClose() 并通过 SocketInformation 重新创建套接字

Question

一些背景知识，尝试制作一个简单的应用程序，可以在 Tracker 中注册的对等点之间创建 P2P 连接，有点想从头开始制作 p2p 架构师 XD（请任何帮助或资源O _ O）

trackerServer只是将连接的客户端套接字信息保存在一个列表中并查询它的请求

namespace PeerTrackerServer
{
    public class PeerSockets
    {
        public string PeerName { get; set; }
        public byte[] SocketInformation { get; set; }
    }

    public class NetworkCommandMessage
    {
        public NetworkCommandMessage(byte[] command)
        {
            var strData = UTF8Encoding.UTF8.GetString(command);
            var arrSplited = strData.Split(':');
            this.Command = arrSplited[0].ToLower().Trim();
            this.Data = arrSplited[1].Replace("\0","").ToLower().Trim();
        }
        public string Command { get; set; }
        public string Data { get; set; }
    }

    class Program
    {
        public static List<PeerSockets> _Peers;

        static void Main(string[] args)
        {
            _Peers = new List<PeerSockets>();

            var srvSocket = new TcpListener(IPAddress.Any, 1313);
            srvSocket.Start();
            while (true)
            {
                var client = srvSocket.AcceptSocket();
                var tsk = new Task(new Action(() => { PeerHandler(client); }));
                tsk.Start();
            }
        }

        public static void PeerHandler(Socket client)
        {
            var commandBuff = new byte[128];
            client.Receive(commandBuff);
            var netMSG = new NetworkCommandMessage(commandBuff);

            switch (netMSG.Command)
            {
                case "register":
                    var duplicatedSocket = client.DuplicateAndClose(Process.GetCurrentProcess().Id);
                    _Peers.Add(new PeerSockets
                    {
                        PeerName = netMSG.Data,
                        SocketInformation = duplicatedSocket.ProtocolInformation
                    });
                    break;
                case "connect":
                    var requestedUser = _Peers.Where(c => c.PeerName == netMSG.Data).FirstOrDefault();
                    if (requestedUser != null)
                    {
                        client.Send(requestedUser.SocketInformation);
                        client.Close();
                    }
                    else
                    {
                        var msg = UTF8Encoding.UTF8.GetBytes("Requested User Not Found !");
                        client.Send(msg);
                        client.Close();
                    }
                    break;
            }

        }
    }
}

Client_1将自己注册到 Tracker Server 和 Server 复制其套接字并使其保持活动状态（我不知道多久！^_^）

namespace Client_1
{
    class Program
    {
        public static Socket _Socket;
        static void Main(string[] args)
        {
            //Register To Tracker Server
            var tsk = new Task(new Action(() => { RegisterMe(); }));
            tsk.Start();
            tsk.Wait();

            //Start Receiving Data
            var buff = new byte[4096];
            var ns = new NetworkStream(_Socket, true);
            var readCount = 0;

            while ((readCount = ns.Read(buff,0,buff.Length))>0)
            {
                var strData = UTF8Encoding.UTF8.GetString(buff, 0, readCount);
                Console.Write(strData);
            }
        }

        public static void RegisterMe()
        {
            var registerBuffer = new byte[128];

            var tcpClient = new TcpClient("127.0.0.1", 1313);
            var registerCommand = "register:Client1";
            var cmdData = UTF8Encoding.UTF8.GetBytes(registerCommand);
            Array.Copy(cmdData, registerBuffer, cmdData.Length);

            var ns = tcpClient.GetStream();
            ns.Write(registerBuffer, 0, registerBuffer.Length);
            ns.Flush();

            _Socket = tcpClient.Client;
        }
    }
}

这是Client_2尝试接收重复的Client_1套接字信息并重新创建套接字，client_1当前正在等待接收数据

namespace Client_2
{
    class Program
    {
        static void Main(string[] args)
        {
            var buffConnect = new byte[128];
            var cmdConnect = "connect:Client1";
            var cmdData = UTF8Encoding.UTF8.GetBytes(cmdConnect);
            Array.Copy(cmdData, buffConnect, cmdData.Length);

            //send Connect Command
            var tcpClient = new TcpClient("127.0.0.1", 1313);
            var ns = tcpClient.GetStream();
            ns.Write(buffConnect, 0, buffConnect.Length);
            ns.Flush();

            //Wait For ProtocolSocketInformation
            var buff = new byte[32*4096];
            var readBytes = 0;
            readBytes = ns.Read(buff, 0, buff.Length);

            var sockProtocolInfo = new byte[readBytes];
            Array.Copy(buff,sockProtocolInfo,readBytes);

            //Create New Socket
            var peerSocketInfo = new SocketInformation();
            peerSocketInfo.ProtocolInformation = sockProtocolInfo;
            peerSocketInfo.Options = SocketInformationOptions.Connected;

            /*
            * HERE IS THE ERROR ArgumentException : "The specified value for the socket information is invalid"
            */
            var peerSocket = new Socket(peerSocketInfo);


            //Send Message To Peer Client
            var msg = UTF8Encoding.UTF8.GetBytes("\r\n\r\nYoo there ! Im From Client 2!\r\n");
            var peerNS = new NetworkStream(peerSocket);
            peerNS.Write(msg, 0, msg.Length);
            peerNS.Flush();
            peerNS.Close();
        }
    }
}