5

我认为简短的回答可能是否定的，但我希望我能得到其他建议。假设我有一个数据对象和一个数据服务。数据服务是一个接口，有以下方法。

public Data getData();

我正在使用以下调用处理程序和 Netty 为服务创建代理，以执行我称之为异步 rpc 的操作。代理在客户端。

@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    // Convert the call into an async request that returns a ListenableFuture
    APCRequest request = new APCRequest(serviceType, method, args);
    ListenableFuture future = apcClient.asyncMessage(request);

    // This blocks until the future finishes
    return future.get();
}

这工作正常。但是，如果我的客户端是一个 UI，我最终会将服务调用包装在类似于 SwingWorker 的东西中。我更愿意想出一种方法来返回我已经坐在那里的 ListenableFuture。有什么方法可以在不创建单独的异步服务 API 的情况下实现这一点。例如：

public ListenableFuture<Data> getData();

如果我可以让我的 InvocationHandler 返回错误的类型，我可以使用这样的东西。

public abstract class AsyncServiceCall<S, D> { // S = service type, D = expected doCall return type
    protected final S service;

    protected AsyncServiceCall(Class<S> serviceType, APCClient client) {
        ProxyFactory proxyFactory = new ProxyFactory(client);

        // The true tells the proxyFactory we're expecting a ListenableFuture<D>
        // rather than the real return type.
        service = proxyFactory.createProxy(serviceType, true);
    }

    // Sub-classes would make a normal method call using this.  For
    // example, service.getData()
    public abstract Object doCall();

    @SuppressWarnings("unchecked")
    public ListenableFuture<D> execute() {
        return (ListenableFuture<D>) doCall();
    }

有没有另一种方式来完成我想要的？性能对我来说不是问题，因此如果没有简单的方法来做我想做的事情，那么在代理可以从未来获取返回值之前进行阻塞仍然是一种选择。这似乎是一种浪费，因为无论如何我都希望在 UI 中进行异步调用。

保持我的服务 API 简单比什么都重要。我希望能够使用一个简单的服务提供者进行原型设计，该服务提供者直接实例化服务实现，并在开发周期的后期插入使用动态代理/Netty 的远程协议/服务器。

4

1 回答 1

3

如果你想让你的 API 保持简单，那么我建议在接口中只提供异步 API - 在异步 API 中包含同步实现比反之亦然容易得多。

public interface DataService {
  public ListenableFuture<Data> getData();
}

public abstract class LocalDataService implements DataService {
  public ListenableFuture<Data> getData() {
    SettableFuture<Data> result = SettableFuture.create();
    try {
      Data theData = computeData();
      result.set(theData);
    } catch(Throwable t) {
      result.setException(e);
    }
    return result;
  }

  protected abstract Data computeData() throws Throwable;
}
于 2012-07-21T10:40:54.470 回答