我必须在 Web 应用程序中对 Web 服务进行一些后台调用。电话的响应并不是真正的时间紧迫,而且对我来说几乎没有兴趣。它仅在极少数情况下发生变化,在这种情况下,我会通过抛出异常或记录失败或其他方式对其做出反应。
我现在的具体问题是指在 Jersey Client 2 中正确处理此类异步调用。
选项 1 使用来自 jersey 的异步调用,但随后为每个响应启动一个线程。
选项 2 将立即启动一个线程并从该线程内部使用球衣。
一般来说,哪种选择更可取?
Option 1
private static final ExecutorService executorService = Executors.newFixedThreadPool(20);
--
Client client = ClientBuilder.newClient();
WebTarget target = client.target("somehost").path("somepath");
final AsyncInvoker asyncInvoker = target.request().async();
final Future<Response> responseFuture = asyncInvoker.post(Entity.json(myjsonobject));
executorService.execute(new Worker(responseFuture));
-- 工作线程
public class Worker implements Runnable {
private Future<Response> futureResponse;
public Worker(Future<Response> futureResponse){
this.futureResponse = futureResponse;
}
@Override
public void run() {
try {
final Response response = futureResponse.get();
if(response.getStatus() == 500)
doSomething();
} catch(Exception e) {
e.printStackTrace();
}
}
}
Option 2
private static final ExecutorService executorService = Executors.newFixedThreadPool(20);
--
executorService.execute(new Worker());
-- 工作线程
public class Worker implements Runnable {
public Worker(){
}
@Override
public void run() {
try {
Client client = ClientBuilder.newClient();
WebTarget target = client.target("somehost").path("somepath");
ClientResponse response = target.request().accept(MediaType.APPLICATION_JSON).post(Entity.json(myjsonobject), ClientResponse.class);
if(response.getStatus() == 500) {
doSomething();
}
} catch(Exception e) {
e.printStackTrace();
}
}
}