Dubbo想要个网关怎么办?试试整合Spring Cloud Gateway

本文涉及的产品
AI 网关免费试用,400元 Serverless
简介: 在以Dubbo框架体系来构建的微服务架构下想要增加API网关,如果不想自研开发的情况下在目前的开源社区中几乎没有找到支持dubbo协议的主流网关,但是Spring Cloud体系下却有两个非常热门的开源API网关可以选择;本文主要介绍如何通过Nacos整合Spring Cloud Gateway与Dubbo服务。

dubbo.jpg

一、背景

在微服务架构中 API网关 非常重要,网关作为全局流量入口并不单单是一个反向路由,更多的是把各个边缘服务(Web层)的各种共性需求抽取出来放在一个公共的“服务”(网关)中实现,例如安全认证、权限控制、限流熔断、监控、跨域处理、聚合API文档等公共功能。

在以 Dubbo 框架体系来构建的微服务架构下想要增加API网关,如果不想自研开发的情况下在目前的开源社区中几乎没有找到支持dubbo协议的主流网关,但是 Spring Cloud 体系下却有两个非常热门的开源API网关可以选择;本文主要介绍如何通过 Nacos 整合 Spring Cloud GatewayDubbo 服务

 

二、传统 dubbo 架构

dubbo属于rpc调用,所以必须提供一个web层的服务作为http入口给客户端调用,并在上面提供安全认证等基础功能,而web层前面对接Nginx等反向代理用于统一入口和负载均衡。

web层一般是根据业务模块来切分的,用于聚合某个业务模块所依赖的各个service服务

传统dubbo架构.png

PS:我们能否把上图中的web层全部整合在一起成为一个API网关呢?(不建议这样做)

因为这样的web层并没有实现 泛化调用 必须引入所有dubbo服务的api依赖,会使得网关变得非常不稳定,任何服务的接口变更都需要修改网关中的api依赖!

 

三、整合 Srping Cloud Gateway 网关

下面就开始聊聊直接拿热门的 Srping Cloud Gateway 来作为dubbo架构体系的网关是否可行,首先该API网关是属于 Spring Cloud 体系下的组件之一,要整合dubbo的话需要解决以下问题:

  1. 打通注册中心:spring cloud gateway 需要通过注册中心发现下游服务,而 dubbo 也需要通过注册中心实现服务的注册与发现,如果两者的注册中心不能打通的话就会变成双注册中心架构就非常复杂了!
  2. 协议转换: gateway 使用http传输协议调用下游服务,而dubbo服务默认使用的是tcp传输协议

上面提到的第一个问题“打通注册中心”其实已经不是问题了,目前dubbo支持 ZookeeperNacos 两个注册中心,而 Spring Cloud 自从把 @EnableEurekaClient 改为 @EnableDiscoveryClient 之后已经基本上支持所有主流的注册中心了,本文将使用 Nacos 作为注册中心打通两者

 

3.1. 方式一

把传统dubbo架构中的 Nginx 替换为 Spring Cloud Gateway ,并把 安全认证 等共性功能前移至网关处实现
整合gateway架构01.png

由于web层服务本身提供的就是http接口,所以网关层无需作协议转换,但是由于 安全认证 前移至网关了需要通过网络隔离的手段防止被绕过网关直接请求后面的web层

 

3.2. 方式二

dubbo服务本身修改或添加 rest 传输协议的支持,这样网关就可以通过http传输协议与dubbo服务通信了

rest传输协议:基于标准的Java REST API——JAX-RS 2.0(Java API for RESTful Web Services的简写)实现的REST调用支持

整合gateway架构02.png

目前版本的dubbo已经支持dubbo、rest、rmi、hessian、http、webservice、thrift、redis等10种传输协议了,并且还支持同一个服务同时定义多种协议,例如配置 protocol = { "dubbo", "rest" } 则该服务同时支持 dubborest 两种传输协议

 

3.3. 总结

方式一 对比 方式二 多了一层web服务所以多了一次网络调用开销,但是优点是各自的职责明确单一,web层可以作为聚合层用于聚合多个service服务的结果经过融合加工一并返回给前端,所以这种架构下能大大减少服务的 循环依赖

 

四、代码实践

依赖环境

  • lombok
  • jdk 1.8
  • Nacos 1.3
  • Spring Boot 2.2.8.RELEASE
  • Spring Cloud Hoxton.SR5
  • Spring Cloud Alibaba 2.2.1.RELEASE

在根目录的 pom.xml 中定义全局的依赖版本

    <properties>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>8</java.version>

        <spring-boot-dependencies.version>2.2.8.RELEASE</spring-boot-dependencies.version>
        <spring-cloud-dependencies.version>Hoxton.SR5</spring-cloud-dependencies.version>
        <spring-cloud-alibaba-dependencies.version>2.2.1.RELEASE</spring-cloud-alibaba-dependencies.version>
        <jaxrs.version>3.12.1.Final</jaxrs.version>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot-dependencies.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud-dependencies.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>${spring-cloud-alibaba-dependencies.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

 

4.1. 创建dubbo-api工程

分别定义两个api接口

DubboService 使用dubbo协议的服务

public interface DubboService {
    String test(String param);
}

RestService 使用rest协议的服务

public interface RestService {
    String test(String param);
}

 

4.2. 创建web-dubbo工程

使用 方式一 整合对接网关,这里为了简化在同一个服务下只使用逻辑分层定义controller层与service层,并没有做服务拆分

4.2.1. 创建配置

定义 spring boot 配置

server:
  port: 8081

spring:
  application:
    name: zlt-web-dubbo
  main:
    allow-bean-definition-overriding: true
  cloud:
    nacos:
      server-addr: 192.168.28.130:8848
      username: nacos
      password: nacos

server.port:配置应用服务器暴露的端口

spring.cloud.nacos:配置 spring cloud 的注册中心相关参数,nacos 的配置需要改为自己环境所对应

定义 dubbo 配置

dubbo:
  scan:
    base-packages: org.zlt.service
  protocols:
    dubbo:
      name: dubbo
      port: -1
  registry:
    address: spring-cloud://localhost
  consumer:
    timeout: 5000
    check: false
    retries: 0
  cloud:
    subscribed-services:

dubbo.scan.base-packages:指定 Dubbo 服务实现类的扫描基准包

dubbo.protocols:服务暴露的协议配置,其中子属性 name 为协议名称,port 为协议端口( -1 表示自增端口,从 20880 开始)

dubbo.registry.address:Dubbo 服务注册中心配置,其中子属性 address 的值 "spring-cloud://localhost",说明挂载到 Spring Cloud 注册中心

 

4.2.2. 创建DubboService的实现类

通过 protocol = "dubbo" 指定使用 dubbo协议 定义服务

@Service(protocol = "dubbo")
public class DubboServiceImpl implements DubboService {
    @Override
    public String test(String param) {
        return "dubbo service: " + param;
    }
}

 

4.2.3. 创建Controller类

使用 Spring Boot@RestController 注解定义web服务

@RestController
public class WebController {
    @Autowired
    private DubboService dubboService;

    @GetMapping("/test/{p}")
    public String test(@PathVariable("p") String param) {
        return dubboService.test(param);
    }
}

 

4.3. 创建rest-dubbo工程

使用 方式二 整合对接网关,由于该服务是通过dubbo来创建rest服务,所以并不需要使用 Spring Boot 内置应用服务

4.3.1. 创建配置

定义 spring boot 配置

spring:
  application:
    name: zlt-rest-dubbo
  main:
    allow-bean-definition-overriding: true
  cloud:
    nacos:
      server-addr: 192.168.28.130:8848
      username: nacos
      password: nacos

因为不使用 Spring Boot 内置的应用服务所以这里并不需要指定 server.port

定义 dubbo 配置

dubbo:
  scan:
    base-packages: org.zlt.service
  protocols:
    dubbo:
      name: dubbo
      port: -1
    rest:
      name: rest
      port: 8080
      server: netty
  registry:
    address: spring-cloud://localhost
  consumer:
    timeout: 5000
    check: false
    retries: 0
  cloud:
    subscribed-services:

dubbo.protocols:配置两种协议,其中rest协议定义 8080 端口并使用 netty 作为应用服务器

 

4.3.2. 创建RestService的实现类

通过 protocol = "rest" 指定使用 rest协议 定义服务

@Service(protocol = "rest")
@Path("/")
public class RestServiceImpl implements RestService {
    @Override
    @Path("test/{p}")
    @GET
    public String test(@PathParam("p") String param) {
        return "rest service: " + param;
    }
}

 

4.4. 创建Spring Cloud Gateway工程

定义 spring boot 配置

server:
  port: 9900

spring:
  application:
    name: sc-gateway
  main:
    allow-bean-definition-overriding: true
  cloud:
    nacos:
      server-addr: 192.168.28.130:8848
      username: nacos
      password: nacos

server.port:定义网关端口为 9090

定义网关配置

spring:
  cloud:
    gateway:
      discovery:
        locator:
          lowerCaseServiceId: true
          enabled: true
      routes:
        - id: web
          uri: lb://zlt-web-dubbo
          predicates:
            - Path=/api-web/**
          filters:
            - StripPrefix=1
        - id: rest
          uri: lb://zlt-rest-dubbo
          predicates:
            - Path=/api-rest/**
          filters:
            - StripPrefix=1

分别定义两个路由策略:

  • 路径 /api-web/ 为请求 web-dubbo 工程
  • 路径 /api-rest/ 为请求 rest-dubbo 工程

 

4.5. 测试

分别启动:Nacos、sc-gateway、web-dubbo、rest-dubbo 工程,通过网关的以下两个接口分别测试两种整合方式

  1. http://127.0.0.1:9900/api-web/test/abc :请求 web-dubbo 工程测试整合方式一
  2. http://127.0.0.1:9900/api-rest/test/abc :请求 rest-dubbo 工程测试整合方式二

 

五、demo下载

ide需要安装 lombok 插件

https://github.com/zlt2000/dubboSpringCloud

目录
相关文章
|
4月前
|
存储 缓存 负载均衡
Gateway 网关坑我! 被这个404 问题折腾了一年?
小富分享了一个困扰团队一年多的 SpringCloud Gateway 路由 404 问题。通过日志追踪和源码分析,发现是网关在 Nacos 配置更新后未能正确清理旧的路由权重缓存,导致负载均衡时仍使用已删除的路由数据。最终通过监听路由刷新事件并手动更新缓存,成功解决了问题。
930 125
Gateway 网关坑我! 被这个404 问题折腾了一年?
|
4月前
|
负载均衡 监控 Java
Spring Cloud Gateway 全解析:路由配置、断言规则与过滤器实战指南
本文详细介绍了 Spring Cloud Gateway 的核心功能与实践配置。首先讲解了网关模块的创建流程,包括依赖引入(gateway、nacos 服务发现、负载均衡)、端口与服务发现配置,以及路由规则的设置(需注意路径前缀重复与优先级 order)。接着深入解析路由断言,涵盖 After、Before、Path 等 12 种内置断言的参数、作用及配置示例,并说明了自定义断言的实现方法。随后重点阐述过滤器机制,区分路由过滤器(如 AddRequestHeader、RewritePath、RequestRateLimiter 等)与全局过滤器的作用范围与配置方式,提
Spring Cloud Gateway 全解析:路由配置、断言规则与过滤器实战指南
|
3月前
|
缓存 JSON NoSQL
别再手写过滤器!SpringCloud Gateway 内置30 个,少写 80% 重复代码
小富分享Spring Cloud Gateway内置30+过滤器,涵盖请求、响应、路径、安全等场景,无需重复造轮子。通过配置实现Header处理、限流、重试、熔断等功能,提升网关开发效率,避免代码冗余。
487 1
|
3月前
|
机器学习/深度学习 Kubernetes API
【Azure APIM】自建网关(self-host gateway)收集请求的Header和Body内容到日志中的办法
在Azure API Management中,通过配置trace策略可完整记录API请求的Header和Body信息。在Inbound和Outbound策略中分别使用context.Request/Response.Headers和Body.As&lt;string&gt;方法捕获数据,并写入Trace日志,便于排查与审计。
150 7
|
5月前
|
安全 虚拟化
Omnissa Secure Email Gateway 2.33 - 电子邮件网关
Omnissa Secure Email Gateway 2.33 - 电子邮件网关
121 0
|
6月前
|
前端开发 Java API
Spring Cloud Gateway Server Web MVC报错“Unsupported transfer encoding: chunked”解决
本文解析了Spring Cloud Gateway中出现“Unsupported transfer encoding: chunked”错误的原因,指出该问题源于Feign依赖的HTTP客户端与服务端的`chunked`传输编码不兼容,并提供了具体的解决方案。通过规范Feign客户端接口的返回类型,可有效避免该异常,提升系统兼容性与稳定性。
472 0
|
7月前
|
缓存 监控 Java
说一说 SpringCloud Gateway 堆外内存溢出排查
我是小假 期待与你的下一次相遇 ~
1043 5
|
7月前
|
Java API Nacos
|
JSON Java API
利用Spring Cloud Gateway Predicate优化微服务路由策略
Spring Cloud Gateway 的路由配置中,`predicates`​(断言)用于定义哪些请求应该匹配特定的路由规则。 断言是Gateway在进行路由时,根据具体的请求信息如请求路径、请求方法、请求参数等进行匹配的规则。当一个请求的信息符合断言设置的条件时,Gateway就会将该请求路由到对应的服务上。
1227 69
利用Spring Cloud Gateway Predicate优化微服务路由策略
|
11月前
|
前端开发 Java Nacos
🛡️Spring Boot 3 整合 Spring Cloud Gateway 工程实践
本文介绍了如何使用Spring Cloud Alibaba 2023.0.0.0技术栈构建微服务网关,以应对微服务架构中流量治理与安全管控的复杂性。通过一个包含鉴权服务、文件服务和主服务的项目,详细讲解了网关的整合与功能开发。首先,通过统一路由配置,将所有请求集中到网关进行管理;其次,实现了限流防刷功能,防止恶意刷接口;最后,添加了登录鉴权机制,确保用户身份验证。整个过程结合Nacos注册中心,确保服务注册与配置管理的高效性。通过这些实践,帮助开发者更好地理解和应用微服务网关。
2034 0
🛡️Spring Boot 3 整合 Spring Cloud Gateway 工程实践