Spring Cloud简述及简单入门实例

wuchangjian2021-11-12 01:32:54编程学习

1 概述
Spring Cloud基于Spring Boot,提供了多个组件来帮助企业进行微服务系统建设;它提供的主要功能有:服务注册中心/服务注册/服务调用/负载均衡/断路器等;一般情况下它都是使用已有的开源软件,在其基础上按Spring Boot的理念来进行封装,简化各种个组件的调用以及各个组件之间的交互。

2 常用组件
Spring Cloud主要包含以下常用组件:

2.1 Eureka
注册中心eureka-server,用于提供服务注册/服务申请等功能;
服务提供者provider,用于向eureka-server注册服务;

服务消费者consumer,用于向eureka-server获取服务;

2.2 Ribbon
负责进行客户端负载均衡的组件;一般与RestTemplate结合,在访问provider提供的服务时进行负载均衡处理。
也就是说,Ribbon用于服务调用者向被调用者进行服务调用,并且如果服务者有多个节点时,会进行客户端的负载均衡处理;

2.3 Feign
与Ribbon功能类型,用于调用方与被调用方的服务调用,同时进行客户端负载均衡的处理;不过它能提供类似本地调用的方式调用远程的EurekaClient提供的服务;它实际上是在Ribbon基础上进行了进一步的封装来提高调用服务的简便性。


3.1 示例场景
假设现在有provider向外提供服务,该服务同时部署两个节点;consumer通过Feign或者是Ribbon调用其提供的服务,其部署关系及数据流向图如下所示:


第一步:启动注册中心;服务提供者及调用者向服务中心注册;
第二步:服务调用者向服务中心申请服务,根据服务中心返回的地址信息调用服务提供者提供的服务;
第三步:注册中心通过心跳检测方式检测服务提供者的状态,当某个提供者连接不上时,发送消息通知所有注册者;

下面详细说明每个节点的实现; 具体代码见springcloud-demo: SpringCloud 入门案例,包含了swagger2、eureka、zuul、openfeign、hystrix 等组件。

3.2 Eureka服务端
详细代码见GITEE工程中名为eureka-server的模块;
a. MVN依赖引入
引入eureka-server相关的依赖包

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
b. Spring Boot注解引入及服务启动类
主要是通过EnableEurekaServer来表明节点是服务端。
@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {

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

}

c. application.yml配置
主要是配置端口及配置是否向服务中心注册及向服务中心获取注册信息;
这两项配置均需配置成false; 单纯的做服务器的节点不需要再向服务器注册及申请注册信息。
eureka:
    client:
        fetch-registry: false
        register-with-eureka: false
    instance:
        hostname: localhost
        ip-address: 127.0.0.1
        lease-expiration-duration-in-seconds: 90
        lease-renewal-interval-in-seconds: 30
        prefer-ip-address: false
server:
    port: 2001
spring:
    application:
        name: eureka-server
    profiles:
        active: dev

启动完后通过http://localhost:2001/可以看到EurekaServer的监控页面; 此时还没有节点注册;

3.3 服务提供方
详细代码见GITEE工程中名为provider的模块;
a. MVN依赖引入
需要引入EurekaClient相关的依赖包;

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

b. 注解引入
通过EnableDiscoveryClient 注解会使得应用向eureka-server进行注册。
@SpringBootApplication
@EnableDiscoveryClient
public class ProviderApplication {

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

}
@RestController
public class WebController {

    @RequestMapping("/")
    public String working() {
        return "this is provider client";
    }

}

3.4 服务调用方

3.4.1 通过Feign调用服务
Feign与Ribbon功能类似,它们的不同只是Feign在调用上进行了进一步的封装。
a. 依赖

<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-hystrix</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>


b. 启动服务

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
@EnableCircuitBreaker
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
        System.out.println("本地文档路径:http://127.0.0.1:2004/doc.html");
    }

    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @Bean
    public IRule ribbonRule() {
        return new RandomRule();//这里配置策略,和配置文件对应
    }

}


c. ProviderClient 定义
通过Feign调用服务时,主要是利用FeignClient注解指定需要调用的服务在哪类节点上;这个注解作用在接口上; 与RequestMapping结合使用,这样就可以指定接口的某个方法调用的是远程服务器的哪个接口。

@FeignClient(name = "provider")
public interface ProviderClient {

    @RequestMapping(value = "/")
    String working();

}



d. application.yml配置

server:
    port: 2004
spring:
    application:
        name: consumer
    profiles:
        active: dev
consumer:
    ribbon:
        NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
eureka:
    client:
        serviceUrl:
            defaultZone: http://127.0.0.1:2001/eureka/


e. 服务调用
通过预先定义好的ProviderClient 类来调用远程服务器的相应接口;

package com.chiyi.controller;

import com.chiyi.model.UserDo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @date 2020/11/13 14:32
 */
@Api(tags = "消费者测试Api接口")
@RestController
@RequestMapping("/web")
public class WebController {

    @Resource
    ProviderClient providerClient;


    @ApiOperation("消费者测试接口")
    @GetMapping("/work")
    public String working() {
        return "this is consumer client";
    }

}


启动main方法后,通过eureka-server 的监控页面可以看到又多了一个名称为consumer的节点;
 

相关文章

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。