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

目录
相关文章
|
10月前
|
人工智能 Java API
Nacos 3.1.0 正式发布,支持 A2A 注册中心与 MCP 注册协议增强
3.1.0 发布核心全新功能-Agent 注册中心,助力构建基于 A2A 协议的多 Agent 协作的AI应用,同时 MCP 注册中心适配最新 MCP 官方注册中心协议及升级优化多项核心功能。
2489 79
|
存储 网络协议 Nacos
高效搭建Nacos:实现微服务的服务注册与配置中心
Nacos(Dynamic Naming and Configuration Service)是阿里巴巴开源的一款动态服务发现、配置管理和服务管理平台。它旨在帮助开发者更轻松地构建、部署和管理分布式系统,特别是在微服务架构中。
3008 81
高效搭建Nacos:实现微服务的服务注册与配置中心
|
负载均衡 Kubernetes 网络协议
注册中心如何选型?Eureka、Zookeeper、Nacos怎么选
这是小卷对分布式系统架构学习的第9篇文章,继续探讨注册中心的原理及选型。文章详细介绍了Eureka、Nacos的工作机制与特点,并对比了Eureka、Nacos、Consul和Zookeeper在一致性协议、健康检查、负载均衡等方面的差异。最后根据不同的应用场景给出了注册中心的选型建议,帮助读者理解如何选择最适合的注册中心。
1479 100
|
存储 Kubernetes 安全
Nacos-Controller 2.0:使用 Nacos 高效管理你的 K8s 配置
无论是使用 Nacos-Controller 实现配置的双向同步,还是直接在应用中接入 Nacos SDK 以获得更高级的配置管理特性,都能显著提升配置管理的灵活性、安全性和可维护性。使用 Nacos,您能够更好地管理和优化您的应用配置,从而提高系统的稳定性和可靠性。
1176 50
|
JSON Java Nacos
SpringCloud 应用 Nacos 配置中心注解
在 Spring Cloud 应用中可以非常低成本地集成 Nacos 实现配置动态刷新,在应用程序代码中通过 Spring 官方的注解 @Value 和 @ConfigurationProperties,引用 Spring enviroment 上下文中的属性值,这种用法的最大优点是无代码层面侵入性,但也存在诸多限制,为了解决问题,提升应用接入 Nacos 配置中心的易用性,Spring Cloud Alibaba 发布一套全新的 Nacos 配置中心的注解。
1925 156
|
存储 人工智能 测试技术
Nacos托管LangChain应用Prompts和配置,助力你的AI助手快速进化
AI 应用开发中,总有一些让人头疼的问题:敏感信息(比如 API-KEY)怎么安全存储?模型参数需要频繁调整怎么办?Prompt 模板改来改去,每次都得重启服务,太麻烦了!别急,今天我们就来聊聊如何用 Nacos 解决这些问题。
|
Cloud Native Java Nacos
springcloud/springboot集成NACOS 做注册和配置中心以及nacos源码分析
通过本文,我们详细介绍了如何在 Spring Cloud 和 Spring Boot 中集成 Nacos 进行服务注册和配置管理,并对 Nacos 的源码进行了初步分析。Nacos 作为一个强大的服务注册和配置管理平台,为微服务架构提供
5127 14
|
监控 负载均衡 安全
微服务(五)-服务网关zuul(一)
微服务(五)-服务网关zuul(一)
|
应用服务中间件 网络安全 数据安全/隐私保护
网关服务器配置指南:实现自动DHCP地址分配、HTTP服务和SSH无密码登录。
哇哈哈,道具都准备好了,咱们的魔术秀就要开始了。现在,你的网关服务器已经魔法满满,自动分配IP,提供网页服务,SSH登录如入无人之境。而整个世界,只会知道效果,不会知道是你在幕后操控一切。这就是真正的数字世界魔法师,随手拈来,手到擒来。
624 14
|
安全 5G 网络性能优化
深入理解5G中的SAEGW:服务网关边界
【10月更文挑战第9天】
736 0