如何解决使用jersey-1.7在Google Appengine上上传分段文件
|| 我在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)
解决方法
对于超出默认大小的文件，ѭ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();
}
App Engine SDK 1.9.10
Jersey 2.12
\\war\\WEB-INF\\classes
jersey-multipart-config.properties
jersey-multipart-config.properties
WEB-INF/classes
web.xml
appengine-web.xml
WEB-INF/
WEB-INF/classes
<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>
jersey-multipart-config.properties
jersey.config.multipart.bufferThreshold = -1
@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);
}
}
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。