Асинхронный сокет Сервер C#, как получить данные от AsyncCallback

Question

Я пытался научиться использовать асинхронные сокеты, и я уверен, что мой вопрос невероятно прост, но мне очень трудно найти решение для него , Я собираюсь начать с кода, предоставленного в MSDN, для Asynchronous Server и Asynchronous Client. Я следую за тем, как работает код, кроме одного большого вопроса. Как получить строку, которую клиент отправляет обратно в основную функцию программы? Я вижу, где строка полностью сформирована в функции ReadCallback().

Вопрос в том, как получить содержимое содержимого строки обратно до Main()? Я добавил несколько комментариев, чтобы попытаться выяснить, к чему я пытаюсь добраться. Спасибо заранее за вашу помощь.

Асинхронный сервер:

using System; 
using System.Net; 
using System.Net.Sockets; 
using System.Text; 
using System.Threading; 

// State object for reading client data asynchronously 
public class StateObject { 
    // Client socket. 
    public Socket workSocket = null; 
    // Size of receive buffer. 
    public const int BufferSize = 1024; 
    // Receive buffer. 
    public byte[] buffer = new byte[BufferSize]; 
// Received data string. 
    public StringBuilder sb = new StringBuilder();  
} 

public class AsynchronousSocketListener { 
    // Thread signal. 
    public static ManualResetEvent allDone = new ManualResetEvent(false); 

    public AsynchronousSocketListener() { 
    } 

    public static void StartListening() { 
     // Data buffer for incoming data. 
     byte[] bytes = new Byte[1024]; 

     // Establish the local endpoint for the socket. 
     // The DNS name of the computer 
     // running the listener is "host.contoso.com". 
     IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName()); 
     IPAddress ipAddress = ipHostInfo.AddressList[0]; 
     IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000); 

     // Create a TCP/IP socket. 
     Socket listener = new Socket(AddressFamily.InterNetwork, 
      SocketType.Stream, ProtocolType.Tcp); 

     // Bind the socket to the local endpoint and listen for incoming connections. 
     try { 
      listener.Bind(localEndPoint); 
      listener.Listen(100); 

      while (true) { 
       // Set the event to nonsignaled state. 
       allDone.Reset(); 

       // Start an asynchronous socket to listen for connections. 
       Console.WriteLine("Waiting for a connection..."); 
       listener.BeginAccept( 
        new AsyncCallback(AcceptCallback), 
        listener); 

       // Wait until a connection is made before continuing. 
       allDone.WaitOne(); 
      } 

     } catch (Exception e) { 
      Console.WriteLine(e.ToString()); 
     } 

     Console.WriteLine("\nPress ENTER to continue..."); 
     Console.Read(); 

    } 

    public static void AcceptCallback(IAsyncResult ar) { 
     // Signal the main thread to continue. 
     allDone.Set(); 

     // Get the socket that handles the client request. 
     Socket listener = (Socket) ar.AsyncState; 
     Socket handler = listener.EndAccept(ar); 

     // Create the state object. 
     StateObject state = new StateObject(); 
     state.workSocket = handler; 
     handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, 
      new AsyncCallback(ReadCallback), state); 
    } 

    public static void ReadCallback(IAsyncResult ar) { 
     String content = String.Empty; 

     // Retrieve the state object and the handler socket 
     // from the asynchronous state object. 
     StateObject state = (StateObject) ar.AsyncState; 
     Socket handler = state.workSocket; 

     // Read data from the client socket. 
     int bytesRead = handler.EndReceive(ar); 

     if (bytesRead > 0) { 
      // There might be more data, so store the data received so far. 
      state.sb.Append(Encoding.ASCII.GetString( 
       state.buffer,0,bytesRead)); 

      // Check for end-of-file tag. If it is not there, read 
      // more data. 
      content = state.sb.ToString(); 
      if (content.IndexOf("<EOF>") > -1) { 
       // All the data has been read from the 
       // client. Display it on the console. 
       Console.WriteLine("Read {0} bytes from socket. \n Data : {1}", 
        content.Length, content); 
       // Echo the data back to the client. 
       // AT THIS POINT content SHOULD HAVE THE STRING SENT 
       Send(handler, content); 
      } else { 
       // Not all data received. Get more. 
       handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, 
       new AsyncCallback(ReadCallback), state); 
      } 
     } 
    } 

    private static void Send(Socket handler, String data) { 
     // Convert the string data to byte data using ASCII encoding. 
     byte[] byteData = Encoding.ASCII.GetBytes(data); 

     // Begin sending the data to the remote device. 
     handler.BeginSend(byteData, 0, byteData.Length, 0, 
      new AsyncCallback(SendCallback), handler); 
    } 

    private static void SendCallback(IAsyncResult ar) { 
     try { 
      // Retrieve the socket from the state object. 
      Socket handler = (Socket) ar.AsyncState; 

      // Complete sending the data to the remote device. 
      int bytesSent = handler.EndSend(ar); 
      Console.WriteLine("Sent {0} bytes to client.", bytesSent); 

      handler.Shutdown(SocketShutdown.Both); 
      handler.Close(); 

     } catch (Exception e) { 
      Console.WriteLine(e.ToString()); 
     } 
    } 

    public static int Main(String[] args) { 
     StartListening(); 
     // I want to make string here that has the result from ReadCallback so I can then perform other logic on the string. 
     return 0; 
    } 
} 

Answer 1

Ваш последовал пример совершенно верно. Вам просто нужно подождать ввода. Поставьте Console.ReadLine(); до возвращения заявления:

public static int Main(String[] args) 
{ 
    StartListening(); 
    // I want to make string here that has the result from ReadCallback so I can then perform other logic on the string. 

    Console.ReadLine(); 
    return 0; 
} 

Если вы хотите распечатать вход. Просто используйте Console.WriteLine() после декодируют полученный bytesin в ReadCallback метода:

if (bytesRead > 0) { 

    // There might be more data, so store the data received so far. 
    state.sb.Append(Encoding.ASCII.GetString( 
     state.buffer,0,bytesRead)); 

    // Check for end-of-file tag. If it is not there, read 
    // more data. 
    content = state.sb.ToString(); 

    // print the stuff to the console 
    Console.WriteLine(content); 

Если вы хотите, чтобы содержание и сделать что-то с ним вы можете объявить его как статической переменной класса и вы сможете получить к нему доступ в основной метод:

public class AsynchronousSocketListener 
{ 
    public static string content = ""; 


public static int Main(String[] args) 
{ 
    StartListening(); 
    // I want to make string here that has the result from ReadCallback so I can then perform other logic on the string. 

    Console.ReadLine(); 

    // wait until the message has arrive and press enter to jump to this line 
    Console.WriteLine("Now I can do what ever I want with the incoming message: " + content); 
    // just to be able to read it one more time before the program ends ;) 
    Console.ReadLine(); 
    return 0; 
} 

конечно, вы должны удалить объявление из ReadCallback.

Вы должны знать, что он асинхронен и, следовательно, вам придется ждать сообщения. Но вы можете увидеть его на консоли, если вы его распечатаете. Остальное зависит от вас