乐趣区

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

指标

  • 运行 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 代理。

退出移动版