Problema con socket y envió de imágenes C#

Nemutagk · #1 (**permalink**) 31/12/2010, 06:29

Que tal compañeros, traigo un problema, estoy comenzando con C# y estoy haciendo pruebas con sockets en programas cliente/servidor, ya logre enviar y recibir archivos, mas especifico en imágenes, pero tengo un problema, al principio se me complico mucho porque al parecer el socket envía el archivo (sea cual sea el tipo) en bloques de x bytes, así que siempre recibía solo una parte del archivo (la prueba la hacia con imágenes, con lo cual solo se veía una parte, lo demás de color gris), logré al final eh digamos compaginar (no encuentro otra forma de decirlo) los bloques de bytes y crear el archivo completo, el problema ahora y de plano llevo bastante buscando y no encuentro la razon es que no me llega el archivo completo, lo que pienso es que no obtengo el peso total en bytes en el cliente (o lo obtengo de forma erronea) o de plano la "solución" que implemente esta mal, ya que siempre falta algunos bytes (no mas de 10 en las pruebas que eh hecho), por ejemplo, al enviar una imagen verifico la ventana de propiedades de windows y me marca un peso de 48,758 bytes, pero en el archivo que obtengo al enviarlo me marca 48,750 bytes, como verán faltan 8 bytes...

Si me pudieran ayudar viendo si lo que hice esta bien o de plano regreso a estudiar mas >.<, aquí dejo el código de los programas...

Cliente (el que envía)

Código c#:

Ver originalusing System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.IO;
using System.Threading;
 
namespace EnvioArchivos
{
    public partial class Form1 : Form
    {
        bool conectado = false;
        Socket socket;
        Thread trabajo;
 
        public Form1()
        {
            InitializeComponent();
        }
 
        delegate void SetTextCallback(string text);
 
        private void button1_Click(object sender, EventArgs e)
        {
            if (!conectado)
            {
                conectar();
                conectado = true;
            }
            else
            {
                byte[] msn = System.Text.Encoding.ASCII.GetBytes("close");
                socket.Send(msn);
                desconectar();
            }
        }
 
        private void button2_Click(object sender, EventArgs e)
        {
            if (openFileDialog1.ShowDialog() == DialogResult.OK)
            {
                enviarArchivo(openFileDialog1.FileName);
            }
        }
 
        private void conectar()
        {
            button1.Text = "Desconectar";
            button2.Enabled = true;
            button3.Enabled = true;
            textBox3.Enabled = true;
 
            IPAddress ipServer = Dns.GetHostEntry(textBox1.Text).AddressList[0];
            IPEndPoint ipEndPoint = new IPEndPoint(ipServer, 1050);
            socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 
            try
            {
                addText("Intentando conectar...");
                socket.Connect(ipEndPoint);
 
                ParameterizedThreadStart threadMensajes = new ParameterizedThreadStart(this.checarMensajes);
                trabajo = new Thread(threadMensajes);
                trabajo.IsBackground = true;
                trabajo.Start(socket);
 
                if (socket.Connected)
                {
                    addText("Conectado!!!");
                }
            }
            catch (Exception e)
            {
                addText("Error al intentar conectar \r\n" + e.ToString());
                button1.Text = "Conectar";
                button2.Enabled = false;
                conectado = false;
            }    
        }
 
        private void desconectar()
        {
            //trabajo.Join();
            trabajo.Suspend();
            socket.Close();
 
            addText("Desconectado");
 
            button1.Text = "Conectar";
            button2.Enabled = false;
            button3.Enabled = false;
            textBox3.Enabled = false;
            conectado = false;
        }
 
