springcloud微服务全家桶实战

港控/mmm° 2022-02-12 14:13 408阅读 0赞

springcloud微服务实战:Eureka+Zuul+Feign/Ribbon+Hystrix Turbine+SpringConfig+sleuth+zipkin

注意:这篇文章是基于springboot1.x老版本springcloud，springboot2.x的springcloud（Finchley之后）新版本文章，请移步升级版专贴

相信现在已经有很多小伙伴已经或者准备使用springcloud微服务了，接下来为大家搭建一个微服务框架，后期可以自己进行扩展。会提供一个小案例： 服务提供者和服务消费者 ，消费者会调用提供者的服务，新建的项目都是用springboot，附源码下载，推荐使用coding地址下载，因为可以切换分支，后期可以及时更新。

coding仓库地址（推荐下载）： coding地址 csdn下载地址： csdn下载地址 远程配置仓库地址 远程配置仓库地址

如果有问题请在下边评论，或者200909980加群交流。

Eureka/Consul：服务发现 （根据情况选择一个）
Hystrix：断路器
Zuul：智能路由
Ribbon/Feign：客户端负载均衡 （Feign用的更多）
Turbine：集群监控
Springcloud-config：远程获取配置文件

img\_6212d40de15eb7e796d4ba8f53753dd3.png

这里写图片描述

接下来，我们开始搭建项目，首先我们到spring为我们提供的一个网站快速搭建springboot项目，点击访问，我这里用的是gradle，如果各位客官喜欢用maven，好吧你可以到http://mvnrepository.com/查看对应的依赖，点我访问。

一、搭建eureka-server服务springcloud-eureka-server

使用 spring-cloud-consul 作为服务发现 请参考 点击查看使用springcloud consul 作为服务发现

eureka-server作为服务发现的核心，第一个搭建，后面的服务都要注册到eureka-server上，意思是告诉eureka-server自己的服务地址是啥。当然还可以用zookeeper或者springconsul。

img\_5932ecdae9ae9704f4052d6302b83371.png

这里写图片描述

  • 1.修改build.gradle文件

如果是maven项目请对应的修改pom.xml

  1. //加入阿里的私服仓库地址
  2. maven { url "http://maven.aliyun.com/nexus/content/groups/public/" }
  4. //加入依赖  
  5. compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-eureka-server', version: '1.3.4.RELEASE'
  6. //加入security，是因为访问eureka-server需要用户名和密码访问，为了安全
  7. compile group: 'org.springframework.boot', name: 'spring-boot-starter-security', version: '1.5.6.RELEASE'

还有几点需要修改的，大家对应图片看看，就是springboot打包的时候会提示找不到主累。

img\_fac8b8b4f8b01419f98dc6f313a0230c.png

这里写图片描述

  • 2.修改 application.yml，建议用yml。

    server:
    port: 8761
    eureka:
    datacenter: trmap
    environment: product
    client:

    1. healthcheck:
    2.   enabled: true
    3. service-url:
    4.   defaultZone: http://root:booszy@localhost:8761/eureka
    5. register-with-eureka: false #关闭自己作为客户端注册
    6. fetch-registry: false

    security:
    basic:

    1. enabled: true

    user:

    1. name: root #用户名和密码，等会访问的时候，会要求你登录，服务注册的时候也需要带着用户名和密码
    2. password: booszy

  • 3.修改程序的主类，建议修改类名，要加如eureka的 @EnableEurekaServer 注解，然后运行main方法。

    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaServerApplication {

    1. public static void main(String[] args) {
    2.     SpringApplication.run(EurekaServerApplication.class, args);
    3. }

    }

img\_64e722c44e03db8732f9ee8b441d5597.png

这里写图片描述

http://localhost:8761/ 这个是eureka-server的页面地址，到这里，说明eureka-server搭建好了，简单吧，这一步一定要成功，否则后面的就不能继续进行下去了，后边基本类似。

二、搭建config-server服务springcloud-config-server

springcloud-config-server是用来将远程git仓库的配置文件动态拉下来，这样配置文件就可以动态的维护了。当然也可以选择本地仓库。

