springcloud-2

短命女 2021-12-11 23:39 100阅读 0赞

容错：Hystrix  
spring-cloud-starter-hystrix，@EnableCircuitBreaker或@EnableHystrix（两者一样）

@GetMapping("/consumer")
        @HystrixCommand(fallbackMethod="fallbackM")
        public String consume() {
            return dCClient.consume();
        }
        public String fallbackM() {
            return "fallback";
        }

1 @HystrixCommand为consume方法提供降级逻辑，若里面发生异常如调用接口超时，调用fallbackMethod指定的方法  
2 @HystrixCommand实现了依赖隔离，每个@HystrixCommand定义了一个线程池，这样我们各接口的调用和并发度的控制可以做到互不影响，若execution.isolation.strategy设置为SEMAPHORE，不使用线程池即接收请求后在当前线程执行，信号量开销小，不能实现异步和设置超时，无线程池隔离安全性就差，仅做并发控制  
3 @HystrixCommand实现了断路器，当在快照时间窗（最近10秒）请求超过请求总数下限（默认为20）且错误超过错误百分比下限（默认50%），断路器打开，即后续请求直接调用降级逻辑，当休眠时间窗到期，释放一次请求到主逻辑，若主逻辑恢复，则断路器闭合完全恢复，若主逻辑尚未恢复，重新计时休眠时间窗

Hystrix监控面板：spring-cloud-starter-hystrix-dashboard，spring-cloud-starter-hystrix，spring-boot-starter-actuator  
@EnableHystrixDashboard，此监控面板应用可抓取某集群（这里的集群需要通过Turbine实现）或单个实例的Hystrix数据（Delay设置抓取时间间隔）

Zuul网关应用：权限控制，路由，负载均衡，过滤等各种功能  
spring-cloud-starter-zuul，@EnableZuulProxy

zuul.routes.user-service.path=/user-service/**   
    zuul.routes.user-service.url=http://localhost:8080/ //path匹配，则适用user-service这条路由规则，此规则定位到localhost:8080
    
    zuul.routes.user-service.path=/user-service/**
    zuul.routes.user-service.serviceId=user-service //path匹配，适用user-service规则，此规则定位到user-service服务
    
    zuul.routes.user-service=/user-service/** //同上，简写
    
    ribbon.eureka.enabled=false
    user-service.ribbon.listOfServers=http://localhost:8080/,http://localhost:8081/  //当定位到user-service服务后，不想或无法使用服务发现，也可这样定义服务地址
    
    默认路由规则，截取URI第一部分为访问的服务

ZuulFilter：filterType如pre，filterOrder，shouldFilter，实现后可通过在@Configuration类的@Bean方法加入ApplicationContext

Swagger：提供文档化功能，swagger-spring-boot-starter，@EnableSwagger2Doc，  
swagger.base-package=com.xu 此package下的Controller才会被生成文档，通过/swagger-ui.html访问此应用的文档  
应用的文档分散，可通过在网关统一获取各应用文档，需实现SwaggerResourcesProvider并注册入BeanFactory

Spring Cloud Stream：消息驱动，支持rabbitmq和kafka，高层概念：输入通道，输出通道和Binder  
应用只和通道打交道，从输入通道读，写到输出通道，通道操作如何映射到具体消息中间件上是Binder实现的，即如果新加一种消息中间件，只需实现对应Binder  
spring-cloud-starter-stream-rabbit

@EnableBinding(Sink.class) // Sink接口在方法上含@Input("input")，绑定了input这条输入通道
    public class SinkReceiver {
        @StreamListener("input") //在input这条输入通道上监听消息
        public void receive(Object payload) {
           //
        }
    }

Topic：发布-订阅模式的一般概念，rabbitmq使用topic exchange实现

spring.cloud.stream.bindings.input.destination=greetings //input 通道映射到greetings 这个topic，默认通道名为topic名
    spring.cloud.stream.bindings.input.group=Service-A // 应用在input 通道的Service-A消费组内，同一消费组只有一个实例能接收到消息，rabbitmq放在同一队列下

消息分区：相同特征的消息被消费组内同一个实例进行消费，rabbitmq放在不同队列了，即未消息分区的消费组在同一队列，消息分区的消费组在不同队列但是bindingkey不同

spring.cloud.stream.bindings.input.consumer.partitioned=true //接收端
    spring.cloud.stream.instanceCount=2
    spring.cloud.stream.instanceIndex=0
    
    spring.cloud.stream.bindings.output.producer.partitionKeyExpression=payload //发送端
    spring.cloud.stream.bindings.output.producer.partitionCount=2

sleuth进行服务追踪，本质还是TraceId（root），SpanId，ParentSpanId进行串联，请求头发送，线程本地保存