[Java知识库] 初学springcloud

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> 初学springcloud -> 正文阅读

[Java知识库]初学springcloud

1、什么是springcloud

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

注： springcloud不能算是一个技术，更像是一种生态

2、为什么要学习是springcloud

? ?随着时代的发展,需求越来越,传统的开发架构本质就是All in one，即一个项目作为一个整体进行开发和部署，整个项目需要作为一个整体部署在一台服务器上，当这一台服务器支持不了当前用户量的时候我们的解决办法就是"横向"的扩展服务器? ?

一台服务器不够就再加一台服务器，但是加上服务器之后就需要考虑负载均衡问题；说白了就是在服务器集群前面加一个程序，程序根据算法实现，用于保证后面的一大堆服务器被雨露均沾，不会出现一台服务器上的资源都要被耗光了，另一台服务器上的资源还没用的情况

所以为了解决这个问题，提出了新的开发架构 —— 微服务架构

但使用微服务架构会迎来许多新的问题。

微服务的四个核心问题？

服务很多，客户端怎么访问？
(怎么获取服务？设置注册中心，用户请求都发送到注册中心，再由注册中心分发用户请求到具体服务器)
这么多服务，服务之间如何通信？(服务之间怎么通信？)
这么多服务，如何管理？(对于这么多服务怎么统一管理？设置一个统一的服务管理平台，比如zookeeper)
服务挂了怎么办？(服务器崩溃、断电之后怎么应对？熔断机制)

微服务的四个核心问题的解决方案：
? ?Spring Cloud 是一套生态！专门用于解决微服务的四个核心问题的生态?

? ?学习SpringCloud的前提是学习SpringBoot，原因就是因为SpringCloud是基于SpringBoot的

3、springcloud有什么作用

1.SpringCloud NetFilx(第一套SpringCloud生态)

NetFilx公司推出了一套解决SpringCloud生态，或者说一站式解决微服务架构中问题的方案，我们要使用直接拿来使用即可

问题1：服务很多，客户端怎么访问?
- API网关，实现统一服务治理，使用zuul组件
问题2：这么多服务，服务之间如何通信？
- 网络通信都是基于HTTP的通信，NetFilx推出了一个自己对HTTP的包装版Feign(Feign基于HttpClient，HttpClient基于HTTP)，通信方式：同步并阻塞
问题3：这么多服务，如何管理？
- 服务注册与发现，使用插件Eureka解决
问题4：服务挂了怎么办？
- 熔断机制，Hystrix

springcloud提供了一套用来解决微服务面临的问题，上手很容易，可以满足大多数中小企业的需求?

4、springcloud和springboot有什么关系

1、springBoot专注于快速开发的开发单个个体微服务

2、springCloud是关注全局的微服务协调治理的框架，它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用Spring Boot的开发风格做到一键启动和部署。

3、springBoot可以离开springCloud独立使用，开发项目

?但springCloud离不开springBoot 属于依赖关系

springCloud主要有5大组件：

1、服务发现Netflix Eureka；

2、客服端负载均衡Netflix Ribbon；

3、断路器Netflix Hystrix；

4、服务网关Netflix Zuul；

5、分布式配置

1、服务注册与发现Netflix Eureka

? ? springCloud封装了Netflix公司开发的Eureka来实现服务注册和发现，

为什么使用服务注册和发现

? ? 在服务启动时，服务提供者会向注册中心注册服务，暴露自己的地址和端口等，注册中心会更新服务列表。服务消费者启动时会向注册中心请求可用的服务地址，并且在本地缓存一份提供者列表，这样即便注册中心宕机了，仍然可以正常调用服务。如果提供者集群发生变更，注册中心会将变更推送给服务消费者，更新可用的服务地址列表。

使用Netflix的步骤：

1、先导入需要的架包

2、编写配置类

3、在主程序中开启对eureka的支持

Netflix Eureka架包

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

?2、在application需要的配置

server:
  port: 7001


# Eureka配置
eureka:
  instance:
    a-s-g-name: localhost # Eureka服务端的实例名称
  client:
    register-with-eureka: false #表示是否向注册中心注册自己
    fetch-registry: false #fetch-registry如果为false，表示自己为注册中心
    service-url: #监控页面
      defaultZone: http://localhost:7002/eureka/,http://localhost:7003/eureka/ 
