Dubbo想要个网关怎么办？试试整合Spring Cloud Gateway-低调大师

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

2020-06-28 683

一、背景

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

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

二、传统 dubbo 架构

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

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

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

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

三、整合 Spring Cloud Gateway 网关

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

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

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

3.1. 方式一

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

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

3.2. 方式二

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

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

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

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 工程，通过网关的以下两个接口分别测试两种整合方式

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

五、demo下载

ide需要安装 lombok 插件

https://github.com/zlt2000/dubboSpringCloud

扫码关注有惊喜！

微信关注我们

原文链接：https://my.oschina.net/zlt2000/blog/4327240

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Ignite在集群内存空间不足时的处理方式

如果内存空间即将用完，Ignite可以水平扩展以存储应用和服务生成的更多数据，这是Ignite的基础功能之一，因此增加资源是最简单的处理方法。但是实际上多数情况都无法立即扩展集群，通常都是为应用配置了固定内存容量的Ignite集群，增加更多资源可能是一项艰巨而持续的工作。下面会介绍几种功能，这样即使在内存成为稀缺资源的情况下也可以保持集群的稳定运行。配置Ignite退出策略以避免内存不足问题数据退出是防止内存过度使用的经典机制，它通过监控正在使用的内存空间并在内存占用超过阈值时删除多余的数据，从而避免内存不足的问题。 Ignite支持多种退出策略，这些策略最终会在达到最大数据区大小时从内存中清除最近最少使用的页面，下面的代码片段显示了如何为自定义数据区启用DataPageEvictionMode.RANDOM_2_LRU策略： DataStorageConfiguration storageCfg = new DataStorageConfiguration(); DataRegionConfiguration regionCfg = new DataRegionConfigur...

2020-06-27

798

这一篇文章来讲解一下如何做leetcode回溯算法题目，这一段时间我把leetcode上面的回溯算法的题目都刷了个遍，发现了其中一些规律，所以，就想写一篇文章来总结一下，怕以后忘记。刷完回溯算法的题目，我发现其实可以总结为三大类：子集问题、组合问题、排列问题，那这三大类都是什么意思呢，我分别举一个例子来说明。子集问题，比如说，数组[1,2,3]，那么对应的子集问题就是，这个数组的子集有：[],[1],[2],[3],[1,3],[2,3],[1,2],[1,2,3]，这就是这个数组的子集，这一类问题在leetcode上面很多个，而且有些题目数组中的元素是可以重复的，然后来求子集问题。组合问题，比如说，数组[1,2,3]，组合出target为3的可能的选择，那么就有：[1,2],[3]，这就是leetcode中的组合问题。排列问题，排列问题就比较简单了，比如，我们常见的全排列问题，leetcode也有这一类问题。这篇文章，我们就来讲讲，怎么用回溯的算法去解决这些问题。 1 一步一步讲解回溯算法框架最开始，我还是想通过一个简单的例子，一步一步的带大家看一下回溯算法的题目应该是怎...

2020-06-28

634

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。