learnSpringCloud

    Eureka 实现服务治理(服务注册与发现)

    Ribbon  提供客户测得软件负载均衡算法

    Hystrix 断路器 ，保护系统，控制故障范围

    Zuul  api 网关、路由、负载均衡等多种作用

    Config 配置管理  支持标签版本的配置环境

其中maven中dependencyManagement和dependencies区别
dependencyManagement里只是声明依赖，并不实现引入，因此子项目需要显式的声明需要用的依赖。如果不在子项目中声明依赖，是不会从父项目中继承下来的；只有在子项目中写了该依赖项，并且没有指定具体版本，才会从父项目中继承该项，并且version和scope都读取自父pom;另外如果子项目中指定了版本号，那么会使用子项目中指定的jar版本。
简言之 父类写一个dependencyManagement 对应的管理在子类中可以复用，默认则是复用父类的版本。

  1.建module  

  2.改pom 文件

  3.写yml 文件 

  4.主启动 

  5 .业务类

<!--        引入自己定义的api依赖包-->
        <dependency>
            <groupId>com.grapecc.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>

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

#  eureka  配置
eureka:
  client:
    # false 用于 不注册自己
    register-with-eureka: true
    #fasle 表示自己端就是注册中心
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

高可用

############StrpingCloud2021#################
127.0.0.1  eureka7001.com
127.0.0.1  eureka7002.com
127.0.0.1  eureka7003.com

#7001 的配置
eureka:
  instance:
    hostname: eureka7001.com
  client:
    # false 用于 不注册自己
    register-with-eureka: false
    #fasle 表示自己端就是注册中心
    fetch-registry: false
    service-url:
        #设置 与 Eureka server 交互的地址查询服务和注册服务都需要以来这个地址
      defaultZone: http://eureka7002.com:7002/eureka/

#  eureka  配置
eureka:
  client:
    # false 用于 不注册自己
    register-with-eureka: true
    #fasle 表示自己端就是注册中心
    fetch-registry: true
    service-url:
#      defaultZone: http://localhost:7001/eureka  单机版
       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

#      defaultZone: http://localhost:7001/eureka  单机版
       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

  instance:  #  和eureka下的client 平齐
    instance-id: payment8001

    prefer-ip-address: true   # 路径显示ip

  @Resource
    private DiscoveryClient discoveryClient;
    
     @GetMapping(value = "/payment/discovery")
    public Object discovery(){
        List<String> list = discoveryClient.getServices();
        for (String s : list) {
            System.out.println(s);
        }
        List<ServiceInstance> instances = discoveryClient.getInstances("cloud-payment-service");
        for (ServiceInstance instance : instances) {
           log.info(instance.getInstanceId()+"\t"+ instance.getHost()+"\t"
                   +instance.getPort());
        }
        return  this.discoveryClient;
    }

默认情况下，如果Eureka Server 在一定时间内没有收到某个微服务实例的心跳，Eureka Server 将会注销该实例（默认90秒）。但是网络分区故障发生时（延时、卡顿、拥挤）时，微服务和Eureka Server之间无法正常通信，以上行为可能变得非常危险了----------因为微服务本身其实是健康的。此时本不应该注销这个微服务。Eureka 通过"自我保护模式" 来解决这个问题-------当Eureka Server 节点在短时间内丢失过多客户端时（网络分区故障），那么节点进入故障模式。

综上所述宁可保护所有微服务，也不盲目注销任何健康的微服务

在eureka 注册中心模块 添加  一下配置 进行关闭自我保护机制
  server:
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 2000   # 默认时间为2000毫秒
    
在提供方 模块中进行 追加配置
  instance:
    instance-id: payment8001
    prefer-ip-address: true   # 路径显示ip
#    Eureka 客户端 向服务端 发送心跳的时间间隔 ，单位为秒(默认30秒)
    lease-renewal-interval-in-seconds: 1
#    Eureka服务端在收到最后一次心跳后等待时间上限，单位微妙(90秒)，超时将剔除服务
    lease-expiration-duration-in-seconds: 2

下载地址  https://www.consul.io/downloads
中文操作手册: https://www.springcloud.cc/spring-cloud-consul.html
安装后 相应目录中  调出dos命令   
consul --version
consul agent -dev   //启动命令

@Configuration
public class MySelfRule {

    @Bean
    public IRule getMyRule(){
        return new RandomRule();  //随机
    }
}

@RibbonClient(name = "cloud-payment-service",configuration = MySelfRule.class)

OpenFeign  定义 
feign是一个生命是的web服务客户端，让编写web服务客户端变动非常容易，只需创建一个接口并在接口上添加注解 

@FeignClient(value = "CLOUD-PAYMENT-SERVICE")   //服务名称
public interface PaymentFeignService {

    @GetMapping("/payment/get/{id}")
   CommonResult<Payment> getPayment(@PathVariable("id") Long id);
}

@RestController
@Slf4j
public class OrderFeignController {

    @Resource
    private PaymentFeignService paymentFeignService;