        private void enviarArchivo(string NombreFichero)
        {
            string RutaFichero = "";
 
            NombreFichero = NombreFichero.Replace("\\", "/");
            while (NombreFichero.IndexOf("/") > -1)
            {
                RutaFichero += NombreFichero.Substring(0, NombreFichero.IndexOf("/") + 1);
                NombreFichero = NombreFichero.Substring(NombreFichero.IndexOf("/") + 1);
            }
 
 
            byte[] TamanoFicheroBytes = Encoding.ASCII.GetBytes(NombreFichero);
            if (TamanoFicheroBytes.Length > 99999 * 2024)
            {
                addText("Tamaño del archivo es más de 200MB, por favor, pruebe con archivos pequeños.");
                return;
            }
 
            //Msg = "Creando Cache buffer ...";
            byte[] DatosFichero = File.ReadAllBytes(RutaFichero + NombreFichero);
            
            byte[] TamanoFicheroEnviar = new byte[4 + TamanoFicheroBytes.Length + DatosFichero.Length];
            addText("El peso a enviar " + TamanoFicheroBytes.Length.ToString() + " bytes");
 
            addText("Enviando aviso de archivo y su peso");
            byte[] byteAvisoArchivo = Encoding.ASCII.GetBytes("file:" + TamanoFicheroEnviar.Length.ToString());
            socket.Send(byteAvisoArchivo);
 
            byte[] fileNameLen = BitConverter.GetBytes(TamanoFicheroBytes.Length);
 
            fileNameLen.CopyTo(TamanoFicheroEnviar, 0);
            TamanoFicheroBytes.CopyTo(TamanoFicheroEnviar, 4);
            DatosFichero.CopyTo(TamanoFicheroEnviar, 4 + TamanoFicheroBytes.Length);
 
            addText("Enviando archivo...");
            int bytesEnviados = socket.Send(TamanoFicheroEnviar);
            addText("Se enviaron " + bytesEnviados.ToString() + " bytes");
 
            addText("Enviando aviso que se termino de enviar el archivo");
            byte[] byteAvisoEndArchivo = Encoding.ASCII.GetBytes("endfile");
            //socket.Send(byteAvisoEndArchivo);
        }
 
        private void addText(string texto)
        {
            if (textBox2.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(addText);
                this.Invoke(d, new object[] { texto });
            }
            else
            {
                string datetime = DateTime.Now.ToString();
                string[] partes = datetime.Split(' ');
                string hora = partes[1] + " " + partes[2];
 
                if (textBox2.Text == "")
                {
                    textBox2.Text = hora + " " + texto;
                }
                else
                {
                    textBox2.Text = hora + " " + texto + "\r\n" + textBox2.Text;
                }
            }
        }
 
        private void button3_Click(object sender, EventArgs e)
        {
            if (socket.Connected)
            {
                enviarTexto(textBox3.Text);
 
                if (textBox3.Text == "close")
                {
                    desconectar();
                }
 
                textBox3.Text = "";
            }
        }
 
        private void enviarTexto(string texto) {
            if (this.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(enviarTexto);
                this.Invoke(d, new object[] { texto });
            }
            else
            {
                byte[] msn = System.Text.Encoding.ASCII.GetBytes(texto);
                socket.Send(msn);
            }
        }
 
        private void checarMensajes(object orSocket)
        {
            //bool conectado = true;
            int numPasadas = 1;
            Socket socket = (Socket) orSocket;
            addText("Iniciando escucha");
            while (true)
            {
                if (socket.Connected)
                {
                    byte[] bytesRecibidos = new byte[1024];
                    int info = socket.Receive(bytesRecibidos);
                    string texto = System.Text.Encoding.ASCII.GetString(bytesRecibidos, 0, info);
 
                    if (texto == "recibido")
                    {
                        addText("Se recibio mensaje del servidor");
                        enviarTexto("endfile");
                    }
                    numPasadas++;
                }
                checarMensajesNum(numPasadas.ToString());
            }
 
        }
 
        private void checarMensajesNum(string num)
        {
            if (this.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(checarMensajesNum);
                this.Invoke(d, new object[] { num });
            }
            else
            {
                textBox4.Text = num;
            }
        }
    }
}

El código del servidor lo coloco en otro post porque rebazo el limite de caracteres...

Nemutagk · #2 (**permalink**) 31/12/2010, 06:29

Código del servidor (el que recibe)

Sevidor (el que recibe)

Código c#:

Ver originalusing System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.IO;
using System.Threading;
 
namespace RecibirArchivos
{
    public partial class Form1 : Form
    {
        Thread trabajo;
        bool nextDataFile = false;
        string nombreFile;
 
        public Form1()
        {
            InitializeComponent();
        }
 
        delegate void SetTextCallback(string text);
        delegate void SetBytesCallback(int fichero, int ficheroNameLen, string nombre);
 
        private void button1_Click(object sender, EventArgs e)
        {
            ParameterizedThreadStart conexion = new ParameterizedThreadStart(escuchar);
            trabajo = new Thread(conexion);
            trabajo.IsBackground = true;
            trabajo.Start(textBox1.Text);
        }
 
