那些遇到过的问题

在 RESTful Web 服务中使用多个资源

Art*_*ich 6 java xml rest jax-rs wildfly-8

在我的 web 服务器应用程序中，我有一个方法，它修改一个 xml 文档，看起来类似于：

@POST
@Path("somePath")
@Consumes({"application/xml", "application/zip"})
public Response modifyXml() {
    //some processing
}
Run Code Online (Sandbox Code Playgroud)

使用的 zip 存档包含需要修改的 xml 文件和一些其他文件。如何区分消耗的 xml 文件和方法内的存档，以及我应该使用哪种方法参数来表示这个消耗的资源？

Pau*_*tha 5

一种解决方案是仅从InputStream. 你可以在包裹InputStream中ZipInputStream。WithZipInputStream你可以得到一个ZipEntrywith ZipInputStream.getNextEntry()，然后你可以得到一个with的文件名ZipEntry.getName()。然后只需检查名称endsWith(".xml")。

尽管如此，你需要消耗application/octet-stream. 这是一个简单的例子

@Path("/zip")
public class ZipResource {

    @POST
    @Consumes(MediaType.APPLICATION_OCTET_STREAM)
    public Response postZipFile(InputStream is) throws Exception {
        StringBuilder builder;
        try (ZipInputStream zip = new ZipInputStream(is)) {
            builder = new StringBuilder("==== Data ====\n");
            ZipEntry entry;
            while ((entry = zip.getNextEntry()) != null) {
                String filename = entry.getName();
                if (filename.endsWith(".xml")) {
                    builder.append("name: ").append(entry.getName()).append("\n");
                    String xml = filePartToString(zip, (int) entry.getSize());
                    builder.append("data: ").append(xml).append("\n");
                }
                zip.closeEntry();
            }
        }
        return Response.ok(builder.toString()).build();
    }

    private String filePartToString(InputStream is, int size) throws Exception {
        String xml;
        byte[] buff = new byte[size];
        is.read(buff, 0, size);
        return new String(buff);
    }
}
Run Code Online (Sandbox Code Playgroud)

这是一个测试

@Test
public void testResteasy() throws Exception {
    WebTarget target = client.target(
            TestPortProvider.generateURL(BASE_URI)).path("zip");
    File file = new File("C:/test/test.zip");
    Response response = target.request().post(
            Entity.entity(file, MediaType.APPLICATION_OCTET_STREAM));
    System.out.println(response.getStatus());
    System.out.println(response.readEntity(String.class));
    response.close();
}
Run Code Online (Sandbox Code Playgroud)

在 zip 中使用这些文件

test1.xml
---------
<test1>hello world</test1>

test2.xml
---------
<test2>hello squirrel</test2>

test3.json
----------
{
    "test3":"Hello Girls"
}
Run Code Online (Sandbox Code Playgroud)

我得到以下结果

==== Data ====
name: test1.xml
data: <test1>hello world</test1>
name: test2.xml
data: <test2>hello squirrel</test2>
Run Code Online (Sandbox Code Playgroud)

顺便说一句，如果您可以控制数据的发送方式，您可能还需要研究多部分解决方案。在那里您可以设置内容类型，您可以为每个部分命名，以便更容易访问。

您可以在此处查看 Resteasy 对 multipart 的支持以及所需的依赖项。

更新

如果您必须使用application/zip，则没有对此的标准支持。所以你需要掀起你自己的MessageBodyReader. 它可以像包装并返回已经提供的一样简单InputStream

@Provider
@Consumes("application/zip")
public class ZipMessageBodyReader implements MessageBodyReader<ZipInputStream> {

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

    @Override
    public ZipInputStream readFrom(Class<ZipInputStream> type, 
            Type genericType, Annotation[] annotations, MediaType mediaType, 
            MultivaluedMap<String, String> httpHeaders, 
            InputStream entityStream) throws IOException, WebApplicationException {

        return new ZipInputStream(entityStream);
    }    
}
Run Code Online (Sandbox Code Playgroud)

然后在您的资源方法中，您可以只有一个ZipInputStream参数，而不是InputStream.

