将文档流发送到 Jersey @POST 端点

我希望能够sendWeb 服务的一堆文档流。这将节省 Http 请求/响应开销并专注于文档本身。

在Python中你可以做这样的事情：

r = requests.post('https://stream.twitter.com/1/statuses/filter.json',
    data={'track': 'requests'}, auth=('username', 'password'),
    stream=True)

for line in r.iter_lines():
    if line: # filter out keep-alive new lines
        print json.loads(line)

我正在寻找一个将请求传输到 Jersey Rest api 的示例。我希望看到客户端和服务器端来展示它的工作原理。但我正在努力寻找一个例子。

理想情况下，该示例将显示：

Client:
  Open request
  Iterate over huge document list
    Write document to open request stream
  Close request

Server:
  @POST method
    Open entity stream
    Iterate over entity stream while next document is available
        Process document
    Close entity stream              

如果我们做对了，您将在服务器上处理实体，同时仍在客户端上发送它们！巨大的胜利！

实现此目的的最简单方法之一是让 Jersey 为 POST 处理程序提供InputStream对于 HTTP POST 正文。该方法可以使用InputStream和您选择的 JSON 解析器来解析然后处理每个对象。

在以下示例中，杰克逊ObjectReader产生一个MappingIterator它解析并处理每个Person文档在传递到服务器时位于数组中

/**
 * Parse and process an arbitrarily large JSON array of Person documents
 */
@Path("persons")
public static class PersonResource {

    private static final ObjectReader reader = new ObjectMapper().readerFor(Person.class);

    @Path("inputstream")
    @Consumes("application/json")
    @POST
    public void inputstream(final InputStream is) throws IOException {
        final MappingIterator<Person> persons = reader.readValues(is);
        while (persons.hasNext()) {
            final Person person = persons.next();
            // process
            System.out.println(person);
        }
    }
}

同样，Jersey 客户端框架在配置了 Jackson 后可以发送文档流ObjectMapper。以下示例使用 Jersey Test 框架演示了这一点。客户端传输任意大的迭代器Person文件

public class JacksonStreamingTest extends JerseyTest {

    @Override
    protected Application configure() {
        return new ResourceConfig(PersonResource.class, ObjectMapperProvider.class);
    }

    /**
     * Registers the application {@link ObjectMapper} as the JAX-RS provider for application/json
     */
    @Provider
    @Produces(MediaType.APPLICATION_JSON)
    public static class ObjectMapperProvider implements ContextResolver<ObjectMapper> {

        private static final ObjectMapper mapper = new ObjectMapper();

        public ObjectMapper getContext(final Class<?> objectType) {
            return mapper;
        }
    }

    @Override
    protected void configureClient(final ClientConfig config) {
        config.register(ObjectMapperProvider.class);
    }

    @Test
    public void test() {
        final Set<Person> persons = Collections.singleton(Person.of("Tracy", "Jordan"));
        final Response response = target("persons/inputstream").request().post(Entity.json(persons.iterator()));
        assertThat(response.getStatus()).isEqualTo(204);
    }
}