java - Jersey 2 客户端如何将输入/输出二进制流发送到服务器，反之亦然

Question

我是 Jersey 的新手。我有两件事要知道。1. 将领域对象从客户端发送到服务器2. 从服务器向客户端发送域对象。

1. 我想将自定义对象从客户端发送到服务器应用程序。由于要发送的对象类型可能不同(它可以是域对象、文件或图像)，我应该将这些对象转换为流并发送到服务器。同样对于流，我也需要发送一些参数。然后我需要在服务器中检索流并对其进行处理。

2. 一旦域对象转换为流，它们也应该被发送到客户端。

   我使用 Jersey 2.8。 Java 8。汤姆卡特 6。这是我尝试这样做的方法，但它失败了(可能是一种错误的方法)

这是我的客户:

InputStream returnStrem = (InputStream)client.target("http://localhost:8080/TestJerseyProject")
                                                                .path("rest/save")
                                                                .request(new MediaType[]    {MediaType.APPLICATION_OCTET_STREAM_TYPE})
                                                                .get(InputStream.class);

                        try {
                          ObjectInputStream ois = new ObjectInputStream(new BufferedInputStream(returnStrem));
                          Object o=  ois.readObject();
                          System.out.println("Entity  : "+o );
                      }catch(Exception e){
                    e.printStackTrace();  
                      }finally {
                     returnStrem.close();
                      }

服务端代码:

@Path("/cache")
public class ObjectCacheAction {

        @GET
        @Consumes("application/octet-stream")
        @Produces(MediaType.APPLICATION_OCTET_STREAM)
        public Response streamExample(InputStream is) {

                 try {
                  ObjectInputStream ois = new ObjectInputStream(new BufferedInputStream(is));
                  Object o=  ois.readObject();
                  System.out.println("Entity : "+o );
                  is.close();
              }catch(Exception e){
             e.printStackTrace();
              }finally {

              }


          StreamingOutput stream = new StreamingOutput() {
                public void write(OutputStream os) throws IOException,
                                WebApplicationException {

                        try {
                                MyObj m=new MyObj();//My Domain Object
                                m.setName("sdfsdf");

                                 ObjectOutputStream oos1 = new ObjectOutputStream(os);
                                 oos1.writeObject(m);
                                 oos1.flush();
                                 oos1.close();

                        } catch (Exception e) {
                                e.printStackTrace();
                        }
                }
        };

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

}

可能是我的方法不对。但是，请让我知道如何使用工作代码示例执行此操作。我在 Internet 上尝试过，但大多数都是 Jersey 1.X。

Answer 1

InputStream returnStrem = (InputStream)client.target("http://localhost:8080/TestJerseyProject")
            .path("rest/save")
            .request(new MediaType[] {MediaType.APPLICATION_OCTET_STREAM_TYPE})
            .get(InputStream.class);

在最后一条语句中，您实际上是在请求收集 InputStream 的一个实例，事实上，您应该在其中请求您期望接收的对象。从服务器代码看来，您应该请求一个 MyObj.class，这样客户端代码实际上更像是

MyObj myObj = client.target("http://localhost:8080/TestJerseyProject")
            .path("rest/save")
            .request(new MediaType[] {MediaType.APPLICATION_OCTET_STREAM_TYPE})
            .get(MyObj.class);

我不熟悉以这种方式使用流，因此您可能需要对其进行调整...