#在这里是注册服务器的地址，因为使用了集群所以有多个地址(如不使用集群地址为：http://localhost:7001/eureka)

3、在主启动类上加上注解（@EnableEurekaService）

package com.springcloud;

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

@SpringBootApplication
@EnableEurekaServer //表示EnableEurekaServer 服务端的启动类 可以让别人注册进来
public class EurekaService_7001 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaService_7001.class,args);
    }
}

到这里Eureka就好了，如果使用集群就重复写几个，只要改变端口号就行（如7002，7003......）

注：别忘记在注启动类上加注解。

下面需要写服务的提供者：

提供者需要注册到服务中

步骤：

1、先导入需要的架包

2、编写配置类

3、启动程序


<!--        eureka自动注册-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
<!--        实体类api是自己写的 更具自己的名字导入-->
        <dependency>
            <groupId>com.jie</groupId>
            <artifactId>springcloud-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-core</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-test</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
<!--        数据库连接池使用的是德鲁伊-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
        </dependency>
<!--        jetty和tomcat差不多-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jetty</artifactId>
        </dependency>
<!--        热部署工具-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
        </dependency>

2、application.yaml

server:
  port: 8001
#  mybatis配置
mybatis:
  type-aliases-package: com.springcloud.pojo
  mapper-locations: classpath:mybatis/mapper/*.xml
# spring配置
spring:
  application:
    name: springcloud-provider-dept
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    username: root
    password: 123456
    url: jdbc:mysql://localhost:3306/db01?useSSL=true&serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8
    driver-class-name: org.gjt.mm.mysql.Driver

#eureka配置
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/,http://localhost:7003/eureka/
  instance:
    instance-id: springcloud-provider-dept8001

提供者微服务使用mvc的三层架构访问数据库

?3、在主启动注解

//主启动类
@SpringBootApplication
@EnableEurekaClient
public class Dept_8001 {
    public static void main(String[] args) {
        SpringApplication.run(Dept_8001.class,args);
    }
}

写完后先启动 eureka 服务注册7001? ?在启动提供者8001

访问localhost:7001

?发现有Status 下UP（1）

说明提供者服务已经被注册到服务了

下面还需要写一个消费者微服务

步骤：

1、导入架包

2、配置application

3、主启动类注解

4、启动

        <dependency>
            <groupId>com.jie</groupId>
            <artifactId>springcloud-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
<!--        eureka-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>
    </dependencies>

2、application.yaml

server:
  port: 80

# eureka配置
eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/,http://localhost:7003/eureka/

3、主启动类

@SpringBootApplication
@EnableEurekaClient
public class Dbpt_consumer_80 {
    public static void main(String[] args) {
        SpringApplication.run(Dbpt_consumer_80.class,args);
    }
}

因为是消费者服务所以不能有service层只存在controller层用来调用数据

@RestController
public class ConsumerController {

    @Autowired
    private RestTemplate restTemplate;
//    ribbon在这里的地址 应该是一个变量 通过服务名访问
//    private static final String REST_URL_PREFIX="http://localhost:8001";
      private static final String REST_URL_PREFIX="http://SPRINGCLOUD-PROVIDER-DEPT";

    @RequestMapping("/consumer/add")
    public boolean addddd(Dbpt dbpt){
        return restTemplate.postForObject(REST_URL_PREFIX+"/add",dbpt,Boolean.class);
    }
    @RequestMapping("/consumer/queryId/{deptId}")
    public Dbpt queryId(@PathVariable("deptId") int deptId){
        return restTemplate.getForObject(REST_URL_PREFIX+"/queryId/"+deptId,Dbpt.class);
    }
    @RequestMapping("/consumer/query")
    public List<Dbpt> query(){
        return restTemplate.getForObject(REST_URL_PREFIX+"/query",List.class);
    }
}

这里使用了RestTemplate模板通过查看源码得知RestTemplate不在spring容器中，所以我们需要自己创建一个config类把RestTemplate注册到spring容器中。

@Configuration
public class BeanConfig { //@Configuration 相当于applicationContext.xml中的配置类
    @Bean
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

写完之后启动三个服务分别是：eureka：7001? 提供者：8001 消费者：80

通过访问消费者在服务中查找相应数据返回在浏览器上