当前位置: 首页 > article >正文

Spring Cloud 微服务全面概述

Spring Cloud 微服务全面概述

1. 微服务架构概述

微服务架构(Microservices Architecture)是将应用程序拆分为多个小的、独立的服务,每个服务围绕特定的业务功能构建。这种架构使得应用程序能够更灵活地扩展和维护。

1.1 微服务的特点

  • 模块化:服务可以独立开发、测试、部署和扩展。
  • 异构技术:不同的服务可以使用不同的技术栈(编程语言、数据库等)。
  • 分布式:服务通常通过 HTTP REST、消息队列等网络协议通信。
  • 弹性:系统能在部分服务故障时保持可用。

1.2 微服务架构的优势

  • 可扩展性:可以根据需求独立扩展某些服务。
  • 开发效率:小团队可以并行开发不同的服务,加快交付速度。
  • 容错性:某个服务的失败不会导致整个系统崩溃。

2. Spring Cloud 介绍

Spring Cloud 是一套基于 Spring Boot 的开源工具,帮助开发者快速构建分布式系统。它提供了多个模块,支持服务发现、配置管理、负载均衡、断路器等功能。

2.1 Spring Cloud 的核心模块

  • Spring Cloud Netflix:提供了与 Netflix 生态系统集成的组件,如 Eureka、Ribbon、Hystrix、Zuul 等。
  • Spring Cloud Config:集中管理服务的配置。
  • Spring Cloud Gateway:API 网关,用于路由和负载均衡。
  • Spring Cloud Sleuth:提供分布式追踪功能。
  • Spring Cloud Bus:用于事件传播和配置更新。

3. Spring Cloud 核心知识点

3.1 服务注册与发现

Eureka 是一个服务注册与发现的组件。它允许微服务在启动时注册到 Eureka 服务器,并可以通过服务名查找其他服务。

3.1.1 Eureka 服务器的设置
  1. 添加依赖
    pom.xml 中添加 Eureka 服务器依赖:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka-server</artifactId>
    </dependency>
    
  2. 主类配置
    在应用主类上添加 @EnableEurekaServer 注解,启动 Eureka 服务器。

    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaServerApplication {
        public static void main(String[] args) {
            SpringApplication.run(EurekaServerApplication.class, args);
        }
    }
    
  3. 配置文件
    application.yml 中配置 Eureka 服务器:

    server:
      port: 8761
    eureka:
      client:
        register-with-eureka: false
        fetch-registry: false
    
  4. 启动 Eureka 服务器
    运行应用,访问 http://localhost:8761 查看 Eureka Dashboard。

3.1.2 Eureka 客户端的设置
  1. 添加依赖
    在微服务的 pom.xml 中添加:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka-client</artifactId>
    </dependency>
    
  2. 主类配置
    在微服务的主类上添加 @EnableEurekaClient 注解。

    @SpringBootApplication
    @EnableEurekaClient
    public class MyServiceApplication {
        public static void main(String[] args) {
            SpringApplication.run(MyServiceApplication.class, args);
        }
    }
    
  3. 配置文件
    application.yml 中配置 Eureka 客户端信息:

    spring:
      application:
        name: my-service
      cloud:
        discovery:
          client:
            serviceUrl:
              defaultZone: http://localhost:8761/eureka/
    
  4. 服务启动
    启动微服务,查看 Eureka Dashboard 可以看到注册的服务。

3.2 负载均衡

Ribbon 是一个客户端负载均衡器,支持服务的自动负载均衡。

3.2.1 Ribbon 的设置
  1. 添加依赖
    在微服务的 pom.xml 中添加:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-ribbon</artifactId>
    </dependency>
    
  2. 使用 Ribbon
    在微服务中,可以使用 RestTemplate 发起请求,并利用 Ribbon 进行负载均衡。

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
    
    @GetMapping("/call-service")
    public String callOtherService() {
        return restTemplate.getForObject("http://my-service/api", String.class);
    }
    

3.3 API 网关

Spring Cloud Gateway 提供了一种简单的方式来路由请求到后端服务,支持负载均衡和安全性。

