resteay上传单个文件/多个文件到本地

代码如下：

CADLocalControlle.java

package com.xgt.controller;

import com.xgt.common.BaseController;
import com.xgt.common.PcsResult;
import com.xgt.service.bs.ExcelService;
import com.xgt.util.MD5Util;
import org.apache.commons.io.IOUtils;
import org.jboss.resteasy.plugins.providers.multipart.InputPart;
import org.jboss.resteasy.plugins.providers.multipart.MultipartFormDataInput;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;

import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.MultivaluedMap;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.Map;

/**
 * Created by Administrator on 2017/8/28.
 * 上传Excel到本地
 */
@Controller
@Path("/cadlocal")
public class CADLocalController extends BaseController{
    @Autowired
    private ExcelService excelService;


    private final String UPLOADED_FILE_PATH = "e:\upload\";
    @POST
    @Path("/uploadLocalCAD")
    @Consumes(MediaType.MULTIPART_FORM_DATA )
    @Produces(MediaType.APPLICATION_JSON)
    //@RequiresPermissions("picturelocal:uploadPicture")
    public PcsResult uploadFile(MultipartFormDataInput input) {
        String fileName = "";
        Map<String, List<InputPart>> uploadForm = input.getFormDataMap();
        List<InputPart> inputParts = uploadForm.get("fileselect[]");
        for (InputPart inputPart : inputParts) {
            try {
                MultivaluedMap<String, String> header = inputPart.getHeaders();
                fileName = getFileName(header);
                fileName = MD5Util.MD5(fileName+System.currentTimeMillis());
                fileName = fileName+".dwg";
                //convert the uploaded file to inputstream
                InputStream inputStream = inputPart.getBody(InputStream.class,null);
                byte [] bytes = IOUtils.toByteArray(inputStream);
                //constructs upload file path
                fileName = UPLOADED_FILE_PATH + fileName;
                writeFile(bytes,fileName);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return newResult(true);

    }

    private String getFileName(MultivaluedMap<String, String> header) {
        String[] contentDisposition = header.getFirst("Content-Disposition").split(";");
        for (String filename : contentDisposition) {
            if ((filename.trim().startsWith("filename"))) {
                String[] name = filename.split("=");
                String finalFileName = name[1].trim().replaceAll(""", "");
                return finalFileName;
            }
        }
        return "unknown";
    }

    //save to somewhere
    private void writeFile(byte[] content, String filename) throws IOException {
        File file = new File(filename);
        if (!file.exists()) {
            file.createNewFile();
        }
        FileOutputStream fop = new FileOutputStream(file);
        fop.write(content);
        fop.flush();
        fop.close();
    }
}

BaseController.java

package com.xgt.common;

import com.xgt.dao.entity.User;
import com.xgt.exception.EnumPcsServiceError;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Value;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import java.util.List;

/**
 * Base controller which contains common methods for other controllers.
 */
public class BaseController {

    @Value("${default.pageSize}")
    private int defPageSize;


    @Value("${default.maxPageSize}")
    private int defMaxPageSize;


    @Value("${aliyunOSS.accessKeyId}")
    protected String accessKeyId;

    @Value("${aliyunOSS.accessKeySecret}")
    protected String accessKeySecret;

    @Value("${aliyunOSS.uploadUrl}")
    protected String endpoint;

    @Value("${aliyunOSS.bucketname}")
    protected String bucketName;

    @Value("${aliyunOSS.imageAddress}")
    protected String imageAddress;

    /**
     * Generate new PcsResult object, default with "SUCCESS" code.
     *
     * @return PcsResult result.
     */
    protected PcsResult newResult() {
        PcsResult result = new PcsResult();
        result.setCode(EnumPcsServiceError.SUCCESS.getCode()).setMessage(EnumPcsServiceError.SUCCESS.getDesc());
        return result;
    }
    /**
     * Generate new PcsResult object, default with "SUCCESS" code.
     *
     * @return PcsResult result.
     */
    protected PcsResult newResult(Boolean success) {
        PcsResult result = new PcsResult();
        result.setSuccess(success);
        result.setCode(EnumPcsServiceError.SUCCESS.getCode()).setMessage(EnumPcsServiceError.SUCCESS.getDesc());

        return result;
    }


    protected PcsResult failedResult(EnumPcsServiceError error) {
        PcsResult result = new PcsResult();
        result.setCode(error.getCode()).setMessage(error.getDesc());
        return result;
    }

    @SuppressWarnings("unused")
    protected PcsResult validateFailedResult(Integer errorCode, String description) {
        PcsResult result = new PcsResult();
        result.setCode(errorCode).setMessage(description);
        return result;
    }

    @SuppressWarnings("unused")
    protected PcsResult validateFailedResult(EnumPcsServiceError error) {
        PcsResult result = new PcsResult();
        result.setCode(error.getCode()).setMessage(error.getDesc());
        return result;
    }

    protected Integer getLoginUserId(){
        User user = (User) SecurityUtils.getSubject().getPrincipal();
        return user.getUserId();
    }

    protected List<Integer> getDepartmentUserIdList(){
        User user = (User) SecurityUtils.getSubject().getPrincipal();
        return user.getDepartmentUserIdList();
    }


    /**
     * 构建 分页 页数
     * @param page 页
     * @return int
     */
    protected int getCurPage(Integer page) {
        if (page==null || page<1) {
            return 1;
        }
        return page;
    }
    /**
     * 构建 分页 每页显示条数
     * @param pageSize 每页显示条数
     * @return int
     */
    protected int getPageSize(Integer pageSize) {
        if (pageSize==null || pageSize<1) {
            return defPageSize;
        }
        if (pageSize>defMaxPageSize) {
            return defMaxPageSize;
        }
        return pageSize;
    }

}

补充说明：

for (InputPart inputPart : inputParts) {}用于获得接收到的文件，可以接收多文件
fileName = MD5Util.MD5(fileName+System.currentTimeMillis());这里把文件名用MD5算法加密，不是为了加密，而是我在流中获取的中文文件名乱码，还没想好解决方案
fileName = fileName+".dwg";这里上传的是CAD文件，拼接后缀dwg