        private void escuchar(object ip)
        {
            IPAddress ipServer = Dns.GetHostEntry((string)ip).AddressList[0];
            IPEndPoint ipEndPoint = new IPEndPoint(ipServer, 1050);
 
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            socket.Bind(ipEndPoint);
            socket.Listen(100);
 
            addText("Escuchando puerto...");
            Socket conexion = socket.Accept();
            addText("Conectado!!!");
 
            bool conectado = true;
            bool isFile = false;
 
            BinaryWriter ArchivoBinario = null;
            int fileNameLen = 0;
            bool createFile = false;
            string totalSizeFile = "";
            string NombreFichero = "";
            int recibeSizeFile = 0;
 
            while (conectado)
            {
                if (!isFile)
                {
                    byte[] bytesRecibe = new byte[1024];
                    int datosRecibe = conexion.Receive(bytesRecibe);
                    addText("Se recibieron " + datosRecibe.ToString() + " bytes");
                    string mensaje = System.Text.Encoding.ASCII.GetString(bytesRecibe, 0, datosRecibe);
                    string[] partes = mensaje.Split(':');
                    if ((string)partes[0] == "file")
                    {
                        addText("Se va a recibir un archivo de " + partes[1] + " bytes");
                        totalSizeFile = partes[1];
                        isFile = true;
                    }
                    else if (mensaje == "close")
                    {
                        conectado = false;
                    }
                    else
                    {
                        addText(mensaje);
                    }
                }
                else
                {
                    byte[] TamanioDatos = new byte[2024 * 99999];
                    addText("Recibiendo archivo...");
                    int BytesRecibidosLen = conexion.Receive(TamanioDatos);
                    recibeSizeFile = recibeSizeFile + BytesRecibidosLen;
                    
                    addText("Se recibieron " + BytesRecibidosLen.ToString() + " bytes");
 
                    if (!createFile)
                    {
                        fileNameLen = BitConverter.ToInt32(TamanioDatos, 0);
                        addText("fileNameLen: " + fileNameLen.ToString());
                    }
                    else
                    {
                        fileNameLen = 0;
                    }
 
                    if (NombreFichero == "")
                    {
                        NombreFichero = Encoding.ASCII.GetString(TamanioDatos, 4, fileNameLen);
                        addText("Obtenemos el nombre del archivo: " + NombreFichero);
                    }
 
                    string rutaArchivo = "D:/prueba/" + NombreFichero;
 
                    if (!createFile)
                    {
                        addText("Creando archivo en disco: " + rutaArchivo);
                        ArchivoBinario = new BinaryWriter(File.Open(rutaArchivo, FileMode.Append));
                        createFile = true;
                    }
 
                    addText("Guardando archivo");
                    ArchivoBinario.Write(TamanioDatos, 4 + fileNameLen, BytesRecibidosLen - 4 - fileNameLen);
 
                    if (recibeSizeFile.ToString() == totalSizeFile)
                    {
                        ArchivoBinario.Close();
                        addText("Archivo recibido y guardado");
                        addText("En total se recibio " + recibeSizeFile.ToString() + " bytes");
                        isFile = false;
                        createFile = false;
                        recibeSizeFile = 0;
                        NombreFichero = "";
                    }
                }
            }
 
            addText("Cerrando la conexion");
            conexion.Shutdown(SocketShutdown.Both);
            socket.Close();
            addText("Conexion cerrada");
        }
        
        private void addText(string texto)
        {
            if (textBox2.InvokeRequired)
            {
                SetTextCallback d = new SetTextCallback(addText);
                this.Invoke(d, new object[] { texto });
            }
            else
            {
                string datetime = DateTime.Now.ToString();
                string[] partes = datetime.Split(' ');
                string hora = partes[1] + " " + partes[2];
 
                if (textBox2.Text == "")
                {
                    textBox2.Text = hora + " " + texto;
                }
                else
                {
                    textBox2.Text = hora + " " + texto + "\r\n" + textBox2.Text;
                }
            }
        }
    }
}

Se me olvidaba una cosa que también me sucede, en un equipo con Windows XP y NET Framework 4 no funciona, abre pero cuando pongo a escucha el servidor se cierra, es necesario instalar las otras versiones de NET Framework?

Nemutagk · #3 (**permalink**) 04/01/2011, 20:04

Por mas que busco no encuentro solución, se siguen perdiendo bytes en los archivos que envió/recibo, alguien tiene por hay algún buen ejemplo de como enviar y recibir datos usando sockets y threads, agradeceré toda ayuda que me puedan dar

Porlachucha · #4 (**permalink**) 06/01/2011, 08:02

mirando el codigo, me llama la atencion el 2024.. esto no es producto de 2 elevado a un entero.. creo que tendria que ser 1024. Aunque no explica nada, puede ser que puedas encontrar los bytes faltantes en esa prueba.
intentalo y comentas.

Saludos
plch