5

我创建了一个简单的 Jersey 客户端,它能够成功地使用有效负载执行 POST 请求。但现在它等待来自 http 端点的响应:

public void callEndpoint(String endpoint, String payload) {

    try {
        ClientConfig config = new DefaultClientConfig();
        Client client = Client.create(config);
        WebResource webResource = client.resource(getBaseURI(endpoint));

        log.debug("Sending payload [" + payload + "] to URL - [" + getBaseURI(endpoint) + "]");

        // POST method - Is this blocking?
        // Is it possible to not wait for response here
        ClientResponse response = webResource.accept("application/json")
                                             .type("application/json")
                                             .post(ClientResponse.class, payload);
        if (response.getStatus() != 200) {
            log.error("The endpoint [" + getBaseURI(endpoint) + "] returned a non 200 status code [" + response.getStatus() + "] ");
        }

    } catch (Exception e) {
        log.error("The endpoint for " + endpoint + " - " + getBaseURI(endpoint) + " is not reachable. This is the exception - " + e);
    }

}

private URI getBaseURI(String endpoint) {
    // Get this URI from config
    String URL = "http://www.somewhere.com/v2/" + endpoint;
    return UriBuilder.fromUri(URL).build();
}

问题:代码是否有可能不等待响应。

我试图阅读Jersey 客户端文档以查找我的代码是否有可能不等待响应?我看到我们只能在阅读响应后关闭连接,但在我的情况下它没有用。我想在将有效负载发布到端点后立即关闭连接。

我只需要触发并忘记 POST 请求,因为我不关心响应。这是因为该端点的处理需要大量时间,我不希望线程等待处理。

是否可以等待某些请求的响应,但不能等待所有请求的响应?我可以在客户端中设置一个参数来让它等待/不等待吗?我仍在阅读 java 文档,所以这可能是一个非常简单的设置,但直到现在我都无法找到,所以在这里询问。谢谢!

[更新]

我让它使用以下代码,但是当我运行我的 java 示例代码时,它会立即打印start & done但程序会继续运行一段时间然后退出。我猜它正在等待未来的响应,所以我可以让我的脚本不等待它吗?代码是:

public static void callEndpoint(String endpoint, String payload) {

    try {
        ClientConfig config = new DefaultClientConfig();
        Client client = Client.create(config);
        AsyncWebResource webResource = client.asyncResource(getBaseURI(endpoint));

        // POST method
        System.out.println("start");
        Future<ClientResponse> resp = webResource.accept("application/json")
                .type("application/json")
                .post(ClientResponse.class, payload);
        // This line makes the code wait for output
        //System.out.println(resp.get()); 

    } catch (Exception e) {

        System.out.println ("The endpoint for " + endpoint + " - " + getBaseURI(endpoint) + " is not reachable. This is the exception - " + e);
    }
    System.out.println("done");
}
4

2 回答 2

2

我使用 TypeListener 使其真正异步。收到响应时将调用 onComplete 方法。

webResource.post(new TypeListener<ClientResponse>(ClientResponse.class) {
             @Override
             public void onComplete(Future<ClientResponse> f) throws InterruptedException {
                 try {
                    ClientResponse response = f.get();
                    if (response == null || response.getClientResponseStatus() != Status.OK) {
                        System.err.println(" Async " + response.getClientResponseStatus()+" "+response.getStatus());
                    } else{
                        System.out.println(" Async " + response.getClientResponseStatus()+" "+response.getStatus()+" "+response.getEntity(String.class));
                    }
                } catch (ExecutionException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
             }
         });
于 2017-02-23T13:53:00.817 回答
0

我的回复有点晚了,但我似乎对你的两个问题都有解决方案。希望它可以帮助将来的人。

我保持简短,并提供该平台上已经提出的问题的参考

对于第一个问题,您不想等待。您可以在其客户端对象中使用 jersey 提供的超时属性。以下是解决此问题的链接。 如何使用 Jersey 2.x 设置连接和读取超时?

对于第二个问题,您可以看到它仅在运行一段时间后才停止是因为客户端线程一直运行直到超时。请在下面找到具有更好描述的链接 JerseyClient 异步调用似乎留下了挂起的线程

于 2019-10-15T15:24:41.830 回答