Elysian Shadows

Code: Select all

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

public class TestClient extends Object {
	public static void main(String[] args) {
		try {
			Socket socket = new Socket("localhost", 80);
			PrintStream ps = new PrintStream(socket.getOutputStream(), true);
			ps.println("send test.txt");
			ps.println("4");
			ps.println("test");
			ps.close();
		} catch(Exception ex) {
			ex.printStackTrace();
		}
	}
}

Code: Select all

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

public class TestServer extends Object {
    public static void main(String[] args) {
        try {
            ServerSocket serverSocket = new ServerSocket(8080);;
            Socket clientSocket = null;
            String inputLine;
            
            clientSocket = serverSocket.accept();
            BufferedReader in = new BufferedReader(new InputStreamReader(
                                                clientSocket.getInputStream()));
            
            while ((inputLine = in.readLine()) != null) {
                System.out.printf("Read: %s\n", inputLine);
            }


        } catch(Exception ex) {
            ex.printStackTrace();
        }
    }
}

Code: Select all

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

public class FileServer extends Object {
	public static void main(String[] args) {
		try {
			ServerSocket serverSocket = new ServerSocket(80);
			System.out.println("Listening for connections on port 80...");
			while(true) {
				Socket socket = serverSocket.accept();
				System.out.println("Connection received! "+socket.getInetAddress());
				
				Service service = new Service(socket);
				service.start();
			}
		} catch(Exception ex) {
			System.out.println("Exception Raised! Exiting...");
			System.out.println();
			
			ex.printStackTrace();
		}
	}
} class Service extends Thread {
	protected Socket socket;
	protected PrintStream ps;
	protected Scanner scan;
	
	public Service(Socket socket) throws Exception {
		this.socket = socket;
		ps = new PrintStream(socket.getOutputStream());
		scan = new Scanner(socket.getInputStream());
	}
	
	public void run() {
		try {
			InputStream is = socket.getInputStream();
			OutputStream os = socket.getOutputStream();
			
			while(true) {
				String request = scan.nextLine();
				
				if(request.toLowerCase().startsWith("request ")) {
					String file = request.substring(7, request.length()).trim();
					
					FileInputStream fis = new FileInputStream(new File(file));
					
					byte[] bytes = new byte[fis.available()];
					while(true) {
						int b = fis.read(bytes);
						if(b == -1 || b == 0) break;
						ps.write(bytes);
						bytes = new byte[fis.available()];
					}
					fis.close();
					ps.flush();
					System.out.println("Request Complete!");
				} else if(request.equalsIgnoreCase("list")) {
					String list = "";
					String[] files = new File("./").list();
					for(int i = 0; i < files.length; i++) {
						list += files[i];
						if(i != files.length-1) list += ", ";
					}
					ps.println(list);
					ps.flush();
					System.out.println("Done Listing!");
				} else if(request.toLowerCase().startsWith("send ")) {
				//issues
					String placement = request.substring(4, request.length()).trim();
					int num = scan.nextInt();
					System.out.println(num);
					File file = new File(placement);
					FileOutputStream fos = new FileOutputStream(file);
					for(int i = 0; i < num; i++) {
						byte b = (byte)is.read();
						System.out.print(b);
						fos.write(b);
					}
					System.out.println("Finished Writing File!");
					fos.flush();
					fos.close();
				} else {
					socket.close();
					break;
				}
			}
		} catch(Exception ex) {
			ex.printStackTrace();
			try { socket.close(); } catch(Exception ex2) {}
		}
	}
}

Code: Select all

...
else if(request.toLowerCase().startsWith("send ")) {
            //issues
               String placement = request.substring(4, request.length()).trim();
               int num = scan.nextInt();
               System.out.println(num);
               File file = new File(placement);
               FileOutputStream fos = new FileOutputStream(file);
               for(int i = 0; i < num; i++) {
                  byte b = (byte)is.read();
                  System.out.print(b);
                  fos.write(b);
               }
               System.out.println("Finished Writing File!");
               fos.flush();
               fos.close();
}
...

Code: Select all

scan.nextLine();