elhacker.net cabecera Bienvenido(a), Visitante. Por favor Ingresar o Registrarse
¿Perdiste tu email de activación?.

 

 


Tema destacado: Únete al Grupo Steam elhacker.NET


+  Foro de elhacker.net
|-+  Programación
| |-+  Programación General
| | |-+  Java
| | | |-+  Error tonto con threads y sockets
0 Usuarios y 1 Visitante están viendo este tema.
Páginas: [1] 2 3 Ir Abajo Respuesta Imprimir
Autor Tema: Error tonto con threads y sockets  (Leído 12,194 veces)
Debci
Wiki

Desconectado Desconectado

Mensajes: 2.021


Actualizate o muere!


Ver Perfil WWW
Error tonto con threads y sockets
« en: 26 Diciembre 2009, 15:39 pm »

Hola a todos jeje, soy yo otra vez, he vuelto al java xD
Mirad estoy constryendo una aplicacion con sockets, que gestiona varios cliente mediante el uso de threads, la cosa esta en que cada vez que se conecta un cliente al servidor, este le abre un thread, y lo deja en ejecucion hasta que el cliente se cierra y le envia un binario, cuando le envia el binario se cumple el bucle y el thread muere, pero ocurre una cosa extraña, mirad el codigo:

ClienteGui.java
Código
  1.  
  2. package sockets;
  3.  
  4. import java.io.DataInputStream;
  5. import java.io.DataOutputStream;
  6. import java.io.IOException;
  7. import java.io.InputStream;
  8. import java.io.OutputStream;
  9. import java.net.Socket;
  10. import java.util.logging.Level;
  11. import java.util.logging.Logger;
  12.  
  13. /**
  14.  *
  15.  * @author debci
  16.  */
  17. public class ClienteGui extends javax.swing.JFrame {
  18.            public static Socket socket;
  19.            public static InputStream is;
  20.            public static OutputStream os;
  21.            public static DataInputStream dis;
  22.            public static DataOutputStream dos;
  23.    /** Creates new form ClienteGui */
  24.    public ClienteGui() {
  25.        initComponents();
  26.    }
  27.  
  28.    /** This method is called from within the constructor to
  29.      * initialize the form.
  30.      * WARNING: Do NOT modify this code. The content of this method is
  31.      * always regenerated by the Form Editor.
  32.      */
  33.    @SuppressWarnings("unchecked")
  34.    // <editor-fold defaultstate="collapsed" desc="Generated Code">
  35.    private void initComponents() {
  36.  
  37.        jButton1 = new javax.swing.JButton();
  38.        jScrollPane1 = new javax.swing.JScrollPane();
  39.        textoEnv = new javax.swing.JTextArea();
  40.  
  41.        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
  42.        addWindowListener(new java.awt.event.WindowAdapter() {
  43.            public void windowClosed(java.awt.event.WindowEvent evt) {
  44.                formWindowClosed(evt);
  45.            }
  46.            public void windowClosing(java.awt.event.WindowEvent evt) {
  47.                formWindowClosing(evt);
  48.            }
  49.        });
  50.  
  51.        jButton1.setText("Enviar");
  52.        jButton1.addActionListener(new java.awt.event.ActionListener() {
  53.            public void actionPerformed(java.awt.event.ActionEvent evt) {
  54.                jButton1ActionPerformed(evt);
  55.            }
  56.        });
  57.  
  58.        textoEnv.setColumns(20);
  59.        textoEnv.setRows(5);
  60.        jScrollPane1.setViewportView(textoEnv);
  61.  
  62.        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
  63.        getContentPane().setLayout(layout);
  64.        layout.setHorizontalGroup(
  65.            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
  66.            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
  67.                .addContainerGap(337, Short.MAX_VALUE)
  68.                .addComponent(jButton1)
  69.                .addContainerGap())
  70.            .addGroup(layout.createSequentialGroup()
  71.                .addGap(21, 21, 21)
  72.                .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
  73.                .addContainerGap(117, Short.MAX_VALUE))
  74.        );
  75.        layout.setVerticalGroup(
  76.            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
  77.            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
  78.                .addContainerGap(89, Short.MAX_VALUE)
  79.                .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
  80.                .addGap(83, 83, 83)
  81.                .addComponent(jButton1)
  82.                .addContainerGap())
  83.        );
  84.  
  85.        pack();
  86.    }// </editor-fold>
  87.  
  88.    private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {
  89.        try {
  90.            String cadena = textoEnv.getText();
  91.            dos.writeBoolean(true);
  92.            dos.writeUTF(cadena);
  93.  
  94.        } catch (IOException ex) {
  95.            Logger.getLogger(ClienteGui.class.getName()).log(Level.SEVERE, null, ex);
  96.        }
  97.    }
  98.  
  99.    private void formWindowClosed(java.awt.event.WindowEvent evt) {
  100.  
  101.    }
  102.  
  103.    private void formWindowClosing(java.awt.event.WindowEvent evt) {
  104.        try {
  105.            dos.writeBoolean(false);
  106.        } catch (IOException ex) {
  107.            Logger.getLogger(ClienteGui.class.getName()).log(Level.SEVERE, null, ex);
  108.        }
  109.    }
  110.  
  111.    /**
  112.     * @param args the command line arguments
  113.     */
  114.    public static void main(String args[]) {
  115.        java.awt.EventQueue.invokeLater(new Runnable() {
  116.            public void run() {
  117.                try {
  118.                    new ClienteGui().setVisible(true);
  119.                    socket = new Socket("localhost", 5557);
  120.                    is = socket.getInputStream();
  121.                    os = socket.getOutputStream();
  122.                    dis = new DataInputStream(is);
  123.                    dos = new DataOutputStream(os);
  124.                } catch (IOException ex) {
  125.                    Logger.getLogger(ClienteGui.class.getName()).log(Level.SEVERE, null, ex);
  126.                }
  127.            }
  128.        });
  129.    }
  130.  
  131.    // Variables declaration - do not modify
  132.    private javax.swing.JButton jButton1;
  133.    private javax.swing.JScrollPane jScrollPane1;
  134.    private javax.swing.JTextArea textoEnv;
  135.    // End of variables declaration
  136.  
  137. }
  138.  
  139.  


