问异步通信

EN

        byte[] ba = new byte[1024];
        new Task(() => {
            Output("Going to listen to messages...");
            Socket listeningS = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            // Listening to local address. You should listen to external IP for real server
            IPEndPoint ep = new IPEndPoint(IPAddress.Any, port);
            listeningS.Bind((EndPoint)ep);
            // One and only client at a time :)
            listeningS.Listen(1);
            while (isRunning)
            {
                // Accept client, receive data and send it back
                Socket clientS = listeningS.Accept();
                int total = clientS.Receive(ba, 0, ba.Length, SocketFlags.None);
                total = clientS.Send(ba, 0, total, SocketFlags.None);
                // Client will open new connection (but later it is possible to use same)
                clientS.Shutdown(SocketShutdown.Both);
                clientS.Close();

            }
        }).Start();

    byte[] ba = Encoding.UTF8.GetBytes(message);
    Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    s.Connect(IPAddress.Loopback, port);
    total = s.Send(ba, SocketFlags.None);
    total = s.Receive(ba, 0, ba.Length, SocketFlags.None);
    if (total > 0)
    {
        Output(Encoding.UTF8.GetString(ba, 0, total));
    }