147 lines
4.5 KiB
Java
147 lines
4.5 KiB
Java
package stub_skeleton;
|
|
|
|
import socket_test.test.Record;
|
|
|
|
import java.io.IOException;
|
|
import java.io.ObjectInputStream;
|
|
import java.io.ObjectOutputStream;
|
|
import java.net.Socket;
|
|
import java.util.logging.Logger;
|
|
|
|
/**
|
|
* Created with xgiovio.macbookair.
|
|
* User: xgiovio
|
|
* Date: 21/10/14
|
|
* Time: 12:31
|
|
*/
|
|
public class Stub implements Impiegato{
|
|
|
|
private static final Logger log = Logger.getLogger(Stub.class.getName());
|
|
|
|
public Stub (String in_ip, int in_port){
|
|
server_ip = in_ip;
|
|
port = in_port;
|
|
}
|
|
|
|
@Override
|
|
public String getNome() {
|
|
try {
|
|
Socket sock = new Socket(server_ip, port);
|
|
saved_socket = sock;
|
|
log.info("Connessione a " + server_ip + " " + port);
|
|
ObjectOutputStream out = new ObjectOutputStream(sock.getOutputStream());
|
|
log.info("inviando getNome al server");
|
|
out.writeObject(new String("getNome"));
|
|
ObjectInputStream in = new ObjectInputStream(sock.getInputStream());
|
|
String to_return = (String) in.readObject();
|
|
sock.close();
|
|
return to_return;
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
} catch (ClassNotFoundException e) {
|
|
e.printStackTrace();
|
|
}
|
|
finally {
|
|
if (saved_socket!=null)
|
|
try {
|
|
saved_socket.close();
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
return "";
|
|
}
|
|
|
|
|
|
@Override
|
|
public String getCognome() {
|
|
try {
|
|
Socket sock = new Socket(server_ip, port);
|
|
saved_socket = sock;
|
|
log.info("Connessione a " + server_ip + " " + port);
|
|
ObjectOutputStream out = new ObjectOutputStream(sock.getOutputStream());
|
|
log.info("inviando getCognome al server");
|
|
out.writeObject(new String("getCognome"));
|
|
ObjectInputStream in = new ObjectInputStream(sock.getInputStream());
|
|
String to_return = (String) in.readObject();
|
|
sock.close();
|
|
return to_return;
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
} catch (ClassNotFoundException e) {
|
|
e.printStackTrace();
|
|
}
|
|
finally {
|
|
if (saved_socket!=null)
|
|
try {
|
|
saved_socket.close();
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
return "";
|
|
}
|
|
|
|
@Override
|
|
public double getStipendio() {
|
|
try {
|
|
Socket sock = new Socket(server_ip, port);
|
|
saved_socket = sock;
|
|
log.info("Connessione a " + server_ip + " " + port);
|
|
ObjectOutputStream out = new ObjectOutputStream(sock.getOutputStream());
|
|
log.info("inviando getStipendio al server");
|
|
out.writeObject(new String("getStipendio"));
|
|
ObjectInputStream in = new ObjectInputStream(sock.getInputStream());
|
|
double to_return = in.readDouble();
|
|
sock.close();
|
|
return to_return;
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
finally {
|
|
if (saved_socket!=null)
|
|
try {
|
|
saved_socket.close();
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
return -1;
|
|
}
|
|
|
|
@Override
|
|
public double aumentaStipendio(double in_aumento) {
|
|
try {
|
|
Socket sock = new Socket(server_ip, port);
|
|
saved_socket = sock;
|
|
log.info("Connessione a " + server_ip + " " + port);
|
|
ObjectOutputStream out = new ObjectOutputStream(sock.getOutputStream());
|
|
log.info("inviando aumentaStipendio al server");
|
|
out.writeObject(new String("aumentaStipendio"));
|
|
out.flush();
|
|
out.writeDouble(in_aumento);
|
|
out.flush();
|
|
ObjectInputStream in = new ObjectInputStream(sock.getInputStream());
|
|
double to_return = in.readDouble();
|
|
sock.close();
|
|
return to_return;
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
finally {
|
|
if (saved_socket!=null)
|
|
try {
|
|
saved_socket.close();
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
return -1;
|
|
|
|
}
|
|
|
|
private String server_ip;
|
|
private int port;
|
|
private Socket saved_socket= null;
|
|
}
|