Foro de elhacker.net

public string recibirString()
        {
            if (stream == null)
                stream = conexion.GetStream();
            int longitud = recibirLongitud();
            //stream = conexion.GetStream();
            Byte[] bytes = new Byte[longitud];
            Int32 i;
            String datos = String.Empty;
            if ((i = stream.Read(bytes, 0, bytes.Length)) != 0)
            {
                datos = System.Text.Encoding.UTF8.GetString(bytes, 0, i);
                return datos;
            }
            return datos;
        }
 

private int recibirLongitud()
        {
            if (stream == null)
                stream = conexion.GetStream();
            Int32 longitud = 0;
            Byte[] longitudByte = new Byte[4];
            //stream = conexion.GetStream();
            stream.Read(longitudByte, 0, longitudByte.Length);
            longitud = BitConverter.ToInt32(longitudByte, 0);
            return longitud;
        }
 

public bool enviarString(string mensaje)
        {
            if (stream == null)
                stream = conexion.GetStream();
            try
            {
                Byte[] paquete = System.Text.Encoding.UTF8.GetBytes(mensaje);
                enviarLongitud(paquete);
                stream.Write(paquete, 0, paquete.Length);
                stream.Flush();
                return true;
            }
            catch { return false; }
        }
 

private bool enviarLongitud(Byte[] paquete)
        {
            if (stream == null)
                stream = conexion.GetStream();
            try
            {
                int longitud = paquete.Length;
                byte[] longitudBytes = BitConverter.GetBytes(longitud);
                stream.Write(longitudBytes, 0, longitudBytes.Length);
                stream.Flush();
                return true;
            }
            catch { return false; }
        }
 

while (BytesRecidos < BytesEsperados) {
if ((B = ELStream.Read(byteBuffer, BytesRecibidos,
       BytesRecibidos - BytesEsperados)) == 0) {
       Console.WriteLine("fallo");
        break;
        }
 
BytesRecibidos += B;
}
 
 

 
  if ((i = stream.Read(bytes, 0, bytes.Length)) != 0)
            {
                datos = System.Text.Encoding.UTF8.GetString(bytes, 0, i);
                return datos;
            }
 
 
