Spring Cloud Demo

本文介绍Spring Cloud 常用的组件的demo代码。gitee代码：https://gitee.com/Aes_yt/spring-cloud-demo

包括Spring Cloud Eureka，Spring Cloud Feign，Spring Cloud Hystrix，Spring Cloud Ribbon，Spring Cloud Zuul，Spring Cloud Config，Spring Cloud Sleuth。

Spring Cloud Eureka

Server

  1. pom引入：

    org.springframework.cloud    spring-cloud-starter-netflix-eureka-server

  2. 代码：

    SpringBootApplication 启动类加入 @EnableEurekaServer注解。

  3. 配置：

    server:  port: 8761eureka:  instance:    hostname: localhost  client:    register-with-eureka: false    fetch-registry: false    service-url:      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/  server:    wait-time-in-ms-when-sync-empty: 0    enable-self-preservation: false

Client

  1. pom引入：

    org.springframework.cloudspring-cloud-starter-netflix-eureka-client

  2. 代码：

    SpringBootApplication 启动类加入 @EnableDiscoveryClient注解。

  3. 配置：

    server:  port: 8081spring:  application:    name: demo-client1eureka:  client:    service-url:      defaultZone: http://localhost:8761/eureka/

TIPS. 非java语言也可使用Eureka提供的REST API接口接入Server。 wiki

常见问题

  1. 为什么服务上线了，Eureka Client 不能及时获取到。

    Eureka Server 的 REST API 有response cache，需要等缓存过期后才能更新数据。

  2. 为什么服务下线了，Eureka Server 接口返回的信息还会存在。

    应用实例异常挂掉，没有在挂掉之前告知Server 要下线。这个就需要依赖Eureka Server的EvictionTask 去剔除。

  3. 其他：

    springcloud对springboot的版本是有要求的，如果不一致，会启动不起来的。详细可以看官网的版本要求。

Spring Cloud Feign + Spring Cloud Hystrix

demo-hello

  1. 首先先创建一个 demo 的 module，接入Eureka配置（eureka-client ）。设置端口8082，里面只有一个get方法，我们用postman调用 http://localhost:8082/hello/testGet?param=hello，能够正常返回。

    @RestController@RequestMapping("/hello")@Slf4jpublic class HelloController {    @GetMapping("/testGet")    public BaseResp testGet(@RequestParam("param") String param) {        log.info("[demo-hello] testGet:{}", param);        return BaseResp.success(param);    }}

    yml:

    server:  port: 8082spring:  application:    name: demo-helloeureka:  client:    service-url:      defaultZone: http://localhost:8761/eureka/

