hdfs service added.

pom.xml

@@ -42,6 +42,11 @@
 			<artifactId>javassist</artifactId>
 			<version>3.18.0-GA</version>
 		</dependency>
+		<dependency>
+			<groupId>org.apache.hadoop</groupId>
+			<artifactId>hadoop-core</artifactId>
+			<version>1.1.2</version>
+		</dependency>
 	</dependencies>
 	<build>
 		<finalName>bench4q-agent</finalName>

src/main/java/org/bench4q/agent/storage/HdfsService.java

@@ -0,0 +1,138 @@
+package org.bench4q.agent.storage;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FSDataInputStream;
+import org.apache.hadoop.fs.FSDataOutputStream;
+import org.apache.hadoop.fs.FileStatus;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.io.IOUtils;
+import org.springframework.stereotype.Component;
+
+@Component
+public class HdfsService {
+	private FileSystem getFileSystem() throws IOException {
+		Configuration conf = new Configuration();
+		return FileSystem.get(conf);
+	}
+
+	public boolean uploadFile(String localPath, String remotePath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			fs.copyFromLocalFile(new Path(localPath), new Path(remotePath));
+			return true;
+		} catch (Exception e) {
+			e.printStackTrace();
+			return false;
+		}
+	}
+
+	public boolean writeFile(String content, String remotePath) {
+		try {
+			InputStream in = new ByteArrayInputStream(content.getBytes());
+			FileSystem fs = this.getFileSystem();
+			OutputStream out = fs.create(new Path(remotePath));
+			IOUtils.copyBytes(in, out, 4096, true);
+			return true;
+		} catch (Exception e) {
+			e.printStackTrace();
+			return false;
+		}
+	}
+
+	public boolean downloadFile(String localPath, String remotePath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			fs.copyToLocalFile(new Path(remotePath), new Path(localPath));
+			return true;
+		} catch (Exception e) {
+			e.printStackTrace();
+			return false;
+		}
+	}
+
+	public String readFile(String remotePath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			FSDataInputStream hdfsInStream = fs.open(new Path(remotePath));
+			OutputStream out = new ByteArrayOutputStream();
+			byte[] ioBuffer = new byte[1024];
+			int readLen = hdfsInStream.read(ioBuffer);
+			while (-1 != readLen) {
+				out.write(ioBuffer, 0, readLen);
+				readLen = hdfsInStream.read(ioBuffer);
+			}
+			out.close();
+			String ret = out.toString();
+			hdfsInStream.close();
+			return ret;
+		} catch (Exception e) {
+			e.printStackTrace();
+			return null;
+		}
+	}
+
+	public boolean appendFile(String content, String remotePath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			FSDataOutputStream out = fs.append(new Path(remotePath));
+			int readLen = content.getBytes().length;
+			while (-1 != readLen) {
+				out.write(content.getBytes(), 0, readLen);
+			}
+			out.close();
+			return true;
+		} catch (Exception e) {
+			e.printStackTrace();
+			return false;
+		}
+	}
+
+	public boolean deleteFile(String remotePath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			return fs.delete(new Path(remotePath), false);
+		} catch (Exception e) {
+			e.printStackTrace();
+			return false;
+		}
+	}
+
+	public boolean deleteDirectory(String remotePath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			return fs.delete(new Path(remotePath), true);
+		} catch (Exception e) {
+			e.printStackTrace();
+			return false;
+		}
+	}
+
+	public boolean renameFile(String fromPath, String toPath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			return fs.rename(new Path(fromPath), new Path(toPath));
+		} catch (Exception e) {
+			e.printStackTrace();
+			return false;
+		}
+	}
+
+	public FileStatus[] listFile(String remotePath) {
+		try {
+			FileSystem fs = this.getFileSystem();
+			FileStatus[] fileList = fs.listStatus(new Path(remotePath));
+			return fileList;
+		} catch (Exception e) {
+			e.printStackTrace();
+			return null;
+		}
+	}
+
+}