新建一个springboot项目，修改maven私服地址，并加入一下依赖。

  • 1.修改build.gradle文件

    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-eureka’, version: ‘1.3.4.RELEASE’
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-config-server’, version: ‘1.3.2.RELEASE’
    compile group: ‘org.springframework.boot’, name: ‘spring-boot-actuator’, version: ‘1.5.6.RELEASE’
    //连接config-server也需要用户名和密码
    compile group: ‘org.springframework.boot’, name: ‘spring-boot-starter-security’, version: ‘1.5.6.RELEASE’

  • 2.修改application.yml文件

    server:
    port: 8500
    eureka:
    client:

    1. service-url:
    2.   #注册服务到eureka上，记住这里要加上eureka-server的用户名和密码
    3.   defaultZone: http://root:booszy@localhost:8761/eureka

    instance:

    1. prefer-ip-address: true
    2. #可能比较长，复制的时候请写在一行
    3. instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
    4. appname: springcloud-config-server

    spring:
    application:

    1. name: springcloud-config-server

    cloud:

    1. config:
    2.   server:
    3.     git:
    4.       #这是其他项目配置文件的git仓库地址
    5.       uri: https://git.coding.net/yirenyishi/springcloud-config-profile
    6.       searchPaths: '{application}'

    security:
    basic:

    1. enabled: true

    user:

    1. #这是config-server的用户名和密码
    2. name: root
    3. password: booszy

  • 3.修改启动类

修改启动类，要加入这三个注解，因为要注册到eureka-server上，所以需要@EnableEurekaClient这个注解

  1. @SpringBootApplication
  2. @EnableConfigServer
  3. @EnableEurekaClient
  4. public class ConfigServerApplication {
  6.     public static void main(String[] args) {
  7.         SpringApplication.run(ConfigServerApplication.class, args);
  8.     }
  9. }

然后运行启动springboot项目，等启动成功后访问eureka的页面，会发现springcloud-config-server已经注册到上面了，如果启动报错，请检查错误信息。

img\_fedd986418f1fc47a276923d6b497f07.png

这里写图片描述

三、搭建服务提供者服务springcloud-provider-config

编写一个服务提供者，提供两个接口，即获取单个用户的信息和获取一个用户列表。用到了spring-data-jpa 和 spring-webmvc ，当然你们公司用什么你还是继续用什么。

  • 注意 ： 这里除了application.xml,还需要一个bootstrap.yml, 因为bootstrap.yml得加载顺序是在application.xml前边

    1. 修改build.gradle文件

    compile(‘org.springframework.boot:spring-boot-starter-data-jpa’)
    compile(‘org.springframework.boot:spring-boot-starter-web’)
    compile(“com.alibaba:druid-spring-boot-starter:1.1.2”)
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-eureka’, version: ‘1.3.4.RELEASE’
    compile group: ‘org.springframework.boot’, name: ‘spring-boot-actuator’, version: ‘1.5.6.RELEASE’
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-config’, version: ‘1.3.2.RELEASE’
    compile group: ‘org.springframework.session’, name: ‘spring-session-data-redis’, version: ‘1.3.1.RELEASE’
    runtime(‘mysql:mysql-connector-java’)

  • 2.编写配置文件bootstrap.yml

** 注意 ： 这里除了application.xml,还需要一个bootstrap.yml*

application.xml我是放到远程仓库地址的，大家可以直接到我的远程仓库，根据项目名（springcloud-provider-config）查询。配置文件的仓库地址：点击访问。

  1. spring:
  2.   application:
  3.     name: springcloud-provider-config
  4.   cloud:
  5.     config:
  6.       #config-server的配置，不需要硬编码config-server的地址，使用service-id去eureka-server获取cong-server的地址
  7.       discovery:
  8.         enabled: true
  9.         service-id: springcloud-config-server
  10.       fail-fast: true
  11.       username: root
  12.       password: booszy
  13.       profile: dev
  14. eureka:
  15.   client:
  16.     service-url:
  17.       defaultZone: http://root:booszy@localhost:8761/eureka
  18.   instance:
  19.     prefer-ip-address: true
  20.     instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
  21.     appname: springcloud-provider-config
  • 3.编写代码

编写主类

  1. @SpringBootApplication
  2. @EnableEurekaClient
  3. public class ProviderApplication {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(ProviderApplication.class, args);
  6.     }
  7. }

