微服务架构——笔记（4）

基于分布式的微服务架构
本次笔记为 此次项目的记录，便于整理思路，仅供参考，笔者也将会让程序更加完善
内容包括：8001集群构建，负载均衡，服务发现，Eureka自我保护

文章来源B站视频
尚硅谷SpringCloud框架开发教程(SpringCloudAlibaba微服务分布式架构丨Spring Cloud)教程
本次笔记内容为支付服务提供者8001集群环境构建

一、支付服务提供者8001集群环境构建

1.1 yml修改

server:
  port: 8002

spring:
  application:
    name: cloud-payment-service
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource  #当前数据源操作类型
    driver-class-name: org.gjt.mm.mysql.Driver                 #mysql驱动包
    url: jdbc:mysql://localhost:3306/db2023?useUnicode=true&&characterEncoding=utf-8&useSSL=false
    username: root
    password: tiger

eureka:
  client:
    # 表示是否将自己注册进eurekaserver默认为true
    register-with-eureka: true
    # 是否从eurekaserver抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合
    fetchRegistry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

mybatis:
  mapperLocations: classpath:mapper/*.xml
  type-aliases-package: com.liangstar.springcloud.entities   #所有Entity别名类所在包

1.2 启动修改

package com.liangstar.springcloud;

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

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

注：8002与8001完全相同，除了端口等

1.3 Controller修改

8001controller

@RestController
@Slf4j
public class PaymentController {
    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;

    @PostMapping(value = "/payment/create")
    public CommonResult create(@RequestBody Payment payment){
        int result = paymentService.create(payment);
        log.info("********插入结果"+result);
        if(result > 0){
            return new CommonResult(200,"插入数据库成功,serverPort:"+serverPort,result);
        }else{
            return new CommonResult(444,"插入数据库失败,serverPort:"+serverPort,null);
        }
    }

    @GetMapping(value = "/payment/get/{id}")
    public CommonResult getPaymentById(@PathVariable("id") Long id){
       Payment payment = paymentService.getPaymentId(id);
        log.info("@@@@@@@@查询结果"+payment);
        if(payment != null){
            return new CommonResult(200,"查询成功,serverPort:"+serverPort,payment);
        }else{
            return new CommonResult(444,"没有对应记录,查询Id"+id,null);
        }
    }
}

实际就添加了个来源声明，serverPort

1.4 负载均衡

coustmer中的controller初始状态为写死状态

但我们需要使用Eureka指明的服务端口。
通过Eureka识别服务名

第一步：修改OrderController

//    public static final String PAYMENT_URL = "http://localhost:8001";
    public static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";

第二步：修改Orderconfig，resttemplate添加@LoadBalanced注解

默认轮询

1.5 actuator微服务信息完善

主机名称服务名称修改：
访问信息有IP信息提示
8001、8002application.yml
添加instance与client对齐

  instance:
    instance-id: payment8001
    prefer-ip-address: true   #访问路径可以显示IP地址

1.6 服务发现Discovery

 @Resource
    private DiscoveryClient discoveryClient;

    @GetMapping(value = "/payment/discovery")
    public Object discovery(){
        List<String> services = discoveryClient.getServices();
        for(String element :services){
            log.info("******element******"+element);
        }
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        for (ServiceInstance instance : instances) {
            log.info(instance.getServiceId()+"\t"+instance.getHost()+"\t"+instance.getPort()+"\t"+instance.getUri());
        }
        return this.discoveryClient;
    }

启动类，添加注解

@EnableDiscoveryClient

二、Eureka自我保护

某时刻某一个微服务不可用了，Eureka不会立即清理，依旧对该微服务

2.1 关闭自我保护

自我保护版本：Eureka 相当于房东，或物业给客户端提供服务，当
用户拥堵，不能正常运行，会等待微服务重连重启等行为，一直连接不上会清理，会导致8001服务端宕机后，80无法快速切换找到新的可用微服务。
绝情版本：Eureka每天提供服务并无时无刻在收租，只要断供就立即关闭服务。

第一步7001：
禁用自我保护模式默认为true，人为改定false
自动心跳时间默认30秒，人为改定2000

eureka:
  instance:
    hostname: eureka7001.com #eureka服务端的实例名称
  client:
    #false表示不向注册中心注册自己
    register-with-eureka: false
    #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检查服务
    fetch-registry: false
    service-url:
      #设置与Eureka server交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://eureka7002.com:7002/eureka/
  server:
    #关闭自我保护
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 2000

第二步8001：

  instance:
    instance-id: payment8001
    # 访问路径可以显示IP地址
    prefer-ip-address: true
    # Eureka客户端向服务端发送心跳的时间间隔，单位为秒默认30
    lease-renewal-interval-in-seconds: 1
    # Eureka服务端在最后一个收到心跳等待时间上限，默认为90秒
    # 原来每天30天交房费，现在1天一交，2天一催缴
    lease-expiration-duration-in-seconds: 2