本文介紹了通過(guò)導(dǎo)入架包的方式與使用maven依賴的方式分別使用springmvc框架實(shí)現(xiàn)單文件的上傳主要邏輯流程，多文件上傳留作后續(xù)更新。?
一 离赫、 導(dǎo)入架包實(shí)現(xiàn)Spring MVC 文件上傳到服務(wù)器本地
除了spring 架包外還需要org.apache.commons-fileupload-x.x.x.ja包的支持
springmvc.xml 中配置bean
<!-- 處理文件上傳 -->
<!-- id="multipartResolver" 屬于spring文件裝配時(shí)的一個(gè)屬性坚踩，名稱固定不能改變！Ｕ毕АＭ厍帷！ -->
<bean id="multipartResolver"
class="org.springframework.web.multipart.commons.CommonsMultipartResolver" >
<property name="defaultEncoding" value="utf-8"/> <!-- 默認(rèn)編碼 (ISO-8859-1) -->
<property name="maxInMemorySize" value="10240"/> <!-- 最大內(nèi)存大小 (10240) -->
<property name="uploadTempDir" value="/upload/"/> <!-- 上傳后的目錄名 (WebUtils#TEMP_DIR_CONTEXT_ATTRIBUTE) -->
<property name="maxUploadSize" value="-1"/><!-- 最大文件大小经伙，-1為無(wú)限止(-1) -->
</bean>
jsp 界面的處理 特別注意單詞的拼寫：
enctype = "multipart/form-data"
<form action="/RestMyibatisSpring/file/upload" method="post" enctype = "multipart/form-data">
<!-- <input type = "hidden" name = "method" value ="upload"> -->
<input type = "text" name = "fileName" >
<input type = "file" name = "file" >
<input type = "submit" value = "上傳文件">
</form>
設(shè)置相應(yīng)的controller處理
import java.io.File;
import javax.servlet.ServletContext;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.context.ServletContextAware;
import org.springframework.web.multipart.commons.CommonsMultipartFile;
@Controller
@RequestMapping("/file")
public class FileController_Rest implements ServletContextAware{
private ServletContext servletContext;
@Override
public void setServletContext(ServletContext arg0) {
this.servletContext = arg0;
}
@RequestMapping(value="/upload",method = RequestMethod.POST)
public String uploadFile(String fileName,@RequestParam("file")CommonsMultipartFile file) {
if (!file.isEmpty()) {
String path = this.servletContext.getRealPath("/upload");
String oriFileName = file.getOriginalFilename();
String fileType = oriFileName.substring(oriFileName.lastIndexOf("."));
String newFileName = fileName + fileType;
File newFile = new File(path + "/" + newFileName);
try {
file.getFileItem().write(newFile);
} catch (Exception e) {
e.printStackTrace();
}
}
return "/jsps/upload";
}
}
二扶叉、 maven 使用spring 上傳文件到hdfs系統(tǒng)
spring使用文件上傳功能處理springmvc的基礎(chǔ)包之外還需要兩個(gè)庫(kù)
commons-fileupload-1.2.2.jar，commons-io-2.0.1.jar的支持
使用maven的直接導(dǎo)入commons-fileupload依賴就可以了帕膜，commons-fileupload會(huì)自動(dòng)下載io依賴包
<!-- https://mvnrepository.com/artifact/commons-fileupload/commons-fileupload -->
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.2</version>
</dependency>
![enter description here][4]
然后springmvc.xml中要配置spring的相關(guān)依賴
<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
<property name="defaultEncoding" value="utf-8"/>
</bean>
jsp界面代碼如下
<form id="uploadFile" action="/cd/fileIndex/uploadFile" method="post" enctype="multipart/form-data">
<div class=":form-group">
<label>選擇文件</label>
<input id="file" type="file" name="file" class="form-control"/>
<input type="hidden" name="parentId" value="<%=rootDir.getFileIndexId()%>"/>
<input type="hidden" name="parentPath" value="<%=rootDir.getPath()%>"/>
</div>
</form>
Java代碼如下
controller
@RequestMapping(value="/uploadFile",method=RequestMethod.POST)
public String uploadFile(@RequestParam(value="file",required=false) MultipartFile file
,@SessionAttribute("loginUser") AppUser loginUser,String parentId,String parentPath)
throws IllegalArgumentException, IOException, NoSuchAlgorithmException{
//接受前臺(tái)傳輸過(guò)來(lái)的文件并保存在hdfs上
String fileName = file.getOriginalFilename();
InputStream fStream = file.getInputStream();
Long fileSize = file.getSize();
String pathStr = "/user/root/clouddisk/" + fileName;
String md5 = HDFSUtil.upLoadFileToHdfs(fStream, pathStr);
return "redirect:/fileIndex/openDirectory?dirId=" + parentId;
}
HDFSUtil.java
import java.io.IOException;
import java.io.InputStream;
import java.math.BigInteger;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class HDFSUtil {
public static final Configuration CONFIGURATION = new Configuration();
// 獲取FileSystem 對(duì)象
public static FileSystem getFileSystem() {
try {
return FileSystem.get(CONFIGURATION);
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
public static String upLoadFileToHdfs(InputStream iStream, String pathStr)
throws IllegalArgumentException, IOException, NoSuchAlgorithmException {
FileSystem fileSystem = HDFSUtil.getFileSystem();
FSDataOutputStream outputStream = fileSystem.create(new Path(pathStr));
byte[] buffer = new byte[1024];
MessageDigest mDigest = MessageDigest.getInstance("MD5");
int lenth = iStream.read(buffer,0,1024);
while (lenth > -1) {
//保證文件不失真
if (lenth < 1024) {
byte[] lastBuffer = Arrays.copyOf(buffer, lenth);
mDigest.update(lastBuffer);
outputStream.write(lastBuffer);
} else {
mDigest.update(buffer);
outputStream.write(buffer);
}
lenth = iStream.read(buffer, 0, lenth);
System.out.println("read" + lenth);
}
outputStream.hsync();
outputStream.close();
iStream.close();
fileSystem.close();
BigInteger bigInteger = new BigInteger(1, mDigest.digest());
return bigInteger.toString(16);
}
}