Servidor.java

Código
  1. package sockets;
  2.  
  3. import java.io.IOException;
  4. import java.net.ServerSocket;
  5. import java.net.Socket;
  6. import threads.ThreadServidor;
  7.  
  8. /**
  9.  *
  10.  * @author debci
  11.  */
  12. public class Servidor {
  13.  
  14.    public static void main(String[] args) throws IOException {
  15.      Servidor servidor = new Servidor();
  16.      servidor.ServidorChat();
  17.  
  18.    }
  19.  
  20.   public void ServidorChat()
  21.    {
  22.        try
  23.        {
  24.            ServerSocket socketServidor = new ServerSocket(5557);
  25.  
  26.            while (true)
  27.            {
  28.                System.out.println("Esperando conexiones...");
  29.                Socket cliente = socketServidor.accept();
  30.  
  31.                Runnable nuevoCliente = new ThreadServidor(cliente);
  32.                Thread hilo = new Thread(nuevoCliente);
  33.                hilo.start();
  34.  
  35.            }
  36.        } catch (Exception e)
  37.        {
  38.            e.printStackTrace();
  39.        }
  40.    }
  41. }
  42.  
  43.  
  44.  

ThreadServidor.java
Código
  1. package threads;
  2.  
  3. import java.io.DataInputStream;
  4. import java.io.DataOutputStream;
  5. import java.io.IOException;
  6. import java.net.Socket;
  7. import java.util.logging.Level;
  8. import java.util.logging.Logger;
  9.  
  10. /**
  11.  *
  12.  * @author debci
  13.  */
  14. public class ThreadServidor extends Thread {
  15.  
  16. //Socket al que esta conectado el cliente
  17.    private Socket socket1;
  18.  
  19. /** Para lectura de datos en el socket */
  20.    private DataInputStream dataInput;
  21.  
  22.    /** Para escritura de datos en el socket */
  23.    private DataOutputStream dataOutput;
  24.  
  25.    private boolean acabado = true;
  26.  
  27.  
  28.    public ThreadServidor(Socket socket) {
  29.        try {
  30.            socket1 = socket;
  31.            dataInput = new DataInputStream(socket.getInputStream());
  32.            dataOutput = new DataOutputStream(socket.getOutputStream());
  33.  
  34.        } catch (IOException ex) {
  35.  
  36.            System.err.println("Error de procesamiento de datos: \n" + ex);
  37.  
  38.        }
  39.    }
  40.  
  41.    public void run() {
  42.        try {
  43.          while(acabado){
  44.            acabado = dataInput.readBoolean();
  45.            String mensajeRecivido = dataInput.readUTF();
  46.            System.out.println(mensajeRecivido + "\n");
  47.  
  48.          }
  49.  
  50.        } catch (IOException ex) {
  51.            Logger.getLogger(ThreadServidor.class.getName()).log(Level.SEVERE, null, ex);
  52.        }
  53.  

Me explico, la cosa esta en que cuando el cliente, se cierra (formClosing) se envia el booleano al thread que lo esta atendiendo.
Si el booleano se cambia, se rompe el bucle while y se muere el thread.

El problema, y no se de donde viene, es que cuando cierro un cliente y le pido desconexion y que mate al thread, el servidor libera un error:

Código:
26-dic-2009 15:30:55 threads.ThreadServidor run
GRAVE: null
java.io.EOFException
        at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:323)
        at java.io.DataInputStream.readUTF(DataInputStream.java:572)
        at java.io.DataInputStream.readUTF(DataInputStream.java:547)
        at threads.ThreadServidor.run(ThreadServidor.java:50)
        at java.lang.Thread.run(Thread.java:619)
Me da ese error y luego continua atendiendo clientes, cada vez que cierro un cliente me lo da, y no se porque es, y como comprendereis no quiero darle uso a una aplicacon que tiene un defecto claro.

Saludos y gracias a todos.


En línea

Leyer


Desconectado Desconectado

Mensajes: 786


leyer@elhacker.net


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #1 en: 26 Diciembre 2009, 23:34 pm »

 :P si es verdad es un error tonto. te da ese error por que  no estas haciendo la comprobacion del cierre de conexion en el hilo usuario que estas creando en tu caso es ThreadServidor..

Saludos!


En línea

Debci
Wiki

Desconectado Desconectado

Mensajes: 2.021


Actualizate o muere!


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #2 en: 27 Diciembre 2009, 15:00 pm »

:P si es verdad es un error tonto. te da ese error por que  no estas haciendo la comprobacion del cierre de conexion en el hilo usuario que estas creando en tu caso es ThreadServidor..

Saludos!
Mmm comprovacion? a que te refieres, algun tipo de ping?

Saludos
En línea

panaka


Desconectado Desconectado

Mensajes: 513



Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #3 en: 27 Diciembre 2009, 16:45 pm »

Supongo que se referirar a que cuando intentas utilizar una conexion que has cerrado no has comprobado si efectivametne dicha coenxion esta bind, prueba.isConected(), .isBound()
Saludos
En línea




Chuck Norris es tan friki tan friki que ve la televisión en el osciloscopio
Debci
Wiki

Desconectado Desconectado

Mensajes: 2.021


Actualizate o muere!


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #4 en: 27 Diciembre 2009, 17:06 pm »

Gracias a todos, resuelto ^^
Para no abrir otro post, preguinto aqui mi nueva duda:
Como puedo hacer para que todo lo que envien todos los clientes, el servidor lo envie a todos, es decir, lo que un cliente envia a su thread en el servidor, el thread lo mande a los demas clientes, una sala de chat por asi decirlo, es que mi logica no llega a mas, no veo de que manera podria hacerlo.

Saludos y gracias a todos
En línea

Leyer


Desconectado Desconectado

Mensajes: 786


leyer@elhacker.net


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #5 en: 27 Diciembre 2009, 18:35 pm »

muy facil tienes que hacer un vector o HasTable( lo recomiendo) donde almacenaras los hilos de los usuarios por su IP u otra referencia que puedas usar es decir HasTable.put("127.0.0.1",usuario); donde usuario es el objeto de hilo usuario que creas por cada conexion entrante al servidor  ..entonces cuando llega un mensaje el servidor solo tienes que leer todos los usuarios y eviarle el mensaje recibido a todos..ya que cada uno tendra su metodo de lectura y escritura (In/Out);)  tambien sirve para mensajes privados solo hay que usar un poco mas la logica :) espero te de la idea .asi lo ise en mi Jchat :D

