前言
本篇文章主要介绍的是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