投稿
  1. 半码博客首页
  2. 后端开发

SpringCloudAlibaba组件完整使用

小半 • • 后端开发 • 阅读 47

导读：本篇文章讲解 SpringCloudAlibaba组件完整使用，希望对大家有帮助，欢迎收藏，转发！站点地址：www.bmabk.com

SpringCloud 个大组件使用

一、Feign 自带日志配置 配置到消费者端

1、创建FeignConfig 配置类个级别 我使用的是最全的FULL模式

@Configuration
public class FeignConfing {
    
    @Bean
    Logger.Level feignLoggerLevel() {
        return Logger.Level.FULL;
    }

}

2、在YML 配置开启日志

#开启Feign客户端日志
logging:
  level:
    com.cloud.springcloud.service.PaymentFeginService: debug  #扫描的是你那个service的类全类名

二、Feign 超时配置

1、配置 在消费端 Feign调用默认就是一秒钟）

默认fegin客户端只等待一秒、但是服务端处理需要等待1秒中、导致fegin客户端不想等待了、直接返回报错、为了避免这样的情况、有时候我们需要设置fegin客户端的超时时间

需要在消费者 yml加入超时配置

#设置fegin客户端超时时间（OpenFegin 默认ribbon）
ribbon:
  #指的是建立连接所用的时间，适用于网络状态正常情况下、两端连接所用的时间
  ReadTimeout: 5000
  #指的是建立连接后从服务器读取到可用资源所用时间
  ConnecTimeout: 5000

三、feign 负载均衡

1、自带负载均衡、不需要配置任何东西、把生产者变成集群、比如 80、81 启动服务后、在88服务下通过Fegin客户端 RPC远程调用即可、可以打印一下端口号、确认是负载均衡

四、Ribbon 负载均衡

1、默认是轮询机制 、配置负载均衡 需要加一个配置类

如果不配置不生效 不加LoadBalanced 注解的话 就会报错、访问集群 他不知道找那个生产者

@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced  //8001--8002 集群之后 不知道找那个报错上面的错  需要开启负载均衡器
    // LoadBalanced 赋予 RestTemplate 负载均衡的能力  、调用使用的是 RestTemplate
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

2、更改 负载的算法 使用随机 添加随机算法的配置类 这个类要放到扫描的同等级目录不能被扫描到


@Configuration
public class MySelfRule {
    /**
     * 自定义负载均衡
     * @return
     */

    @Bean
    public IRule myRule() {
        return new RandomRule();   //随机轮询
    }
}
注意：然后 在启动类加上 这段注解、代表使用自定义配置、name 就是生产者的集群名称
@RibbonClient(name = "CLOUD-PAYMENT-SERVICE", configuration = MySelfRule.class)  //自定义随机

五、禁用自我保护机制 默认是true

1、注册中心 Eureka 配置、

eureka:
  server:
    enable-self-preservation: false  #禁用自我保护模式
    eviction-interval-timer-in-ms: 2000 #心跳时间 2秒
 
比如订单要注册到注册中心、需要在配置 、一秒发一次心跳、检查无心跳、立马剔除服务

 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
