lpr-b-2007-2008:serverthread
package nslookup; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.net.InetAddress; import java.net.Socket; import java.util.HashMap; import java.util.Map; public class ServerThread extends Thread { Map<String,InetAddress> cache = null; Socket s = null; public ServerThread(Map<String,InetAddress> c, Socket ts) { cache = c; s = ts; } public void run() { try { System.out.println("ServerThread started"); ObjectInputStream ois = new ObjectInputStream(s.getInputStream()); Object o = ois.readObject(); if(o instanceof NameQuery) { // trattamento della richiesta NameQuery nq = (NameQuery) o; String hostName = nq.getHostname(); System.out.println("Looking up "+hostName); if(cache.containsKey(hostName) && nq.getCached()) { System.out.println(hostName+" gia' in cache con indirizzo "+cache.get(host Name)); } else { // host non in cache o cached false if(cache.containsKey(hostName)) { // se c'era, cancellalo prima di reineri rlo InetAddress ia = cache.get(hostName); cache.remove(hostName); System.out.println("Cancellata entry cache <"+hostName+","+ia+">") ; } InetAddress ia = InetAddress.getByName(hostName); cache.put(hostName, ia); System.out.println("Aggiunto in cache: <"+hostName+","+ia+">"); } // adesso invia la risposta ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream()); QueryAnswer qa = new QueryAnswer(hostName,cache.get(hostName)); oos.writeObject(qa); return; } else { // tipo non previsto, restituisce un messaggio di errore ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream()); System.out.println("Tipo imprevisto per l'oggetto letto"); QueryAnswer qa = new QueryAnswer(); oos.writeObject(qa); return; } } catch (IOException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { System.out.println("Non trovo la class per l'oggetto letto"); return; } } }
lpr-b-2007-2008/serverthread.txt · Ultima modifica: 19/09/2008 alle 14:08 (16 anni fa) da 127.0.0.1