新建UserController, 考虑篇幅 UserService 和 UserRepository就不贴代码了，想看的可以下载我的代码。

  1. @RequestMapping("user")
  2. @RestController
  3. public class UserController {
  5.     @Autowired
  6.     private UserService userService;
  8.     /**
  9.      * @param id
  10.      * @return
  11.      */
  12.     @GetMapping("{id}")
  13.     public User getuser(@PathVariable String id) {
  14.         User user = null;
  15.         try {
  16.             System.out.println(id);
  17.             user = userService.find(id);
  18.         } catch (Exception e) {
  19.             e.printStackTrace();
  20.         }
  21.         return user;
  22.     }
  24.     /**
  25.      * @return
  26.      */
  27.     @GetMapping("list")
  28.     public List<User> users() {
  29.         try {
  30.             List<User> user = userService.findAll();
  31.             if (user != null && user.size() != 0) {
  32.                 return user;
  33.             }
  34.             return null;
  35.         } catch (Exception e) {
  36.             e.printStackTrace();
  37.         }
  38.         return null;
  39.     }
  40. }

运行springboot项目,去eureka-server查看，有没有注册上。

img\_17e2405c5be4f8c9b340f4bcd91edf96.png

这里写图片描述

我们的springcloud-provider-config已经注册到eureka上了，访问接口，成功。

img\_2bf721533d880548a7d3b8704b130f7f.png

这里写图片描述

四、搭建消费者服务springcloud-consumer-ribbon-config-swagger

消费者要访问服务提供者的服务，这里用的是通过RestTemplate请求resetful接口，使用ribbon做客户端负载均衡，hystrix做错误处理，swagger生成接口文档。文章结尾处会更新feign的案例，feign和ribbon二选一，也可以都用。
还是熟悉的配方，熟悉的味道，新建springboot项目，添加项目依赖。

  • 1.修改build.gradle文件

    compile(‘org.springframework.boot:spring-boot-starter-web’)
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-eureka’, version: ‘1.3.4.RELEASE’
    compile group: ‘org.springframework.boot’, name: ‘spring-boot-actuator’, version: ‘1.5.6.RELEASE’
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-config’, version: ‘1.3.2.RELEASE’
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-hystrix’, version: ‘1.3.4.RELEASE’
    compile(

    1. "io.springfox:springfox-swagger2:2.7.0",
    2. "io.springfox:springfox-swagger-ui:2.7.0"

    )

  • 2.修改bootstrap.yml文件

application.yml 在git仓库，请前往git仓库查看。

  1. spring:
  2.   application:
  3.     name: springcloud-consumer-config
  4.   cloud:
  5.     config:
  6.       discovery:
  7.         enabled: true
  8.         service-id: springcloud-config-server
  9.       fail-fast: true
  10.       username: root
  11.       password: booszy
  12.       profile: dev
  13. eureka:
  14.   client:
  15.     service-url:
  16.       defaultZone: http://root:booszy@localhost:8761/eureka
  17.   instance:
  18.     prefer-ip-address: true
  19.     instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
  20.     appname: springcloud-consumer-config
  • 3.编写代码

启动类代码

@RibbonClient 指定服务使用的负载均衡类型，name不指定服务则为所有的服务打开负载均衡，也可以在用yml中进行配置。
@EnableHystrix 是支持hystrix打开断路器，在规定时间内失败参数超过一定参数，就会打开断路器，不会发起请求，而是直接进入到错误处理方法。

  1. @SpringBootApplication
  2. @EnableEurekaClient
  3. @RibbonClient(name = "springcloud-provider-config", configuration = RibbonConfiguration.class)
  4. @ComponentScan(excludeFilters = {@ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExtendRibbon.class)})
  5. @EnableHystrix
  6. public class ConsumerApplication {
  7.     @Autowired
  8.     private RestTemplateBuilder builder;
  10.     @Bean
  11.     @LoadBalanced
  12.     public RestTemplate restTemplate() {
  13.         return builder.build();
  14.     }
  16.     public static void main(String[] args) {
  17.         SpringApplication.run(ConsumerApplication.class, args);
  18.     }
  19. }

新建UserController

ribbon一个坑，不能接受List类型，要使用数组接收。
@Api xxx 是swagger的注解
@HystrixCommand(fallbackMethod=”userFallbackMethod”)
如果请求失败，会进入userFallbackMethod这个方法，userFallbackMethod这个方法要求参数和返回值与回调他的方法保持一致。

