• Thrift 為客戶(hù)端提供了非阻塞的調(diào)用方式，使用 TAsyncClientManager 管理客戶(hù)端的請(qǐng)求，并提供一個(gè) AsyncMethodCallback 接口實(shí)現(xiàn)用于處理調(diào)用結(jié)果，并實(shí)現(xiàn)下面兩個(gè)方法：
  • onComplete：處理服務(wù)返回的結(jié)果值
  • onError：處理調(diào)用服務(wù)過(guò)程中出現(xiàn)的異常
• 下面是客戶(hù)端異步調(diào)用代碼例子

public class Client {
    public static void main(String[] args) throws Exception {
        // 異步調(diào)用管理器
        TAsyncClientManager clientManager = new TAsyncClientManager();
        // 客戶(hù)端應(yīng)該使用非阻塞 IO
        TNonblockingTransport transport = new TNonblockingSocket("localhost",8181);
        // 協(xié)議與服務(wù)端需要一致
        TProtocolFactory tProtocolFactory = new TBinaryProtocol.Factory();
        // 異步調(diào)用
        UserService.AsyncClient asyncClient = new UserService.AsyncClient(tProtocolFactory,clientManager,transport);
        asyncClient.getUser(123, new AsyncMethodCallback<User>() {
            // 處理服務(wù)返回的結(jié)果值
            public void onComplete(User user) {
                System.out.println(user);
            }

            // 處理調(diào)用服務(wù)過(guò)程中出現(xiàn)的異常
            public void onError(Exception e) {

            }
        });
        // 讓線程等待一秒，以免主線程先于異步調(diào)用結(jié)果之前結(jié)束，導(dǎo)致結(jié)果未被輸出
        TimeUnit.SECONDS.sleep(1);
    }
}