0.0.3

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>com.github.immueggpain</groupId>
 	<artifactId>simple-streaming</artifactId>
-	<version>0.0.2</version>
+	<version>0.0.3</version>
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/com/github/immueggpain/simplestreaming/Launcher.java

@@ -10,7 +10,7 @@
 		version = Launcher.VERSTR, subcommands = { HelpCommand.class, StreamServer.class, Serve.class })
 public class Launcher implements Callable<Void> {
 
-	public static final String VERSTR = "0.0.2";
+	public static final String VERSTR = "0.0.3";
 	public static final int LOCAL_PORT = 2233;
 	public static final int LOCAL_OVPN_PORT = 1194;
 

src/main/java/com/github/immueggpain/simplestreaming/Serve.java

@@ -1,12 +1,12 @@
 package com.github.immueggpain.simplestreaming;
 
-import java.io.File;
+import java.io.IOException;
 import java.io.OutputStream;
+import java.io.RandomAccessFile;
 import java.net.ServerSocket;
 import java.net.Socket;
 import java.util.concurrent.Callable;
 
-import org.apache.commons.io.FileUtils;
 import picocli.CommandLine.Command;
 import picocli.CommandLine.Option;
 
@@ -37,6 +37,7 @@ private void accept_thread(int listen_port) {
 
 			while (true) {
 				Socket socket = serverSocket.accept();
+				System.out.println("new client");
 				Thread sendThread = Util.execAsync("send_thread", () -> send_thread(socket));
 				sendThread.join();
 			}
@@ -48,13 +49,31 @@ private void accept_thread(int listen_port) {
 	private void send_thread(Socket socket) {
 		try {
 			OutputStream os = socket.getOutputStream();
+			byte[] buf = new byte[1024 * 8];
+
+			RandomAccessFile file = new RandomAccessFile(filepath, "r");
+			long length = file.length();
+			file.seek(length);
+
+			long ct = copyLarge(file, os, buf);
 
-			long ct = FileUtils.copyFile(new File(filepath), os);
 			System.out.println("close socket " + ct);
+			file.close();
 			socket.close();
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
 	}
 
+	private static long copyLarge(final RandomAccessFile input, final OutputStream output, final byte[] buffer)
+			throws IOException {
+		long count = 0;
+		int n;
+		while (-1 != (n = input.read(buffer))) {
+			output.write(buffer, 0, n);
+			count += n;
+		}
+		return count;
+	}
+
 }