SpringCloud系列之二---Feign实现服务间调用,集成Hystrix熔断器Hystrix-Dashboard仪表盘

Posted 小小的bug

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了SpringCloud系列之二---Feign实现服务间调用,集成Hystrix熔断器Hystrix-Dashboard仪表盘相关的知识,希望对你有一定的参考价值。

前言

本篇文章主要介绍的是Feign实现服务间调用,集成Hystrix熔断器、Hystrix-Dashboard仪表盘

GitHub源码链接位于文章底部。

Feign 简介

Feign是一个http请求调用的轻量级框架,可以以Java接口注解的方式调用Http请求,而不用像Java中通过封装HTTP请求报文的方式直接调用。Feign通过处理注解,将请求模板化,当实际调用的时候,传入参数,根据参数再应用到请求上,进而转化成真正的请求。

在实际开发中,所有的服务都要注册到注册中心,然后一个服务可以在eureka注册中心通过feign调用另一个服务。因此我们需要先建立eureka注册中心,再建立一些普通服务作为eureka客户端,作为被调用的服务,其实只是一个普通的微服务项目,而需要调用别的服务的,则需要加入feign,也就是feign客户端,这里是没有真正定义的feign服务端的。

一、eureka注册中心

先创建springcloud-feign父工程。

和上篇文章中写的过程一样,这里建立一个单点eureka服务端。

添加eureka服务端依赖
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>
配置文件
#服务端口号
server:
  port: 8100

spring:
  application:
    name: eureka-server

#eureka基本配置信息
eureka:
  client:
    service-url:
      #Eureka 客户端与 Eureka 服务端进行交互的地址
      defaultZone: http://127.0.0.1:${server.port}/eureka
    #是否将自己注册到Eureka服务中,本身就是注册中心所以无需注册
    register-with-eureka: false
    #是否从Eureka中检索注册信息,本身就是注册中心所以无需检索
    fetch-registry: false
  server:
    # 测试时关闭自我保护机制,保证不可用服务及时踢出
    enable-self-preservation: false
    ##剔除失效服务间隔
    eviction-interval-timer-in-ms: 2000
启动类
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApp {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApp.class, args);
    }
}

二、创建一个普通服务,作为被调用的一方

引入依赖

这个服务也是eureka客户端,要被注册到注册中心,所以只需要添加eureka客户端的依赖即可。

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>
配置文件
#端口号
server:
  port: 8101

spring:
  application:
    name: feign-server

#eureka基本配置信息
eureka:
  client:
    service-url:
      #Eureka 客户端与 Eureka 服务端进行交互的地址
      defaultZone: http://127.0.0.1:8100/eureka/
  # 心跳检测检测与续约时间
  # 测试时将值设置设置小些,保证服务关闭后注册中心能及时踢出服务
  instance:
    # Eureka客户端向服务端发送心跳的时间间隔,单位为秒(客户端告诉服务端自己会按照该规则)
    lease-renewal-interval-in-seconds: 1
    # Eureka服务端在收到最后一次心跳之后等待的时间上限,单位为秒,超过则剔除(客户端告诉服务端按照此规则等待自己)
    lease-expiration-duration-in-seconds: 2

feign是通过配置文件中的spring : application : name : eureka-server应用名调用的

controller层中添加一个接口
@RestController
public class ServerController {
    @RequestMapping("/index")
    public String index(@RequestParam String name) {
        return name+"----这是被调用的服务!";
    }
}
启动类
@SpringBootApplication
@EnableEurekaClient
public class FeignServerApp {
    public static void main(String[] args) {
        SpringApplication.run(FeignServerApp.class, args);
    }
}

先启动eureka服务端,访问 http://localhost:8100/ ,可以看到该服务已经被注册到注册中心了。

再启动该服务,调用接口 http://localhost:8101/index?name=测试

三、 创建一个Feign客户端,去调用刚才创建的服务中的接口

引入依赖

该服务作为eureka客户端和feign客户端,所以要引入eureka客户端和feign依赖

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>
创建Feign接口

创建一个serverFeign

@FeignClient(name = "feign-server")
public interface ServerFeign {
    @RequestMapping(value = "/index")
    public String index(@RequestParam(value = "name") String name) ;
}

