首頁手記 SpringCloud微服務學習：從入門到實踐

SpringCloud微服務學習：從入門到實踐

標簽：

Spring Cloud 微服務

概述

本文介绍了Spring Cloud微服务学习的相关内容，涵盖了微服务的基本概念、Spring Cloud的核心组件及功能，详细讲解了服务发现与注册、负载均衡、服务熔断与降级、配置管理和API网关等关键知识点。

微服务简介与Spring Cloud入门

微服务的基本概念

微服务是一种设计模式，它将大型的单体应用拆分成一组小的、独立部署的服务，每个服务都是一个独立的进程，可以被多个不同的客户端（如Web、移动应用）使用。这种架构模式使得应用可以更好地适应不断变化的业务需求，提高开发效率，同时提升了系统的可维护性和可扩展性。

优点

独立部署：每个服务都可以独立部署、升级和扩展。
技术多样性：每个服务可以选择最适合的技术栈，而不需要整个应用使用相同的技术。
故障隔离：一个服务的故障不会影响到其他服务。
易于维护：由于每个服务都很小，因此更容易理解和维护。
灵活的扩展：可以根据需要单独扩展服务，而不是整个应用。
自动化测试：微服务可以更容易地进行单元测试、集成测试和端到端测试。

缺点

复杂性：微服务架构需要更多的组件和工具来管理和维护，增加了复杂性。
数据一致性：由于数据分散在不同的服务中，保持数据一致性变得更加复杂。
运维挑战：需要管理和监控更多的服务实例，增加了运维的复杂性。
服务通信：服务之间的通信需要更复杂的机制，如API网关、服务注册与发现等。

Spring Cloud简介

Spring Cloud是一组框架和服务的集合，它基于Spring Boot构建，简化了微服务架构的开发和部署。Spring Cloud提供了多个子项目，如服务发现、配置管理、断路器、负载均衡、API网关等，以帮助开发者快速构建和部署微服务应用。

主要子项目

Spring Cloud Config：配置中心，用于集中化管理应用的配置。
Spring Cloud Netflix：提供了一组Netflix OSS的实现，包括服务发现（Eureka）、负载均衡（Ribbon）和断路器（Hystrix）等。
Spring Cloud Gateway：API网关，用于处理入站请求。
Spring Cloud Consul：服务发现和配置管理，依赖于Consul。
Spring Cloud Bus：用于实现动态刷新配置。
Spring Cloud Sleuth：分布式跟踪实现。
Spring Cloud Zookeeper：服务发现和配置管理，依赖于Zookeeper。
Spring Cloud OpenFeign：声明式HTTP客户端。
Spring Cloud Stream：构建基于消息驱动的应用，支持多种中间件。

Spring Cloud环境搭建

依赖配置

要使用Spring Cloud，需要在项目中添加必要的依赖。以下是使用Spring Boot和Spring Cloud的Maven依赖配置示例：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-gateway</artifactId>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>2021.0.0</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

应用配置

在Spring Cloud中，应用配置通常放在application.yml或application.properties文件中。下面是一个简单的配置示例：

spring:
  application:
  name: eureka-client # 应用名
  eureka:
    client:
      register-with-eureka: true
      fetch-registry: true
      service-url:
        defaultZone: http://localhost:8761/eureka/

服务发现与注册

Eureka服务注册与发现

Eureka是Netflix开源的一个服务注册与发现组件，Spring Cloud集成了Eureka，提供了服务注册与发现的功能。

Eureka服务端配置

首先，创建一个Eureka服务端，配置如下：

spring:
  application:
  name: eureka-server
eureka:
  instance:
    hostname: localhost
  client:
    register-with-eureka: false
    fetch-registry: false
  server: true
server:
  port: 8761

Eureka客户端配置

接下来，创建一个Eureka客户端，配置如下：

spring:
  application:
  name: eureka-client
eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:8761/eureka/

客户端代码示例

下面是一个简单的Eureka客户端服务示例：

package com.example.eurekaclient;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class EurekaClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaClientApplication.class, args);
    }
}

服务注册与心跳检测机制

Eureka采用客户端和服务器端互相注册、互相轮询的模式来实现服务发现与注册。Eureka Server通过心跳机制来检查服务实例是否存活。

心跳检测机制

Eureka客户端定时向Eureka Server发送心跳请求。如果Eureka Server在一段时间内没有收到心跳，就会认为服务实例已经失效，并从服务列表中移除该实例。同时，Eureka Server也会定时发送心跳请求到客户端，以确认客户端是否存活。

服务注册与心跳检测机制代码示例

以下是一个简单的Eureka心跳检测机制的实现示例：

package com.example.eurekaregistration;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class EurekaRegistrationApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaRegistrationApplication.class, args);
    }
}

负载均衡与Ribbon

Ribbon的基本使用

Ribbon是Netflix开源的一个客户端负载均衡器，它可以在客户端实现负载均衡，根据预定的负载均衡算法从服务列表中选择一个服务实例。

配置Ribbon

在Spring Cloud中使用Ribbon，需要在服务客户端的配置文件中指定负载均衡策略和Eureka服务地址：

spring:
  application:
  name: service-hello
eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:8761/eureka/
ribbon:
  eureka:
    enabled: true

自定义Ribbon规则

Ribbon支持多种负载均衡策略，可以自定义这些策略以满足不同的需求。以下是一个自定义Ribbon规则的示例：

package com.example.ribbon;

