PROSAGA码农传奇-SOA/RPC-grpc完成异步java服务请求/响应映射

<div class =“post-text”itemprop =“text”>
  <P>
    gRPC Java可以相对容易地创建代理。对这样的代理使用异步存根很常见。当代理创建其传出RPC时，它可以在传出RPC的回调中保存对原始RPC的引用。当传出RPC的回调触发时，只需对原始RPC发出相同的调用。这解决了消息和错误。
  </p>
  <P>
    截止日期和取消传播由...自动处理
     <code>
      io.grpc.Context
    </code>
    。
  </p>
  <P>
    你可能想参考
    <a href="https://github.com/ejona86/grpc-java/commit/29728aeb003ced3c190197c176563643be22bef1" rel="nofollow noreferrer">
      这个grpc级别的代理示例
    </A>
     （尚未合并到grpc / grpc-java）。它用
     <code>
      ClientCall
    </code>
    /
     <code>
      ServerCall
    </code>
     因为它很方便，因为它不想解析消息。使用它可以做同样的事情
     <code>
      StreamObserver
    </code>
     API。
  </p>
  <P>
    这种代理的主要困难是观察流量控制。我引用的例子就是这样做的。如果使用
     <code>
      StreamObserver
    </code>
     您应该投射的API
     <code>
      StreamObserver
    </code>
     传递到服务器
     <code>
      ServerCallStreamObserver
    </code>
     得到一个
     <code>
      ClientCallStreamObserver
    </code>
     通过一个
     <code>
      ClientResponseObserver
    </code>
     到客户端存根。
  </p>
</DIV>