[Java] Appello Reti di Calcolatori

[luxorl]

Ciao a tutti, di seguito riporto la traccia di un esercizio di un vecchio appello di reti di calcolatori della mia università:


Si vuole realizzare un’applicazione Director capace di gestire una serie di attività eseguibili parallelamente.
Il sistema è composto da un coordinatore centrale, chiamato Master, e da un numero N di macchine,
chiamate Slave, che eseguono tutte lo stesso tipo di attività. Ogni Slave può eseguire una sola attività. Il
Master attende la richiesta di un client e, una volta ricevuta, individua se possibile uno Slave libero e lo
contatta per dare inizio all’attività. Se tutte le macchine Slave sono occupate il Master risponde
immediatamente al client inviando la stringa “SYSTEM BUSY”.
Per avviare l’attività di una macchina Slave, il Master deve semplicemente inviargli la stringa “START
ACTIVITY”. Il Master attende la fine dell’attività della macchina Slave e poi avvisa il client inviando la
stringa “ACTIVITY OVER”.
Si richiede di implementare in Java :
− una classe per la gestione del modulo Master (IP: 150.100.100.100 TCP port: 1111).
− una classe per la gestione delle macchine Slave (IP: 150.100.100.10x TCP port: 2222, con
x = 1….N ).


Vorrei sapere, per favore, se secondo voi potrebbe andare bene questa mia soluzione...

Classe Slave da installare su ogni singola macchina Slave:

import java.net.*;
import java.io.*;
import java.util.*;

public class Slave{
public static final int PORT=2222;

public static void main(String args[]){
try{
while(true){
ServerSocket serverSocket=new ServerSocket(PORT);
//attesa comando
Socket socket=serverSocket.accept();

//creazione stream in input
BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//creazione stream in output
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
PrintWriter out=new PrintWriter(bw, true);

//controllo comando
if(in.readLine().equals("START ACTIVITY")){
Thread.sleep(15000); //simulo lo svolgimento dell'attività
out.println("ACTIVITY OVER");
}else{
out.println("COMMAND ERROR");
}
//chiudo le risorse
in.close();
out.close();
serverSocket.close();
socket.close();
}//while

}catch(Exception e){ System.out.println(e); }
}//run
}


Classe Master da installare sulla macchina master

import java.net.*;
import java.util.*;
import java.io.*;

public class Master{
public static void main(String args[]){
int nSlave=9;
boolean slaveLiberi[]=new boolean[nSlave];

//inizialmente tutti liberi
for(int i=0; i<nSlave; i++){
slaveLiberi[i]=true;
}

try{
while(true){
//creo il datagram socket sulla porta 1111
DatagramSocket ds=new DatagramSocket(1111);
byte buf[]=new byte[256];
DatagramPacket packet=new DatagramPacket(buf, buf.length);
//mi metto in attesa di una richiesta
ds.receive(packet);

//arrivata la richiesta controllo se ci sono slave liberi
int x=-1;
for(int i=0; i<nSlave; i++){
if(slaveLiberi[i]==true){
x=i;
slaveLiberi[i]=false;
break;
}
}

//se non ce ne sono
if(x==-1){
String s="SYSTEM BUSY";
buf=s.getBytes();

//prendo indirizzo e porta del richiedente e gli invio SYSTEM BUSY
InetAddress address=packet.getAddress();
int portClient=packet.getPort();
DatagramPacket packet2=new DatagramPacket(buf, buf.length, address, portClient);
ds.send(packet2);

}else{ //se c'è uno slave libero creo la connessione verso di lui
String ipSlave="150.100.100.10"+x;
InetAddress addressSlave=InetAddress.getByName(ipSlave);
Socket socket=new Socket(addressSlave, 2222);
String s="START ACTIVITY";
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
PrintWriter out=new PrintWriter(bw, true);
out.println(s); //gli invio il comando di partire

//attendo risposta
BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
System.out.println(in.readLine());
}
}//while

}catch(Exception e){
System.out.println(e);
}
}

}


Il compilatore non da errori, però non posso provarlo runtime... per questo chiedo a voi :) ...grazie