defaultmultipartdecoder.java

欢迎使用 FastJsp 开发框架! 编译说明： * 若要生成Api Javadoc文档

// Copyright 2005-2007 onetsoft.com
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package com.onetsoft.fastjsp.request.multipart;

import com.onetsoft.fastjsp.ApplicationRuntimeException;
import org.apache.commons.fileupload.FileItemFactory;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;

import javax.servlet.http.HttpServletRequest;
import java.io.File;
import java.text.MessageFormat;
import java.util.List;
import java.util.Map;

/**
 * @author <a href="mailto:[e-mail]">hgw</a>
 */
public class DefaultMultipartDecoder extends AbstractMultipartDecoder {
    private UploadConfig config = null;

    /**
     * @since 3.1
     */
    private Map paramsMap = null;

    public DefaultMultipartDecoder(Map paramsMap, UploadConfig config) {
        this.config = config;
        this.paramsMap = paramsMap;
    }


    public HttpServletRequest decode(HttpServletRequest request) {
        _encoding = request.getCharacterEncoding();
  

        ServletFileUpload upload = createFileUpload();
        try {
            List fileItems = upload.parseRequest(request);
            processFileItems(fileItems);
        }
        catch (FileUploadException ex) {
            throw new ApplicationRuntimeException(MessageFormat.format("Unable to decode multipart encoded request:{0}",
                    new Object[]{request}), ex);
        }
        Map parameterMap = buildParameterMap(paramsMap);
        return new UploadFormParametersWrapper(request, parameterMap);
    }

    private ServletFileUpload createFileUpload() {
        FileItemFactory factory = new DiskFileItemFactory(config.getThresholdSize(), new File(config.getRepositoryPath()));
        ServletFileUpload upload = new ServletFileUpload(factory);

        // set maximum file upload size
        upload.setSizeMax(config.getMaxSize());

        if (_encoding != null)
            upload.setHeaderEncoding(_encoding);

        return upload;
    }


}