Dubbo接入soul网关

编辑
更新时间: 2021-06-23

说明

  • 此篇文章是dubbo用户使用dubbo插件支持,以及自己的dubbo服务接入soul网关的教程。
  • 支持 alibaba dubbo(< 2.7.x) 以及 apache dubbo (>=2.7.x)。
  • 接入前,请正确的启动 soul-admin,以及搭建环境 Ok。

引入网关对dubbo支持的插件

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

    • alibaba dubbo 用户, dubbo版本换成你的,注册中心的jar包换成你的,以下是参考。
    <!--soul alibaba dubbo plugin start-->
    <dependency>
      <groupId>org.dromara</groupId>
      <artifactId>soul-spring-boot-starter-plugin-alibaba-dubbo</artifactId>
       <version>${last.version}</version>
    </dependency>
    <!-- soul  alibaba dubbo plugin end-->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.5</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>
    
    • apache dubbo 用户,dubbo版本换成你的,使用什么注册中心换成你的,以下是参考,使用什么注册中心,就引入啥。
    <!--soul apache dubbo plugin start-->
    <dependency>
       <groupId>org.dromara</groupId>
       <artifactId>soul-spring-boot-starter-plugin-apache-dubbo</artifactId>
       <version>${last.version}</version>
    </dependency>
    <!--soul apache dubbo plugin end-->
        
    <dependency>
       <groupId>org.apache.dubbo</groupId>
       <artifactId>dubbo</artifactId>
       <version>2.7.5</version>
    </dependency>
    <!-- Dubbo Nacos registry dependency start -->
    <dependency>
       <groupId>org.apache.dubbo</groupId>
       <artifactId>dubbo-registry-nacos</artifactId>
       <version>2.7.5</version>
    </dependency>
    <dependency>
       <groupId>com.alibaba.nacos</groupId>
       <artifactId>nacos-client</artifactId>
       <version>1.1.4</version>
    </dependency>
    <!-- Dubbo Nacos registry dependency  end-->
        
    <!-- Dubbo zookeeper registry dependency start-->
    <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>
    <!-- Dubbo zookeeper registry dependency end -->
    
  • 重启网关服务。

dubbo服务接入网关,可以参考:soul-examples-dubbo

  • alibaba dubbo 用户

    • springboot

      • 引入以下依赖
      <dependency>
           <groupId>org.dromara</groupId>
           <artifactId>soul-spring-boot-starter-client-alibaba-dubbo</artifactId>
           <version>${last.version}</version>
      </dependency>
      
      • 注册中心详细接入配置请参考:注册中心接入

      • spring

      • 引入以下依赖 :

      <dependency>
         <groupId>org.dromara</groupId>
         <artifactId>soul-client-alibaba-dubbo</artifactId>
         <version>${last.version}</version>
      </dependency>
      
      • 在你的 bean定义的xml文件中新增如下 :
      <bean id ="alibabaDubboServiceBeanPostProcessor" class ="org.dromara.soul.client.alibaba.dubbo.AlibabaDubboServiceBeanPostProcessor">
         <constructor-arg  ref="soulRegisterCenterConfig"/>
      </bean>
              
      <bean id="soulRegisterCenterConfig" class="org.dromara.soul.register.common.config.SoulRegisterCenterConfig">
             <property name="registerType" value="http"/>
             <property name="serverList" value="http://localhost:9095"/>
             <property name="props">
                <map>
                  <entry key="contextPath" value="/你的contextPath"/>
                  <entry key="appName" value="你的名字"/>
                  <entry key="ifFull" value="false"/>
                </map>
              </property>
        </bean>
      
  • apache dubbo 用户

    • springboot

      • 引入以下依赖
      <dependency>
           <groupId>org.dromara</groupId>
           <artifactId>soul-spring-boot-starter-client-apache-dubbo</artifactId>
           <version>${last.version}</version>
      </dependency>
      
      <dependency>
         <groupId>org.dromara</groupId>
         <artifactId>soul-client-apache-dubbo</artifactId>
         <version>${last.version}</version>
      </dependency>
      
      • 在你的 bean定义的xml文件中新增如下 :
        <bean id ="apacheDubboServiceBeanPostProcessor" class ="org.dromara.soul.client.apache.dubbo.ApacheDubboServiceBeanPostProcessor">
             <constructor-arg  ref="soulRegisterCenterConfig"/>
        </bean>
              
        <bean id="soulRegisterCenterConfig" class="org.dromara.soul.register.common.config.SoulRegisterCenterConfig">
             <property name="registerType" value="http"/>
             <property name="serverList" value="http://localhost:9095"/>
             <property name="props">
                <map>
                  <entry key="contextPath" value="/你的contextPath"/>
                  <entry key="appName" value="你的名字"/>
                  <entry key="ifFull" value="false"/>
                </map>
              </property>
        </bean>
      