ribbon这个方法就是通过service-id获取获取服务实际的地址，这样服务的地址就不用硬编码了。

  1. @Api("springcloud consumer user 控制器")
  2. @RequestMapping("user")
  3. @RestController
  4. public class UserController {
  6.     @Autowired
  7.     private RestTemplate restTemplate;
  9.     @Autowired
  10.     private LoadBalancerClient loadBalancerClient;
  12.     /**
  13.      * @param id
  14.      * @return
  15.      */
  16.     @ApiOperation(value = "根据用户id查询用户信息", httpMethod = "GET", produces = "application/json")
  17.     @ApiResponse(code = 200, message = "success", response = User.class)
  18.     @GetMapping("{id}")
  19.     @HystrixCommand(fallbackMethod="userFallbackMethod")
  20.     public User getUser(@ApiParam(name = "id", required = true, value = "用户Id") @PathVariable String id) {
  21.         return this.restTemplate.getForObject("http://springcloud-provider-config/user/" + id, User.class);
  22.     }
  24.     public User userFallbackMethod(String id){
  25.         return null;
  26.     }
  28.     /**
  29.      * 这块ribbon不支持复杂数据类型list，所以要用数组接受，然后转list
  30.      * @return
  31.      */
  32.     @GetMapping("list")
  33.     @HystrixCommand(fallbackMethod = "userList")
  34.     public List<User> users(HttpServletRequest request) {
  35.         try {
  36.             User[] forObject = this.restTemplate.getForObject("http://springcloud-provider-config/user/list", User[].class);
  37.             List<User> users = Arrays.asList(forObject);
  38.             return users == null ? new ArrayList<User>() : users;
  39.         } catch (Exception e) {
  40.             e.printStackTrace();
  41.         }
  42.         return null;
  43.     }
  45.     public List<User> userList(HttpServletRequest request) {
  46.         return null;
  47.     }
  49.     /**
  50.      * 通过服务id获取服务的地址
  51.      * @return
  52.      */
  53.     @GetMapping("ribbon")
  54.     public String ribbon(){
  55.         ServiceInstance serviceInstance = loadBalancerClient.choose("springcloud-provider-config");
  56.         return serviceInstance.getUri().toString();
  57.     }
  58. }

运行springboot项目，先看有没有注册到eureka-server上。

img\_a46811dbff3490f5bbe2fec201cead4a.png

这里写图片描述

注册成功后，访问接口，测试是否正确。

img\_d3914045008fb91894e2a7e8c38228cf.png

这里写图片描述

测试swagger-ui，访问localhost:8200/swagger-ui.html

img\_15d8d2e4ea76a72a0db4e4b7a1567270.png

这里写图片描述

到这里消费者服务就算是完成了，后边大家自己进行扩展。

五、用zuul做路由转发和负载均衡

这些微服务都是隐藏在后端的，用户是看不到，或者不是直接接触，可以用nginx或者zuul进行路由转发和负载均衡，zuul负载均衡默认用的是ribbon。

  • 1.修改build.gradle文件

    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-eureka’, version: ‘1.3.4.RELEASE’
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-zuul’, version: ‘1.3.4.RELEASE’
    compile group: ‘org.springframework.boot’, name: ‘spring-boot-actuator’, version: ‘1.5.6.RELEASE’
    compile group: ‘org.springframework.cloud’, name: ‘spring-cloud-starter-config’, version: ‘1.3.2.RELEASE’

  • 2.修改bootstrap.yml

还是原来的配方，application.yml在git仓库

  1. spring:
  2.   application:
  3.     name: springcloud-zuul
  4.   cloud:
  5.     config:
  6.       discovery:
  7.         enabled: true
  8.         service-id: springcloud-config-server
  9.       fail-fast: true
  10.       username: root
  11.       password: booszy
  12.       profile: dev
  13. eureka:
  14.   client:
  15.     service-url:
  16.       defaultZone: http://root:booszy@localhost:8761/eureka
  17.   instance:
  18.     prefer-ip-address: true
  19.     instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
  20.     appname: springcloud-zuul
  • 3.启动类

@RefreshScope这个注解是当application.yml配置文件发生变化的时候，不需要手动的进行重启，调用localhost:8400/refresh,就会加载新的配置文件，当然正在访问的客户并不影响还是使用旧的配置文件，因为不是重启，后来的用户会使用新的配置文件。注意这块的刷新要用post请求。

  1. @SpringBootApplication 
  3. @EnableEurekaClient
  4. @EnableZuulProxy
  5. @RefreshScope
  6. public class ZuulApplication {
  7.     public static void main(String[] args) {
  8.         SpringApplication.run(ZuulApplication.class, args);
  9.     }
  11. }

