POO Lab Lucrarea 5

Noțiuni și cunoștințe necesare

• Paradigma Obiect-Orientare; Clase și obiecte
• Noțiuni despre Java
• Realizarea și execuția unui program Java
• Sintaxa limbajului Java; Structura lexicală a unui program
• Convenții de programare
• Noțiuni avansate de programare obiect-orientată
• Java Application Programming Interface (API)
• Stream-uri de Input/Output
• Tratarea excepțiilor
• Serializarea obiectelor
• Socket-uri de rețea
• Programare concurentă - fire de execuție (Threads)

Cerințe

1. Modificați clasa seriaf.poo.client.ClientPeer scrisă la tema anterioară, transformând-o într-un fir de execuție care în paralel cu firul principal de execuție, să citească obiecte de tip seriaf.poo.structs.Message dinspre server și să le afișeze pe ecran. Acest thread, odată instanțiat, trebuie pornit de către clasa seriaf.poo.client.TextClient.
2. Modificați clasa seriaf.poo.server.ServerPeer scrisă la tema anterioară, transformând-o într-un fir de execuție. Acest fir nou de execuție trebuie să citească obiectele de tip seriaf.poo.structs.Message și seriaf.poo.structs.PrivateMessage de la clientul asociat și să le distribuie corect la ceilalți clienți.
3. Adăugați clasei seriaf.poo.structs.Message o metodă getter publică pentru expeditor, numită String getSender().
4. Pentru a putea retransmite mesajele celorlalți clienți, clasa seriaf.poo.server.ServerPeer trebuie să aibă o metodă publică void sendMessage(Message) care să serializeze obiectul primit ca argument către clientul conectat.
5. Pentru a putea folosi clasa seriaf.poo.server.Server să trimită mesajele clienților conectați, clasa seriaf.poo.server.ServerPeer trebuie să aibă o referință la clasa seriaf.poo.server.Server. Astfel, modificați constructorul clasei seriaf.poo.server.ServerPeer astfel încât să aibă semnătura ServerPeer(Server, Socket).
6. Pentru a putea trimite corect mesajele private, clasa seriaf.poo.server.ServerPeer trebuie să aibă o metodă publică numită String getUsername() care să întoarcă numele client-ului conectat la acel ServerPeer. Numele este stocat în clasă într-un câmp privat, care se actualizează la fiecare mesaj primit, extrăgând din mesaj numele expeditorului.
7. Modificați clasa seriaf.poo.server.Server scrisă la tema anterioară, astfel încât la conectarea unui client, aceasta să creeze un nou seriaf.poo.server.ServerPeer pe care să-l pornească ca Thread, apoi să revină în metoda ServerSocket.accept(), așteptând o nouă conexiune.
8. Clasa seriaf.poo.server.Server trebuie acum să fie instanțiabilă. Adăugați un constructor care să ia ca argument port-ul TCP pe care server-ul sa asculte și numărul maxim de clienți posibili. În acest constructor trebuie instanțiat obiectul de tip ServerSocket.
9. Bucla cu apelul metodei accept din seriaf.poo.server.Server trebuie acum să fie mutată într-o metodă separată a clasei seriaf.poo.server.Server numită void listen().
10. În metoda main din seriaf.poo.server.Server trebuie să rămână o instanțiere de obiect seriaf.poo.server.config.ServerConfig, o instanțiere de obiect seriaf.poo.server.Server și un apel de metodă listen(), cu blocurile try-catch necesare.
11. Clasa seriaf.poo.server.Server trebuie să mai conțină două metode, void dispatch(Message) și void removeClient(ServerPeer). Prima este apelată de către obiectele de tip seriaf.poo.server.ServerPeer cu mesajele primite de la clienți, și are rolul de a le trimite mai departe, către ceilalți clienți. A doua metodă este apelată când un client de deconectează (voit sau datorită unei erori), pentru a fi elimiat din listă.
12. Server-ul nu trebuie să accepte o conexiune dacă numărul de clienți conectați este deja egal cu proprietatea MAX_CLIENTS citită din fișierul server.conf de către seriaf.poo.server.config.ServerConfig.
13. Atenție care metode trebuie să fie sincronizate (pentru a trece testele, nu folosiți blocuri synchronized, ci declarați toată metoda sincronizată).
14. Administrați excepțiile astfel încât dacă apare o eroare de conexiune, server-ul să fie robust și să continue să servească corect ceilalți clienți conectați și să poate accepta un client nou în locul clientului pierdut.

Note:

• Obiectele de tip seriaf.poo.structs.Message se trimit tuturor clienților conectați. Obiectele de tip seriaf.poo.structs.PrivateMessage se trimit doar către expeditor și către destinatar.
• Clasa Server ar trebui să păstreze o listă cu toți clienții conectați (cu obiectele de tip ServerPeer). Pentru acest lucru vă puteți folosi de clasa java.util.ArrayList.
• Această listă trebuie să fie menținută în sensul că noii clienți trebuie adăugați, iar clienții deconectați trebuie eliminați.
• Pentru a verifica dacă un obiect e instanță a unei clase anume, puteți folosi operatorul instanceof:

Object o = ois.readOject();
if(o instanceof String){
    String s = (String)o;
    System.out.print(s);
}else{
    System.out.print("The object is not a String!");
}