feign-client

  1. 创建一个新module。引入Eureka-client依赖，feign依赖和hystrix依赖。

        org.springframework.cloud    spring-cloud-starter-netflix-eureka-client    org.springframework.cloud    spring-cloud-starter-openfeign    org.springframework.cloud    spring-cloud-starter-netflix-hystrix

    注意：hystrix 在 spring-cloud 2020.0.x 版本废弃，之后的版本推荐使用 Resilience4j 进行服务的熔断。

  2. yaml 配置

    server:  port: 8083spring:  application:    name: feign-clienteureka:  client:    service-url:      defaultZone: http://localhost:8761/eureka/feign:#  hystrix熔断开关  hystrix:    enabled: true#  feign-client的超时时间  client:    config:      default:        connect-timeout: 3000        read-timeout: 3000        logger-level: basic# 设置hystrix服务降级超时时间hystrix:  command:    default:      execution:        isolation:          thread:            timeoutInMilliseconds: 15000

  3. Application 注解

    @EnableFeignClients：@EnableFeignClients 是一个 Spring Cloud 注解，用于启用 Feign 客户端的功能。

    @EnableCircuitBreaker：@EnableCircuitBreaker 是 Spring Cloud 提供的一个注解，用于启用熔断器（Circuit Breaker）的功能。

    @SpringBootApplication@EnableDiscoveryClient@EnableFeignClients@EnableCircuitBreakerpublic class FeignClientApplication {    public static void main(String[] args) {        SpringApplication.run(FeignClientApplication.class, args);    }}

  4. 建立Feign调用Service

    @FeignClient(name = "demo-hello", contextId = "feign-hello", path = "/hello", fallbackFactory = FeignHelloServiceHystrix.class)public interface FeignHelloService {    @RequestMapping(value = "/testGet", method = RequestMethod.GET)    BaseResp testGet(@RequestParam("param") String param);}

    name = “demo-hello” 就是 demo 项目的 spring.application.name，contentxId 就相当于这个调用service的唯一id，path就是统一前缀。fallbackFactory 就是降级后的工厂。所以我们要实现这个工厂。

    我这边的逻辑，就是记录一下日志，然后返回统一的错误对象。

    @Slf4j@Componentpublic class FeignHelloServiceHystrix implements FallbackFactory {    @Override    public FeignHelloService create(Throwable cause) {        log.error("feign调用helloController报错", cause);        return new FeignHelloService() {            public BaseResp testGet(String param) {                return BaseResp.error(param);            }        };    }}

  5. 测试一下，

        @GetMapping("/testGet")    public BaseResp testGet(@RequestParam("param") String param) {//        try {//            Thread.sleep(6000);//        } catch (InterruptedException e) {//            throw new RuntimeException(e);//        }//        if(!param.isEmpty()){//            throw new RuntimeException("error...");//        }        log.info("[demo-hello] testGet:{}", param);        return BaseResp.success(param);    }

    testGet 6秒钟才响应或者直接抛出异常，都是会进入FeignHelloServiceHystrix中打印日志。

附加

  1. Feign 加日志打印

    1. xml配置Feign客户端

      # Feign 日志配置logging:  level:    com.yt.demo.service.feign: debug

    2. Feign 配置

      /** * Feign 配置 */@Slf4j@Configurationpublic class FeignConfig {    /**     * NONE:不记录任何信息     * BASIC:仅记录请求方法、URL以及响应状态码和执行时间.     * HEADERS:除了记录BASIC级别的信息外，还会记录请求和响应的头信息     * FULL:记录所有请求与响应的明细，包括头信息、请求体、元数据     */    @Bean    Logger.Level feignLoggerLevel() {        return Logger.Level.FULL;    }}

    3. 效果如下:

      2023-06-23 11:38:43.026 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] --> POST http://demo-hello/hello/testPost HTTP/1.12023-06-23 11:38:43.026 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] Content-Length: 302023-06-23 11:38:43.026 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] Content-Type: application/json2023-06-23 11:38:43.026 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] 2023-06-23 11:38:43.026 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] {"param":"Post method: hello"}2023-06-23 11:38:43.026 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] ---> END HTTP (30-byte body)2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] <--- HTTP/1.1 200 (2ms)2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] connection: keep-alive2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] content-type: application/json2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] date: Fri, 23 Jun 2023 03:38:43 GMT2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] keep-alive: timeout=602023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] transfer-encoding: chunked2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] 2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] {"code":200,"data":"Post method: hello","msg":"success"}2023-06-23 11:38:43.029 DEBUG 496 --- [ix-demo-hello-4] c.y.d.service.feign.FeignHelloService    : [FeignHelloService#testPost] <--- END HTTP (56-byte body)

  2. 文件上传

    1. feign Client 里面新增文件上传方法

          @RequestMapping(value = "/testFile", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE,            consumes = MediaType.MULTIPART_FORM_DATA_VALUE)    BaseResp testFile(@RequestPart("file") MultipartFile file);

      注意配置@RequestPart 注解，参数加上：produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.MULTIPART_FORM_DATA_VALUE

常见问题

  1. demo项目的方法返回报错，或者超时，都并没有进入熔断工厂。

    检查一下feign-client的hystrix是否启用： feign.hystrix.enabled: true

  2. 配置了feign-client的超时时间为3s，demo返回时间6s，但是1s就马上进入熔断工厂报超时，并没有等待3s。

    feign-client的超时时间和hystrix的超时时间都要配置。

  3. 配置了超时时间，但是还是不生效。

    根据你的cloud版本搜索一下，对应的配置怎么配。有可能不同版本的配置方法不一样，单词改变了之类的都是有可能的。

  4. feign调用报错：Load balancer does not have available server for client : xxx

    feign客户端的yaml配置加上 fetch-registry: true

    eureka:  client:    service-url:      defaultZone: http://localhost:8761/eureka/    fetch-registry: true

Spring Cloud Ribbon

demo-hello

  1. demo-hello 复用上面Feign的controller新增一个测试方法，打印出当前服务器端口

        @GetMapping("/testRibbon")    public BaseResp testRibbon(@RequestParam("param") String param, HttpServletRequest httpServletRequest) {        log.info("接收到请求，参数:{}, serverPort:{}", param, httpServletRequest.getServerPort());        return BaseResp.success("Response from server port: " + httpServletRequest.getServerPort());    }

  2. 启动项目，之后修改application.xml的端口号port，重新启动一个实例。

  3. 启动成功之后，在Eureka界面可以看到两个启动的实例。

    ApplicationAMIsAvailability ZonesStatus
    DEMO-HELLOn/a (2)(2)UP (2) – 192.168.0.101:demo-hello:8082 , 192.168.0.101:demo-hello:8084

ribbon-client

  1. 新建一个项目。[可以从Eureka-client复制，然后修改spring.application.name和pom文件的artifactId]。

  2. 引入ribbon依赖

        org.springframework.cloud    spring-cloud-starter-netflix-ribbon

  3. 新建ribbon配置类，重点是用@LoadBalance注解来声明restTemplate具有负载均衡能力。而且这样在使用restTeamplate的时候就能通过eureka上面的服务名来调用服务了，

    @Slf4j@Configurationpublic class RibbonConfig {    @Bean    @LoadBalanced    public RestTemplate restTemplate(){        return new RestTemplate();    }}

  4. 新建一个测试类，直接调用十次请求

    @RestController@RequestMapping("/client")@Slf4jpublic class HelloController {    @Autowired    private RestTemplate restTemplate;    @GetMapping("/testRibbon")    public BaseResp testRibbon(@RequestParam("param") String param) {        String url = "http://demo-hello/hello/testRibbon?param=" + param;        for (int i = 0; i < 10; i++) {            BaseResp resp = restTemplate.getForObject(url, BaseResp.class);            log.info("i-{}: {}", i, resp);        }        return BaseResp.success(null);    }}

  5. 返回结果：

    2023-06-23 15:42:40.802  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-0: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:42:40.805  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-1: BaseResp(code=200, data=Response from server port: 8082, msg=success)2023-06-23 15:42:40.807  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-2: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:42:40.810  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-3: BaseResp(code=200, data=Response from server port: 8082, msg=success)2023-06-23 15:42:40.812  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-4: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:42:40.814  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-5: BaseResp(code=200, data=Response from server port: 8082, msg=success)2023-06-23 15:42:40.818  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-6: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:42:40.820  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-7: BaseResp(code=200, data=Response from server port: 8082, msg=success)2023-06-23 15:42:40.824  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-8: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:42:40.826  INFO 7916 --- [nio-8085-exec-2] com.yt.demo.controller.HelloController   : i-9: BaseResp(code=200, data=Response from server port: 8082, msg=success)

    ribbon的默认负载均衡策略是ZoneAvoidanceRule，可以看出请求分别调到了8084和8082两个服务实例上。

  6. 负载均衡策略配置

    1. Ribbon内置的负载均衡规则：

      规则名称特点
      AvailabilityFilteringRule过滤掉一直连接失败的被标记为circuit tripped的后端Server，并 过滤掉那些高并发的后端Server或者使用一个AvailabilityPredicate 来包含过滤server的逻辑，其实就是检查status里记录的各个server 的运行状态
      BestAvailableRule选择一个最小的并发请求的server，逐个考察server， 如果Server被tripped了，则跳过
      RandomRule随机选择一个Server
      WeightedResponseTimeRule根据响应时间加权，响应时间越长，权重越小，被选中的可能性越低
      RetryRule对选定的负载均衡策略加上重试机制，在一个配置时间段内当 选择Server不成功，则一直尝试使用subRule的方式选择一个 可用的Server
      RoundRobinRule轮询选择，轮询index，选择index对应位置的Server
      ZoneAvoidanceRule复合判断Server所在区域的性能和Server的可用性 选择Server，在没有区域的环境下，类似于轮询(RandomRule)

    2. 修改策略为随机：

      RibbonConfig.java 新增配置[全局]

      /** * 配置轮询策略为RandomRule * 其他的策略配置也一样，策略类路径都是 com.netflix.loadbalancer.xxx */@Beanpublic IRule ribbonRule(){    return new RandomRule();}

      或：按服务粒度进行配置：(demo-hello 是目标服务的服务名)

      demo-hello:  ribbon:    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

      我直接配置全局的 ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule不生效，不知道是不是不支持全局配置。

      效果：

      2023-06-23 15:59:31.095  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-0: BaseResp(code=200, data=Response from server port: 8082, msg=success)2023-06-23 15:59:31.097  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-1: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:59:31.100  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-2: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:59:31.104  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-3: BaseResp(code=200, data=Response from server port: 8082, msg=success)2023-06-23 15:59:31.108  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-4: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:59:31.112  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-5: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:59:31.117  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-6: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:59:31.124  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-7: BaseResp(code=200, data=Response from server port: 8082, msg=success)2023-06-23 15:59:31.132  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-8: BaseResp(code=200, data=Response from server port: 8084, msg=success)2023-06-23 15:59:31.137  INFO 11492 --- [nio-8085-exec-3] com.yt.demo.controller.HelloController   : i-9: BaseResp(code=200, data=Response from server port: 8082, msg=success)

