import com.sun.jersey.core.header.ContentDisposition; //导入依赖的package包/类
@POST @Path("add/files")
@Consumes(MediaType.MULTIPART_FORM_DATA)
public void addFiles(FormDataMultiPart body) {
    List<IBridge.UploadedFileInfo> files = new LinkedList<>();
    for(BodyPart part : body.getBodyParts()) {
        InputStream is = part.getEntityAs(InputStream.class);
        ContentDisposition meta = part.getContentDisposition();

        try {
            File tmpFile = File.createTempFile("dlup", ".dat");
            tmpFile.deleteOnExit();
            FileUtils.copyInputStreamToFile(is, tmpFile);
            LOGGER.info("File {} uploaded to {}", meta.getFileName(), tmpFile);
            files.add(new IBridge.UploadedFileInfo(tmpFile, meta.getFileName()));
        } catch (IOException e) {
            LOGGER.error("Cannot create temporary file for upload", e);
        }
    }

    downloadsService.addFiles(files, globalConfig.getDownloadPath());
}
 

import com.sun.jersey.core.header.ContentDisposition; //导入依赖的package包/类
private static void setFormParams(FormDataMultiPart formData, Run run, String... excluded) throws IOException {
	Collection<String> ex = new HashSet<String>(Arrays.asList(excluded));
	Map<String,List<FormDataBodyPart>> formFields = formData.getFields();
	for (Map.Entry<String,List<FormDataBodyPart>> e : formFields.entrySet()) {
		String name = e.getKey();
		if (ex.contains(name)) {
			continue;
		}
		List<FormDataBodyPart> fields = e.getValue();
		if (fields.isEmpty()) {
			continue;
		}
		FormDataBodyPart field = fields.get(fields.size() - 1);
		if (name.startsWith(ParamValue.METHOD_UPLOAD + "-")) {
			name = name.substring(7);
			ContentDisposition cd = field.getContentDisposition();
			
			run.addUploadParamValue(name, cd.getFileName(), field.getValueAs(InputStream.class));
		}
		else {
			String value = field.getValue();
			setParam(run, name, value);
		}
	}
}
 

import com.sun.jersey.core.header.ContentDisposition; //导入依赖的package包/类
/**
 * Extracts certificate from the multipart form.
 * 
 * @param part
 *            parsed multipart form body part.
 * @return extracted certificate or <code>null</code> if empty field was passed.
 * @throws UnableToParseFormException
 *             should passed value be invalid.
 */
private byte[] extractInputFileSource(FormDataBodyPart part)
        throws UnableToParseFormException {
    ContentDisposition disp = part.getContentDisposition();
    if (disp.getFileName() != null) {
        InputStream is = part.getValueAs(InputStream.class);
        try {
            byte[] certificate = IOUtils.toByteArray(is);
            return certificate.length > 0 ? certificate : null;
        } catch (IOException e) {
            // fall through, error will be thrown nonetheless from the last line.
            logger.debug("IO error while parsing certificate data from multipart form: " + e.toString());
        }
    }
    throw new UnableToParseFormException("Could not parse the certificate information");
}
 

import com.sun.jersey.core.header.ContentDisposition; //导入依赖的package包/类
private String getFileNameFromResponse(final ClientResponse response) {
	String value = response.getHeaders().getFirst("Content-Disposition");
	String fileName = "executeTask";
	try {
		ContentDisposition contentDisposition = new ContentDisposition(value);
		fileName = contentDisposition.getFileName();
	} catch (ParseException e) {
		e.printStackTrace();
	}
	return fileName;
}
 

import com.sun.jersey.core.header.ContentDisposition; //导入依赖的package包/类
public FileStream(String requestUri, ClientResponse response) {
	this.inputStream = response.getEntityInputStream();
	if(response.getType() != null){
		this.contentType = response.getType().toString();
	}
	
	MultivaluedMap<String, String> headers = response.getHeaders();
	try {
		// http://www.ietf.org/rfc/rfc2183.txt
		ContentDisposition cd = new ContentDisposition(headers.getFirst("Content-Disposition"));
		fileName = cd.getFileName() == null ? getFileNameFromUrl(requestUri) : cd.getFileName();
		size = cd.getSize() == 0 ? response.getLength() : cd.getSize();
	} catch (ParseException e) {
	}
}
 

import com.sun.jersey.core.header.ContentDisposition; //导入依赖的package包/类
@GET
@Path("/{service}/{id}/{filename}")
public Response download(
        @Auth ClientPermission clientPermission,
        @SuppressWarnings("TypeMayBeWeakened") @Context HttpServletRequest req,
        @Metadata final BackupMetadata backup,
        @PathParam("filename") final String filename) throws MetadataNotFoundException {

    if (!(backup.isSuccessful() || backup.isFailed())) {
        throw new IllegalStateException("Attempted to download a non-complete backup.");
    }

    final List<Chunk> chunks = backup.getChunks(filename);
    if (chunks.isEmpty()) {
        throw new WebApplicationException(Response.Status.NOT_FOUND);
    }

    LOG.info("SecEvent: Downloading backup {}, requested by {}", backup, req.getRemoteAddr());

    long size = 0;
    for (Chunk chunk : chunks) {
        size += chunk.getOriginalSize();
    }

    final ContentDisposition disposition = ContentDisposition
            .type("attachment")
            .fileName(filename)
            .build();

    final Response.ResponseBuilder builder = Response
            .status(Response.Status.OK)
            .type(MediaType.APPLICATION_OCTET_STREAM)
            .header(HttpHeaders.CONTENT_DISPOSITION, disposition)
            .entity(new StreamingOutput() {
                @Override
                public void write(OutputStream output) throws IOException {
                    try {
                        backupProcessor.download(backup, filename, output);
                    }
                    finally {
                        output.close();
                    }
                }
            });

    // Only add a content length if we have one
    if (size > 0) {
        builder.header(HttpHeaders.CONTENT_LENGTH, size);
    }

    return builder.build();
}