启动springboot项目，访问eureka-server

img\_17728932a1eb960a70438913fda28742.png

这里写图片描述

这时候，我们就要通过zuul访问微服务了，而不是直接去访问微服务。
应该访问地址http://192.168.89.89:8400/springcloud-consumer-config/user/list，这块你要换成你的zuul地址。

但是有些人就会说，这样以后用户请求会不会太长，比较反感，所以可以通过配置进行修改访问地址。

  1. zuul:
  2.   routes:
  3.     springcloud-consumer-config: /consumer/**
  4.     springcloud-provider-config: /provider/**

在application.yml中加入这样一段配置，其实就是nginx中的反向代理，使用一下简短的可以代理这个微服务。这个时候我们就可以这样去访问了http://192.168.89.89:8400/consumer/user/list，是不是简短了很多

img\_ff5d70575ca12c766fd1746ade053128.png

这里写图片描述

六、用hystrix-turbine-dashboard 做集群监控

项目在生产环境中，每个服务的访问量都不通，有些服务的访问量比较大，有时候有些服务挂了，不能继续服务，需要重启的时候，我们并不知道，所以这时候就需要使用hystrix-turbine-dashboard做一个监控，监控所有的微服务，可以看到这个接口实时访问量，和健康状况。
新建一个springboot项目，老套路，加入如下依赖

  • 1 添加依赖

    compile(‘org.springframework.boot:spring-boot-starter-web’)

    1. compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-eureka', version: '1.3.4.RELEASE'
    2. compile group: 'org.springframework.cloud', name: 'spring-cloud-netflix-turbine', version: '1.3.4.RELEASE'
    3. compile group: 'org.springframework.boot', name: 'spring-boot-actuator', version: '1.5.6.RELEASE'
    4. compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-hystrix', version: '1.3.4.RELEASE'
    5. compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-hystrix-dashboard', version: '1.3.4.RELEASE'

  • 2 修改application.yml配置文件

    server:
    port: 8900
    eureka:
    client:

    1. healthcheck:
    2.   enabled: true
    3. service-url:
    4.   defaultZone: http://root:booszy@localhost:8761/eureka

    instance:

    1. prefer-ip-address: true
    2. instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
    3. appname: springcloud-turbine-dashboard

    turbine:
    aggregator:

    1. clusterConfig: default

    appConfig: springcloud-consumer-config,springcloud-provider-config
    clusterNameExpression: “‘default’”
    spring:
    application:

    1. name: springcloud-turbine-dashboard

appConfig 后面是要检测的注册在eureka上的服务名，必须要有

  • 3 修改主类

@EnableTurbine ，@EnableHystrixDashboard 一个都不能少

  1. @SpringBootApplication
  2. @EnableTurbine
  3. @EnableEurekaClient
  4. @EnableHystrixDashboard
  5. public class TurbineDashboardApplication {
  7.     public static void main(String[] args) {
  8.         SpringApplication.run(TurbineDashboardApplication.class, args);
  9.     }
  10. }
  • 4 访问测试

这块的端口是8900，访问地址http://localhost:8900/hystrix.stream，看到的是下面的页面。

img\_fe80653e0991297c9a56785e0160212f.png

访问hystrix-dashboard页面

然后在那个网址的输入框里输网址http://localhost:8900/turbine.stream，点击monitor stream。刚打开的时候可能是空的，什么也没有，这并不表示你已经错了。这时候你访问消费者服务的接口，例如访问http://localhost:8200/user/list，多访问几次，然后看控制台有没有出现一个监控面板，没有就等会刷新一次，如果一直不出现，应该是配置有问题。

img\_0772e01f8a1e1e6b325fbce353c10d34.png

这里写图片描述

后边更新会追加到后边,后边随时更新

2018-01-24 更新：补充使用feign

七、使用feign

在实际开发中，feign使用的还是挺多的，feign底层还是使用了ribbon。废话不多说，直接上步骤，在服务消费者中使用feign访问服务提供者。新建一个springboot项目，或者复制一个。

  • 1加入依赖

swagger不使用的话，可以删掉。

  1. compile('org.springframework.boot:spring-boot-starter-web')
  2.     compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-eureka', version: '1.3.4.RELEASE'
  3.     compile group: 'org.springframework.boot', name: 'spring-boot-actuator', version: '1.5.6.RELEASE'
  4.     compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-config', version: '1.3.2.RELEASE'
  5.     compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-feign', version: '1.3.4.RELEASE'
  6.     compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-hystrix', version: '1.3.4.RELEASE'
  7.     compile(
  8.             "io.springfox:springfox-swagger2:2.7.0",
  9.             "io.springfox:springfox-swagger-ui:2.7.0"
  10.     )
  • 2修改配置文件

这里修改的是bootstrap.yml，这里吧application.yml的配置也贴出来，这个是放在远程仓库的，通过config动态拉取下来。

  1. spring:
  2.   application:
  3.     name: springcloud-consumer-feign
  4.   cloud:
  5.     config:
  6.       discovery:
  7.         enabled: true
  8.         service-id: springcloud-config-server
  9.       fail-fast: true
  10.       username: root
  11.       password: booszy
  12.       profile: csdn
  13. eureka:
  14.   client:
  15.     service-url:
  16.       defaultZone: http://root:booszy@localhost:8761/eureka
  17.   instance:
  18.     prefer-ip-address: true
  19.     instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
  20.     appname: springcloud-consumer-feign

application.yml

  1. server:
  2.   port: 8201
  3. logging:
  4.   level:
  5.     com.yasaka.stock.feign.MFeignClient: debug
  6. feign:
  7.   hystrix:
  8.     enabled: true
  9. ribbon:
  10.   ReadTimeout:  30000
  11.   ConnectTimeout:  15000
  12. hystrix:
  13.   command:
  14.     default:
  15.       execution:
  16.         isolation:
  17.           thread:
  18.             timeoutInMilliseconds: 10000

feign的默认请求超时时间是1s，所以经常会出现超时的问题，这里我设置的是10s，因为我的数据库服务器在美国，所以有时候请求会比较慢。ribbon的请求时间也要设置，因为feign用的是ribbon。

  • 3 编码

1、主类注解

@EnableFeignClients
@EnableCircuitBreaker
@EnableHystrix

这三个都要，hystrix主要作用是断路器，会进如fein的fallback中。

  1. @SpringBootApplication
  2. @EnableEurekaClient
  3. @EnableFeignClients
  4. @EnableCircuitBreaker
  5. @EnableHystrix
  6. public class ConsumerApplication {
  8.     public static void main(String[] args) {
  9.         SpringApplication.run(ConsumerApplication.class, args);
  10.     }
  11. }

2、编写feign接口，MFeignClient.class

name是指要请求的服务名称。这里请求的是服务提供者
fallback 是指请求失败，进入断路器的类，和使用ribbon是一样的。
configuration 是feign的一些配置，例如编码器等。

  1. @FeignClient(name = "springcloud-provider-config",fallback = HystrixFeignFallback.class, configuration = MFeignConfig.class)
  2. public interface MFeignClient {
  4.     //这里是使用feign请求的地址
  5.     @RequestMapping(method = RequestMethod.GET, value = "/user/{id}")
  6.     User getUser(@PathVariable("id") String id);
  8.     //新版本支持使用GetMapping，之前的老版本可能不支持
  9.     @GetMapping(value = "/user/list")
  10.     List<User> getUsers();
  11. }
  • 3 MFeignConfig.class feign的配置

这里配置了feign的打印日志等级

  1. @Configuration
  2. public class MFeignConfig {
  3.     @Bean
  4.     Logger.Level feignLoggerLevel() {
  5.         return Logger.Level.FULL;
  6.     }
  7. }
  • 4 HystrixFeignFallback.class ，断路器回调方法

断路器要实现上边定义的MFeignClient接口，请求失败，进入断路器时，会回调这里的方法。

  1. @Component
  2. public class HystrixFeignFallback implements MFeignClient {
  3.     @Override
  4.     public User getUser(String id) {
  5.         User user = new User();
  6.         user.setId("233");
  7.         return user;
  8.     }
  10.     @Override
  11.     public List<User> getUsers() {
  12.         return new ArrayList<User>();
  13.     }
  14. }

  • 5 在controller中使用feign

    @Api(“springcloud consumer user 控制器”)
    @RequestMapping(“user”)
    @RestController
    public class UserController {

    1. @Autowired
    2. private MFeignClient feignClient;
    4. /**
    5.  * @param id
    6.  * @return
    7.  */
    8. @ApiOperation(value = "根据用户id查询用户信息", httpMethod = "GET", produces = "application/json")
    9. @ApiResponse(code = 200, message = "success", response = User.class)
    10. @GetMapping("{id}")
    11. public User getUser(@ApiParam(name = "id",   required = true, value = "用户Id") @PathVariable String id) {
    12.     User user = feignClient.getUser(id);
    13.     return user;
    14. }
  1.     @GetMapping("list")
  2.     public List<User> users(HttpServletRequest request) {
  3.         try {
  4.             List<User> users = feignClient.getUsers();
  5.             return users == null ? new ArrayList<User>() : users;
  6.         } catch (Exception e) {
  7.             e.printStackTrace();
  8.         }
  9.         return null;
  10.     }
  11. }

