SpringCloud学习笔记（一）-搭建一个SpringCloud

简介

摘自百度百科;
SpringCloud是一系列框架的有序集合。它利用SpringBoot的开发便利性巧妙地简化了分布式系统基础设施的开发;如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等;都可以用SpringBoot的开发风格做到一键启动和部署。SpringCloud并没有重复制造轮子;它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来;通过SpringBoot风格进行再封装屏蔽掉了复杂的配置和实现原理;最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。

反正SpringCloud是一个用来做微服务的框架;主要是基于SpringBoot来完成的;相关的微服务框架还有比较出名的Dubbo和DubboX。关于微服务是用来做什么的;有什么好处自行百度。

SpringCloud是Spring全家桶中的一员;所以SpringCloud对于Spring的其他组件都有着很好的支持。

SpringCloud主要采用的Eureka;Dubbo主要采用的是zookeeper。

上代码

provider 服务提供者

直接新建一个SpringBoot项目;由于是为了示例;本次示例中不使用数据库;只引入了spring-boot-starter-web

项目及其简单;只暴露了一个接口;用于测试;yml文件只配置了端口号为7900

consumer 服务消费者

同样新建一个SpringBoot项目;使其调用consumer的接口;同样只引入了spring-boot-starter-web;yml文件只是修改了端口号为7910。

这里解释一下RestTemplates这个类;关于这个类;这个老哥https://blog.csdn.net/u012702547/article/details/77917939的解释我觉得非常完整了;RestTemplates在SpringCloud中;消费者通过这个类访问生产者;;bean注解是为了实例化这个类;实例化之后通过;AutoWired注解引入;将其交给Spring进行管理。

分别启动两个类;分别访问localhost:7900/provider/demo和http://localhost:7910/consumer/demo应该都能得到ProviderDemo这个结果;说明consumer成功调用了provider中的方法。

问题;
这样的编码方式是将接口;http://localhost:7900/provider/demo;硬编码在代码中;但是项目发布之后;ip地址必然是变动的。而且;硬编码的方式肯定是无法实现负载均衡的;就是说如果同时启动多个provider服务;这种硬编码方式是无法根据负载均衡策略去调用服务的。

解决方法;
在Dubbo中使用的ZooKeeper作为服务注册与发现的容器;在Springcloud中使用的是Eureka作为服务注册与发现的容器。

Eureka

同样创建一个SPringBoot项目;下面是pom.xml文件;我是在idea中直接添加spring-cloud-starter-netflix-eureka-server这个依赖的。

<?xml version=;1.0; encoding=;UTF-8;?>
<project xmlns=;http://maven.apache.org/POM/4.0.0; xmlns:xsi=;http://www.w3.org/2001/XMLSchema-instance;
    xsi:schemaLocation=;http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd;>
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.edu.nuaa</groupId>
    <artifactId>eureka-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>eureka-demo</name>
    <description>eureka-demo</description>

    <parent>
        <groupId>org.springFramework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
    </properties>

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

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

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

;SpringBootApplication
;EnableEurekaServer
public class EurekaDemoApplication {

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

server:
  port: 8761
eureka:
  client:
    register-with-eureka: false
    fetch-registry: false
    service-url:
      defaultZone: http://localhost:8761/eureka/

${spring.cloud.client.hostname}:${spring.application.name}:${spring.application.instance_id:${server.port}}

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

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
    <version>RELEASE</version>
</dependency>

;SpringBootApplication
;EnableEurekaClient
public class ProviderDemoApplication {

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

server:
  port: 7900
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

spring:
  application:
    name: provider-demo

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
  instance:
    lease-renewal-interval-in-seconds: 1
    lease-expiration-duration-in-seconds: 2

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

management:
  endpoints:
    web:
      exposure:
        include: ;*;

;RestController
public class ConsumerController {

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

    ;Autowired
    private RestTemplate restTemplate;

    ;RequestMapping(;/consumer/demo;)
    public String ConsumerDemo(){
        return this.restTemplate.getForObject(;http://provider-demo:7900/provider/demo;, String.class);
    }

}

 ;Autowired
 private LoadBalancerClient loadBalancerClient;

 ;RequestMapping(;/consumer/getInterfaceInfo;)
 public void getInterfaceInfo(){
     ServiceInstance choose = loadBalancerClient.choose(;provider-demo;);
     System.out.println(choose.getPort());
 }

7901
7900
7901
7900
7901
7900
7901
7900
7901
7900
7901

#服务提供者的名字
provider-demo:  
  ribbon:
    # 所要采用的策略
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule