Java06. ДЗ 05, Егоров Антон

README.md

@@ -1 +1,13 @@
-# java_homeworks
+### Torrent
+
+Для сборки выполнить
+
+```
+mvn install
+
+```
+
+В папке target появятся client.jar и server.jar .
+Клиенту при запуске можно передать имя хоста. По умолчанию localhost.
+
+У клиента есть команда `help`, показывающая список команд.

torrent/pom.xml

@@ -0,0 +1,99 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>1</groupId>
+	<artifactId>torrent</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<!-- <packaging>jar</packaging> -->
+
+	<name>torrent</name>
+	<url>http://maven.apache.org</url>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+	</properties>
+	<build>
+		<plugins>
+			<plugin>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<configuration>
+					<source>1.9</source>
+					<target>1.9</target>
+					<encoding>UTF-8</encoding>
+				</configuration>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-assembly-plugin</artifactId>
+				<executions>
+					<execution>
+						<id>torrent_server</id>
+						<phase>package</phase>
+						<goals>
+							<goal>single</goal>
+						</goals>
+						<configuration>
+							<archive>
+								<manifest>
+									<mainClass>
+										torrent.server.Main
+									</mainClass>
+								</manifest>
+							</archive>
+							<descriptorRefs>
+								<descriptorRef>jar-with-dependencies</descriptorRef>
+							</descriptorRefs>
+							<finalName>server</finalName>
+							<appendAssemblyId>false</appendAssemblyId>
+						</configuration>
+					</execution>
+					<execution>
+						<id>torrent_client</id>
+						<phase>package</phase>
+						<goals>
+							<goal>single</goal>
+						</goals>
+						<configuration>
+							<archive>
+								<manifest>
+									<mainClass>
+										torrent.client.Main
+									</mainClass>
+								</manifest>
+							</archive>
+							<descriptorRefs>
+								<descriptorRef>jar-with-dependencies</descriptorRef>
+							</descriptorRefs>
+							<finalName>client</finalName>
+							<appendAssemblyId>false</appendAssemblyId>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
+		</plugins>
+	</build>
+	<dependencies>
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<version>4.12</version>
+			<scope>test</scope>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-core -->
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+			<version>2.9.7</version>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-io -->
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-io</artifactId>
+			<version>1.3.2</version>
+		</dependency>
+	</dependencies>
+</project>

torrent/src/main/java/torrent/client/FileProblemException.java

@@ -0,0 +1,14 @@
+package torrent.client;
+
+public class FileProblemException extends Exception {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1L;
+
+	public FileProblemException(String string) {
+		super(string);
+	}
+
+}

torrent/src/main/java/torrent/client/FilesDownloader.java

@@ -0,0 +1,64 @@
+package torrent.client;
+
+import java.io.IOException;
+import java.net.SocketAddress;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+import torrent.client.FilesHolder.FileStatus;
+
+public class FilesDownloader {
+
+	private FilesHolder filesHolder;
+	private SocketAddress toServer;
+
+	private ExecutorService pool = Executors.newCachedThreadPool();
+
+	private Map<Integer, Future<?>> fileDownloadsFutures = new HashMap<>();
+
+	public FilesDownloader(FilesHolder stm, SocketAddress toServer) {
+		this.filesHolder = stm;
+		this.toServer = toServer;
+		stm.fileStatus.forEach((id, status) -> {
+			if (status == FileStatus.Downloading ) {
+				try {
+					startFileDownload(id);
+				} catch (IOException e) {
+					System.err.println("Failed. to start download at startup");
+					e.printStackTrace();
+				}
+			}
+		});
+	}
+
+	public boolean startFileDownload(int fileId) throws IOException {
+		if (fileDownloadsFutures.containsKey(fileId)) {
+			return false;
+		}
+
+		filesHolder.fileStatus.put(fileId, FileStatus.Downloading);
+
+		SingleFileDownloader downloader = new SingleFileDownloader(toServer, filesHolder, fileId, this);
+		fileDownloadsFutures.put(fileId, pool.submit(downloader));
+		return true;
+	}
+
+	public void stopFileDownload(int fileId) {
+		if (!filesHolder.fileStatus.containsKey(fileId)) {
+			throw new IllegalStateException("This file wasn't been downloading");
+		}
+
+		if (filesHolder.fileStatus.get(fileId) != FileStatus.Downloading) {
+			return;
+		}
+
+		fileDownloadsFutures.get(fileId).cancel(true);
+		fileDownloadsFutures.remove(fileId);
+
+		filesHolder.fileStatus.put(fileId, FileStatus.Paused);
+	}
+
+}