Kako pošiljanje datotek v JAVI.

Hmmm, server mora poslušati na določenem portu (npr. 7777), client pa potem odpira konekcije z objekti tipa URLConnection. Pošiljanje fajlov tudi ni problem - datoteko na clientu prebereš z FileInputStream-om in jo pošlješ preko konekcije na server, kjer jo zapišeš s FileOutputStream-om. Malce težje je le implementirati server, ker mora biti multithreaded, če hočeš, da lahko hkrati sprejme konekcije večih clientov. Osnovne koncepte client-server koncepta in branja/zapisovanja datotek si lahko pogledaš v kaki javanski knjigi (npr. Thinking in Java, ki je zastonj v html obliki).
Upam, da se že kaj spoznaš na Javo (vsaj stvari okrog kompajlanja classov in njihovega zaganjanja), ker se mi ne da razlagati. Aja, stvar sem stipkal na hitro, tako da so napake možne. Stestiraj in boš videl.

Client na kratko:

 import java.io.FileInputStream;
 import java.io.IOException;
 import java.io.OutputStream;
 import java.net.MalformedURLException;
 import java.net.URL;
 import java.net.URLConnection;
 
 public class Client 
 {
 public static void main(String[] args) {
 //ime datoteke, ki jo hoces poslati
 String fileName = args[0];
 //url serverja (npr. http://127.0.0.1:7777 , ce bos testiral 
 //clienta in server kar na istem racunalniku - tisti port 7777 nastavis na serverju).
 String serverAddress = args[1];
 //file bomo brali po 1K
 byte[] buffer = new byte[1024];
 
 //nalozi datoteko
 FileInputStream in = null;
 //ouput stream, v katerega bomo pisali prebrano datoteko
 OutputStream out = null;
 try {
 //odpri konekcijo do serverja
 URL url = new URL(serverAddress);
 URLConnection connection = url.openConnection();
 
 //preberi datoteko in pisi na stream v konekciji
 in = new FileInputStream(args[0]);
 out = connection.getOutputStream();
 int size = 0;
 while((size = in.read(buffer)) != -1) {
 out.write(buffer);
 }
 } catch(MalformedURLException me) {
 //napaka pri povezovanju na streznik
 me.printStackTrace();
 } catch(IOException e) {
 //napaka pri branju/posiljanju datoteke
 e.printStackTrace();
 } finally {
 try {
 in.close();
 out.close();
 } catch(IOException ex) {
 //lahko ignoriras
 }
 }
 }
 }
 
 
 

Server na kratko (potrebna sta vsaj dva razreda - da je koda bolj razclenjena)):

 import java.io.IOException;
 import java.net.ServerSocket;
 import java.net.Socket;
 
 public class Server {
 
 public static void main(String[] args) throws IOException {
 String serverPort = args[0];
 //spremenljivka za lazje zapisovnje datotek.
 int fileCount = 0;
 //server poslusa na portu serverPort
 ServerSocket server = new ServerSocket(Integer.parseInt(serverPort));
 System.out.println("Server zagnan na vratih:\t" + serverPort);
 
 //neskoncna zanka
 while(true) {
 Socket client = server.accept();
 fileCount++;
 
 //izpisemo nekaj podatkov o clientu
 System.out.println("Nov client [" + client + "]");
 FileFetch fetcher = new FileFetch();
 fetcher.setClient(client);
 fetcher.setFileNumber(fileCount);
 
 //pozenemo thread, ki se bo posvetil trenutnemu clientu
 new Thread(fetcher).start();
 }
 }
 }
 

in še FileFetcher:

 import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.net.Socket;
 
 public class FileFetch implements Runnable {
 private Socket client = null;
 private int fileNumber = -1;
 
 public void run() {
 String file = null;
 
 if(fileNumber != -1) {
 file = "file" + fileNumber;
 InputStream in = null;
 FileOutputStream out = null;
 
 try {
 //zapisovali bomo v datoteko (ce ze obstaja, jo prepisemo)
 out = new FileOutputStream(file);
 //beremo iz socketa
 in = this.client.getInputStream();
 
 byte[] buffer = new byte[1024];
 int size = 0;
 
 while((size = in.read(buffer)) != -1) {
 out.write(buffer);
 }
 
 System.out.println("Datoteka " + file + "shranjena!");
 } catch (FileNotFoundException e) {
 //napaka pri kreiranju (odpiranju) datoteke
 e.printStackTrace();
 } catch (IOException e1) {
 // vhodno-izhodna napaka
 e1.printStackTrace();
 } finally {
 try {
 in.close();
 out.close();
 } catch (Exception ex) {
 //ignoriramo napako
 }
 }
 }
 }
 
 /** Nastavi socket. */
 public void setClient(Socket socket) {
 client = socket;
 }
 
 /** Nastavi fileNumber. */
 public void setFileNumber(int i) {
 fileNumber = i;
 }
 }
 

