SpringCloud + Gateway(网关) + Nacos(注册中心+配置中心)+ Dubbo(内部服务调用)

简介: SpringCloud + Gateway(网关) + Nacos(注册中心+配置中心)+ Dubbo(内部服务调用)

微服务

Dubbo

Apache Dubbo是一款微服务开发框架,它提供了 RPC通信 与 微服务治理 两大关键能力

Dubbo 与 SpringCloud 的通信 Openfeign的区别

1、协议支持方面

  • Feign更加优雅简单。Feign是通过REST API实现的远程调用,基于Http传输协议,服务提供者需要对外暴露Http接口供消费者调用,服务粒度是http接口级的。通过短连接的方式进行通信,不适合高并发的访问
  • Dubbo方式更灵活。Dubbo是通过RPC调用实现的远程调用,支持多传输协议(Dubbo、Rmi、http、redis等等),可以根据业务场景选择最佳的方式,非常灵活。默认的Dubbo协议:利用Netty,TCP传输,单一、异步、长连接,适合数据量小、高并发和服务提供者远远少于消费者的场景。Dubbo通过TCP长连接的方式进行通信,服务粒度是方法级的。

2、通信性能方面

  • Feign基于Http传输协议,底层实现是rest。在高并发场景下性能不够理想。
  • Dubbo框架的通信协议采用RPC协议,属于传输层协议,提升了交互的性能,保持了长连接,高性能。

Nacos

Nacos致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。

Nacos 与 Eureka 的选择

  • Eureka 是 springcloud最早的注册中心,目前已经进入停更维护了
  • Nacos 除了服务的注册发现之外,还支持动态配置服务。动态配置消除了配置变更时重新部署应用和服务的需要,让配置管理变得更加高效和敏捷

搭建

一、创建父工程

1、新建父工程项目gateway_nacos_dubbo_springcloud

2、在build.gradle中配置项目依赖版本控制

plugins {
id'java'id'org.springframework.boot'version'2.7.0'//springboot依赖版本id'io.spring.dependency-management'version'1.0.11.RELEASE'//spring的依赖管理插件版本}
//版本控制ext {
set('springCloudVersion', "2021.0.3")                     //SpringCloud依赖版本set('springCloudAlibabaVersion', "2021.0.1.0")           //SpringCloudAlibaba依赖版本set('springBootVersion', "2.7.0")
}
//全部模块通用配置allprojects{
// 项目的默认名称和版本group='com.threesides'version='1.0.0-SNAPSHOT'// 指定JDK版本sourceCompatibility='11'// 指定仓库地址repositories {
// aliyun镜像maven { url'https://maven.aliyun.com/repository/public' }
maven { url'https://maven.aliyun.com/repository/google' }
maven { url'https://maven.aliyun.com/repository/gradle-plugin' }
maven { url'https://maven.aliyun.com/repository/spring' }
maven { url'https://maven.aliyun.com/repository/grails-core' }
maven { url'https://maven.aliyun.com/repository/apache-snapshots' }
//        本地仓库mavenLocal()
//   中央️仓库mavenCentral()
    }
}
// 子模块配置subprojects {
// 使用插件applyplugin: 'java'applyplugin: 'org.springframework.boot'applyplugin: 'io.spring.dependency-management'//子模块通用依赖dependencies {
testImplementation"org.springframework.boot:spring-boot-starter-test:${springBootVersion}"testRuntimeOnly"org.junit.jupiter:junit-jupiter-engine:${springBootVersion}"    }
//子模块依赖管理dependencyManagement {
dependencies {
dependency"org.springframework.boot:spring-boot-starter:${springBootVersion}"        }
imports {
mavenBom"org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"mavenBom"com.alibaba.cloud:spring-cloud-alibaba-dependencies:${springCloudAlibabaVersion}"        }
    }
}

二、创建网关 gateway

1、新建子工程项目demo-gateway

2、在build.gradle中引入启动器以及依赖