20180125更新： 补充使用sleuth+zipkin 实现链路追踪服务

八、使用sleuth+zipkin 实现链路追踪服务

在使用微服务的时候，我们发现，有时候排错不好排查，所以就给大家整个这个链路追踪，很方便知道是哪一个服务调用哪一个服务出现了问题。因为有些项目可能服务比较多。

  • 1 添加依赖

新建一个springboot项目
虽然其他服务调用zipkin不是从eureka上动态过去服务地址，而是硬编码，但是这块还是考虑吧zipkin注册到eureka上。

  1. compile group: 'io.zipkin.java', name: 'zipkin-server', version: '2.4.4'
  2. compile group: 'io.zipkin.java', name: 'zipkin-autoconfigure-ui', version: '2.4.4'
  3. compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-eureka', version: '1.3.4.RELEASE'

  • 2 修改application配置文件

    server:
    port: 9411
    eureka:
    client:

    1. service-url:
    2.   defaultZone: http://root:booszy@localhost:8761/eureka

    instance:

    1. prefer-ip-address: true
    2. instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}
    3. appname: springcloud-zipkin-server

    spring:
    application:

    1. name: springcloud-zipkin-server

  • 3 主类注解添加

@EnableZipkinServer 主要是这个注解
启动服务后访问http://localhost:9411,就可以打开zipkin的控制台页面，这时候应该是什么都没有

  1. @SpringBootApplication
  2. @EnableZipkinServer
  3. @EnableEurekaClient
  4. public class ZipkinServerApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(ZipkinServerApplication.class, args);
  7.     }
  8. }
  • 4 其他服务中调用