dubbo 插件设置

  • 首先在 soul-admin 插件管理中,把dubbo 插件设置为开启。

  • 其次在 dubbo 插件中配置你的注册地址,或者其他注册中心的地址。

{"register":"zookeeper://localhost:2181"}   or {"register":"nacos://localhost:8848"}

接口注册到网关

  • 你dubbo服务实现类的,方法上加上 @SoulDubboClient 注解,表示该接口方法注册到网关。

  • 启动你的提供者,输出日志 dubbo client register success 大功告成,你的dubbo接口已经发布到 soul网关.如果还有不懂的,可以参考 soul-test-dubbo项目。

dubbo用户请求以及参数说明

  • 说白了,就是通过http的方式来请求你的dubbo服务

  • soul网关需要有一个路由前缀,这个路由前缀就是你接入项目进行配置 contextPath

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

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

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

  • 参数传递:

    • 通过 http post 方式访问网关,通过body,json类型传递。

    • 更多参数类型传递,可以参考 soul-examples-dubbo 中的接口定义,以及参数传递方式。

  • 单个java bean参数类型 (默认)

  • 多参数类型支持,在网关的yaml 配置中新增如下配置:

soul :
    dubbo :
      parameter: multi
  • 自定义实现多参数支持:

    • 在你搭建的网关项目中,新增一个类 A,实现 org.dromara.soul.web.dubbo.DubboParamResolveService
    public interface DubboParamResolveService {
        
       /**
        * Build parameter pair.
        * this is Resolve http body to get dubbo param.
        *
        * @param body           the body
        * @param parameterTypes the parameter types
        * @return the pair
        */
       Pair<String[], Object[]> buildParameter(String body, String parameterTypes);
    }
    
    • body为http中body传的json字符串。

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

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

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

    @Bean
    public DubboParamResolveService A() {
          return new A();
    }
    

服务治理

  • 标签路由
    • 请求时在header中添加Dubbo_Tag_Route,并设置对应的值,之后当前请求就会路由到指定tag的provider,只对当前请求有效;
  • 服务提供者直连
    • 设置@SoulDubboClient注解中的url属性;
    • 修改Admin控制台修改元数据内的url属性;
    • 对所有请求有效;
  • 参数验证和自定义异常

    • 指定validation="soulValidation";
    • 在接口中抛出SoulException时,异常信息会返回,需要注意的是显式抛出SoulException
    @Service(validation = "soulValidation")
    public class TestServiceImpl implements TestService {
        
        @Override
        @SoulDubboClient(path = "/test", desc = "test method")
        public String test(@Valid HelloServiceRequest name) throws SoulException {
            if (true){
                throw new SoulException("Param binding error.");
            }
            return "Hello " + name.getName();
        }
    }
    
    • 请求参数
    public class HelloServiceRequest implements Serializable {
        
        private static final long serialVersionUID = -5968745817846710197L;
        
        @NotEmpty(message = "name cannot be empty")
        private String name;
        
        @NotNull(message = "age cannot be null")
        private Integer age;
        
        public String getName() {
            return name;
        }
        
        public void setName(String name) {
            this.name = name;
        }
        
        public Integer getAge() {
            return age;
        }
        
        public void setAge(Integer age) {
            this.age = age;
        }
    }
    
    • 发送请求
    {
        "name": ""
    }
    
    • 返回
    {
        "code": 500,
        "message": "Internal Server Error",
        "data": "name cannot be empty,age cannot be null"
    }
    
    • 当按照要求传递请求参数时,会返回自定义异常的信息
    {
        "code": 500,
        "message": "Internal Server Error",
        "data": "Param binding error."
    }
    

    大白话讲解如果通过http –> 网关–> dubbo provider

    • 说白了,就是把http请求,转成dubbo协议,内部使用dubbo泛化来进行调用。

    • 首先你要回想下,你的dubbo服务在接入网关的时候,是不是加了个 @SoulDubboClient 注解,里面是不是有个path字段来指定你请求的路径?

    • 你是不是还在yml中配置了一个 contextPath?

    • 如果您还记得,那我们就开始。

    • 假如你有一个这样的方法, contextPath 配置的是 /dubbo

    @Override
    @SoulDubboClient(path = "/insert", desc = "插入一条数据")
    public DubboTest insert(final DubboTest dubboTest) {
    return dubboTest;
    }
    
  • 那么我们请求的路径为:http://localhost:9195/dubbo/insert,再说一下,localhost:9195是网关的域名,如果你更改了,这里也要改。

  • 那么请求参数呢? DubboTest 是一个javabean对象,有2个字段,id与name ,那么我们通过body中传递这个对象的json数据就好。

    {"id":"1234","name":"XIAO5y"}
    
  • 如果你的接口中,没有参数,那么body传值为:

    {}
    
  • 如果你的接口有很多个参数?往上看一点,有介绍。