1.消费者一个线程调用远程接口，生成一个唯一的ID（比如一段随机字符串，UUID等），Dubbo是使用AtomicLong从0开始累计数字的。

2.将方法调用信息（如调用的接口名称，方法名称，参数值列表等）和处理结果的回调对象callback（即ResponseFuture对象），全部封装在一起组成一个对象object。向专门存放调用信息的全局ConcurrentHashMap里面put(ID, object)。 3.将ID和打包的方法调用信息封装成一对象connRequest，通过Netty异步发送出去。 4.当前线程再使用callback的get()方法试图获取远程返回的结果，在get()内部，则使用lock.lock()获取回调对象callback的锁， 再先检测是否已经获取到结果，如果没有，然后调用callback的wait()方法，释放callback上的锁，让当前线程处于等待状态。 5.服务端接收到请求并处理后，将结果（此结果中包含了前面的ID，即回传）发送给客户端，客户端socket连接上专门监听消息的线程收到消息，分析结果，取到ID，再从前面的ConcurrentHashMap里面get(ID)，从而找到callback，将方法调用结果设置到callback对象里。 6.监听线程接着使用lock.lock()获取回调对象callback的锁，再调用signal()（类似notifyAll()）方法唤醒前面处于等待状态的线程继续执行。至此，整个过程结束。

附源码：https://blog.csdn.net/u010942020/article/details/79263854