Dubbo想要个网关怎么办?试试整合Spring Cloud Gateway
一、背景
在微服务架构中 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
扫码关注有惊喜!
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
Ignite在集群内存空间不足时的处理方式
如果内存空间即将用完,Ignite可以水平扩展以存储应用和服务生成的更多数据,这是Ignite的基础功能之一,因此增加资源是最简单的处理方法。但是实际上多数情况都无法立即扩展集群,通常都是为应用配置了固定内存容量的Ignite集群,增加更多资源可能是一项艰巨而持续的工作。 下面会介绍几种功能,这样即使在内存成为稀缺资源的情况下也可以保持集群的稳定运行。 配置Ignite退出策略以避免内存不足问题 数据退出是防止内存过度使用的经典机制,它通过监控正在使用的内存空间并在内存占用超过阈值时删除多余的数据,从而避免内存不足的问题。 Ignite支持多种退出策略,这些策略最终会在达到最大数据区大小时从内存中清除最近最少使用的页面,下面的代码片段显示了如何为自定义数据区启用DataPageEvictionMode.RANDOM_2_LRU策略: DataStorageConfiguration storageCfg = new DataStorageConfiguration(); DataRegionConfiguration regionCfg = new DataRegionConfigur...
- 下一篇
回溯算法的题目,这样做,秒杀!!
这一篇文章来讲解一下如何做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 一步一步讲解回溯算法框架 最开始,我还是想通过一个简单的例子,一步一步的带大家看一下回溯算法的题目应该是怎...
相关文章
文章评论
共有0条评论来说两句吧...