springCloud 待完结。。。。

什么是SpringCloud?
springCloud ,基于springBoot 提供了一套微服务解决方案，包括服务注册与发现，配置中心全链路监控，服务网关，负载均衡，熔断器等组件，除了基于netFlix 的开源组件做高度抽象封装之外，还有一些选型中立的开源组件
SpringCloud 利用SpringBoot 的开发便利性，巧妙地简化了分布式系统基础实施开发，SpringCloud 为开发人员提供了快速构建分布式系统的一些工具，包括配置管理，服务发现，断路器，路由，微代理，实际总线，全局锁，决策竞选，分布式会话等，都可以用Springboot 的开发风格做到一键启动和部署
SpringBoot 并没有重复造轮子，它只是将目前各家公司开发的比较成熟，经得起实际考验的服务框架组合起来，通过SpringBoot 风格再封装，屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂，易部署和易维护的分布式系统开发工具包
SpringCloud 是分布式微服务结构下的一站式解决方案，是各个微服务架构落地技术的集合体，俗称微服务全家桶。
SpringCloud 和SpringBoot 关系
Springboot 专注快速方便的开发单个个体微服务
SpringCloud 是关注全局的微服务协调整理治理框架，它将Springboot 开发的一个个单体微服务整合并管理起来，为各个微服务之间提供：配置管理，服务发现，断路器，路由，微代理，事件总线，全局锁，决策竞选分布式会话等等集成服务。
SpringBoot 可以离开Springboot 独立使用，开发项目，但是SpringCloud 离不开Springboot,属于依赖关系
Springboot 专注于快速，方便的开发个个体微服务，SpringCloud 关注全局的服务治理框架
Dubbo 和SpringCloud 对比
在这里插入图片描述
最大区别: SpringCloud抛弃了Dubbo的RPC通信,采用的是基于HTTP的REST方式。
严格来说，这两种方式各有优劣。虽然从- -定程度上来说，后者牺牲了服务调用的性能，但也避免了上面提到的原
生RPC带来的问题。而且REST相比RPC更为灵活，服务提供方和调用方的依赖只依靠- -纸契约，不存在代码级别的
强依赖，这在强调快速演化的微服务环境下，显得更加合适。
品牌机与组装机的区别
很明显，Spring Cloud的功能比DUBBO更加强大,涵盖面更广,而且作为Spring的拳头项目，它也能够与Spring
Framework、Spring Boot、Spring Data、Spring Batch等其他Spring项目完美融合,这些对于微服务而言是至
关重要的。使用Dubbo构建的微服务架构就像组装电脑，各环节我们的选择自由度很高，但是最终结果很有可能
因为一条内存质量不行就点不亮了，总是让人不怎么放心，但是如果你是一名高手，那这些都不是问题;而Spring
Cloud就像品牌机，在Spring Source的整合下，做了大量的兼容性测试,保证了机器拥有更高的稳定性，但是如
果要在使用非原装组件外的东西，就需要对其基础有足够的了解。
社区支持与更新力度
最为重要的是，DUBBO停止了5年左右的更新，虽然2017.7重启了。对于技术发展的新需求，需要由开发者自行
拓展升级(比如当当网弄出了DubboX),这对于很多想要采用微服务架构的中小软件组织，显然是不太合适的,
中小公司没有这么强大的技术能力去修改Dubbo源码+周边的一整套解决方案, 并不是每一个公司都有阿里的大牛
+真实的线上生产环境测试过。
总结:
曾风靡国内的开源RPC服务框架Dubbo在重启维护后，令许多用户为之雀跃,但同时，也迎来了一些质疑的声
音。互联网技术发展迅速, Dubbo是否还能跟上时代? Dubbo与Spring Cloud相比又有何优势和差异?是否会
有相关举措保证Dubbo的后续更新频率?
人物: Dubbo重启维护开发的刘军，主要负责人之一
刘军，阿里巴巴中间件高级研发工程师，主导了Dubbo重启维护以后的几个发版计划，专注于高性能RPC框架
Rest案例
实体类
在这里插入图片描述

单独把实体类写成一个api 接口。专业得事交给更专业得人
服务提供者
pom .xml

