关于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 代理。