lp

Pa še nekaj me zanima, kako pa je s preobremenitvijo procesorja? To bi preobremenjeval procesor kot eMule in Co.?

aja, mimogrede, obstaja že en open.source projekt,

Limewire

ki je cel spisan v Javi (če te zanima bolj podrobno, kako je narejen file-sharing).

aja sem naredil en tak program server in client s pomočjo tvojega primera in sem opazil, da nastopa problem lih pri tej vrstici

while((size = in.read(buffer)) != -1) {
out.write(buffer);
}

Tukaj mi piše v fajl večkratno vsebino zarad te zanke, podatki skoz internet mi tečejo počasneje kot piše to na disk in npr. buffer se mi napolne šele po 4 ciklih while zanke

Vem, da ni lahko samo malo poglej kako je s tistim delom na serverski strani, saj tista zanka je tako hitra da prepisuje v datoteko ponovno star bufer. Če hočeš ti pošljem na e-mail moje datoteke. Drugače sem stestiral iz dveh računal, ki so v mreži.

ne gre vseen. Če hočeš ti pošljem fajle da bi videl kako veliko datoteko mi naredi ;)

Sem iskal po internetu pa sem naletel na naslednji primer

CODE FOR SERVER

import java.io.*;
import java.net.*;
public class ReadFile
{
public static void main(String[] args)
{
ServerSocket serverSocket = null;
Socket clientSocket;
try
{
serverSocket = new ServerSocket(2000);
}
catch (IOException e)
{
System.out.println("Couldn't listen to port 2000");
System.exit(1);
}
clientSocket = null;
try
{
clientSocket = serverSocket.accept();
}
catch (IOException e)
{
System.out.println("I/O exception in serverSocket.accept()");
}
try
{
File f = new File("ReadFile.java");
FileInputStream fis = new FileInputStream (f);
DataInputStream is = new DataInputStream(new
BufferedInputStream(clientSocket.getInputStream()));
OutputStream os = clientSocket.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
String inp;
int fsize = fis.available();
System.out.println("Size is " + fsize);
dos.writeInt(fsize);
dos.flush();
is.readByte();
byte[] buf = new byte[3000];
while ((fis.read(buf)) != -1)
{
System.out.println("Sending");
os.write(buf);
os.flush();
is.readByte();
}
fis.close();
os.close();
is.close();
}
catch (IOException e)
{
System.err.println("I/O Exception");
}
}
}


CODE FOR CLIENT:

import java.lang.*;
import java.io.*;
import java.net.*;

public class GetFile
{
public static void main(String[] args)
{
Socket echoSocket = null;
DataOutputStream os = null;
InputStream is = null;
DataInputStream dis = null;
try
{
echoSocket = new Socket("206.78.144.21", 2000);
os = new DataOutputStream(echoSocket.getOutputStream());
is = echoSocket.getInputStream();
dis = new DataInputStream(echoSocket.getInputStream());
}
catch (UnknownHostException e)
{
System.err.println("Don't know host xxx.xxx.com");
System.exit(1);
}
catch (IOException e)
{
System.err.println("Couldn't get I/O for host xxx.xx.com");
System.exit(1);
}
if (echoSocket != null && os != null && is != null)
{
System.out.println("Trying to receive data");
try
{
String inp;
File outputFile = new File("myReadFile.java");
FileOutputStream fos = new FileOutputStream(outputFile);
byte[] buff = new byte[3000];
int fSize;
int sizeRead = 0;
fSize = dis.readInt();
System.out.println ("Size of file is " + fSize);
os.writeByte('\n');
os.flush();
while ((is.read(buff)) != -1)
{
sizeRead += 3000;
if (sizeRead < fSize)
fos.write(buff);
else
{
byte[] buff1 = new byte[fSize - (sizeRead-3000)];
for (int i=0; i < (fSize -(sizeRead - 3000)); i++)
buff1 = buff;
fos.write(buff1);
}
os.writeByte('\n');
os.flush();
System.out.println("File copied");
break;
}
os.close();
is.close();
fos.close();
echoSocket.close();
}
catch (IOException e)
{
System.err.println("I/O failure");
}
}
}
}

Zdaj bi nekoga prosil, če bi poskusli naredit tole in če vam dela. Meni nikakor ne uspe poslat iz enga racunalnika v drugi racunalnik datoteko. Vedno pride do napake z I/O Exception.

pa še eno stvar bi prosil za razlago, kaj pomeni pri klientu ko pošlješ

os.writeByte('\n');
os.flush();

in server čaka na

is.readByte();

Hvala