5

我想使用 primefaces 使用 Java EE 上传大于 2 GB 的文件。一般来说，这没什么大不了的，但我有一个小问题。PrimeFaces 的通常方式是上传一个文件，拥有 UploadedFile-Object，从中获取 InputStream，然后将其写入磁盘。

但是写入磁盘大文件是一项耗时的任务。相反，我想在文件系统中找到上传的文件，然后将其移动到我存储所有文件的文件夹中，因为移动文件不会浪费时间。

因此，根据这里的这个问题，我想设置 PrimeFaces-Tmp-folder 和大小限制，文件何时放在那里。现在每个上传的文件都直接进入该文件夹。关键是，我现在在磁盘上有一个文件，而用户正在上传 - 而不是之后创建它。

到现在为止还挺好。我可以识别文件并移动它（尽管它有一个奇怪的名称）。但是指向Primefaces Userguide (Page 187)，这个 Tmp-Folder 只是在内部使用。我什至会从 Primefaces 窃取 UploadedFile-Object 的内容。对我来说似乎不是一个干净的解决方案。

任何提示如何实现这一目标？

我也看到了这个问题。也可能是我的头衔，但这不是我要找的。

编辑：

由于注释，一些代码。首先，我在 fileUploadListener 中收集 UploadFile-Objects：

   public void handleFileUpload(FileUploadEvent event) throws IOException {
    FacesMessage msg = new FacesMessage("Succesful", event.getFile().getFileName() + " is uploaded.");
    FacesContext.getCurrentInstance().addMessage(null, msg);

    getUploadedFilesDTO().add(new UploadedFileDTO(event.getFile(), uploadedFilesCounter));
    uploadedFilesCounter++;

}

在 EJB 中，我为每个 UploadedFile-Object 调用 copyFile：

private void copyFile(UploadedFile uploadedFile, String randomFilename) throws IOException {


    InputStream originalFile = uploadedFile.getInputstream();
    OutputStream fileOutput = null;

    try {
        fileOutput = new FileOutputStream("/pvtfiles/" + randomFilename);
        IOUtils.copy(originalFile, fileOutput);
    } finally {
        IOUtils.closeQuietly(fileOutput);
        IOUtils.closeQuietly(originalFile);
    }
}
4

2 回答 2

2

我可以通过编写自定义过滤器来做到这一点，正如 AZ_ 建议的那样，并添加以下内容：

FileItem fileItem = multipartRequest.getFileItem("form:fileUpload");
File file = new File(uploadDir + "/" + fileItem.getName());
fileItem.write(file);

诀窍是使用MultipartRequest对象来获取FileItem对象。FileItem的 write方法可用于将文件保存在不同的位置或使用不同的名称。根据文档，某些实现可能仍然使用副本来执行此操作，但我正在使用的（Apache Commons 1.3）似乎可以根据需要通过重命名/移动来执行此操作。请注意，用于getFileItem查找的字符串FileItem是标签中的 ID 属性<p:fileUpload>。

更多代码：

的修改部分web.xml：

<filter>
    <filter-name>PrimeFaces FileUpload Filter</filter-name>
    <filter-class>some.package.CustomFileUploadFilter</filter-class>
</filter>

示例 jsf：

<h:form id="form">
    <h:panelGrid columns="1" class="blockleft">
        <p:fileUpload
            id="fileUpload"
            auto="true" />
    </h:panelGrid>
</h:form>

示例自定义过滤器类：

package some.package;

import java.io.File;
import java.io.IOException;

import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.primefaces.webapp.MultipartRequest;
import org.primefaces.webapp.filter.FileUploadFilter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class CustomFileUploadFilter extends FileUploadFilter {

    private static final Logger LOG = LoggerFactory.getLogger(CustomFileUploadFilter.class);

    private String thresholdSize;

    private String uploadDir;

    private final static String THRESHOLD_SIZE_PARAM = "thresholdSize";

    private final static String UPLOAD_DIRECTORY_PARAM = "uploadDirectory";

    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        thresholdSize = filterConfig.getInitParameter(THRESHOLD_SIZE_PARAM);
        uploadDir = filterConfig.getInitParameter(UPLOAD_DIRECTORY_PARAM);

        LOG.info("CatalogFileUploadFilter initiated successfully");
    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain filterChain) throws IOException, ServletException {
        HttpServletRequest httpServletRequest = (HttpServletRequest) request;
        boolean isMultipart = ServletFileUpload.isMultipartContent(httpServletRequest);

        if (isMultipart) {
            LOG.info("Parsing file upload request");

            DiskFileItemFactory diskFileItemFactory = new DiskFileItemFactory();

            if (thresholdSize != null){
                diskFileItemFactory.setSizeThreshold(Integer.valueOf(thresholdSize).intValue());
            }
            if (uploadDir != null){
                diskFileItemFactory.setRepository(new File(uploadDir));
            }

            ServletFileUpload servletFileUpload = new ServletFileUpload(diskFileItemFactory);
            MultipartRequest multipartRequest = new MultipartRequest(httpServletRequest, servletFileUpload);

            try {
                FileItem fileItem = multipartRequest.getFileItem("form:fileUpload");
                File file = new File("path/to/location/" + fileItem.getName());
                fileItem.write(file);
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            LOG.info("File upload request parsed successfully, continuing with filter chain with a wrapped multipart request");

            filterChain.doFilter(multipartRequest, response);
        } else {
            filterChain.doFilter(request, response);
        }

    }
}
于 2014-02-26T20:28:21.273 回答
0

通过创建自己的过滤器它不会创建临时文件。请在下面的另一篇文章中阅读我的回答

https://stackoverflow.com/a/19581257/185022

于 2013-10-25T04:48:57.767 回答