Saludos

Edit:
Sobre lo anterior.
Yo me referia a que en el servidor no estabas creando la comprobacion del cierre es decir que cuando el cliente enviaba el boolean para cerrar..daba error en el hilo usuario del servidor por que no estaba la accion de dicha accion de cierre. if(!acabado) break;
« Última modificación: 27 Diciembre 2009, 18:58 pm por LEYER » En línea

Debci
Wiki

Desconectado Desconectado

Mensajes: 2.021


Actualizate o muere!


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #6 en: 27 Diciembre 2009, 19:01 pm »

muy facil tienes que hacer un vector o HasTable( lo recomiendo) donde almacenaras los hilos de los usuarios por su IP u otra referencia que puedas usar es decir HasTable.put("127.0.0.1",usuario); donde usuario es el objeto de hilo usuario que creas por cada conexion entrante al servidor  ..entonces cuando llega un mensaje el servidor solo tienes que leer todos los usuarios y eviarle el mensaje recibido a todos..ya que cada uno tendra su metodo de lectura y escritura (In/Out);)  tambien sirve para mensajes privados solo hay que usar un poco mas la logica :) espero te de la idea .asi lo ise en mi Jchat :D

Saludos

Edit:
Sobre lo anterior.
Yo me referia a que en el servidor no estabas creando la comprobacion del cierre es decir que cuando el cliente enviaba el boolean para cerrar..daba error en el hilo usuario del servidor por que no estaba la accion de dicha accion de cierre. if(!acabado) break;
Mira yo he pensado lo siguiente, a cada user una id, y a partir de esto le asigno un hilo a cada uno, pero se me plantea una duda, si meto la id con el hilo en la hashtable como escribo los streams solo con e hilo alamacenado?

