使用Context传递控制消息

    Context 保存的内容分为 context 和 localContext。 localContext 在调用过程中，会在进程内部传递， 而 context 的内容会传递到调用过程中 远端服务。 这种传递是单向的。比如在一个 Provider 内部， 调用接口， 那么 localContext 的内容会复制给调用接口运行过程中的 localContext， 如果这个接口在调用过程中修改了 localContext， 接口返回后， Provider 后续的逻辑处理看不到对于 context 的修改。

    在 Handler 或者 Filter 中调用其他微服务， context 信息默认不会复制，需要开发者显示的将 context 信息传递过去。 使用 RestTemplate 或者 RPC 方式传递 context 的例子，请参考本文后面的案例。

    • 在认证场景，Edge Service 认证通过以后，需要将会话 ID、用户名称等信息传递给微服务，实现鉴权等逻辑。
    • 灰度发布场景，需要结合自定义的 tag 实现引流，tag 信息需要传递给微服务。
    • 开发 Handler 处理链的时候，一个 Handler 需要将计算结果传递给下一个 Handler。

    • 在 Hanlder 中获取和设置Context Handler 包含了 Invocation 对象，可以直接调用 invocation.addContext 和 invocation.getContext 。

    • 在服务接口中获取Context

      或者

      2. ContextUtils.getInvocationContext()
      3. ```

    • 在Edge Service中设置Context

      通过重载EdgeInvocation

    通常微服务的调用，是将请求发送到一个实例，这个实例是根据负载均衡策略决定的，业务开发不可控制。为了实现轮询调用一个微服务的所有实例， 首先需要获取一个微服务的所有实例列表，然后逐个调用。 LoadBalance 模块支持通过 Context 传递 Endpoint 信息， 如果 Endpoint 已经 设置， 可以跳过负载均衡判断， 使用用户自己指定的 Endpoint。

      1. ```java
      2. public class TestDateTimeSchema {
      3.   private DiscoveryTree discoveryTree = new DiscoveryTree();
      5.   public TestDateTimeSchema() {
      6.     discoveryTree.addFilter(new CustomEndpointDiscoveryFilter());
      7.     discoveryTree.sort();
      9.   private void testDateTimeSchemaMulticast() throws Exception {
      10.     DiscoveryContext context = new DiscoveryContext();
      11.     VersionedCache serversVersionedCache = discoveryTree.discovery(context, "springmvctest", "springmvc", "0+");
      12.     List<String> enpoints = serversVersionedCache.data(); // 获取到实例列表，可以给下面的处理流程使用
      13.   }
      16. public class CustomEndpointDiscoveryFilter extends AbstractEndpointDiscoveryFilter {
      17.   @Override
      18.   protected String findTransportName(DiscoveryContext context, DiscoveryTreeNode parent) {
      19.     //only need rest endpoints
      20.     return "rest";
      21.   }
      23.   @Override
      24.   protected Object createEndpoint(String transportName, String endpoint, MicroserviceInstance instance) {
      25.     return endpoint;
      26.   }
      28.   public int getOrder() {
      29.     return 0;
      31. }
      32. ```

      上面的代码通过 DiscoveryTree 发现实例列表， 并且实现了 CustomEndpointDiscoveryFilter ， 将发现的实例信息转换为 cache 的返回 类型， 即 String。

    • 通过 InvocationContext 传递 Endpoint 信息给 Load Balance, 每次调用访问用户指定的 Endpoint。 访问 InvocationContext 分几种场景， 参考文章上面提到的情况。 在 Consumer 调用的场景下， 可能不在一个 Provider 的处理上下文中， 这个时候系统中还没有 InvocationContext 实例， 这个时候可以新创建一个实例， 新创建的实例信息会复制到系统内部。

      使用 RPC Consumer 传递 InvocationContext 的例子：

      使用 RestTemplate 传递 InvocationContext 的例子：

      1. ```
      2. for (String endpoint : enpoints) {
      3.   CseHttpEntity<?> entity = new CseHttpEntity<>(null);
      4.   InvocationContext invocationContext = new InvocationContext();
      5.   invocationContext.addLocalContext(LoadbalanceHandler.SERVICECOMB_SERVER_ENDPOINT, parseEndpoint(endpoint));
      6.   entity.setContext(invocationContext);
      8.   Date date = new Date();
      9.   String dateValue = RestObjectMapperFactory.getRestObjectMapper().convertToString(date);
      10.   TestMgr.check(date.getTime(),
      11.       restTemplate
      12.           .exchange("cse://springmvc/dateTime/getDate?date={1}", HttpMethod.GET,
      13.               entity, Date.class, dateValue).getBody().getTime());
      14.  ｝