- Thrift 为客户端提供了非阻塞的调用方式，使用 TAsyncClientManager 管理客户端的请求，并提供一个 AsyncMethodCallback 接口实现用于处理调用结果，并实现下面两个方法：
- onComplete：处理服务返回的结果值
- onError：处理调用服务过程中出现的异常
- 下面是客户端异步调用代码例子
public class Client {
public static void main(String[] args) throws Exception {
// 异步调用管理器
TAsyncClientManager clientManager = new TAsyncClientManager();
// 客户端应该使用非阻塞 IO
TNonblockingTransport transport = new TNonblockingSocket("localhost",8181);
// 协议与服务端需要一致
TProtocolFactory tProtocolFactory = new TBinaryProtocol.Factory();
// 异步调用
UserService.AsyncClient asyncClient = new UserService.AsyncClient(tProtocolFactory,clientManager,transport);
asyncClient.getUser(123, new AsyncMethodCallback<User>() {
// 处理服务返回的结果值
public void onComplete(User user) {
System.out.println(user);
}
// 处理调用服务过程中出现的异常
public void onError(Exception e) {
}
});
// 让线程等待一秒，以免主线程先于异步调用结果之前结束，导致结果未被输出
TimeUnit.SECONDS.sleep(1);
}
}