<dependencies>
<!--    拿到我们得实体类-->
    <dependency>
        <groupId>org.example</groupId>
        <artifactId>Springcloud-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>

    <!--           Springboot 启动器-->
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>1.3.2</version>
    </dependency>
    <!--     druid 连接池   -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.0.9</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.11</version>
    </dependency>





    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>RELEASE</version>
        <scope>compile</scope>
    </dependency>

</dependencies>

yml 得配置

server:
  port: 8001
  #mybatis 配置
mybatis:
  type-aliases-package: com.jj.pojo
#  config-location: classpath:mybatis/mybatis-config.xml
  mapper-locations: classpath:mybatis/mapper/*.xml
  #spring 得配置
spring:
  application:
    name: springcloud-proviser-dept-8001springcloud-proviser-dept
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT
    username: root
    password: 123456
    type: com.alibaba.druid.pool.DruidDataSource

mapper 类

package com.jj.mapper;

import com.jj.pojo.Dept;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * @author fjj
 * @date 2021/2/20 18:25
 */
@Mapper
@Repository
public interface Deptmapper {
    
    
    //添加
    public boolean adddept(Dept dept);
    //通过id 查询
    public Dept querybyid(int id);
    //全查
    public List<Dept> queryall();
}

mapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.jj.mapper.Deptmapper">
<!--    添加-->
    <insert id="adddept" parameterType="Dept">
        insert into dept(dname,db_source)
        values (#{dname},DATABASE())
    </insert>
<!--    通过id查询-->
    <select id="querybyid" resultType="Dept" parameterType="int">
        select * from dept where deptno =#{deptno}
    </select>
<!--    全查-->
    <select id="queryall" resultType="Dept">
        select * from dept
    </select>
</mapper>

service 层

package com.jj.service;

import com.jj.mapper.Deptmapper;
import com.jj.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author fjj
 * @date 2021/2/20 18:31
 */
@Service
public class Deptserviceimpl implements Deptservice {
    
    
   //注入
    @Autowired
   Deptmapper deptmapper;

    @Override
    public boolean adddept(Dept dept) {
    
    
        return deptmapper.adddept(dept);
    }

    @Override
    public Dept querybyid(int id) {
    
    
        return deptmapper.querybyid(id);
    }

    @Override
    public List<Dept> queryall() {
    
    
        return deptmapper.queryall();
    }
}

控制层

package com.jj.Controller;

import com.jj.pojo.Dept;
import com.jj.service.Deptserviceimpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;


/**
 * @author fjj
 * @date 2021/2/20 18:35
 */
@RestController
public class DeptController {
    
    
    //注入
    @Autowired
    private Deptserviceimpl deptserviceimpl;
    //添加
    @PostMapping("/dept/add")
    public boolean addDept(Dept dept){
    
    
        return  deptserviceimpl.adddept(dept);
    }
    //通过id 获取
    @GetMapping("/dept/get/{id}")
    public Dept get(@PathVariable("id") int id){
    
    
        return  deptserviceimpl.querybyid(id);
    }
    //全查
    @GetMapping("/dept/list")
    public List<Dept> queryAll(){
    
    
        return deptserviceimpl.queryall();
    }
}

消费者代码
写config 把注入到我们

package com.jj.demo.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * @author fjj
 * @date 2021/2/21 17:05
 */
@Configuration
public class Configbean {
    
    
@Bean
    public RestTemplate getRestTemplate(){
    
    
    return new RestTemplate();
}

}

控制层

package com.jj.demo.controller;

import com.jj.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.awt.*;
import java.util.List;

/**
 * @author fjj
 * @date 2021/2/21 17:03
 */
@RestController
public class DeptConsumer {
    
    
    //注入rest 模板
    @Autowired
   private RestTemplate rtstTemplate;
    //url
    private static final String url="http://localhost:8001";
    //全查
    @RequestMapping("/consumer/dept/list")
public List<Dept> list(){
    
    
        return rtstTemplate.getForObject(url+"/dept/list",List.class);
    }
    //通过id
    @RequestMapping("consumer/dept/get/{id}")
    public Dept getid(@PathVariable("id") int id){
    
    
        return rtstTemplate.getForObject(url+"dept/get/"+id,Dept.class);
    }
}

效果
在这里插入图片描述
Eureka 服务注册与发现
什么事eureka?
Netflix 在设计Eureka 时遵循得就是AP 原则
Eureka 是Netflix 得一个子模块，也是核心模块之一，Eureka 是一个基于rest 得服务，用于定位服务，以实现云端中间层服务发现和故障转移，服务注册与发现对于微服务来说是非常重要得，有了服务发现与注册，只需要使用服务得标识符，就可以访问到服务，而不需要修改服务调用得配置文件，功能类似于Dubbo 得注册中心，比如zookeeper

原理
Eureka 得基本架构
SpringCloud 封装了netflix 公司开发得Eureka模块来实现服务注册和发现（对比zookeeper）
Eureka 采用了c-s 得架构设计，Eurekaserver 作为服务注册功能得服务器，他就是服务注册中心，而系统中得其他微服务，使用Eureka客户端连接到Eurekaserver 并维持心跳连接，这也系统得为湖人员可以通过Eurekaserver 来监控系统中各个微服务是否正常运行，SPringlecloud 得一些其他模块，就可以通过Eurekaserver 来发现系统中得其他微服务，并执行相关得逻辑
Eureka 包含两个组件 Eurekaserver 和Eureka client
Eurekaserver 提供服务注册服务，各个节点启动后，会在Eurekaserver 中进行注册，这也Eurekaserver 中服务注册表中将会所有得服务节点得幸喜，服务节点得信息可以在界面中直观得看到。
EurekaClient 是一个java 客户端，用于简化Eurekaserver 得交互，客户端同时也具备一个内置得，使用轮询负载算法得负载均衡器，在应用启动后，将会向Eurekaserver 发送心跳，如果Eurekaserver 在多个心跳周期内没有接收到某个节点得心跳 Eurekaserver 将会从服务注册表中把这个服务节点移除掉

三大角色
Eurekaserver 提供服务得注册于发现 zookeeper
Eurekaprovider 将自身服务注册到Eureka中，从而使消费方能够找到
server consumer 服务消费方从Eureka中获取注册服务列表，从而找到消费者服务
导入jar 包

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

配置文件

server:
  port: 7001
#Eureka 配置
eureka:
  instance:
    hostname: localhost  #Eureka 服务端得实例名称
  client:
    fetch-registry: false  # 设置为flase 表示自己是注册中心
    register-with-eureka: false #表示是否向Eureka 注册中心注册自己
    service-url:
      defaultZone: http://${
    
    eureka.instance.hostname}:${
    
    server.port}/eureka/