这里我们在消费者服务和提供者服务里都加入如下依赖

  1. ....
  2. compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-sleuth', version: '1.3.1.RELEASE'
  3. compile group: 'org.springframework.cloud', name: 'spring-cloud-sleuth-zipkin', version: '1.3.1.RELEASE'
  4. ...

然后修改配置文件，bootstrap.yml、
这块zipkin的地址是硬编码的，目前还没发现怎么从服务注册中心eureka上动态获取，以后有解决方案，会更新帖子
sleuth这个是配置提取率，可以配置也可以不配置

  1. spring:
  2.   zipkin:
  3.     base-url: http://localhost:9411
  4.   sleuth:
  5.     sampler:
  6.       percentage: 1.0

启动服务，然后访问消费者服务的接口，这时候访问zipkin的控制台http://localhost:9411

img\_0a259c38b9e47fe1d315959d47926ce8.png

查看服务列表

点击依赖分析，可以看到调用服务链，因为这块只涉及到两个服务，所以只有两个，在实际生产环境中，这块可能有很多，到时候看起来就特别直观了。

img\_9bb616f5946472624445862f74f871f6.png

这里写图片描述

关注

如果有问题，请在下方评论，或者加群讨论 200909980

关注下方微信公众号，可以及时获取到各种技术的干货哦，如果你有想推荐的帖子，也可以联系我们的。

img\_cb380af3d7a871d3f66df87a6eae835e.png

码农笔录二维码

发表评论

表情：
评论列表 （有 0 条评论，408人围观）

还没有评论，来说两句吧...

相关阅读

    相关 一文读懂SpringCloud全家桶

    一、云原生应用 SpringCloud是对Springboot使用的分布式解决方案，适合分布式、中大型的项目架构开发，现在也逐渐成为Java服务端的主流框架。使用Spri

    蔚落蔚落/ 0 赞/ 74 阅读