SpringCloud 实践笔记-Eureka Client服务提供优化(五)

系统管理员 2022-01-12 09:13 138阅读 0赞

## 服务提供与消费-熔断-服务追踪 ##

## 1、一般使用结构 ##

common 是公共模块，需要导入的公共包，需要使用的公共类等

client 本服务，对外开放的调用方法（其他服务直接导入这个包，就能调用方法。贼方便！！）

server 本地服务业务逻辑，也可以内部又调用其他服务的 client方法（一般是一个服务固定使用维护一个数据库，其他需要访问这个数据库的都调用这个服务对外开放的接口）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1NDE4NTE4_size_16_color_FFFFFF_t_70][]

##  2、server 服务提供者（这里我就直接把熔断加进去了） ##

*  pom配置

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

*  yml配置 
    
     *  bootstrap.yml
 *      spring:
          cloud:
            config:
              discovery:
                enabled: true
                service-id: CONFIG
              profile: dev
              name: clientUser,datasource,rabbitmq
              label: master
        eureka:
          client:
            service-url:
              defaultZone: http://localhost:8761/eureka/
    
    配置中心的：clientUser-dev.yml 
    
        spring:
          application:
            name: client-user
                
        eureka:
          client:
            service-url:
              defaultZone: http://localhost:8761/eureka/
        server:
          port: 8601
        PRODUCT:
          ribbon:
            # 均衡荷载策略，调用方,里面的规则都是实现IRule 接口
            NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
        msg:
          name: 李黑
    
    启动类添加  @SpringCloudApplication（内含@SpringBootApplication，@EnableDiscoveryClient 代表客户端提供者，@EnableCircuitBreaker 熔断）
 *  提供服务

@RestController
    @RefreshScope   //用与配置中心刷新使用
    public class UserMsgController {
    
    
        @Value("${server.port}")
        private int port;
    
        @Value("${msg.name}")
        private String msg;
    
        @RequestMapping("/findById")
        public String findById(@RequestBody int id){
            if(id == 1){
                return "李斯";
            }else if(id == 2){
                return "宙斯";
            }
            return "没有找到！！";
        }
    
        @RequestMapping("/port")
        public String getPort(){
            return "order-port:" + port + "msg:" + msg;
        }
    }

3、服务调用者client

pom添加依赖

<dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-web</artifactId>
            </dependency>
        </dependencies>

需要使用的接口

@FeignClient(name = "client-user")
    public interface UserClient {
    
        @PostMapping("/findById")
        String findById(@RequestBody int id);
    
        @PostMapping("/port")
        String getPort();
    }

启动类添加EnableFeignClients

@SpringCloudApplication
    @EnableFeignClients(basePackages = "com.gray")
    public class UserOpenInterfaceApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserOpenInterfaceApplication.class, args);
        }
    
    }

直接注入调用

public class UserOpenInterfaceApplicationTests {
    
        @Autowired
        UserClient userClient;
    
        public void contextLoads() {
            String find = userClient.findById(1);
            System.out.println(find);
            String port = userClient.getPort();
            System.out.println(port);
        }
    }

## 3、熔断**（就是当调用的方法，无法返回或者超时，直接返回临时错误消息提示）** ##

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

*  我理解的就两种情况：服务提供者。1、提供的方法超时。2、提供的方法报错
 *  添加位置也是两种：1、设置在服务提供者方法上。2、设置在消费者方法上  （我比较喜欢第二种，当提供者服务挂了仍能返回值）

配置中开启熔断（降级设置在谁身上，这个添加在哪里）

feign:
      hystrix:
        enabled: true

设置超时时间，默认是1秒 （降级设置在谁身上，这个添加在哪里）

hystrix:
      command:
        default: # 统一超时时间配置，调用方法必须加上@HystrixCommand 注解
          execution:
            isolation:
              thread:
                timeoutInMilliseconds: 3000

添加在消费者方法上

就是实现消费方法

@Component
    public class UserClientError implements UserClient {
    
        @Override
        public String findById(int id) {
            return "服务发生故障！";
        }
    
        @Override
        public String getPort() {
            return "服务发生故障！";
        }
    }

消费方法添加一个fallback 指定上面，调用失败时，使用的实例方法

@FeignClient(name = "client-user",fallback = UserClientError.class)
    public interface UserClient {
    
        @PostMapping("/findById")
        String findById(@RequestBody int id);
    
        @PostMapping("/port")
        String getPort();
    }

启动类，这就是一个坑，，嗨，可能只有我被坑吧！

不使用SpringCloudApplication 是应为指定不了扫描范围，应为我的消费方法 是引入的接口类，路径不再当前目录内。

添加熔断后，必须指定调用方法的路径。

当原服务报错或者超时 就会返回：服务发生故障！

@EnableFeignClients(basePackages = "com.gray")
    //@SpringCloudApplication
    @SpringBootApplication(scanBasePackages = "com.gray")
    @EnableDiscoveryClient
    @EnableCircuitBreaker
    public class UserOpenInterfaceApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserOpenInterfaceApplication.class, args);
        }
    }

添加在提供者上

单个方法降级（findById 异常或超时，返回fallback）