import com.netflix.loadbalancer.ILoadBalancer;
import com.netflix.loadbalancer.LoadBalancerBuilder;
import com.netflix.loadbalancer.RandomRule;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class CustomRibbonRule extends RandomRule {

    @Autowired
    private ILoadBalancer loadBalancer;

    @Override
    public Server choose(Object key) {
        // 自定义选择逻辑
        Server server = super.choose(key);
        if (server == null) {
            return null;
        }
        // 可以根据需要进行自定义处理
        return server;
    }
}

服务熔断与Hystrix

Hystrix的工作原理

Hystrix是一种服务降级和超时控制的工具，它可以保护依赖的服务，防止它们在负载过高或网络延迟时导致依赖服务崩溃。Hystrix通过引入隔离和降级机制来实现服务的容错。

实现服务熔断与降级

Hystrix通过断路器模式来实现服务熔断和降级。当服务调用失败次数达到一定阈值时，Hystrix会开启断路器，阻止新的请求到达服务，从而保护服务。

下面是一个简单的Hystrix示例：

package com.example.hystrix;

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.HystrixCommandKey;
import com.netflix.hystrix.HystrixCommandProperties;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HystrixController {

    @GetMapping("/hystrix")
    public String hystrixService() {
        return new HystrixCommand<String>(HystrixCommandKey.Factory.asKey("hystrixCommand"),
                HystrixCommandGroupKey.Factory.asKey("ExampleGroup")) {
            @Override
            protected String run() throws Exception {
                // 模拟服务调用
                return "Hello Hystrix";
            }
        }.execute();
    }
}

配置管理与Spring Cloud Config

Spring Cloud Config的基本使用

Spring Cloud Config提供了一种集中式的配置管理方式。它支持多种存储方式，如Git、SVN和本地文件系统等。

配置中心

创建一个配置中心应用，配置如下：

spring:
  application:
  name: config-server
cloud:
  config:
    server:
      git:
        uri: https://github.com/your-repo/config-repo
        username: your-username
        password: your-password
server:
  port: 8888

配置客户端

在客户端应用中，可以通过spring.cloud.config属性来指定配置中心的位置：

spring:
  application:
  name: config-client
cloud:
  config:
    uri: http://localhost:8888
    username: your-username
    password: your-password

配置文件示例

配置文件通常放在配置中心的Git仓库中，例如：

# config-client.yml
spring:
  application:
    name: config-client

配置文件使用示例

下面是一个简单的配置文件使用示例：

package com.example.configclient;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@RefreshScope
public class ConfigClientApplication {

    @RestController
    public class ConfigController {

        @GetMapping("/config")
        public String getConfig() {
            return "Hello, Config!";
        }
    }

    public static void main(String[] args) {
        SpringApplication.run(ConfigClientApplication.class, args);
    }
}

服务网关与Spring Cloud Gateway

Spring Cloud Gateway的功能与优势

Spring Cloud Gateway是由Spring Cloud提供的API网关，它集成了Spring Cloud Router和Spring Cloud Stream的功能，提供了丰富的路由规则和过滤器支持。

Gateway的基本配置与使用

首先，配置一个Spring Cloud Gateway应用，示例如下：

spring:
  application:
  name: gateway-server
cloud:
  gateway:
    routes:
      - id: my_route
        uri: http://example.com
        predicates:
          - Path=/api/**

Gateway示例代码

下面是一个简单的Gateway示例代码：

package com.example.gateway;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class GatewayServerApplication {

    @Bean
    public RouteLocator myRouteLocator(RouteLocatorBuilder builder) {
        return builder.routes()
                .route("my_route", r -> r.path("/api/**")
                        .uri("http://example.com"))
                .build();
    }

    public static void main(String[] args) {
        SpringApplication.run(GatewayServerApplication.class, args);
    }
}

总结

通过上述内容，我们学习了Spring Cloud框架的基本概念和使用方法，包括服务发现与注册、负载均衡、服务熔断与降级、配置管理以及API网关。这些功能共同构建了一个完整的微服务生态系统，大大简化了微服务架构的开发和部署过程。

點擊查看更多內容

為 TA 點贊

若覺得本文不錯，就分享一下吧！

評論

評論

共同學習，寫下你的評論

評論加載中...

展開查看更多評論

作者其他優質文章

正在加載中

慕碼人8056858

手記
篇

粉絲

351

獲贊與收藏

1324

關注作者，訂閱最新文章

閱讀免費教程

Spring Cloud Hystrix

15個小節 6354 125

后端通用面試教程

41個小節 32074 358

網絡編程入門教程

20個小節 13196 249

推薦

評論

收藏

共同學習，寫下你的評論



感謝您的支持，我會繼續努力的～

掃碼打賞，你說多少就多少

贊賞金額會直接到老師賬戶

支付方式

打開微信掃一掃，即可進行掃碼打賞哦

今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與放棄機會

點擊
抽獎

慕課手記新用戶專享福利

恭喜你，你的運氣太好了，居然抽中了 100個積分！

恭喜你，抽中了價值元的專欄！

太棒了，直接落到你賬戶里！

積分商城里的羅技鼠標、機械鍵盤、
Kindle 閱讀器、小米平衡車
Apple iPad （10.2英寸）、大額優惠券
在等著你去兌換了噢

作者：

免費贈送

兌換碼：1111222211 復制

優惠券可用于購買實戰課、體系課
無門檻使用

先去看看，有什么好東西馬上兌換我愛學習，選課去


亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

熱搜

最近搜索清空