Estoy haciendo pruebas con sockets con hilos y quiero que cada nuevo cliente que se conecta al servidor sea atendido por un hilo y que en el servidor aparezca el número de sockets en cuestión. Alguna sugerencia?
import java.net.Socket;
public class MainCliente extends Thread {
static long clientesAtendidos = 0;
static long hilosActivos = 0;
Socket socket;
public MainCliente(Socket socket) {
this.socket = socket;
}
synchronized long clientesAtendidos() {
return clientesAtendidos;
}
synchronized void iniciando() {
clientesAtendidos++;
hilosActivos++;
}
synchronized void terminando() {
hilosActivos--;
}
public void run() {
iniciando();
try {
despacha();
}
catch (Exception e) {
//aqui manejas la excepción
e.printStackTrace(System.err);
}
finally {
terminando();
}
}
protected void despacha() throws Exception {
hilosActivos++; //etc etc
//aquí tienes el Socket con el que estás conectado al cliente para comunicarte
//con el cliente
//...
socket.close();
}
}
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
// Clase base Conexíon (de la que hereda MainCliente y MainServidor)
public class Conexion
{
private final int PORT = 8080; // Puerto común para la conexión
private final String HOST = "localhost"; // Host para la conexión
protected ServerSocket ss; // Socket del servidor
protected Socket cs; // Socket del cliente
// Constructor
public Conexion(String tipo) throws IOException
{
if(tipo.equalsIgnoreCase("servidor"))
{
ss = new ServerSocket(PORT); // Se crea el socket para el servidor en puerto 1234
cs = new Socket(); // Socket para el cliente
}
else
{
cs = new Socket(HOST, PORT); // Socket para el cliente en localhost en puerto 1234
}
}
}
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class MainServidor extends Conexion //Se hereda de conexión para hacer
uso de los sockets y demás
{
int idCliente = 0;
protected String mensajeEntrantes;
protected DataOutputStream salidaCliente; // Flujo de datos de salida
public MainServidor() throws IOException{ super("servidor");
}
// Método para iniciar el servidor
public void startServer() throws Exception
{
//Nota que no estamos cerrando ServerSocket aquí ya que el método
//es iniciaServidor. Creo que se debería cerrar en otra parte.
while(true) { // ???
System.out.println("Esperando..."); // Esperando conexión
Socket cs = ss.accept();
//aquí se conecta un cliente al server socket y muestra
//el mensaje que se ha conectado un cliente, y despacha
//al cliente en un hilo individual (DespachaClientes)
idCliente++;
System.out.println("Cliente " + idCliente + " en línea");
MainCliente hilo = new MainCliente(cs);
hilo.start();
System.out.println("clientes atendidos:"+hilo.clientesAtendidos());
}
}
}