servidorchatjdk14.java

Example mini chat developed in java.

/*
 * ServidorChatJDK14.java
 *
 * Created on 26 de abril de 2006, 13:58
 */

/**
 *
 * @author  TeimoyM
 */
import java.io.*;
import java.nio.*;
import java.net.*;
import java.nio.channels.*;
import java.util.Vector;
//C骴igo solo v醠ido en JDK 1.4
//Se han utilizado los m閠odos, ejemplos y l韓eas de c骴igo expuestas
//a lo largo del apartado 5
public class ServidorChatJDK14 extends Thread {
private Vector clientesActivos=new Vector();
public ServidorChatJDK14(){ System.out.println("Arrancando servidor");
}
public void run(){
try{
ServerSocketChannel canalss=ServerSocketChannel.open();
canalss.configureBlocking(false);
ServerSocket sservidor =canalss.socket();
//El socket servidor escucha peticiones por el puerto 9000
sservidor.bind(new InetSocketAddress(9000));
Selector miselector=Selector.open();
canalss.register(miselector, SelectionKey.OP_ACCEPT);
while(true){
//Si ocurre alg鷑 evento
if (miselector.select()>0){
Set claves=miselector.selectedKeys();
Iterator iterador=claves.iterator();
//Se recorren los canales que han registrado eventos
while(iterador.hasNext()){ //Cada objeto clave representa un canal que
//tenido un evento
SelectionKey clave=(SelectionKey)iterador.next();
if (clave.isAcceptable()) { //Estamos ante una conexi髇 de un
//cliente: el socket del servidor ha aceptado la conexi髇
//Se acepta la petici髇 del cliente
Socket socket=sservidor.accept();
clientesActivos.addElement(socket);
SocketChannel canalsocket=socket.getChannel();
canalsocket.configureBlocking(false);
canalsocket.register(miselector, SelectionKey.OP_READ);
miselector.selectedKeys().remove(clave);
}
if (clave.isReadable()) 
{ //Estamos ante un recepci髇 de datos por parte
// de un cliente
SocketChannel canalsocketlectura= (SocketChannel)clave.channel();
miselector.selectedKeys().remove(clave);
String mensaje=leerMensaje(canalsocketlectura);
if (mensaje.length()>0) 
    enviarMensajesATodos(mensaje);
}
}
}
}
}
catch(IOException e){System.out.println("Excepci髇: "+e);}
}
}