类上使用FeignClient注解,name属性是被调用服务的名称,在配置文件中有设置,然后将被调用的服务的那个接口复制到这里,去掉方法体即可。

controller层中添加一个接口
@RestController
public class ClientController {
    @Autowired
    private ServerFeign serverFeign;

    @GetMapping("/index/{name}")
    public String index(@PathVariable("name") String name) {
        return serverFeign.index(name);
    }
}

先将刚才创建爱你的Feign接口注入到spring容器,写一个接口去调用Feign中的方法,经测试后可以看到调用这个接口,其实是通过Feign调用了另一个服务中的方法体。

启动类

类上要加EnableFeignClients、EnableEurekaClient注解

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

启动该程序,再次访问eureka服务端,可以看到两个服务都被注册到注册中心了。

最后访问这个服务的接口,http://localhost:8102/index/test

这里显示的值其实就是调用了另一个服务中的接口的返回值。

四、Hystrix熔断器

在微服务场景中,通常会有很多层的服务调用。如果一个底层服务出现问题,故障会被向上传播给用户。我们需要一种机制,当底层服务不可用时,可以阻断故障的传播。这就是熔断器的作用。他是系统服务稳定性的最后一重保障。

SpringCloud默认已经为Feign整合了Hystrix,只要Hystrix在项目的classpath中,Feigin 默认就会用断路器包裹所有的方法.

1.yml配置文件中增加

feign:
  hystrix:
    enabled: true

2.添加一个ServerFeignHystrix类,实现ServerFeign接口

@Component
public class ServerFeignHystrix implements ServerFeign {
    @Override
    public String index(String name) {
        return name+"触发熔断机制!!!";
    }
}

3.修改ServerFeign,在FeignClient注解中增加fallback参数,值为ServerFeignHystrix.class

@FeignClient(name = "feign-server" ,fallback = ServerFeignHystrix.class)
public interface ServerFeign {
    @RequestMapping(value = "/index")
    public String index(@RequestParam(value = "name") String name) ;
}

4.依次重新启动eureka,FeignServer,FeignClient,访问这个服务的接口,http://localhost:8102/index/test

然后将FeignServer关闭,再次访问该接口,因为访问服务端出错,

五、Hystrix Dashboard仪表盘

Hystrix-dashboard是一款针对Hystrix进行实时监控的工具,通过Hystrix Dashboard可以直观地看到各Hystrix Command的请求响应时间,请求成功率等数据。

1.在feign-client项目,即Hystrix所在项目添加依赖:

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

2.在yml中添加配置

management:
  endpoints:
    web:
      exposure:
        include: hystrix.stream
      base-path: /

3.在启动类中添加注解

@SpringBootApplication
@EnableFeignClients
@EnableEurekaClient
@EnableHystrixDashboard
@EnableCircuitBreaker
public class FeignClientApp {
    public static void main(String[] args) {
        SpringApplication.run(FeignClientApp.class, args);
    }
}

4.访问 localhost:8102/hystrix 打开熔断器监控首页

在第一个空格内填写 http://localhost:8102/hystrix.stream
下方左侧是延迟时间,右侧是页面标题。

点击最下方的Monitor Stream 按钮跳转到监控页面。刚进入该页面会出现存在两个loading字样的页面,调用接口再刷新该页面即可。

关于这些信息中说明可以用网上找到的一张来加以说明。

本文GitHub源码:https://github.com/lixianguo5097/springcloud/tree/master/springcloud-feign

CSDN:https://blog.csdn.net/qq_27682773
简书:https://www.jianshu.com/u/e99381e6886e
博客园:https://www.cnblogs.com/lixianguo
个人博客:https://www.lxgblog.com

以上是关于SpringCloud系列之二---Feign实现服务间调用,集成Hystrix熔断器Hystrix-Dashboard仪表盘的主要内容,如果未能解决你的问题,请参考以下文章

SpringCloud系列之Feign-4.Feign的动态代理

SpringCloud系列十:使用Feign实现声明式REST调用

SpringCloud系列——Feign 服务调用

springcloud系列四 feign远程调用服务

SpringCloud系列——Feign 服务调用

SpringCloud 教程 之三 服务消费(Feign)