Skip to main content
Version: 2.6.1

Sofa服务接入

此篇文章是介绍 sofa 服务接入到 Apache ShenYu 网关,Apache ShenYu 网关使用 sofa 插件来接入sofa服务。

接入前,请正确启动 shenyu-admin,并开启sofa插件,在网关端和sofa服务端引入相关依赖。可以参考前面的 Sofa快速开始

关于插件使用可请参考:Sofa插件

应用客户端接入的相关配置请参考:客户端接入配置

数据同步的相关配置请参考:数据同步配置

在网关中引入 sofa 插件#

当前版本,默认已经引入此依赖

  1. 在网关的 pom.xml 文件中增加如下依赖:

           <dependency>           <groupId>com.alipay.sofa</groupId>           <artifactId>sofa-rpc-all</artifactId>           <version>5.7.6</version>           <exclusions>               <exclusion>                   <groupId>net.jcip</groupId>                   <artifactId>jcip-annotations</artifactId>               </exclusion>           </exclusions>       </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.apache.shenyu</groupId>           <artifactId>shenyu-spring-boot-starter-plugin-sofa</artifactId>           <version>${project.version}</version>       </dependency>
  2. 重启网关服务。

sofa服务接入网关#

可以参考示例:shenyu-examples-sofa

  1. springboot构建,引入以下依赖:

            <dependency>            <groupId>com.alipay.sofa</groupId>            <artifactId>rpc-sofa-boot-starter</artifactId>            <version>${rpc-sofa-boot-starter.version}</version>        </dependency>                <dependency>            <groupId>org.apache.shenyu</groupId>            <artifactId>shenyu-spring-boot-starter-client-sofa</artifactId>            <version>${shenyu.version}</version>        </dependency>
  2. 在 application.yml 中配置

com:  alipay:    sofa:      rpc:        registry-address: zookeeper://127.0.0.1:2181 # consul # nacos        bolt-port: 8888shenyu:  register:    registerType: http #zookeeper #etcd #nacos #consul    serverLists: http://localhost:9095 #localhost:2181 #http://localhost:2379 #localhost:8848    props:      username: admin      password: 123456  client:    sofa:      props:        contextPath: /sofa        ipAndPort: sofa        appName: sofa        port: 8888
  1. 在 resources 目录下xml 文件中配置 sofa 服务暴露的服务接口
<beans xmlns="http://www.springframework.org/schema/beans"       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"       xmlns:sofa="http://sofastack.io/schema/sofaboot"       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd            http://sofastack.io/schema/sofaboot https://sofastack.io/schema/sofaboot.xsd"       default-autowire="byName">        <!-- 示例 sofa 接口 -->    <sofa:service ref="sofaSingleParamService" interface="org.apache.shenyu.examples.sofa.api.service.SofaSingleParamService">        <sofa:binding.bolt/>    </sofa:service>        <!-- 示例 sofa 接口 -->    <sofa:service ref="sofaMultiParamService" interface="org.apache.shenyu.examples.sofa.api.service.SofaMultiParamService">        <sofa:binding.bolt/>    </sofa:service></beans>
  1. 在接口上增加@ShenyuSofaClient注解
@ShenyuSofaClient("/demo")@Servicepublic class SofaClientMultiParamServiceImpl implements SofaClientMultiParamService {        @Override    @ShenyuSofaClient("/findByIdsAndName")    public SofaSimpleTypeBean findByIdsAndName(final List<Integer> ids, final String name) {        return new SofaSimpleTypeBean(ids.toString(), "hello world shenyu sofa param findByIdsAndName :" + name);    }}
  1. 启动sofa服务,成功注册后
  • 进入后台管理系统的 插件列表 -> Proxy -> Sofa,会看到自动注册的选择器、规则信息。
  • 进入后台管理系统的 基础配置-> 元数据管理,搜索appName(通过)可以看到元数据,每一个sofa接口方法,都会对应一条元数据。

sofa用户请求及参数说明#

  • 可以通过 http 的方式来请求网关,从而请求到你的 sofa 服务。
    • Apache ShenYu 网关需要有一个路由前缀,这个路由前缀就是接入网关配置的 contextPath

比如你有一个 order 服务 它有一个接口,它的注册路径 /order/test/save

现在就是通过 post 方式请求网关:http://localhost:9195/order/test/save

其中 localhost:9195 为网关的 ip 端口,默认端口是 9195/order 是你sofa接入网关配置的 contextPath

  • 参数传递:

    • 通过 http协议, post 方式访问网关,通过在http body中传入json类型参数。
    • 更多参数类型传递,可以参考 shenyu-examples-sofa 中的接口定义,以及参数传递方式。
  • 单个java bean参数类型 (默认)

  • 自定义实现多参数支持:

    • 在你搭建的网关项目中,新增一个类 MySofaParamResolveService,实现 org.apache.shenyu.plugin.api.sofa.SofaParamResolveService接口。
    public interface SofaParamResolveService {
      /**   * Build parameter pair.   * this is Resolve http body to get sofa param.   *   * @param body           the body   * @param parameterTypes the parameter types   * @return the pair   */  Pair<String[], Object[]> buildParameter(String body, String parameterTypes);}
  • bodyhttpbody传的json字符串。

  • parameterTypes: 匹配到的方法参数类型列表,如果有多个,则使用,分割。

  • Pair中,left为参数类型,right为参数值,这是sofa泛化调用的标准。

  • 把你的类注册成Springbean,覆盖默认的实现。

    @Beanpublic SofaParamResolveService mySofaParamResolveService() {  return new MySofaParamResolveService();}