Spring Cloud Zuul

zuul-server

  1. 新建项目 [可以从Eureka-client复制，然后修改spring.application.name和pom文件的artifactId]。

  2. 引入Eureka-client依赖和zuul依赖

    org.springframework.cloudspring-cloud-starter-netflix-zuul

  3. 启动类加注解： @EnableZuulProxy

  4. application.yml 配置文件，加上zuul配置

    server:  port: 8888spring:  application:    name: zuul-servereureka:  client:    service-url:      defaultZone: http://localhost:8761/eureka/# 将 /demo-hello/ 开头的请求，转到demo-hello组件中zuul:  routes:    demo-hello:      path: /demo-hello/**      serviceId: demo-hello#      也可以直接设置url#      url: http://localhost:8082/

  5. 启动 demo-hello 组件，调用请求： http://localhost:8888/demo-hello/hello/testGet?param=this_is_param，demo-hello[8082] 得到结果。等同于直接调用demo-hello的请求：http://localhost:8082/hello/testGet?param=this_is_param

  6. 路由前缀

    zuul:  routes:    demo-hello:      path: /demo-hello/**      serviceId: demo-hello  prefix: /pre

    我们可以配置zuul.prefix来设置统一前缀。像我这样配置的话，就是得访问：http://localhost:8888/pre/demo-hello/hello/testGet?param=this_is_param，才能跟上面的请求等效。

  7. 屏蔽服务、路径

    zuul:  ignored-services: demo-hello  ignored-patterns: /**/hello/**

请求过滤

  1. 我们可以根据过滤规则，对访问的请求进行校验。不符合规则的可以直接过滤返回。比如我们可以校验请求的参数是否有token参数。

  2. 新建过滤器:

    @Slf4jpublic class AccessFilter extends ZuulFilter {    /**     * 过滤器类型     * pre: 在请求被路由前调用     * routing: 在路由请求时调用     * error: 在处理请求时发生错误时调用     * post: 在routing和error过滤器之后调用     */    @Override    public String filterType() {        return "pre";    }    /**     * 过滤器的执行顺序，数值越小越优先     */    @Override    public int filterOrder() {        return 0;    }    /**     * 是否启用过滤     */    @Override    public boolean shouldFilter() {        return true;    }    /**     * 具体过滤逻辑     */    @Override    public Object run() throws ZuulException {        RequestContext currentContext = RequestContext.getCurrentContext();        HttpServletRequest request = currentContext.getRequest();        log.info("zuul接收到请求，参数:{}", request.getParameterMap());        log.info("zuul接收到请求，参数:{}", request.getParameter("token"));        if (request.getParameterMap().get("token") == null) {            log.info("请求参数未包含token字段，返回");            currentContext.setResponseStatusCode(401);            currentContext.setSendZuulResponse(false);            return null;        }        log.info("正常请求，放行");        return null;    }}

  3. 创建bean

    @Slf4j@Configurationpublic class ZuulConfig {    @Bean    public AccessFilter accessFilter() {        return new AccessFilter();    }}

  4. 测试

    请求 http://localhost:8888/pre/demo-hello/hello/testGet?param=this_is_param&token=gyt%26kal13 可以正常调到demo-hello组件里的方法。

    请求http://localhost:8888/pre/demo-hello/hello/testGet?param=this_is_param返回401错误码

Spring Cloud Config

config-server

  1. 引入依赖

        org.springframework.cloud    spring-cloud-config-server

  2. 启动类添加注解 @EnableConfigServer

  3. bootstrap.yaml配置

    server:  port: 8086spring:  application:    name: config-server  cloud:    config:      server:        git:          uri: https://gitee.com/Aes_yt/spring-cloud-demo.git#          git 仓库的相对搜索路径          search-paths: config-repo          username: xxxx          password: xxxx          default-label: master

  4. git 配置

    第三点使用的是git配置，所以我们需要有一个git仓库。我已经事先建好了，配置文件放在git仓库的config-repo路径下。

    在config-repo上传配置文件，例如上传不同环境的三个配置文件：

    config-client.yaml

    config:  name: myConfig

    config-client-dev.yaml

    config:  name: myConfig-dev

    config-client-test.yaml

    config:  name: myConfig-test

    config-client 是我待会要创建的client项目的application.name，文件名的明明规则就是 {name}-{profile}.yaml 或 .properties。文件内容的配置文件就跟普通的yaml项目一样，配置所需要的一些配置，我这边是随便配置了一个变量名 ${config.name}，后面再输出打印测试。

  5. 先测试。启动config-server，访问地址 : http://localhost:8086/config-client/dev，可以看到输出配置信息。

    {"name": "config-client","profiles": ["dev"],"label": null,"version": "2ec77d4a4f8050fa5a032cf5ff27ff8583d3f663","state": null,"propertySources": [{"name": "https://gitee.com/Aes_yt/spring-cloud-demo.git/config-repo/config-client-dev.yaml","source": {"config.name": "myConfig-dev"}}, {"name": "https://gitee.com/Aes_yt/spring-cloud-demo.git/config-repo/config-client.yaml","source": {"config.name": "myConfig"}}]}

    也可以直接访问 http://localhost:8086/config-client-dev.yaml 查看yaml配置内容

    config:  name: myConfig-dev

