使用jersey-1.7在Google Appengine上上传分段文件

编程问答 2022-04-26

问题描述

|| 我在Google Appengine上使用Jersey编写了一个应用程序来处理简单的文件上传。在球衣1.2上使用时效果很好。在更高版本（当前为1.7）中，引入了@FormDataParam来处理多部分/表单输入。我正在使用jersey-multipart和mimepull依赖项。似乎新的方法是在appengine中创建临时文件，我们都知道这是非法的... 自从Jersey现在可以与AppEngine兼容以来，我在这里错过了什么还是做错了吗？ 
@POST 
@Path(\"upload\") 
@Consumes(MediaType.MULTIPART_FORM_DATA) 
public void upload(@FormDataParam(\"file\") InputStream in) { .... }
调用这些异常时，以上操作将失败。 
/upload
java.lang.SecurityException: Unable to create temporary file
    at java.io.File.checkAndCreate(File.java:1778)
    at java.io.File.createTempFile(File.java:1870)
    at java.io.File.createTempFile(File.java:1907)
    at org.jvnet.mimepull.MemoryData.createNext(MemoryData.java:87)
    at org.jvnet.mimepull.Chunk.createNext(Chunk.java:59)
    at org.jvnet.mimepull.DataHead.addBody(DataHead.java:82)
    at org.jvnet.mimepull.MIMEPart.addBody(MIMEPart.java:192)
    at org.jvnet.mimepull.MIMEMessage.makeProgress(MIMEMessage.java:235)
    at org.jvnet.mimepull.MIMEMessage.parseAll(MIMEMessage.java:176)
    at org.jvnet.mimepull.MIMEMessage.getAttachments(MIMEMessage.java:101)
    at com.sun.jersey.multipart.impl.MultiPartReaderClientSide.readMultiPart(MultiPartReaderClientSide.java:177)
    at com.sun.jersey.multipart.impl.MultiPartReaderServerSide.readMultiPart(MultiPartReaderServerSide.java:80)
    at com.sun.jersey.multipart.impl.MultiPartReaderClientSide.readFrom(MultiPartReaderClientSide.java:139)
    at com.sun.jersey.multipart.impl.MultiPartReaderClientSide.readFrom(MultiPartReaderClientSide.java:77)
    at com.sun.jersey.spi.container.ContainerRequest.getEntity(ContainerRequest.java:474)
    at com.sun.jersey.spi.container.ContainerRequest.getEntity(ContainerRequest.java:538)
有人知道吗？有什么办法可以防止mimepull创建临时文件？     

解决方法

        对于超出默认大小的文件，ѭ2将创建一个临时文件。为了避免这种情况-在gae上创建文件是不可能的-您可以在项目的resources文件夹中创建一个
jersey-multipart-config.properties
文件，并将以下行添加到其中： 
bufferThreshold = -1
然后，代码就是您提供的代码： 
@POST
@Consumes(MediaType.MULTIPART_FORM_DATA)
public Response post(@FormDataParam(\"file\") InputStream stream,@FormDataParam(\"file\") FormDataContentDisposition disposition) throws IOException {
  post(file,disposition.getFileName());
  return Response.ok().build();
}
    ,        为了使那些在Eclipse和GPE（Eclipse的Google插件）结合使用时苦苦挣扎的人受益，我给出了这个略微修改的解决方案，该解决方案源自@yves \'的答案。 我已经用
App Engine SDK 1.9.10
和
Jersey 2.12
测试过。由于其他问题，8等不适用于ѭ8work。 在
\\war\\WEB-INF\\classes
文件夹下，创建一个名为
jersey-multipart-config.properties
的新文件。编辑文件，使其包含行“ 11”。 请注意，“ 12”文件夹在Eclipse中是隐藏的，因此请在操作系统的文件浏览器（例如Windows资源管理器）中查找该文件夹。 现在，无论是在初始化“ 2”功能（在Jersey servlet初始化时）还是在完成文件上传（在Jersey servlet发布请求时），临时文件都将不再创建，并且GAE不会抱怨。     ,        将文件
jersey-multipart-config.properties
放在WAR中的
WEB-INF/classes
下非常重要。 通常在WAR文件结构中，将配置文件（
web.xml
，
appengine-web.xml
）放入
WEB-INF/
，但是在此需要放入
WEB-INF/classes
。 Maven配置示例： 
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-war-plugin</artifactId>
            <version>2.4</version>
            <configuration>
                <archiveClasses>true</archiveClasses>
                <webResources>
                    <resource>
                        <directory>${basedir}/src/main/webapp/WEB-INF</directory>
                        <filtering>true</filtering>
                        <targetPath>WEB-INF</targetPath>
                    </resource>
                    <resource>
                        <directory>${basedir}/src/main/resources</directory>
                        <targetPath>WEB-INF/classes</targetPath>
                    </resource>
                </webResources>
            </configuration>
        </plugin>
您的项目结构如下所示： 泽西岛2.x中
jersey-multipart-config.properties
的内容： 
jersey.config.multipart.bufferThreshold = -1
    ,        我找到了以编程方式避免使用临时文件创建的解决方案（对于GAE实施非常有用） 我的解决方案包括在我的代码下创建一个新的MultiPartReader Provider ... 
  @Provider
    @Consumes(\"multipart/*\")
    public class GaeMultiPartReader implements MessageBodyReader<MultiPart> {

    final Log logger = org.apache.commons.logging.LogFactory.getLog(getClass());

    private final Providers providers;

    private final CloseableService closeableService;

    private final MIMEConfig mimeConfig;

    private String getFixedHeaderValue(Header h) {
        String result = h.getValue();

        if (h.getName().equals(\"Content-Disposition\") && (result.indexOf(\"filename=\") != -1)) {
            try {
                result = new String(result.getBytes(),\"utf8\");
            } catch (UnsupportedEncodingException e) {            
                final String msg = \"Can\'t convert header \\\"Content-Disposition\\\" to UTF8 format.\";
                logger.error(msg,e);
                throw new RuntimeException(msg);
            }
        }

        return result;
    }

    public GaeMultiPartReader(@Context Providers providers,@Context MultiPartConfig config,@Context CloseableService closeableService) {
        this.providers = providers;

        if (config == null) {
            final String msg = \"The MultiPartConfig instance we expected is not present. \"
                + \"Have you registered the MultiPartConfigProvider class?\";
            logger.error( msg );
            throw new IllegalArgumentException(msg);
        }
        this.closeableService = closeableService;

        mimeConfig = new MIMEConfig();
        //mimeConfig.setMemoryThreshold(config.getBufferThreshold());
        mimeConfig.setMemoryThreshold(-1L); // GAE FIX
    }

    @Override
    public boolean isReadable(Class<?> type,Type genericType,Annotation[] annotations,MediaType mediaType) {
        return MultiPart.class.isAssignableFrom(type);
    }

    @Override
    public MultiPart readFrom(Class<MultiPart> type,MediaType mediaType,MultivaluedMap<String,String> headers,InputStream stream) throws IOException,WebApplicationException {
        try {
            MIMEMessage mm = new MIMEMessage(stream,mediaType.getParameters().get(\"boundary\"),mimeConfig);

            boolean formData = false;
            MultiPart multiPart = null;

            if (MediaTypes.typeEquals(mediaType,MediaType.MULTIPART_FORM_DATA_TYPE)) {
                multiPart = new FormDataMultiPart();
                formData = true;
            } else {
                multiPart = new MultiPart();
            }

            multiPart.setProviders(providers);

            if (!formData) {
                multiPart.setMediaType(mediaType);
            }

            for (MIMEPart mp : mm.getAttachments()) {
                BodyPart bodyPart = null;

                if (formData) {
                    bodyPart = new FormDataBodyPart();
                } else {
                    bodyPart = new BodyPart();
                }

                bodyPart.setProviders(providers);

                for (Header h : mp.getAllHeaders()) {
                    bodyPart.getHeaders().add(h.getName(),getFixedHeaderValue(h));
                }

                try {
                    String contentType = bodyPart.getHeaders().getFirst(\"Content-Type\");

                    if (contentType != null) {
                        bodyPart.setMediaType(MediaType.valueOf(contentType));
                    }

                    bodyPart.getContentDisposition();
                } catch (IllegalArgumentException ex) {
                    logger.error( \"readFrom error\",ex );
                    throw new WebApplicationException(ex,400);
                }

                bodyPart.setEntity(new BodyPartEntity(mp));
                multiPart.getBodyParts().add(bodyPart);
            }

            if (closeableService != null) {
                closeableService.add(multiPart);
            }

            return multiPart;
        } catch (MIMEParsingException ex) {
            logger.error( \"readFrom error\",ex );
            throw new WebApplicationException(ex,400);
        }
    }

}
    ,        我们遇到了类似的问题，Jetty不允许我们上传超过9194字节的文件（突然之间-一天），之后我们意识到有人从/ tmp那里获取了我们的用户访问权限，该访问权限对应于java.io .tmpdir在某些linux版本上，因此Jetty无法将上传的文件存储在此处，并且出现400错误。     
appengineappenginegooglejersey-1.7上传使用使用使用分段分段文件