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

 
package sockets;
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
 
/**
 *
 * @author debci
 */
public class ClienteGui extends javax.swing.JFrame {
            public static Socket socket;
            public static InputStream is;
            public static OutputStream os;
            public static DataInputStream dis;
            public static DataOutputStream dos;
    /** Creates new form ClienteGui */
    public ClienteGui() {
        initComponents();
    }
 
    /** This method is called from within the constructor to
     * initialize the form.
     * WARNING: Do NOT modify this code. The content of this method is
     * always regenerated by the Form Editor.
     */
    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">
    private void initComponents() {
 
        jButton1 = new javax.swing.JButton();
        jScrollPane1 = new javax.swing.JScrollPane();
        textoEnv = new javax.swing.JTextArea();
 
        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
        addWindowListener(new java.awt.event.WindowAdapter() {
            public void windowClosed(java.awt.event.WindowEvent evt) {
                formWindowClosed(evt);
            }
            public void windowClosing(java.awt.event.WindowEvent evt) {
                formWindowClosing(evt);
            }
        });
 
        jButton1.setText("Enviar");
        jButton1.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                jButton1ActionPerformed(evt);
            }
        });
 
        textoEnv.setColumns(20);
        textoEnv.setRows(5);
        jScrollPane1.setViewportView(textoEnv);
 
        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap(337, Short.MAX_VALUE)
                .addComponent(jButton1)
                .addContainerGap())
            .addGroup(layout.createSequentialGroup()
                .addGap(21, 21, 21)
                .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addContainerGap(117, Short.MAX_VALUE))
        );
        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap(89, Short.MAX_VALUE)
                .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addGap(83, 83, 83)
                .addComponent(jButton1)
                .addContainerGap())
        );
 
        pack();
    }// </editor-fold>
 
    private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {
        try {
            String cadena = textoEnv.getText();
            dos.writeBoolean(true);
            dos.writeUTF(cadena);
 
        } catch (IOException ex) {
            Logger.getLogger(ClienteGui.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
 
    private void formWindowClosed(java.awt.event.WindowEvent evt) {
 
    }
 
    private void formWindowClosing(java.awt.event.WindowEvent evt) {
        try {
            dos.writeBoolean(false);
        } catch (IOException ex) {
            Logger.getLogger(ClienteGui.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
 
    /**
    * @param args the command line arguments
    */
    public static void main(String args[]) {
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                try {
                    new ClienteGui().setVisible(true);
                    socket = new Socket("localhost", 5557);
                    is = socket.getInputStream();
                    os = socket.getOutputStream();
                    dis = new DataInputStream(is);
                    dos = new DataOutputStream(os);
                } catch (IOException ex) {
                    Logger.getLogger(ClienteGui.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
        });
    }
 
    // Variables declaration - do not modify
    private javax.swing.JButton jButton1;
    private javax.swing.JScrollPane jScrollPane1;
    private javax.swing.JTextArea textoEnv;
    // End of variables declaration
 
}
 
 

Servidor.java

package sockets;
 
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import threads.ThreadServidor;
 
/**
 *
 * @author debci
 */
public class Servidor {
 
    public static void main(String[] args) throws IOException {
      Servidor servidor = new Servidor();
      servidor.ServidorChat();
 
    }
 
   public void ServidorChat()
    {
        try
        {
            ServerSocket socketServidor = new ServerSocket(5557);
 
            while (true)
            {
                System.out.println("Esperando conexiones...");
                Socket cliente = socketServidor.accept();
 
                Runnable nuevoCliente = new ThreadServidor(cliente);
                Thread hilo = new Thread(nuevoCliente);
                hilo.start();
 
            }
        } catch (Exception e)
        {
            e.printStackTrace();
        }
    }
}
 
 
 

ThreadServidor.java

package threads;
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
 
/**
 *
 * @author debci
 */
public class ThreadServidor extends Thread {
 
//Socket al que esta conectado el cliente
    private Socket socket1;
 
/** Para lectura de datos en el socket */
    private DataInputStream dataInput;
 
    /** Para escritura de datos en el socket */
    private DataOutputStream dataOutput;
 
    private boolean acabado = true;
 
 
    public ThreadServidor(Socket socket) {
        try {
            socket1 = socket;
            dataInput = new DataInputStream(socket.getInputStream());
            dataOutput = new DataOutputStream(socket.getOutputStream());
 
        } catch (IOException ex) {
 
            System.err.println("Error de procesamiento de datos: \n" + ex);
 
        }
    }
 
    public void run() {
        try {
          while(acabado){
            acabado = dataInput.readBoolean();
            String mensajeRecivido = dataInput.readUTF();
            System.out.println(mensajeRecivido + "\n");
 
          }
 
        } catch (IOException ex) {
            Logger.getLogger(ThreadServidor.class.getName()).log(Level.SEVERE, null, ex);
        }
 

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:

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.

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

Saludos

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

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

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

llamo al metodo de escritura sobre la hashTable? pero no deberia hacer lo siguiente:

for(int i = 0;length de hashtable; i++){
Socket socketVolatil = hashTable.getKey(o parecido)
socketVolatil.writeUtf(datosrecividosdeuncliente);
}

NO?

Saludos

Me da un nuevo problema... y no entiendo porque :s

Mira te lo enseño:

Cuando el servidor recive una nueva conexion, por tanto un nuevo cliente aumenta el contador de clientes, cuando este se va disminuye en uno el contador, asi que uso esas keys para identificarlos en la hashTable:

 public void ServidorChat()
    {
        try
        {
            ServerSocket socketServidor = new ServerSocket(5558);
 
            while (true)
            {
                System.out.println("Esperando conexiones...");
                Socket cliente = socketServidor.accept();
                contador++;
                System.out.println("Bienvenid@ cliente numero " + contador + ".\n");
 
 
                Runnable nuevoCliente = new ThreadServidor(cliente);
                Thread hilo = new Thread(nuevoCliente);
                hilo.start();
                System.out.println("Te hemos asignado el thread: " + hilo + ".\n");
                vextorClientes.put(contador, socket);
 
 
            }
        } catch (Exception e)
        {
            e.printStackTrace();
        }
    }
 

Y ahi em da error al ejecutar, es decir, cuando recivo una nueva conexion y guardo los datos del cliente en el vector (HashTable), me da el siguiente error:

Esperando conexiones...
java.lang.NullPointerException
Bienvenid@ cliente numero 1.
        at threads.ThreadServidor.<init>(ThreadServidor.java:41)
        at sockets.Servidor.ServidorChat(Servidor.java:41)
        at sockets.Servidor.main(Servidor.java:23)

En la linea que marca error tengo el HashTable que reocje el socket y la clave.
Porque? no lo se...


Saludos

osea que el paso a runable lo puedo quitar y ejecutar directamente el thread?
Edito:
Ahora he declarado la hastable como me has dicho y hay otro error:

Esperando conexiones...
Bienvenid@ cliente numero 1.

java.lang.NullPointerException
Te hemos asignado el thread: Thread[Thread-1,5,main].
        at sockets.Servidor.ServidorChat(Servidor.java:45)
        at sockets.Servidor.main(Servidor.java:23)

Adios cliente 1

No veo porque ocurre pero weno...

Saludos

EDITO:
Solucionado, hacia falta instanciar el obejto mediante el operador new:

public static Hashtable<Integer,Socket> vectorClientes = new Hashtable();
 

Ahoraaa si, voy a probar con el metodo que me dijiste.
Me parece increible que se peuda automatizar una tarea tan compleja, crear microprocesos para cada cliente y que etsen activos todo el rato atendiendo a sus clientes, que se recorran las listas de clientes y se envien datos...

Cada vez es mas flipante.

Saludos