3.3.1 Gateway 的设置
  1. 添加依赖
    pom.xml 中添加:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-gateway</artifactId>
    </dependency>
    
  2. 配置路由
    application.yml 中配置路由规则:

    spring:
      cloud:
        gateway:
          routes:
            - id: my-service-route
              uri: lb://my-service
              predicates:
                - Path=/my-service/**
    
  3. 访问网关
    启动网关服务后,通过网关访问后端服务,例如 http://localhost:8080/my-service/api

3.4 配置管理

Spring Cloud Config 提供了集中管理微服务配置的功能。

3.4.1 Config 服务器的设置
  1. 添加依赖
    在 Config 服务器的 pom.xml 中添加:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-config-server</artifactId>
    </dependency>
    
  2. 启用 Config 服务器
    在主类上添加 @EnableConfigServer 注解。

    @SpringBootApplication
    @EnableConfigServer
    public class ConfigServerApplication {
        public static void main(String[] args) {
            SpringApplication.run(ConfigServerApplication.class, args);
        }
    }
    
  3. 配置 Git 仓库
    application.yml 中配置 Git 仓库地址:

    spring:
      cloud:
        config:
          server:
            git:
              uri: https://github.com/your-repo/config-repo
    
  4. 客户端配置
    微服务客户端在 application.yml 中配置:

    spring:
      application:
        name: my-service
      cloud:
        config:
          uri: http://localhost:8888
    

3.5 断路器

Hystrix 是一个用于服务容错的库,通过断路器模式来保护服务。

3.5.1 Hystrix 的设置
  1. 添加依赖
    在微服务的 pom.xml 中添加:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix</artifactId>
    </dependency>
    
  2. 启用 Hystrix
    在主类上添加 @EnableCircuitBreaker 注解。

    @SpringBootApplication
    @EnableCircuitBreaker
    public class MyServiceApplication {
        public static void main(String[] args) {
            SpringApplication.run(MyServiceApplication.class, args);
        }
    }
    
  3. 使用 Hystrix 注解
    在需要保护的方法上使用 @HystrixCommand 注解:

    @HystrixCommand(fallbackMethod = "fallbackMethod")
    public String callExternalService() {
        // 可能会失败的外部调用
    }
    
    public String fallbackMethod() {
        return "服务暂时不可用,请稍后再试";
    }
    

好的,我们接着讲解 Spring Cloud Bus 的设置以及其他相关内容。

3.6 消息总线

Spring Cloud Bus 可以用于将配置更改、事件等信息广播到所有服务实例,从而实现服务间的事件传播和配置更新。

3.6.1 消息总线的设置
  1. 添加依赖
    在微服务的 pom.xml 中添加 RabbitMQ 或 Kafka 相关依赖。这里以 RabbitMQ 为例:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-rabbit</artifactId>
    </dependency>
    
  2. 配置 RabbitMQ
    application.yml 中配置 RabbitMQ 的连接信息:

    spring:
      rabbit:
        host: localhost
        port: 5672
        username: guest
        password: guest
    
  3. 发送事件
    在微服务中,使用 @RefreshScope 注解来自动刷新配置:

    @RefreshScope
    @RestController
    public class MyController {
        @Value("${my.property}")
        private String myProperty;
    
        @GetMapping("/property")
        public String getProperty() {
            return myProperty;
        }
    }
    

    当配置发生变化时,发送 POST 请求到 /bus/refresh 来通知所有服务更新配置:

    curl -X POST http://localhost:8888/bus/refresh
    

4. 实际案例

下面是一个简单的微服务案例,演示如何将前面的组件整合在一起。

4.1 项目结构
/microservices
    /eureka-server
    /config-server
    /gateway
    /service-a
    /service-b
4.2 Eureka 服务器

使用之前介绍的方法设置 Eureka 服务器。

4.3 Config 服务器

使用之前介绍的方法设置 Config 服务器,并在 Git 仓库中存放配置文件,如 application.yml

4.4 微服务 A 和 B
  1. 创建微服务 A

    @SpringBootApplication
    @EnableEurekaClient
    @EnableCircuitBreaker
    public class ServiceAApplication {
        public static void main(String[] args) {
            SpringApplication.run(ServiceAApplication.class, args);
        }
    
        @HystrixCommand(fallbackMethod = "fallbackMethod")
        public String callServiceB() {
            // 通过服务名调用服务 B
            return restTemplate.getForObject("http://service-b/endpoint", String.class);
        }
    
        public String fallbackMethod() {
            return "服务 B 暂时不可用";
        }
    }
    
  2. 创建微服务 B

    @SpringBootApplication
    @EnableEurekaClient
    public class ServiceBApplication {
        public static void main(String[] args) {
            SpringApplication.run(ServiceBApplication.class, args);
        }
    
        @GetMapping("/endpoint")
        public String endpoint() {
            return "Hello from Service B";
        }
    }
    
4.5 Gateway

配置 Gateway,以便路由请求到微服务 A 和 B。

spring:
  cloud:
    gateway:
      routes:
        - id: service-a
          uri: lb://service-a
          predicates:
            - Path=/service-a/**
        - id: service-b
          uri: lb://service-b
          predicates:
            - Path=/service-b/**

5. 总结

通过使用 Spring Cloud 的一系列组件,你可以快速构建一个健壮的微服务架构,具备服务发现、负载均衡、断路器、配置管理等特性。每个组件都能为你的微服务提供必要的功能,帮助你提高开发效率和系统的可靠性。


http://www.kler.cn/a/372252.html

相关文章:

  • 【Searxng】Searxng docker 安装
  • 安卓登录页面设计(无跳转版本)
  • 【文心智能体 | AI大师工坊】如何使用智能体插件,完成一款旅游类智能体的开发,来体验一下我的智能体『​​​​​​​背包客』
  • Java NIO2 异步IO支持
  • Prompt Engineering (Prompt工程)
  • ppt设计软件哪个好?这5个在线ppt工具不容错过!
  • 【系统面试篇】简述进程调度算法
  • CTF-PWN: 虚表(vtable)
  • Vue学习记录之二十二 Vue3+vite+electron 构建项目实例
  • 别被忽悠了 Lua 数组真的也可以从 0 开始索引?
  • 10 最长回文子串、买卖股票的最好时机(一)、[NOIP2002 普及组] 过河卒24_10_30
  • CodeQL学习笔记(3)-QL语法(模块、变量、表达式、公式和注解)
  • @tarojs/components 和 taro-ui 中的组件之间的区别
  • HarmonyOS NEXT API12最新版 端云一体化开发-创建端云一体化项目流程
  • docker部署SQL审核平台Archery
  • C++类和对象 (中)
  • ubuntu内核更新导致显卡驱动掉的解决办法
  • 软考中级计算题笔记
  • C++朝花夕拾
  • Golang Agent 可观测性的全面升级与新特性介绍
  • 记MySQL下一次DEPENDENT SUBQUERY的优化
  • Github 2024-10-29Python开源项目日报 Top10
  • 算法刷题-小猫爬山
  • 从0开始搭建一个生产级SpringBoot2.0.X项目(二)SpringBoot应用连接数据库集成mybatis-plus
  • ElasticSearch - Bucket Script 使用指南
  • 三菱FX5U PLC使用SD存储卡固件更新的方法