@POST
@Consumes("application/zip")
public Response postZipFile(ZipInputStream zip) throws Exception {
Run Code Online (Sandbox Code Playgroud)

在客户端（使用客户端 API），如果您要使用application/zip，您当然还需要编写一个MessageBodyWriterforapplication/zip

更新 2

来自评论：我需要我的方法能够同时使用一个简单的 xml 文件和一个包含 xml 文件的 zip 存档，所以我对该方法进行了注释（伪代码）：“consumes(xml, zip)”并声明一个带有参数 InputStream 的方法是；然后在方法主体中，我需要确定此 InputStream 是 xml 类型还是 zip 存档，并希望编写类似于以下内容的内容：“if(is of type xml) {then Treat is as an x​​ml} else {treat is as a zip 存档}。希望现在这个问题更容易理解了

我们可以保留您的原始方法签名同时接受application/xml和application/zip。我们还可以通过注入HttpHeaders并Content-Type从中获取来检查实际发送的是哪个。在此基础上，我们将确定如何提取。这是我们如何完成此操作的另一个示例

@Path("/zip")
public class ZipResource {

    @POST
    @Consumes({"application/zip", "application/xml"})
    public Response postZipFile(InputStream is, @Context HttpHeaders headers) throws Exception {
        String contentType = headers.getHeaderString(HttpHeaders.CONTENT_TYPE);
        String returnString = null;

        if (null != contentType) switch (contentType) {
            case "application/xml":
                returnString = readXmlFile(is);
                break;
            case "application/zip":
                returnString = readZipFile(is);
                break;
        }

        return Response.ok(returnString).build();
    }

    private String filePartToString(InputStream is, int size) throws Exception {
        String xml;
        byte[] buff = new byte[size];
        is.read(buff, 0, size);
        return new String(buff);
    }

    private String readXmlFile(InputStream is) {
        StringWriter writer = new StringWriter();
        try {
            IOUtils.copy(is, writer, "utf-8");
        } catch (IOException ex) {
            Logger.getLogger(ZipResource.class.getName()).log(Level.SEVERE, null, ex);
        }
        return writer.toString();
    }

    private String readZipFile(InputStream is) {
        StringBuilder builder = new StringBuilder("==== Data ====\n");
        try (ZipInputStream zip = new ZipInputStream(is)) {
            ZipEntry entry;
            while ((entry = zip.getNextEntry()) != null) {
                String filename = entry.getName();
                if (filename.endsWith(".xml")) {
                    builder.append("name: ").append(entry.getName()).append("\n");
                    String xml = filePartToString(zip, (int) entry.getSize());
                    builder.append("data: ").append(xml).append("\n");
                }
                zip.closeEntry();
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return builder.toString();
    }
}
Run Code Online (Sandbox Code Playgroud)

我们需要一个MessageBodyReader来处理application/zip类型。上面的工作正常，但我们只需要它返回一个InputStream而不是ZipInputStream

@Provider
@Consumes("application/zip")
public class ZipMessageBodyReader implements MessageBodyReader<InputStream> {
    @Override
    public boolean isReadable(Class<?> type, Type genericType, 
            Annotation[] annotations, MediaType mediaType) {
        return type == InputStream.class;
    }

    @Override
    public InputStream readFrom(Class<InputStream> type, 
            Type genericType, Annotation[] annotations, MediaType mediaType, 
            MultivaluedMap<String, String> httpHeaders, 
            InputStream entityStream) throws IOException, WebApplicationException {

        return entityStream;
    }  
}
Run Code Online (Sandbox Code Playgroud)

现在通过测试

@Test
public void testResteasy() throws Exception {
    WebTarget target = client.target(
            TestPortProvider.generateURL(BASE_URI)).path("zip");


    File file = new File("C:/test/test.zip");
    Response response = target.request().post(
            Entity.entity(file, "application/zip"));

    System.out.println(response.getStatus());
    System.out.println(response.readEntity(String.class));
    response.close();

    file = new File("C:/test/test1.xml");
    response = target.request().post(
            Entity.entity(file, "application/xml"));

    System.out.println(response.getStatus());
    System.out.println(response.readEntity(String.class));
    response.close();

}
Run Code Online (Sandbox Code Playgroud)

我们得到以下

200
==== Data ====
name: test1.xml
data: <test1>hello world</test1>
name: test2.xml
data: <test2>hello squirrel</test2>

200
<test1>hello world</test1>
Run Code Online (Sandbox Code Playgroud)

注意：对于客户端，我必须实现 aMessageBodyWriter来处理application/zip类型。下面是一个简单的实现，只是为了让测试工作。真正的实现需要一些修复

@Provider
@Produces("application/xml")
public class ZipClientMessageBodyWriter implements MessageBodyWriter<File> {

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

    @Override
    public long getSize(File t, Class<?> type, Type genericType, 
            Annotation[] annotations, MediaType mediaType) {
        return -1;
    }

    @Override
    public void writeTo(File t, Class<?> type, Type genericType, 
            Annotation[] annotations, MediaType mediaType, 
            MultivaluedMap<String, Object> httpHeaders, OutputStream entityStream) 
            throws IOException, WebApplicationException {

        IOUtils.write(IOUtils.toByteArray(new FileInputStream(t)), entityStream);
    }  
}

....

client.register(ZipClientMessageBodyWriter.class);
Run Code Online (Sandbox Code Playgroud)

您还会在一些示例代码中注意到，我使用了 Apache Commons IOUtils。对不起。我很懒:-)

更新 3

实际上，我们不需要MessageBodyReader。找到读者的算法其实只是默认为InputStream读者，因为它支持application/xml，所以它会已经返回InputStream我们是否有对读者application/zip还是不

归档时间：

查看次数：

12330 次

最近记录：

11 年，2 月 前
相关归档
javax vs java包 367
处理Java ExecutorService任务中的异常 201
应该尝试......赶上环路内外？ 175
什么是胖JAR？ 121
JDK tools.jar作为maven依赖 73
Apache HttpClient临时错误:NoHttpResponseException 66
尝试写入文件夹时获取"java.nio.file.AccessDeniedException" 48
将数组或列表传递给@Pathvariable - Spring/Java 46
Java中的原始强制转换和赋值 45
SimpleXML中的XPath,用于默认名称空间,无需前缀 9
难疑归档
最终C++书籍指南和列表 4246
如何通过引用传递变量？ 2480
静态类变量是否可能？ 1824
在Node.js中编写文件 1538
将浮点数限制为两个小数点 1527
你如何合并两个Git存储库？ 1517
单击div到底层元素 1500
如何使用CSS设置<select>下拉列表的样式？ 1258
如何在Git中仅提交区分大小写的文件名更改？ 1157
visibility:hidden和display:none之间有什么区别？ 1121