Problema con Sockets C#

[DeS_TRoZaDo]

Buenas.

Tengo un servidor, que recibe conexiones de muchos clientes, lo hago usando las clases TcpListener para el servidor y TcpClient para los clientes con su respectivo NetworkStream para enviar y recibir datos.

Entonces, quiero que veais el codigo a ver si veis algo mal, por que si lo depuro, y voy linea por linea con el F11 dandole paso yo funciona perfecto, en el momento que lo dejo libre, falla, por lo cual no puedo saber donde es, un ejemplo, para enviar un string a la conexion hago esto en el que va a recibir:

Código (csharp) [Seleccionar] Expandir


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;
        }


y recibirLongitud es:

Código (csharp) [Seleccionar] Expandir


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;
        }


Eso el que lo recibe, y el que envia hace esto cuando ese esta esperando a recibir:

Código (csharp) [Seleccionar] Expandir


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; }
        }


donde enviarLongitud es:

Código (csharp) [Seleccionar] Expandir


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; }
        }


Graaaacias por leer.

Algun comentario? 

EDITO: stream en este caso seria el NetworkStream y conexion es el TcpClient.

[Lunfardo]

la lectura la tenes que hacer con un while, hasta que hayas leido la misma longuitud de caracter que los esperados.


no basta con un simple "read" por que por el protocolo TCP los mensajes llegan cortados

Código (csharp) [Seleccionar] Expandir


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

BytesRecibidos += B;
}




Espero que se entienda xD , si empieza a leer 0 bytes, es que algo funciona mal =)

[DeS_TRoZaDo]

Estas seguro de eso? yo esque internamente no se como funciona, pero recibir recibe bien, el problema es que despues de recibir, en algun momento, el stream o el tcpClient se peta y da un DisposedObject, pero recibir, cuando recibe, recibe bien.

EDIT: Lo que realmente me jode, es que si pongo un punto de interrupcion, y voy paso a paso, en el que envia los datos, con el F11, haciendolo, va todo perfecto, le mande lo que le mande y las veces que se lo mande, pero en el momento que quito el punto de interrupcion, se peta. :S:S me esta jodiendo mucho eso.

[Lunfardo]

seguro estoy,


proba cerrando los sockets una vez terminada la funcion.


stream.Close();


la longuitud la podes representar con un int de 4 bytes, por lo menos yo lo hacia asi para saber el peso de lo esperado sin complicaciones.

[DeS_TRoZaDo]

Ya he probado con eso, lo que pasa es que la conexion es continua, si hago el stream.Close() peta por todos lados, por que tanto cliente como servidor estan en continua comunicacion, creo que igual he encontrado el problema, por que he reducido el tamaño de los paquetes que envia y ya no peta, es decir, hay un maximo para enviar de 1 tirada? se puede aumentar si lo hay? solo estoy enviando puro string :S me extraña que sea algo de esto por que entonces ya si quisiera enviar una imagen me puede dar algo pero.... si reduciendo el tamaño a enviar ha funcionado.... :S

[Lunfardo]

hace lo del while que te puse al principio , ya que i y bytes.Lenght pueden no coincidir, te tenes que asegurar que lo haga antes de decifrarlo

Código (csharp) [Seleccionar] Expandir



 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;



[DeS_TRoZaDo]

Voy a probarlo ahora mismo, otra duda, el stream = conexion.GetStream(); cuando hay que hacerlo? con 1 vez basta? o cada vez que vaya a enviar y recibir?

[Lunfardo]

con una vez basta, pero el servidor y el cliente tiene que estar sintonizados para cuando el cliente termine de recibir lo que el servidor tenga para enviar ambos cierren los sockets, sino el servidor no podria recibir otra solicitud.

ademas una vez que se termine el proceso, el servidor deberia quedar parado en un punto de espera para responde a una nueva solicitud.

te aconsejo que leas tcp/ip sockets in c # si te quedan muchas dudas

[DeS_TRoZaDo]

la lectura la tenes que hacer con un while, hasta que hayas leido la misma longuitud de caracter que los esperados.


no basta con un simple "read" por que por el protocolo TCP los mensajes llegan cortados

Código (csharp) [Seleccionar] Expandir


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

BytesRecibidos += B;
}




Espero que se entienda xD , si empieza a leer 0 bytes, es que algo funciona mal =)

En el if, el bytesRecibidos - bytesEsperado mmmm no va bien bien, bytesRecibidos la primera vez es 0 por que hemos recibido 0, y los esperados son 1000 alomejor, 0 - 1000 peta por argumentException que querias poner exactamente? Se ha quedado asi:

Código (csharp) [Seleccionar] Expandir


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;
        }


Si, esta bastante controlado el tema de los sockets, ya te digo que el programa funciona, si el paquete no es grande, y aun siendo grande, si lo hago linea a linea, tambien va.

[Lunfardo]

tenes razon , es BytesEsperado-BytesRecibidos lo bytes que tiene que tratar de leer