-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathClient.java
94 lines (83 loc) · 2.84 KB
/
Client.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
import java.net.*;
import java.io.*;
import java.util.Scanner;
public class Client
{
private static final int BUFFER_SIZE = 8192;
private static final int PORT = 4444;
public static void main(String [] args)
{
Scanner scan = new Scanner(System.in);
String ip;
String filename = null;
int bytesRead = 0;
Socket socket = null;
while (true)
{
// connect to server
System.out.print("Server IP: ");
ip = scan.nextLine();
if (ip.equals("quit"))
System.exit(0);
try
{
socket = new Socket(ip, PORT);
}
catch (IOException e)
{
System.out.println("Could not connect.");
continue;
}
System.out.println("Connected...");
try
{
// request file from server
System.out.print("File to transfer: ");
filename = scan.nextLine();
if (filename.equals("quit"))
break;
PrintWriter out = null;
out = new PrintWriter(socket.getOutputStream(), true);
out.println(filename);
Scanner serverScan = new Scanner(socket.getInputStream());
String response = serverScan.nextLine();
if (!response.equals("OKGO"))
{
System.out.println(response);
continue;
}
// setup streams
InputStream is = socket.getInputStream();
String[] splitName = filename.split("/");
File newFile = new File("local_" +
splitName[splitName.length - 1]);
if (newFile.exists()) // || !newFile.canWrite())
{
System.out.println("Error: can't write to file.");
continue;
}
newFile.createNewFile();
FileOutputStream fos = new FileOutputStream(newFile);
BufferedOutputStream bos = new BufferedOutputStream(fos);
// read file from server
int count = 0;
byte[] buffer = new byte[8192];
while ((count = is.read(buffer)) > 0)
{
bytesRead += count;
fos.write(buffer, 0, count);
System.out.print(filename + ": " + bytesRead + "\r");
}
// cleanup
fos.flush();
bos.close();
//socket.close();
System.out.println("File transfer complete.");
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
}