group'com.threesides'version'1.0.0-SNAPSHOT'jar.enabled=truebootJar.enabled=truedependencies {
testImplementation'org.springframework.boot:spring-boot-starter-test'//测试环境testImplementation'org.junit.jupiter:junit-jupiter-api:5.7.0'testRuntimeOnly'org.junit.jupiter:junit-jupiter-engine:5.7.0'implementationgroup: 'com.alibaba.cloud', name: 'spring-cloud-starter-alibaba-nacos-discovery'//注册中心,这里使用的是alibaba-nacos,其他注册中心也可implementationgroup: 'com.alibaba.cloud', name: 'spring-cloud-starter-alibaba-nacos-config'//配置中心,这里使用的是alibaba-nacosimplementation'org.springframework.cloud:spring-cloud-starter-gateway'//网关 gateway 项目不能同时依赖spring-boot-starter-webimplementation'org.springframework.cloud:spring-cloud-loadbalancer'// 负载均衡 SpringCloud 版本在 2021.0.x以上必须引依赖implementation'org.springframework.cloud:spring-cloud-starter-bootstrap'}
test {
useJUnitPlatform()
}

3、启动类

@SpringBootApplication@EnableDiscoveryClientpublicclassGatewayApplication {
publicstaticvoidmain(String[] args) {
SpringApplication.run(GatewayApplication.class, args);
    }
}

4、配置文件 bootstrap.yaml

server:  port: 1101spring:  application:    name: demo-gateway
  cloud:    nacos:      discovery:        server-addr: 127.0.0.1:8848 

三、创建接口

1、新建子工程项目demo-interface

2、创建接口

publicinterfaceDemoInterface {
publicStringdemo(Stringmessage);
}

四、创建提供者

1、新建子工程项目demo-provider

2、在build.gradle中引入启动器以及依赖

group'com.threesides'version'1.0.0-SNAPSHOT'archivesBaseName="demo-provider"jar.enabled=truebootJar.enabled=truedependencies {
// 引入本地的  xxxx模块implementationproject(':demo-interface')
// 引入 spring-cloud 依赖// 注册中心,这里使用的是alibaba-nacos,其他注册中心也可。implementationgroup: 'com.alibaba.cloud', name: 'spring-cloud-starter-alibaba-nacos-discovery'implementationgroup: 'org.springframework.boot', name: 'spring-boot-starter-web'//dubboimplementation'org.apache.dubbo:dubbo-spring-boot-starter:3.0.8'implementation'com.alibaba.nacos:nacos-client:2.1.0'// 由于我使用的客户端是2.1.0 //由于报错  java.lang.ClassNotFoundException: com.google.common.collect.Maps//引入guavaimplementation'com.google.guava:guava:31.1-jre'testImplementation'org.junit.jupiter:junit-jupiter-api:5.7.0'testRuntimeOnly'org.junit.jupiter:junit-jupiter-engine:5.7.0'}
test {
useJUnitPlatform()
}

3、配置文件 application.yaml

server:  port: 8010#  dubbo的配置dubbo:  application:    name: demo-provider
  registry:    address: nacos://127.0.0.1:8848

4、启动类

importorg.apache.dubbo.config.spring.context.annotation.EnableDubbo;
@EnableDubbo@SpringBootApplicationpublicclassProviderApplication {
publicstaticvoidmain(String[] args) {
SpringApplication.run(ProviderApplication.class, args);
    }
}

5、提供者service 需要实现接口

importorg.apache.dubbo.config.annotation.DubboService;
@DubboServicepublicclassDemoProviderImplimplementsDemoInterface {
@OverridepublicStringdemo(Stringmessage) {
System.out.println(message);
returnmessage+"成功了";
    }
}

五、创建消费者

1、新建子工程项目demo-consumer

2、在build.gradle中引入启动器以及依赖

group'com.threesides'version'1.0.0-SNAPSHOT'archivesBaseName="demo-consumer"jar.enabled=truebootJar.enabled=truedependencies {
// 引入本地的  xxxx模块implementationproject(':demo-interface')
// 引入 spring-cloud 依赖// 注册中心,这里使用的是alibaba-nacos,其他注册中心也可。implementationgroup: 'com.alibaba.cloud', name: 'spring-cloud-starter-alibaba-nacos-discovery'implementationgroup: 'org.springframework.boot', name: 'spring-boot-starter-web'//dubboimplementation'org.apache.dubbo:dubbo-spring-boot-starter:3.0.8'implementation'com.alibaba.nacos:nacos-client:2.1.0'// 由于我使用的客户端是2.1.0 //由于报错  java.lang.ClassNotFoundException: com.google.common.collect.Maps//引入guavaimplementation'com.google.guava:guava:31.1-jre'testImplementation'org.junit.jupiter:junit-jupiter-api:5.7.0'testRuntimeOnly'org.junit.jupiter:junit-jupiter-engine:5.7.0'}
test {
useJUnitPlatform()
}

3、配置文件application.yaml

server:  port: 8011spring:  application:    name: demo-consumer
  cloud:    nacos:      discovery:        server-addr: http://127.0.0.1:8848   # 注册中心  http://ip:端口号dubbo:  registry:    address: nacos://127.0.0.1:8848    register: false

4、启动类

importorg.apache.dubbo.config.spring.context.annotation.EnableDubbo;
@EnableDubbo@SpringBootApplicationpublicclassComsumerApplication {
publicstaticvoidmain(String[] args) {
SpringApplication.run(ComsumerApplication.class, args);
    }
}

5、controller层

@RestController@RequestMapping("/demo")
publicclassDemoConsumerController {
@AutowiredprivateDemoConsumerServicedemoConsumerService;
@GetMapping("/getProviderService")
publicStringgetProviderService() {
returndemoConsumerService.getProviderService();
    }
}

6、service层

importorg.apache.dubbo.config.annotation.DubboReference;
@ServicepublicclassDemoConsumerService {
@DubboReferenceprivateDemoInterfacedemoInterface;
publicStringgetProviderService() {
returndemoInterface.demo("使用Dubbo调用");
    }
}

7 、还有最后一步 需要配置网关策略配置

这里引入Nacos的配置中心的使用
  • 在demo-gateway项目中引入依赖
    implementation group: 'com.alibaba.cloud', name: 'spring-cloud-starter-alibaba-nacos-config'
  • Nacos客户端添加配置

Nacos配置.png
yaml.png

spring:  cloud:    gateway:      discovery:        locator:          enabled: true   #开启网关拉取nacos的服务      routes:        - id: demo-consumer
          uri: lb://demo-consumer
          predicates:            - Path=/demo/**
  • 在demo-gateway项目的bootstrap.yaml配置文件中添加
spring:  cloud:    nacos:      config:        server-addr: 127.0.0.1:8848        file-extension: yaml
        refresh-enabled: true # 是否动态刷新,默认为false# 支持多个共享dataId的配置,优先级小于extension-configs,shared-configs是一个集合        shared-configs[0]:# 网关 通用配置可以定义在这个里面          dataId: demo-gateway.yaml # 配置文件名dataId          group: DEFAULT_GROUP  # 默认为DEFAULT_GROUP

发送请求测试

请求测试.png

目录
相关文章
|
负载均衡 监控 Java
Spring Cloud Gateway 全解析:路由配置、断言规则与过滤器实战指南
本文详细介绍了 Spring Cloud Gateway 的核心功能与实践配置。首先讲解了网关模块的创建流程,包括依赖引入(gateway、nacos 服务发现、负载均衡)、端口与服务发现配置,以及路由规则的设置(需注意路径前缀重复与优先级 order)。接着深入解析路由断言,涵盖 After、Before、Path 等 12 种内置断言的参数、作用及配置示例,并说明了自定义断言的实现方法。随后重点阐述过滤器机制,区分路由过滤器(如 AddRequestHeader、RewritePath、RequestRateLimiter 等)与全局过滤器的作用范围与配置方式,提
Spring Cloud Gateway 全解析:路由配置、断言规则与过滤器实战指南
|
12月前
|
人工智能 Java API
Nacos 3.1.0 正式发布,支持 A2A 注册中心与 MCP 注册协议增强
3.1.0 发布核心全新功能-Agent 注册中心,助力构建基于 A2A 协议的多 Agent 协作的AI应用,同时 MCP 注册中心适配最新 MCP 官方注册中心协议及升级优化多项核心功能。
2732 89
|
12月前
|
缓存 JSON NoSQL
别再手写过滤器!SpringCloud Gateway 内置30 个,少写 80% 重复代码
小富分享Spring Cloud Gateway内置30+过滤器,涵盖请求、响应、路径、安全等场景,无需重复造轮子。通过配置实现Header处理、限流、重试、熔断等功能,提升网关开发效率,避免代码冗余。
860 1
|
负载均衡 Kubernetes 网络协议
注册中心如何选型?Eureka、Zookeeper、Nacos怎么选
这是小卷对分布式系统架构学习的第9篇文章,继续探讨注册中心的原理及选型。文章详细介绍了Eureka、Nacos的工作机制与特点,并对比了Eureka、Nacos、Consul和Zookeeper在一致性协议、健康检查、负载均衡等方面的差异。最后根据不同的应用场景给出了注册中心的选型建议,帮助读者理解如何选择最适合的注册中心。
1595 100
|
JSON Java API
利用Spring Cloud Gateway Predicate优化微服务路由策略
Spring Cloud Gateway 的路由配置中,`predicates`​(断言)用于定义哪些请求应该匹配特定的路由规则。 断言是Gateway在进行路由时,根据具体的请求信息如请求路径、请求方法、请求参数等进行匹配的规则。当一个请求的信息符合断言设置的条件时,Gateway就会将该请求路由到对应的服务上。
1890 69
利用Spring Cloud Gateway Predicate优化微服务路由策略
|
缓存 监控 Java
说一说 SpringCloud Gateway 堆外内存溢出排查
我是小假 期待与你的下一次相遇 ~
1667 5
|
Java API Nacos
|
前端开发 Java API
Spring Cloud Gateway Server Web MVC报错“Unsupported transfer encoding: chunked”解决
本文解析了Spring Cloud Gateway中出现“Unsupported transfer encoding: chunked”错误的原因,指出该问题源于Feign依赖的HTTP客户端与服务端的`chunked`传输编码不兼容,并提供了具体的解决方案。通过规范Feign客户端接口的返回类型,可有效避免该异常,提升系统兼容性与稳定性。
979 0
|
Cloud Native Java Nacos
springcloud/springboot集成NACOS 做注册和配置中心以及nacos源码分析
通过本文,我们详细介绍了如何在 Spring Cloud 和 Spring Boot 中集成 Nacos 进行服务注册和配置管理,并对 Nacos 的源码进行了初步分析。Nacos 作为一个强大的服务注册和配置管理平台,为微服务架构提供
5245 14
|
前端开发 Java Nacos
🛡️Spring Boot 3 整合 Spring Cloud Gateway 工程实践
本文介绍了如何使用Spring Cloud Alibaba 2023.0.0.0技术栈构建微服务网关,以应对微服务架构中流量治理与安全管控的复杂性。通过一个包含鉴权服务、文件服务和主服务的项目,详细讲解了网关的整合与功能开发。首先,通过统一路由配置,将所有请求集中到网关进行管理;其次,实现了限流防刷功能,防止恶意刷接口;最后,添加了登录鉴权机制,确保用户身份验证。整个过程结合Nacos注册中心,确保服务注册与配置管理的高效性。通过这些实践,帮助开发者更好地理解和应用微服务网关。
2722 0
🛡️Spring Boot 3 整合 Spring Cloud Gateway 工程实践