在微服务架构中 API网关 非常重要,网关作为全局流量入口并不单单是一个反向路由,更多的是把各个边缘服务(Web层)的各种共性需求抽取出来放在一个公共的“服务”(网关)中实现,例如安全认证、权限控制、限流熔断、监控、跨域处理、聚合API文档等公共功能。
在以 Dubbo 框架体系来构建的微服务架构下想要增加API网关,如果不想自研开发的情况下在目前的开源社区中几乎没有找到支持dubbo协议的主流网关,但是 Spring Cloud 体系下却有两个非常热门的开源API网关可以选择;本文主要介绍如何通过 Nacos
整合 Spring Cloud Gateway
与 Dubbo 服务
。
dubbo属于rpc调用,所以必须提供一个web层的服务作为http入口给客户端调用,并在上面提供安全认证等基础功能,而web层前面对接Nginx等反向代理用于统一入口和负载均衡。
web层一般是根据业务模块来切分的,用于聚合某个业务模块所依赖的各个service服务
PS:我们能否把上图中的web层全部整合在一起成为一个API网关呢?(不建议这样做)
因为这样的web层并没有实现 泛化调用 必须引入所有dubbo服务的api依赖,会使得网关变得非常不稳定,任何服务的接口变更都需要修改网关中的api依赖!
下面就开始聊聊直接拿热门的 Srping Cloud Gateway
来作为dubbo架构体系的网关是否可行,首先该API网关是属于 Spring Cloud 体系下的组件之一,要整合dubbo的话需要解决以下问题:
上面提到的第一个问题“打通注册中心”其实已经不是问题了,目前dubbo支持 Zookeeper
与 Nacos
两个注册中心,而 Spring Cloud 自从把 @EnableEurekaClient
改为 @EnableDiscoveryClient
之后已经基本上支持所有主流的注册中心了,本文将使用 Nacos
作为注册中心打通两者
把传统dubbo架构中的 Nginx
替换为 Spring Cloud Gateway
,并把 安全认证
等共性功能前移至网关处实现
由于web层服务本身提供的就是http接口,所以网关层无需作协议转换,但是由于 安全认证
前移至网关了需要通过网络隔离的手段防止被绕过网关直接请求后面的web层
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
两种传输协议
方式一对比 方式二 多了一层web服务所以多了一次网络调用开销,但是优点是各自的职责明确单一,web层可以作为聚合层用于聚合多个service服务的结果经过融合加工一并返回给前端,所以这种架构下能大大减少服务的 循环依赖
在根目录的 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>
分别定义两个api接口
DubboService 使用dubbo协议的服务
public interface DubboService { String test(String param); }
RestService 使用rest协议的服务
public interface RestService { String test(String param); }
使用 方式一 整合对接网关,这里为了简化在同一个服务下只使用逻辑分层定义controller层与service层,并没有做服务拆分
定义 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 注册中心
通过 protocol = "dubbo"
指定使用 dubbo协议
定义服务
@Service(protocol = "dubbo") public class DubboServiceImpl implements DubboService { @Override public String test(String param) { return "dubbo service: " + param; } }
使用 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); } }
使用 方式二 整合对接网关,由于该服务是通过dubbo来创建rest服务,所以并不需要使用 Spring Boot 内置应用服务
定义 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 作为应用服务器
通过 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; } }
定义 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
工程 分别启动:Nacos、sc-gateway、web-dubbo、rest-dubbo 工程,通过网关的以下两个接口分别测试两种整合方式
web-dubbo
工程测试整合方式一 rest-dubbo
工程测试整合方式二 ide需要安装 lombok
插件
https://github.com/zlt2000/dubboSpringCloud
扫码关注有惊喜!