```java
在这里插入代码片

六、注意：就是配置Eureka 注册中心 注册进来的服务名称 不配置默认是你们电脑的主机名称、不显示ip的

需要配置的 参考我的 五、禁用自我保护机制 第二个配置 主机名的 就好了

七、服务降级之全局使用

  • 服务器忙、请稍后再试、不让客户端等待并立刻返回一个友好提示，fallback
  • 就是 返回友好提示 说等待几秒再试
  • 那些情况会发现服务降级

① 程序运行异常

② 超时

③ 服务熔断触发降级

④ 线程池/信号量打满也会导致服务降级

一、自定义全局降级 减少配置 —- 消费方 80 设置降级 （调用方）
启动类 上方 加入 @EnableHystrix 注解

YML配置  
#开启对feign的支持
feign:
  hystrix:
    enabled: true
/**
   自定义全局降级  减少配置
 * @ClassName HuangXiangXiang
 * @Date 2020/4/5 17:47
 * @Version V1.0
 **/

@RestController
@Slf4j          //@DefaultProperties **第一步**
@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod")  //全局的faback
public class OrderHystirxController {
    @Resource
    private PaymentHystrixService paymentHystrixService;
    /*
    * 这个是使用全局的降级
    */
    @GetMapping("/consumer/payment/hystrix/timeout1/{id}")
    @HystrixCommand  // **第二步 加这个注解**
    public String paymentInfo_TimeOut1(Integer id) {
        int i = 1 / 0;
        String result = paymentHystrixService.paymentInfo_TimeOut(id);
        return result;
    }


    //执行峰值时调用
    public String paymentInfo_TimeOutHandler(@PathVariable("id") Integer id) {
        return "我是消费者80,对方支付系统繁忙请10秒钟后再试或者自己运行出错请检查自己,o(╥﹏╥)o";
    }

    /**
            **第三步**
     * 自定义全局fallback 方法
     */
    public String payment_Global_FallbackMethod() {
        return "Global异常处理信息，请稍后重试，😂";
    }
}

七.一、自定义全局降级 减少配置

/** 单独方法设置降级
 * @ClassName HuangXiangXiang
 * @Date 2020/4/5 17:47
 * @Version V1.0
 **/

@RestController
@Slf4j
public class OrderHystirxController {

    @Resource
    private PaymentHystrixService paymentHystrixService;

    /**
     *  单独方法设置降级、客户端请求 3000 秒 相应超过3000
     * @param id
     * @return
     */

    @GetMapping("/consumer/payment/hystrix/timeout2/{id}")
    @HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler", commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")
    })
    public String paymentInfo_TimeOut2(Integer id) {
        int i = 1 / 0;   //测试程序出错跳转自定义
        String result = paymentHystrixService.paymentInfo_TimeOut(id);
        return result;
    }


    //执行峰值时调用
    public String paymentInfo_TimeOutHandler(@PathVariable("id") Integer id) {
        return "我是消费者80,对方支付系统繁忙请10秒钟后再试或者自己运行出错请检查自己,o(╥﹏╥)o";
    }

}

七.二、防止消费者调用生产者宕机 降级方法

/** 演示 生产者宕机 调用降级方法 控制器调用
 * @ClassName HuangXiangXiang
 * @Date 2020/4/5 17:47
 * @Version V1.0
 **/

@RestController
@Slf4j
public class OrderHystirxController {

    @Resource
    private PaymentHystrixService paymentHystrixService;

    @GetMapping("/consumer/payment/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id) {
        String result = paymentHystrixService.paymentInfo_OK(id);
        return result;
    }
}


/** 创建第一步
 * @auther hxx Fegin客户端   fallback 指引 调用失败的类
 * @create 2020-02-20 11:55
 */

@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT", fallback = PaymentFallbackService.class)
public interface PaymentHystrixService {

    @GetMapping("/payment/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id);

    @GetMapping("/payment/hystrix/timeout/{id}")
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id);
}


/** 创建第二步
 * @auther 代替 Fallback 方法 通配服务降级
 * 测试现在只能 解决 服务端宕机情况下 走进来   程序异常不会进来
 * @create 2020-02-20 18:22
 */
@Component
public class PaymentFallbackService implements PaymentHystrixService {
    @Override
    public String paymentInfo_OK(Integer id) {
        return "-----PaymentFallbackService fall back-paymentInfo_OK ,o(╥﹏╥)o";
    }

    @Override
    public String paymentInfo_TimeOut(Integer id) {
        return "-----PaymentFallbackService fall back-paymentInfo_TimeOut ,o(╥﹏╥)o";
    }
}

八、服务熔断之多种操作

类比保险丝达到最大服务后，直接拒绝访问、拉闸限电、然后调用服务降级的方法返回友好提示

—-这个融断只要达到最大值访问后、就会断路、返回友好提示、不会再像降级一样让你等待再试

服务降级 –》 进行熔断 –》 恢复调用链路
①就是保险丝
1 、生产方 熔断演示 (第一种熔断)

/**
 * @auther 生产方 熔断演示
 * @create 2020-02-20 11:15
 */
@RestController
@Slf4j
public class PaymentController {
    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;
    /**
     * 服务熔断
     *
     * @param id
     * @return
     */
    @GetMapping("/payment/circuit/{id}")
    public String paymentCircuitBreaker(@PathVariable("id") Integer id) {
        String result = paymentService.paymentCircuitBreaker(id);
        log.info("****result: " + result);
        return result;
    }
}

/**
 * @auther 自定义熔断
 * @create 2020-02-20 11:11
 */
@Service
public class PaymentService {

    /**
     * 服务熔断
     * @param id
     * @return
     */
    @HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback", commandProperties = {
            @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),// 是否开启断路器
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),// 请求次数
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"), // 时间窗口期
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60"),// 失败率达到多少后跳闸
    })
    public String paymentCircuitBreaker(@PathVariable("id") Integer id) {
        if (id < 0) {
            throw new RuntimeException("******id 不能负数");
        }
        String serialNumber = IdUtil.simpleUUID();
        return Thread.currentThread().getName() + "\t" + "调用成功，流水号: " + serialNumber;
    }
    public String paymentCircuitBreaker_fallback(@PathVariable("id") Integer id) {
        return "id 不能负数，请稍后再试，/(ㄒoㄒ)/~~   id: " + id;
    }

}

八.一、服务熔断之多种操作

2 、生产方 熔断演示   (第二种熔断)

/**
 * @auther hxx
 * @create 2020-02-20 11:15
 */
@RestController
@Slf4j
public class PaymentController {
    @Resource
    private PaymentService paymentService;

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


    @GetMapping("/payment/hystrix/timeout/{id}")
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id) {
        String result = paymentService.paymentInfo_TimeOut(id);
        log.info("*****result: " + result);
        return result;
    }

 
}


/**
 * @auther 设置 请求超过3秒 就走降级、
 * @create 2020-02-20 11:11
 */
@Service
public class PaymentService {
    @HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler", commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")
    })
    public String paymentInfo_TimeOut(Integer id) {
        int age = 10 / 0;
        try {
            TimeUnit.MILLISECONDS.sleep(0);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "线程池:  " + Thread.currentThread().getName() + " id:  " + id + "\t" + "O(∩_∩)O哈哈~" + "  耗时(秒): ";
    }

    //执行峰值时调用
    public String paymentInfo_TimeOutHandler(Integer id) {
        return "线程池:  " + Thread.currentThread().getName() + "  8001系统繁忙或者运行报错，请稍后再试,id:  " + id + "\t" + "o(╥﹏╥)o";
    }

}

九、服务限流

秒杀高斌发等操作、严禁一窝蜂的过来拥挤、大家排队、一秒中 N个、 有序进行

十、网关GateWay

①、yml配置 重点配置转发就是 这四行

  • id: payment_routh #payment_route
    uri: lb://cloud-payment-service
    predicates:
    – Path=/payment/get/**
 
server:
  port: 9527
 
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由
      routes:
        - id: payment_routh #payment_route    #路由的ID，没有固定规则但要求唯一，建议配合服务名
          #uri: http://localhost:8001          #匹配后提供服务的路由地址
          uri: lb://cloud-payment-service #匹配后提供服务的路由地址
          predicates:
            - Path=/payment/get/**         # 断言，路径相匹配的进行路由
        - id: payment_routh2 #payment_route    #路由的ID，没有固定规则但要求唯一，建议配合服务名
          #uri: http://localhost:8001          #匹配后提供服务的路由地址
          uri: lb://cloud-payment-service #匹配后提供服务的路由地址
          predicates:
            - Path=/payment/lb/**         # 断言，路径相匹配的进行路由
            #- After=2020-04-08T22:44:16.090+08:00[Asia/Shanghai]
            #- Cookie=username,zzyy    访问网关加 这个cookie 不加就报错 防止别人攻击
            #- Header=X-Request-Id, \d+  # 请求头要有X-Request-Id属性并且值为整数的正则表达式
eureka:
  instance:
    hostname: cloud-gateway-service
  client: #服务提供者provider注册进eureka服务列表内
    service-url:
      register-with-eureka: true
      fetch-registry: true
      defaultZone: http://eureka7001.com:7001/eureka

② 网管服务的 拦截、所有服务都从这里经过、可以设置一些验证

/**  网关必须实现 GlobalFilter, Ordered 
 * @auther hxx
 * @create 2020-02-21 16:40
 */
@Component
@Slf4j         
public class MyLogGateWayFilter implements GlobalFilter, Ordered {
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        log.info("***********come in MyLogGateWayFilter:  " + new Date());
 
        String uname = exchange.getRequest().getQueryParams().getFirst("uname");
 
        if (uname == null) {
            log.info("*******用户名为null，非法用户，o(╥﹏╥)o");
            exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);
            return exchange.getResponse().setComplete();
        }
 
        return chain.filter(exchange);
    }
 
    @Override
    public int getOrder() {
        return 0;
    }
}

② pom文件

pom文件
 
 <!--gateway-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>

十一、链路追踪

① 下载 jar网站

cmd 使用 java -jar 下载的包路径

① 加入 pom

  <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-zipkin</artifactId>
    </dependency>

② 把需要的服务加入到 上面启动的服务上

加入yml配置文件

#链路调用
zipkin:
base-url: http://localhost:9411
sleuth:
sampler:
#采样率值介于 0 到 1 之间，1 则表示全部采集
probability: 1
③ 显示链路追踪
在这里插入图片描述

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

文章由半码博客整理，本文链接：https://www.bmabk.com/index.php/post/15545.html

赞 (0)
小半的头像小半
0 0

相关推荐

半码博客——专业性很强的中文编程技术网站，欢迎收藏到浏览器，订阅我们！