Na seguinte classe SocketServidor
envio uma única thread com o out
e o in
, mas o suposto é esta classe conseguir enviar duas threads quando corre.
Supostamente tem de fazer isto:
O servidor deverá funcionar em multithreading, tendo para cada ligação ativa duas threads, que designaremos por in e out:
- in para receção de mensagens dos clientes (input stream) Esta thread estará bloqueada à espera de mensagens do cliente. As mensagens que o servidor recebe deverão ser guardadas numa estrutura em memória. Quando um dado utilizador tem mensagens novas, caso este esteja online, a thread out associada à sua ligação deverá ser notificada, por forma a processar a entrega das mensagens.
- out para entrega de mensagens e notificações aos clientes (output stream) Esta thread estará em espera, tornando se ativa no momento em que existem mensagens novas ou notificações de entrega de mensagens relativas ao utilizador da ligação.
SocketServidor
public class SocketServidor extends Thread{
private ServerSocket servidorSocket;
private Socket socket;
private static final int PORTA = 8080;
//HashMap recurso partilhado! (sempre que invocarmos este recurso temos de fazer synchronized)
private Map<String, ObjectOutputStream> utilizadores = new HashMap<String, ObjectOutputStream>(); //utilizadores da aplicacao (online!)
public SocketServidor(){
try {
servidorSocket = new ServerSocket(PORTA);
System.out.println("Estabelecer ligação TCP/IP no porto: " + PORTA);
System.out.println("A aguardar conexão do cliente...");
while(true){
socket = servidorSocket.accept();
new Thread(new ListennerSocket(socket)).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}