关于SegmentFault:Soul源码阅读04sofa插件初体验

63次阅读

共计 3789 个字符,预计需要花费 10 分钟才能阅读完成。

指标

  • 运行 examples 上面的 sofa-rpc 服务
  • 学习文档,联合 sofa 插件,发动 http 申请 soul 网关,体验 sofa 代理

soul 网关接入 sofa 利用

  • 参考官网文档:https://dromara.org/zh-cn/doc…

    • 引入相干依赖

      soul-bootstrap新增如下依赖:

      <dependency>
      <groupId>com.alipay.sofa</groupId>
      <artifactId>sofa-rpc-all</artifactId>
      <version>5.7.6</version>
      </dependency>
      <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-client</artifactId>
      <version>4.0.1</version>
      </dependency>
      <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-framework</artifactId>
      <version>4.0.1</version>
      </dependency>
      <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-recipes</artifactId>
      <version>4.0.1</version>
      </dependency>
      <dependency>
      <groupId>org.dromara</groupId>
      <artifactId>soul-spring-boot-starter-plugin-sofa</artifactId>
      <version>2.2.1</version>
      </dependency>

      soul-examples-sofa新增如下依赖:

      <dependency>
      <groupId>org.dromara</groupId>
      <artifactId>soul-spring-boot-starter-client-sofa</artifactId>
      <version>2.2.1</version>
      <exclusions>
      <exclusion>
      <artifactId>guava</artifactId>
      <groupId>com.google.guava</groupId>
      </exclusion>
      </exclusions>
      </dependency>
    • application.yml增加相干配置

      soul:
      sofa:
      adminUrl: http://localhost:9095
      contextPath: /sofa
      appName: sofa
      # adminUrl: 为你启动的 soul-admin 我的项目的 ip + 端口,留神要加 http://
      # contextPath: 为你的这个我的项目在 soul 网关的路由前缀,比方 /order,/product 等等,网关会依据你的这个前 缀来进行路由.
      # appName:你的利用名称,不配置的话,会默认取 sofa 配置中 application 中的名称
  • sofa 插件设置

    soul-admin 插件治理中,sofa 插件设置为开启

    sofa 插件中配置你的注册地址

  • 接口注册到网关

    • sofa 服务实现类的办法上加上 @SoulSofaClient 注解,示意该接口办法注册到网关
  • 先启动 zk,而后再启动TestSofaApplication,输入日志 init sofa client reference success,示意sofa 接口曾经公布到 soul 网关

sofa 用户申请以及参数阐明

sofa 参数传递形式:

  • 通过 http post 形式拜访网关,通过 body,json 类型传递
  • 单个 java bean 参数类型(默认)
  • 自定义实现多参数反对:

    • 在你搭建的网关我的项目中,新增一个类 A,实现 org.dromara.soul.plugin.api.sofa.SofaParamResolveService

      public interface SofaParamResolveService {
      /**
      * Build parameter pair.
      * this is Resolve http body to get sofa param.
      *
      * @param body http 中 body 传的 json 字符串
      * @param parameterTypes 匹配到的办法参数类型列表,如果有多个,则应用, 宰割
      * @return pair left 为参数类型,right 为参数值
      */
      Pair<String[], Object[]> buildParameter(String body, String parameterTypes);
      }
  • 通过 http post 形式拜访网关,通过 body,json 类型传递

应用 http post 形式拜访,后盾NullPointerException

打断点,调试

GenericService genericService = reference.refer();
Pair<String[], Object[]> pair;
if (null == body || "".equals(body) ||"{}".equals(body) ||"null".equals(body)) {pair = new ImmutablePair<>(new String[]{}, new Object[]{});
} else {
// body 不为空
pair = sofaParamResolveService.buildParameter(body, metaData.getParameterTypes());
}

body 不为空时,调用了 sofaParamResolveService.buildParameter(String body, String parameterTypes) 办法,但在官网介绍中,只有自定义实现多参数反对才须要实现 org.dromara.soul.plugin.api.sofa.SofaParamResolveService 类,不晓得这块是不是个 BUG。代码中搜了搜,发现只在 SofaProxyServiceTest 类中以动态外部类形式实现了`sofaParamResolveService

先实现下 `sofaParamResolveService 试下后果

public Pair<String[], Object[]> buildParameter(final String body, final String parameterTypes) {Map<String, Object> paramMap = GsonUtils.getInstance().toObjectMap(body);
String[] parameter = StringUtils.split(parameterTypes, ",");
if (parameter.length == 1 && !isBaseType(parameter[0])) {for (String key : paramMap.keySet()) {Object obj = paramMap.get(key);
if (obj instanceof JsonObject) {paramMap.put(key, GsonUtils.getInstance().convertToMap(obj.toString()));
} else if (obj instanceof JsonArray) {paramMap.put(key, GsonUtils.getInstance().fromList(obj.toString(), Object.class));
} else {paramMap.put(key, obj);
}
}
return new ImmutablePair<>(parameter, new Object[]{paramMap});
}
List<Object> list = new LinkedList<>();
for (String key : paramMap.keySet()) {Object obj = paramMap.get(key);
if (obj instanceof JsonObject) {list.add(GsonUtils.getInstance().convertToMap(obj.toString()));
} else if (obj instanceof JsonArray) {list.add(GsonUtils.getInstance().fromList(obj.toString(), Object.class));
} else {list.add(obj);
}
}
Object[] objects = list.toArray();
return new ImmutablePair<>(parameter, objects);
}
private boolean isBaseType(final String paramType) {return paramType.startsWith("java") || paramType.startsWith("[Ljava");
}

再次运行,胜利:

次要理解了一下 soul 网关接入 Sofa 利用,应用各种申请参数通过 http 申请 soul 网关,体验 sofa 代理。

正文完
 0