config-client

  1. 引入maven依赖

        org.springframework.cloud    spring-cloud-starter-config

  2. bootstrap.yaml配置(我这里用application.yaml 配置启动会报错)

    spring:  application:    name: config-client  cloud:    config:      label: master#     config-server的地址      uri: http://localhost:8086/#      环境      profile: devserver:  port: 8087

  3. 新建一个测试类，检测配置值

    @RestController@RequestMapping("/config")public class ConfigTestController {    @Value("${config.name}")    private String configName;    @GetMapping("/test")    public String test() {        return configName;    }}

  4. 启动项目，能看到控制台输出，会打印出当前使用的配置信息

    2023-07-22 10:42:16.447  INFO 13592 --- [           main] c.c.c.ConfigServicePropertySourceLocator : Fetching config from server at : http://localhost:8086/2023-07-22 10:42:17.480  INFO 13592 --- [           main] c.c.c.ConfigServicePropertySourceLocator : Located environment: name=config-client, profiles=[dev], label=master, version=2ec77d4a4f8050fa5a032cf5ff27ff8583d3f663, state=null

    能看出当前环境是 name=config-client, profiles=[dev], label=master ，所以会去maven仓库找到master分支的 config-client-dev 的配置文件。如果找不到的话，在 @Value(“${config.name}”) 时则会报错。

  5. 测试，访问 http://localhost:8087/config/test

    myConfig-dev

结合Eureka

  1. 结合Eureka使用，首先server和client都要引入Eureka-client依赖，pom中引入spring-cloud-starter-netflix-eureka-client 。其次，启动类都要加上 @EnableDiscoveryClient 注解。最后yaml中都需要加上配置 eureka.client.service-url.defaultZone=http://localhost:8761/eureka/ ，这三个都可参考上文的Eureka-client配置。

  2. config-client加上discovery配置:

    spring:  application:    name: config-client  cloud:    config:      label: master      #     config-server的地址#      uri: http://localhost:8086/      #      环境      profile: dev#      使用eureka发现服务      discovery:        enabled: true        service-id: config-servereureka:  client:    service-url:      defaultZone: http://localhost:8761/eureka/server:  port: 8087

Spring Cloud Sleuth

Sleuth 能够对服务间调用的链路进行监控追踪，之前学习 Feign 的时候，我们用 Feign-client 组件，调用了 demo-hello 组件的testGet方法，所以我们可以在之前的Feign-client 和 demo-hello 组件的基础上进行修改验证，添加Sleuth依赖，来观察服务间的调用情况。

  1. 添加Sleuth依赖

  2. 运行，调用，观察打印的日志

    feign-client:

    2023-07-23 10:10:11.296 DEBUG [feign-client,f307a05d85938646,f8b404471ba7448a,true] 15956 --- [ix-demo-hello-5] 2023-07-23 10:10:11.296 DEBUG [feign-client,f307a05d85938646,f8b404471ba7448a,true] 15956 --- [ix-demo-hello-5] 2023-07-23 10:10:11.416 DEBUG [feign-client,f307a05d85938646,f8b404471ba7448a,true] 15956 --- [ix-demo-hello-5] ...

    demo-hello:

    2023-07-23 10:10:11.398  INFO [demo-hello,f307a05d85938646,51bf5d6b238302e9,true] 11736 --- [nio-8082-exec-1] com.yt.demo.controller.HelloController   : [demo-hello] testGet:Get method: hello

    可以从控制台的日志发现，日志多了[feign-client,f307a05d85938646,f8b404471ba7448a,true]部分，第一个参数代表application.name，第二个参数 f307a05d85938646 则是一个请求链路的 Trace ID，第三个参数f8b404471ba7448a表示SpanId，是一个基本的工作单元，第四个参数表示是否要将该信息输出到Zipkin等服务中来收集和展示。

    从feign-client 到 demo-hello 中， Trace ID 都是f307a05d85938646，所以可以将一个请求在不同服务中的日志串联起来。