java-Dropwizard解压缩请求过滤器
作者:互联网
我有一个dropwizard应用程序,其中客户端请求正文内容是压缩的内容.我需要在dropwizard应用程序中解压缩内容.我有以下代码,但在行GZIPInputStream上出现异常java.io.EOFException = new GZIPInputStream(new ByteArrayInputStream(gzipBody))
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Response;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.nio.charset.Charset;
import java.util.zip.GZIPInputStream;
import static javax.ws.rs.core.Response.Status.INTERNAL_SERVER_ERROR;
@Path("/")
public class UserEventResource {
@POST
@Path("/save")
@Produces("application/json;charset=utf-8")
public Response save(byte[] gzipBody) {
try {
try (GZIPInputStream is = new GZIPInputStream(new ByteArrayInputStream(gzipBody))) {
try (ByteArrayOutputStream os = new ByteArrayOutputStream()) {
byte[] buffer = new byte[4096];
int length;
while ((length = is.read(buffer)) > 0) {
os.write(buffer, 0, length);
}
String body = new String(os.toByteArray(), Charset.forName("UTF-8"));
}
}
return Response.status(OK).build();
} catch (Exception exception) {
return Response.status(INTERNAL_SERVER_ERROR).build();
}
}
}
客户端正在发送以下请求,
curl -XPOST -d @test.gz http://localhost:8080/save
通过以下步骤创建test.gz,
echo "hello world" > test
gzip test
解决方法:
代码本身有效.此问题中的问题是cURL请求.如果添加-v(详细)标志,则会看到问题.
$curl -XPOST -v -d @test.gz http://localhost:8080/api/gzip/save
Note: Unnecessary use of -X or --request, POST is already inferred.
* Trying ::1...
* TCP_NODELAY set
* Connected to localhost (::1) port 8080 (#0)
> POST /api/gzip/save HTTP/1.1
> Host: localhost:8080
> User-Agent: curl/7.54.0
> Accept: */*
> Content-Length: 8
> Content-Type: application/x-www-form-urlencoded
问题出在最后一行:Content-Type是application / x-www-form-urlencoded.不仅如此,文件中的数据也不会发送.我不知道具体细节,但是它与-d标志有关. cURL的默认设置是使用-d标志时发送应用程序/ x-www-form-urlencoded数据.
我们应该做的是使用–data-binary选项而不是-d,并将Content-Type设置为application / octet-stream.这也将导致在服务器端调用正确的提供程序.
curl -XPOST -v \
-H 'Content-Type:application/octet-stream' \
--data-binary @test.gz \
http://localhost:8080/api/gzip/save
为了确保我们的端点仅接受application / octet-stream,我们应该添加@Consumes批注.这很重要,因为我们不希望调用随机提供程序,这会导致奇怪的错误消息.
@POST
@Path("/save")
@Produces("application/json;charset=utf-8")
@Consumes("application/octet-stream")
public Response save(byte[] gzipBody) {
}
阿西德斯
>我不会为该方法使用byte []参数.您实际上并不希望将整个文件读入内存.确保该示例已读取它以获取String.但是最有可能在实际应用程序中,将文件保存在某个地方.因此,仅使用InputStream而不是byte []参数.您可以将该InputStream传递给GZIPInputStream构造函数.
>要上传文件,请考虑改用分段.使用multipart,您不仅可以一次发送多个文件,还可以将元数据添加到文件中.参见Jersey support和Dropwizard support(不仅仅是泽西功能的捆绑包装.
标签:jax-rs,gzip,dropwizard,java 来源: https://codeday.me/bug/20191108/2009712.html