    @GetMapping("/consumer/payment/get/{id}")
   public CommonResult<Payment> getPayment(@PathVariable("id") Long id){
        CommonResult<Payment> payment = paymentFeignService.getPayment(id);
        return payment;
    }
}

## 设置feign 客户端超时时间
ribbon:
  ##是指 建立链接所用的时间  5000 ->五秒
  ReadTimeout: 5000
  ## 建立连接后从服务器上读取可用资源所用的时间
  Connectimeout: 5000

断路器定义
Hystrix 是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统里，许多依赖
主要用于服务降级 、 服务熔断、 接近实时监控
保证能够在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式系统的弹性。

@HystrixCommand(fallbackMethod = "payment_timeoutHandler",commandProperties = {
        @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="5000")
})
/// 并追加  payment_timeoutHandler方法  进行兜底

application.yml
#消费端开启 hystrix
feign:
  hystrix:
    enabled: true

@GetMapping("/consumer/payment/hystrix/timeout/{id}")
@HystrixCommand(fallbackMethod = "payment_timeoutHandler",commandProperties = {
        @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
})
public String paymentFeignTimeout(@PathVariable("id") Integer id){
    int  num = 10/0;
    String s = baseService.payment_timeout(id);
    return s;
}
public String payment_timeoutHandler(Integer id){
    return  "线程池:"+Thread.currentThread().getName()+"payment_timeoutHandler_id："+id+"耗时时间为超过5min";
}

@DefaultProperties(defaultFallback = "payment_global_fallbackMethod") ///标注通用的   已经指明的就使用指明得


//    @HystrixCommand(fallbackMethod = "payment_timeoutHandler",commandProperties = {
//            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="1500")
//    })
    @HystrixCommand

@SpringBootApplication
@EnableHystrixDashboard

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

cloud:
  gateway:
    routes:
      - id: payment_routh  #payment_route  路由id 没有固定的规则，要求唯一建议配合服务名
        uri: http://localhost:8001  #匹配后提供路由地址
        predicates:
          - Path=/payment/get/** 

dos 命令控制板  不带cookie
curl http://localhost:9527/payment/lb

带cookie 
curl http://localhost:9527/payment/lb --cookie "username=grape"

带请求头
curl http://localhost:9527/payment/lb -H "X-Request-Id:123"

  功能: 
              集中管理配置文件  

​             不同环境不同配置  动态化配置文件

​            运行期间动态调整配置 

​             当配置发生变化时，服务不需要重启即可感知配置的变化并应用的配置

​            将配置信息以rest接口形式弹出

使用自己账号在github上新建一个名为springcloud-config的新Repository
在当前的项目下D:\projectWork\javaWork\learn-spring-cloud\cloud2020  clone git项目地址
新建模块Module cloud-config-center-3344
它即为cloud的配置中心模块cloudConfig Center

server:
  port: 3344

spring:
  application:
    name: cloud-config-center
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/grapecc/springcloud-config.git
          ###搜索目录
          search-paths:
            - springcloud-config
        ##读取分支
        label: master

##服务注册到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

模块
cloudalibaba-config-nacos-client3377

为啥有两个配置文件
Nacos 彤 springcloud-config 一样 ，在项目初始化时，要保证 从配置中心进行配置拉取
拉去配置之后，才能保证项目的正常启动。

Data Id
# ${spring.application.name}-${spring.profile.active}.${spring.cloud.nacos.config.file-extension}
# nacos-config-client-dev.yaml

group

namespace

https://nacos.io/zh-cn/docs/cluster-mode-quick-start.html 参考文档

nacos\conf\nacos-mysql.sql 执行脚本 
然后nacos\conf\pplication.properties 更改配置

# spring.datasource.platform=mysql

### Count of DB:
# db.num=1
# db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTC
# db.user.0=nacos
# db.password.0=nacos


配置 cluster.conf 梳理三台nacos 集群的不同服务端口号
cp  nacos\conf\cluster.conf.example  cluster.conf
然后编辑 cluster.conf
添加  此处未ip 不能是127.0.0.1的ip
192.168.111.144:3333
192.168.111.144:4444
192.168.111.144:5555

修改start.sh 使它能够接受不同的启动端口号

while getopts ":m:f:s:" opt
do
    case $opt in
        m)
            MODE=$OPTARG;;
        f)
            FUNCTION_MODE=$OPTARG;;
        s)
            SERVER=$OPTARG;;
        ?)
        echo "Unknown parameter"
        exit 1;;
    esac
done


变更为  
while getopts ":m:f:s:p:" opt
do
    case $opt in
        m)
            MODE=$OPTARG;;
        f)
            FUNCTION_MODE=$OPTARG;;
        s)
            SERVER=$OPTARG;;
        s)
            port=$OPTARG;;
        ?)
        echo "Unknown parameter"
        exit 1;;
    esac
done


nohup $JAVA ${JAVA_OPT} nacos.nacos >> ${BASE_DIR}/logs/start.out 2>&1 &
变更为
nohup $JAVA-Dserver.port=${PORT}${JAVA_OPT} nacos.nacos >> ${BASE_DIR}/logs/start.out 2>&1 &