在这里插入图片描述
注意版本一定要符合

eureka 得自我保护机制
自我保护机制：好死不如赖活着
默认情况下，如果EurekaServer 在一定时间内没有接收到某个微服务实例得心跳，Eureserver 将会注销该实例（默认90s）但是当网络分区故障发生时，微服务与Eureka 之间无法正常通行，以上行为可能变得非常危险了，因为微服务本身其实是健康得，此时不应该注销这个服务，Eureka 通过自我保护机制来解决这个问题。当Eurekaserver 节点在短时间内丢失过多客户端时（可能发生了网络分区故障）那么这个节点就会进入自我保护模式，一旦进入该模式，Eurekaserver 就会保护服务注册表中得信息，不在删除服务注册表中得数据（也就是不会注销任何微服务）当网络故障恢复后，该Eurekaserver 节点会自动退出自我保护模式
在自我保护中，Eurekaserver 会保护服务注册表中得信息，不在注销任何服务实例，当它收到得心跳数恢复到阈值以上时，该Eurekaserver 节点就会自动退出自我保护模式，他的设计哲学就是宁可保留错误得服务注册信息，也不盲目注销任何可能健康得服务实例。一句话好死不如赖活着

自我保护模式时一种应对网络异常得安全保护措施，它的架构哲学是宁可同时保留所有得微服务（健康服务和不健康得微服务都会保留）也不盲目注销任何健康得微服务，使用自我保护模式可以让Eureka集群更加得健壮和稳定

springCloud 待完结。。。。

猜你喜欢