一、SpringCloud简介

SpringCloud是一个基于SpringBoot实现的云应用开发工具，为开发人员提供了快速构建分布式系统的一些工具，包括配置管理、服务发现、断路器、路由、微代理、控制总线、全局锁、决策竞选、分布式会话等等。

二、服务注册与发现

Spring Cloud Eureka

Spring Cloud Eureka是Spring Cloud Netflix(Spring Cloud子项目之一)项目下的服务治理模块。主要是对Netfilix公司一系列的开源产品的包装。通过简单的配置，开发者就可以快速在应用中配置常用模块并构建庞大的分布式系统。主要提供的模块: 服务发现（Eureka）、断路器(Hystrix)、智能路由(Zuul)、客户端负载均衡（Ribbon）

• 创建服务注册中心(euraka server)

首先创建一个基础的Spring Boot工程。build.gradle文件如下:

plugins {
    id 'org.springframework.boot' version '2.1.3.RELEASE'
    id 'java'
}

apply plugin: 'io.spring.dependency-management'

group = 'com.example'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '1.8'

repositories {
    mavenCentral()
}

ext {
    set('springCloudVersion', 'Greenwich.SR1')
}

dependencies {
    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-server'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
//    implementation 'org.springframework.cloud:spring-cloud-starter-eureka'
}

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
    }
}

通过@EnableEurekaServer注解启动一个服务注册中心，提供给其他应用。

@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {

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

在默认情况下，该服务注册中心也会将自己作为客户端来尝试注册自己，所以我们要禁止他的客户端注册行为，需要配置application.yml文件：

spring:
  application:
    name: eureka-server

server:
  port: 8888

eureka:
  instance:
    hostname: localhost
  client: #设置下面属性为false表明自己是一个 eureka server
    register-with-eureka: false
    fetch-registry: false

访问localhost:8888显示内容如下：

Eureka

• 创建服务提供者（eureka-client）

首先创建一个基础的Spring Boot工程。build.gradle文件如下:

plugins {
    id 'org.springframework.boot' version '2.1.3.RELEASE'
    id 'java'
}

apply plugin: 'io.spring.dependency-management'

group = 'com.example'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '1.8'

repositories {
    mavenCentral()
}

ext {
    set('springCloudVersion', 'Greenwich.SR1')
}

dependencies {
    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
    }
}

创建/client请求处理接口，通过DiscoverClient对象，打印出服务实例信息。

@RestController
public class DiscoveryClientController {
    @Autowired
    DiscoveryClient discoveryClient;

    @GetMapping("/client")
    public String discoveryClient(){
        String services = "Services: " + discoveryClient.getServices();
        System.out.println(services);
        return services;
    }
}

通过@EnableDiscoveryClient注解，激活Eureka中的DiscoveryClient实现。

@SpringBootApplication
@EnableEurekaClient
public class EurekaClientApplication {

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

在application.yml文件中注明自己的服务注册中心的地址

spring:
  application:
    name: eureka-client
    
server:
  port: 8000
  
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8888/eureka/

注：
spring.application.name属性，指定微服务的名称，后面直接调用该名称就可以进行服务访问。
eureka.client.service-url.defaultZone对应服务注册中心的配置内容，指定服务注册中心的位置。

启动成功后再次访问localhost:8888结果如下

eureka
当我们访问eureka-client中的localhost:8000/client可以获取当前服务清单：

注：
输出的信息eureka-client是通过Spring Cloud定义的DiscoveryClient接口在eureka的实现中获取到的所有清单列表。

三、服务消费者

在Spring Cloud Commons中提供大量的与服务治理相关的抽象接口，包括DidcoveryClient。这里我们介绍LoadBalancerClient负载均衡客户端的抽象定义。
创建一个服务消费工程eureka-consumer

plugins {
    id 'org.springframework.boot' version '2.1.3.RELEASE'
    id 'java'
}

apply plugin: 'io.spring.dependency-management'

group = 'com.example'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '1.8'

repositories {
    mavenCentral()
}

ext {
    set('springCloudVersion', 'Greenwich.SR1')
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-web'
    implementation 'org.springframework.boot:spring-boot-starter-actuator'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
    compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-eureka', version: '1.4.6.RELEASE'

}

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
    }
}

配置application.yml文件，指定eureka注册中心地址

spring:
  application:
    name: eureka-consumer

server:
  port: 8100

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8888/eureka/

创建应用主类。初始化RestTemplate,用来真正发起REST其请求。@EnableDiscoveryClient注解用来将当前应用加入到服务治理体系中。

package com.example.eurekaconsumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableDiscoveryClient
public class EurekaConsumerApplication {
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

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

创建一个接口用来消费eureka-client提供的接口

package com.example.eurekaconsumer.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class ConsumerController {
        @Autowired
        LoadBalancerClient loadBalancerClient;
        @Autowired
        RestTemplate restTemplate;

        @GetMapping("/consumer")
        public String dc() {
            ServiceInstance serviceInstance = loadBalancerClient.choose("eureka-client");
            String url = "http://" + serviceInstance.getHost() + ":" + serviceInstance.getPort() + "/client";
            System.out.println(url);
            return restTemplate.getForObject(url, String.class);
        }
}

注:

• 注入LoadBalancerClient和RestTemplate，并在接口中实现。通过LoadBalancerClient的choose函数来负载均衡选出一个eureka-client的服务实例。
• 服务实例的基本信息存储在ServiceInstance中。
  最后利用RestTemplate来调用服务提供者的接口。

通过访问http://localhost:8100/consumer

image.png