Projekt-sprawozdanie - KarolakKarol-projekt - sq2wkh

Projekt-sprawozdanie.doc
(72 KB) Pobierz
Karolak Karol
Grupa: I6A1N2
Systemy rozproszone
Projekt:
Aplikacja przesyłająca pliki w sieci
z wykorzystaniem technologii Java RMI
Cel projektu
Celem projektu jest stworzenie aplikacji pozwalającej przesyłać pliki z aplikacji serwera do
podłączonych aplikacji klienckich. Aplikacja stworzona ma być z wykorzystaniem technologii Java
RMI.
Wymagania

Funkcjonalność aplikacji musi zawierać takie elementy jak:
wyświetlanie na stacji klienta listy plików udostępnianych przez serwer (graficznie
lub tekstowo),
 odczytywanie udostępnionych plików ze stacji serwera,
 zapisywanie pobranych plików na stacji klienta.
Budowa i uruchamianie aplikacji
Budowa aplikacji składa się z następujących etapów:
1. utworzenie interfejsu opisującego procedury udostępniane przez serwer („IPliki.java”),
2. utworzenie klasy serwera implementującej interfejs „IPliki” („Server.java”),
3. utworzenie klasy klienta wywołującej metody udostępniane przez serwer („Client.java”),
4. kompilacja klas,
5. uruchomienie rejestru RMI,
6. uruchomienie aplikacji serwera i klienta.
Opis działania aplikacji
Uruchomienie aplikacji rozpoczyna się od uruchomienia rejestru RMI za pośrednictwem
którego będą dokonywane wszystkie operacje pomiędzy serwerem i klientami.
Następnie uruchamiany jest program serwera, który oczekuje na zgłoszenia klientów. Przy
uruchamianiu serwera jako parametr można podać ścieżkę katalogu który będzie udostępniony. W
przypadku braku parametru udostępniony zostanie katalog bieżący.
Rys. 1 Okno aplikacji serwera
W trakcie działania serwer wyświetla raport z wykonywanych zadań na standardowy
urządzenie wyjścia. Raport zawiera numer IP klienta który wywoływał procedurę i zadanie jakie
zostało przez niego wykonane.
Uruchomienie aplikacji klienckich wymaga podania adresu IP pod którym aktywny jest
program serwera. Jeżeli parametr ten nie zostanie podany to serwer będzie wyszukiwany na
maszynie lokalnej. Po uruchomieniu aplikacji klienckiej i uzyskaniu komunikacji z programem
serwera na stacji klienkiej pojawia się menu ułatwiające interakcję użytkownika z programem.
Rys. 2 Menu aplikacji klienta
Wybór odpowiedniej cyfry z klawiatury powoduje uruchomienie odpowiadającej jej funkcji.
Udostępnione funkcje to: wyświetlanie ścieżki do katalogu udostępnionego na serwerze, zmiana
katalogu do którego pobierane będą pliki i pobieranie plików z serwera na stację kliencką.
Uruchomienie pobierania plików powoduje wyświetlenie listy plików znajdujących się w
udostępnionym katalogu.
Rys. 3 Lista udostępnionych plików
Wybór numeru pliku powoduje jego pobranie z serwera i zapisanie go w wybranym
wcześniej katalogu.
Kod programu
IPliki.java
package karolak.sr.rmizal;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.ArrayList;
public interface IPliki extends Remote {
void podlaczenie(String ip) throws RemoteException;
String getUdostepnionyKatalog(String ip) throws RemoteException;
ArrayList getListaPlikow(String ip) throws RemoteException;
Object[] getPlik(String ip, String sciezka) throws RemoteException;
void rozlaczenie(String ip) throws RemoteException;
}
Server.java
package karolak.sr.rmizal;
import java.rmi.RemoteException;
import java.rmi.registry.Registry;
import java.rmi.registry.LocateRegistry;
import java.rmi.server.UnicastRemoteObject;
import java.util.ArrayList;
import java.io.DataInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
public class Server implements IPliki {
private static String udostepnionyKatalog = ".";
public Server() {};
public static void main(String[] args){
udostepnionyKatalog = (args.length < 1 ? getAktualnyKatalog() : args[0]);
try{
Server server = new Server();
IPliki pliki = (IPliki)UnicastRemoteObject.exportObject(server, 0);
Registry registry = LocateRegistry.getRegistry();
registry.bind("IPliki", pliki);
System.out.println("Serwer uruchomiony.");
} catch (Exception ex) {
blad("Błąd serwera: ", ex);
}
}
public void podlaczenie(String ip){
System.out.println("[" + ip + "] Host podlaczony.");
}
public void rozlaczenie(String ip){
System.out.println("[" + ip + "] Host odlaczony.");
}
private static String getAktualnyKatalog(){
String wynik = "";
try{
wynik = new File(".").getCanonicalPath();
} catch (IOException ex) {
blad("Błąd pobierania aktualnego katalogu.", ex);
}
return wynik;
}
private static void blad(String tekst, Exception ex){
System.err.println(tekst + ex.getMessage() + "\n" + ex.toString());
}
public String getUdostepnionyKatalog(String ip) throws RemoteException {
System.out.println("[" + ip + "] Wyslano sciezke udostepnionego katalogu.");
return udostepnionyKatalog;
}
public ArrayList getListaPlikow(String ip) throws RemoteException {
ArrayList wynik = new ArrayList();
File katalog = new File(udostepnionyKatalog);
if (katalog.exists()){
File[] listaPlikow = katalog.listFiles();
for (int i = 0; i < listaPlikow.length; i++){
if (!listaPlikow[i].isDirectory()){
wynik.add(listaPlikow[i].getAbsolutePath());
}
}
} else {
wynik.add(" !!! Udostępniony katalog nie istnieje. !!!");
}
System.out.println("[" + ip + "] Wyslano liste plikow.");
return wynik;
}
public Object[] getPlik(String ip, String sciezka) {
try{
FileInputStream fileInputStream = new FileInputStream(sciezka);
int bajt;
DataInputStream dataInputStream = new DataInputStream(fileInputStream);
ArrayList dane = new ArrayList();
while ((bajt = dataInputStream.read()) != -1){
dane.add(new Integer(bajt));
}
System.out.println("[" + ip + "] Wyslano plik '" + sciezka + "'.");
return dane.toArray();
} catch (FileNotFoundException ex) {
} catch (IOException ex) {
}
return null;
}
}
Client.java
package karolak.sr.rmizal;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.util.ArrayList;
public class Client {
private Client() {};
public static void main(String[] args) {
String host = (args.length < 1 ? null : args[0]); //null = localhost
String katalogDocelowy = "c:\\";
try {
System.out.println("Klient uruchomiony.");
Registry registry = LocateRegistry.getRegistry(host);
IPliki pliki = (IPliki)registry.lookup("IPliki");
System.out.println("Obiekt pobrany.");
pliki.podlaczenie(getNumerIp());
BufferedReader userIn = new BufferedReader(new
InputStreamReader(System.in));
char znak;
wyswietlMenu(katalogDocelowy);
while ((znak = pobierzZnak(userIn)) != '0') {
switch (znak){
case '1':
udostepnionyKatalog(pliki);
break;
case '2':
pobierzPlik(pliki, userIn, katalogDocelowy);
break;
case '3':
katalogDocelowy = zmienKatalogDocelowy(katalogDocelowy, userIn);
break;
default:
System.out.println("Nieprawidlowe polecenie.");
break;
}
wyswietlMenu(katalogDocelowy);
}
System.out.println("Koniec.");
pliki.rozlaczenie(getNumerIp());
} catch (Exception ex) {
blad("Błąd klienta: ", ex);
}
}
private static String zmienKatalogDocelowy(String katalogDocelowy,
BufferedReader userIn) {
try{
do {
System.out.println();
System.out.print("Podaj nowy katalog > ");
katalogDocelowy = userIn.readLine();
if (!new File(katalogDocelowy).exists()){
System.out.println();
System.out.println("Wybrany katalog docelowy nie istnieje.");
System.out.println();
} else {
break;
}
} while (true);
} catch (IOException ex){
System.err.println("Blad wyjscia: " + ex.getMessage() + ex.toString());
}
return katalogDocelowy;
}
private static void pobierzPlik(IPliki pliki, BufferedReader userIn, String
katalogDocelowy) {
try{
System.out.println();
System.out.println("Lista plikow:");
String numerStr = null;
do {
ArrayList listaPlikow = pliki.getListaPlikow(getNumerIp());
if (numerStr != null){
int numerInt;
try{
numerInt = Integer.parseInt(numerStr);
if (numerInt > listaPlikow.size() || numerInt < 1) {
System.out.println("Nieprawidlowy numer pliku.");
System.out.println();
} else {
String sciezka = (String)listaPlikow.get(numerInt - 1);
System.out.println("Pobieranie pliku '" + sciezka + "'.");
Object[] dane = pliki.getPlik(getNumerIp(), sciezka);
if (dane == null) {
System.out.println("Podany plik nie istnieje.");
System.out.println();
}
String sciezkaDocelowa = katalogDocelowy +
sciezka.substring(sciezka.lastIndexOf('\\'));
FileOutputStream fileOutputStream = new
FileOutputStream(sciezkaDocelowa, false);
DataOutputStream dataOutputStream = new
DataOutputStream(fileOutputStream);
for (int i = 0; i < dane.length; i++){
dataOutputStream.write(((Integer)dane[i]).intValue());
}
dataOutputStream.close();
System.out.println("Plik '" + sciezka + "' zostal pobrany do '" +
sciezkaDocelowa + "'.");
System.out.println();
}
} catch (NumberFormatException ex) {
System.out.println("Podana wartosc nie jest liczba.");
System.out.println();
} catch (OutOfMemoryError ex) {
System.out.println("Plik jest zbyt duzy.");
System.out.println();
}
}
wyswietlListePlikow(listaPlikow);
} while (!(numerStr = userIn.readLine()).equals("0"));
} catch (RemoteException ex) {
bladPolaczenia(ex);
} catch (IOException ex) {
System.err.println("Blad wyjscia: " + ex.getMessage() + ex.toString());
}
}
private static void wyswietlListePlikow(ArrayList listaPlikow) throws
RemoteException {
for (int i = 1; i <= listaPlikow.size(); i++){
System.out.println(i + ". " + listaPlikow.get(i - 1));
}
System.out.println("0. Wyjscie");
System.out.println();
System.out.print("Podaj numer pliku > ");
}
private static void udostepnionyKatalog(IPliki pliki) {
try{
String response = pliki.getUdostepnionyKatalog(getNumerIp());
System.out.println("Udostepniony katalog: " + response);
} catch (RemoteException ex){
bladPolaczenia(ex);
}
}
private static char pobierzZnak(BufferedReader userIn) {
char wynik = (char)0;
try{
String tekst = userIn.readLine();
wynik = tekst.charAt(0);
} catch (IOException ex) {}
return wynik;
}
private static void blad(String tekst, Exception ex){
System.err.println(tekst + ex.getMessage() + "\n" + ex.toString());
}
private static void bladPolaczenia(Exception ex){
blad("Blad polaczenia z serwerem: ", ex);
}
private static void wyswietlMenu(String katalogDocelowy) {
...
Plik z chomika:
sq2wkh
Inne pliki z tego folderu:

Projekt-sprawozdanie.doc (72 KB)
 IPliki.java (0 KB)
 Client.java (6 KB)
 Server.java (2 KB)
Inne foldery tego chomika:
Zgłoś jeśli naruszono regulamin



Strona główna
Aktualności
Kontakt


Dział Pomocy
Opinie


Regulamin serwisu
Polityka prywatności
Copyright © 2012 Chomikuj.pl