@RestController
    @RefreshScope
    public class UserMsgControllerBase {
    
        @Value("${msg.name}")
        private String msg;
    
        @HystrixCommand(fallbackMethod = "fallback")
        @RequestMapping("/findByIdBase")
        public String findById(@RequestBody int id){
    
            if(id == 1){
                return "李斯";
            }else if(id == 2){
                return "宙斯";
            }
                    int ss = 2/0;
            return "没有找到！！";
        }
    
    
        private String fallback(@RequestBody int id) {
            return "太拥挤了, 请稍后再试~~" + id;
        }
    }

类方法降级，需要降级的方法一定要加    @HystrixCommand

@RestController
    @RefreshScope
    @DefaultProperties(defaultFallback = "defaultFallback")
    public class UserMsgControllerBase {
    
        @Value("${server.port}")
        private int port;
    
        @Value("${msg.name}")
        private String msg;
    
        @RequestMapping("/findByIdBase")
        @HystrixCommand
        public String findById(@RequestBody int id){
    
            if(id == 1){
                return "李斯";
            }else if(id == 2){
                return "宙斯";
            }
                    int ss = 2/0;
            return "没有找到！！";
        }
    
        @RequestMapping("/portBase")
        @HystrixCommand
        public String getPort(){
            return "order-port:" + port + "msg:" + msg;
        }
    
        private String defaultFallback() {
            return "默认提示：太拥挤了, 请稍后再试~~";
        }
    }

这里的服务内调用方法用的是@RequestBody 或者值，给外部的url用的是@Valid

同一个服务使用2个相同的消费者会报错

熔断器（下例：服务在10此调用中，失败率达到百分之60，开始熔断，返回错误信息。等10秒后，开启一小部分调用，如果服务能成功返回，关闭熔断，倒计时重新开始计时）（这个也是两边都能设置）

指定方法熔断

@RestController
    @DefaultProperties(defaultFallback = "defaultFallback")
    public class HystrixController {
    
    
    	@HystrixCommand(commandProperties = {
                            //设置熔断 （开关）
    			@HystrixProperty(name = "circuitBreaker.enabled", value = "true"),  	
    			//请求数达到后才计算 （每10次计算统计一次熔断）
    			@HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),	    
                            //熔断时间 （关闭倒计时）
    			@HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"),    
                            //错误率 
    			@HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60"),	
    	})
    	@HystrixCommand
    	@GetMapping("/getProductInfoList")
    	public String getProductInfoList(@RequestParam("number") Integer number) {
    		if (number % 2 == 0) {
    			return "success";
    		}
    
    		RestTemplate restTemplate = new RestTemplate();
    		return restTemplate.postForObject("http://127.0.0.1:8005/product/listForOrder",
    				Arrays.asList("157875196366160022"),
    				String.class);
    
    //		throw new RuntimeException("发送异常了");
    	}
    
    	private String defaultFallback() {
    		return "默认提示：太拥挤了, 请稍后再试~~";
    	}
    }

配置参考博客

[https://blog.csdn.net/hry2015/article/details/78554846][https_blog.csdn.net_hry2015_article_details_78554846]

这个配置我试了下（通用配置），circuitBreaker貌似没生效，超时时间是能用的

hystrix:
      command:
        default:
          execution:
            isolation:
              thread:
                timeoutInMilliseconds: 2000
          circuitBreaker:
            enabled: true;
            requestVolumeThreshold: 10
            sleepWindowInMilliseconds: 1000
            errorThresholdPercentage: 60

## 服务追踪sleuth ##

网站 ：[https://zipkin.io/][https_zipkin.io]

*  拉取 docker pull openzipkin/zipkin
 *  安装 docker run -d -p 9411:9411 openzipkin/zipkin
 *  访问 [http://192.168.1.16:9411/zipkin/][http_192.168.1.16_9411_zipkin]     查看可视化追逐界面

1、pom 依赖 starter-zipkin里面包含了starter-sleuth和sleuth-zipkin

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

2、yml配置添加 添加[zipkin][https_zipkin.io]按照好的路径，并且设置获取数据概率（默认是百分之10，probability = 0.1）

spring:
      zipkin:
        base-url: http://192.168.1.16:9411/
      sleuth:
        sampler:
          probability: 1

3、额外说明 sleuth 追踪的是 http访问，然后多台服务间访问

Zipkin是一种分布式跟踪系统。它有助于收集解决微服务架构中的延迟问题所需的时序数据。它管理这些数据的收集和查找。Zipkin的设计基于Google Dapper论文。

应用程序用于向Zipkin报告时序数据。Zipkin UI还提供了一个依赖关系图，显示了每个应用程序通过的跟踪请求数。如果要解决延迟问题或错误，可以根据应用程序，跟踪长度，注释或时间戳对所有跟踪进行筛选或排序。选择跟踪后，您可以看到每个跨度所需的总跟踪时间百分比，从而可以识别问题应用程序。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1NDE4NTE4_size_16_color_FFFFFF_t_70]: /images/20220109/053a499e13a042c4bff2a5ac09a2d6da.png
[https_blog.csdn.net_hry2015_article_details_78554846]: https://blog.csdn.net/hry2015/article/details/78554846
[https_zipkin.io]: https://zipkin.io/
[http_192.168.1.16_9411_zipkin]: http://192.168.1.16:9411/zipkin/