Saludos
« Última modificación: 27 Diciembre 2009, 19:03 pm por ,.-~*´¨¯¨`*·~-.¸..::| D3Bć1 |::.,.-~*´¨¯¨`*·~-.¸ » En línea

Leyer


Desconectado Desconectado

Mensajes: 786


leyer@elhacker.net


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #7 en: 27 Diciembre 2009, 19:11 pm »

bueno el obj usuario oviamente tienes que pasarle el socket solo tienes que hacer en el obj o hilo usuario los stream in/out la entrada puedes hacerla en el metodo run del obj usuario para recibir. creo que te refieres a eso.. 
En línea

Debci
Wiki

Desconectado Desconectado

Mensajes: 2.021


Actualizate o muere!


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #8 en: 27 Diciembre 2009, 20:02 pm »

bueno el obj usuario oviamente tienes que pasarle el socket solo tienes que hacer en el obj o hilo usuario los stream in/out la entrada puedes hacerla en el metodo run del obj usuario para recibir. creo que te refieres a eso.. 
Vale, mira, haber si me lo planteo:

Algoritmo:

Server escucha
Cliente activo [1]
Servidor Guarda en hashTable
Cliente activo [2]
Servidor guarda en HashTable
Cliente[1] escribe streamSocket
Servidor lee en el thread de ese cliente, y lo envia al bucle del servidor.
Servidor recorre hashTable (todos los indices) y saca uno a uno los sockets de estos para escribir el stream
Todos los cliente lo reciven.

Seria asi?

Buff y eso aguantar el servidor?
Que duro... y poderoso el lenguaje Java...

Bestial

Saludos
En línea

Leyer


Desconectado Desconectado

Mensajes: 786


leyer@elhacker.net


Ver Perfil WWW
Re: Error tonto con threads y sockets
« Respuesta #9 en: 27 Diciembre 2009, 20:09 pm »

no saca los socket solo llama al metodo escritura y pues si es correpto el servidor funcionara bien ya lo veras
« Última modificación: 27 Diciembre 2009, 20:12 pm por LEYER » En línea

Páginas: [1] 2 3 Ir Arriba Respuesta Imprimir 

Ir a:  

Mensajes similares
Asunto Iniciado por Respuestas Vistas Último mensaje
[Sockets] - Error en BIND
Programación C/C++
farresito 2 4,527 Último mensaje 26 Abril 2011, 19:52 pm
por farresito
[AYUDA] Error en sockets
Programación C/C++
goro_333 6 4,092 Último mensaje 20 Mayo 2012, 22:56 pm
por goro_333
error al compilar sockets en c
Programación C/C++
Drewermerc 1 2,647 Último mensaje 27 Abril 2014, 22:54 pm
por Drewermerc
Corrigen el error más tonto del mundo en la calculadora de Windows 10 que ...
Noticias
wolfbcn 0 943 Último mensaje 24 Enero 2019, 21:58 pm
por wolfbcn
Uso de Threads y error de compilación asignado a una libreria estandar...
Programación C/C++
digimikeh 1 1,712 Último mensaje 4 Agosto 2019, 21:17 pm
por Loretz
WAP2 - Aviso Legal - Powered by SMF 1.1.21 | SMF © 2006-2008, Simple Machines