fijate asi
 
 
int recibidos=0;int Rcvd;
while (recibidos < bytes.Lenght) {
   if ((Rcvd = stream.Read(bytes, recibidos,
   bytes.Length - recibidos)) == 0) {
   Console.WriteLine("error");
   break;
 }
 
datos = System.Text.Encoding.UTF8.GetString(bytes, 0, bytes.Lenght);
return datos;
 
 

while (BytesRecidos < BytesEsperados) {
if ((B = ELStream.Read(byteBuffer, BytesRecibidos,
       BytesRecibidos - BytesEsperados)) == 0) {
       Console.WriteLine("fallo");
        break;
        }
 
BytesRecibidos += B;
}
 
 

public string recibirString()
        {
            if (stream == null)
                stream = conexion.GetStream();
            int longitud = recibirLongitud();
            Byte[] bytes = new Byte[longitud];
            Int32 i;
            String datos = String.Empty;
            int bytesRecibidos = 0;
            while (bytesRecibidos < longitud)
            {
                if ((i = stream.Read(bytes, bytesRecibidos, bytesRecibidos - longitud)) == 0)
                {
                    break;
                }
                bytesRecibidos += i;
            }
            return datos;
        }
 

while (bytesRecibidos < longitud)
            {
                i = stream.Read(bytes, bytesRecibidos, 1);
                bytesRecibidos += i;
            }
            datos = System.Text.Encoding.UTF8.GetString(bytes, 0, bytes.Length);
            return datos;
 

private UdpClient cliente;       
   private IPEndPoint puntoRecepcion;
 
   // inicializa las variables y el subproceso para recibir paquetes
   private void ServidorPaquetesForm_Load( object sender, EventArgs e )
   {
      cliente = new UdpClient(50000);
      puntoRecepcion = new IPEndPoint(new IPAddress(0), 0);
      Thread lecturaThread = new Thread(new ThreadStart(EsperarPaquetes));
      lecturaThread.Start();                                    
   } 
 
   // cierra el servidor
   private void ServidorPaquetesForm_FormClosing( object sender, 
      FormClosingEventArgs e )
   {         
      System.Environment.Exit( System.Environment.ExitCode );
   } // fin del método ServidorPaquetesForm_FormClosing
 
   // delegado que permite llamar al método MostrarMensaje
   // en el subproceso que crea y mantiene la GUI 
   private delegate void DisplayDelegate( string message );  
 
   // el método MostrarMensaje establece la propiedad Text de mostrarTextBox
   // de una manera segura para el proceso
   private void MostrarMensaje( string mensaje )
   {
      // si la modificación de mostrarTextBox no es segura para el subproceso
      if ( mostrarTextBox.InvokeRequired )
      {
         // usa el método heredado Invoke para ejecutar MostrarMensaje
         // a través de un delegado 
         Invoke( new DisplayDelegate( MostrarMensaje ),          
            new object[] { mensaje } );                          
      } // fin de if
      else // sí se puede modificar mostrarTextBox en el subproceso actual
         mostrarTextBox.Text += mensaje;
   } 
 
   // espera a que llegue un paquete
   public void EsperarPaquetes()
   {
      while ( true )
      {
         // prepara el paquete
         byte[] datos = cliente.Receive( ref puntoRecepcion );
         MostrarMensaje( "\r\nSe recibió paquete:" +
            "\r\nLongitud: " + datos.Length +
            "\r\nContenido: " + 
            System.Text.Encoding.ASCII.GetString( datos ) );           
 
         // devuelve (eco) la información del paquete de vuelta al cliente
         MostrarMensaje( "\r\n\r\nEnviando de vuelta datos al cliente..." );
         cliente.Send( datos, datos.Length, puntoRecepcion );
         MostrarMensaje( "\r\nPaquete enviado\r\n" );
      } // fin de while
   }  
 

private UdpClient cliente;       
   private IPEndPoint puntoRecepcion;
 
   // inicializa las variables y el subproceso para recibir paquetes
   private void ClientePaquetesForm_Load( object sender, EventArgs e )
   {
      puntoRecepcion = new IPEndPoint( new IPAddress( 0 ), 0 );
      cliente = new UdpClient( 50001 );                        
      Thread subproceso =                                        
         new Thread( new ThreadStart( EsperarPaquetes ) );    
      subproceso.Start();                                        
   } // fin del método ClientePaquetesForm_Load
 
   // cierra el cliente
   private void ClientePaquetesForm_FormClosing( object sender, 
      FormClosingEventArgs e )
   {
      System.Environment.Exit( System.Environment.ExitCode );
   } // fin del método ClientePaquetesForm_FormClosing
 
   // delegado que permite llamar al método MostrarMensaje
   // en el subproceso que crea y mantiene la GUI 
   private delegate void DisplayDelegate( string message );  
 
   // el método MostrarMensaje establece la propiedad Text de mostrarTextBox
   // de una manera segura para el subproceso
   private void MostrarMensaje( string mensaje )
   {
      // si la modificación de mostrarTextBox no es segura para el subproceso
      if ( mostrarTextBox.InvokeRequired )
      {
         // usa el método heredado Invoke para ejecutar MostrarMensaje
         // a través de un delegado 
         Invoke( new DisplayDelegate( MostrarMensaje ),          
            new object[] { mensaje } );                          
      } // fin de if
      else // sí se puede modificar mostrarTextBox en el subproceso actual
         mostrarTextBox.Text += mensaje;
   } // fin del método MostrarMensaje
 
   // envía un paquete
   private void entradaTextBox_KeyDown( object sender, KeyEventArgs e )
   {
      if ( e.KeyCode == Keys.Enter )
      {
         // crea un paquete (datagrama) como objeto string
         string paquete = entradaTextBox.Text;   
         mostrarTextBox.Text +=
            "\r\nEnviando paquete que contiene: " + paquete;
 
         // convierte el paquete en arreglo de bytes 
         byte[] datos = System.Text.Encoding.ASCII.GetBytes( paquete );
 
         // envía el paquete al servidor en el puerto 50000               
         cliente.Send( datos, datos.Length, "127.0.0.1", 50000 );
         mostrarTextBox.Text += "\r\nPaquete enviado\r\n";
         entradaTextBox.Clear();
      } // fin de if
   } // fin del método entradaTextBox_KeyDown
 
   // espera a que lleguen los paquetes
   public void EsperarPaquetes()
   {
      while ( true )
      {
         // recibe arreglo de bytes del servidor
         byte[] datos = cliente.Receive( ref puntoRecepcion );
 
         // envía el paquete de datos al control TextBox
         MostrarMensaje( "\r\nPaquete recibido:" +
            "\r\nLongitud: " + datos.Length + "\r\nContenido: " + 
            System.Text.Encoding.ASCII.GetString( datos ) + "\r\n" );
      } // fin de while
   } // fin del método EsperarPaquetes