feat(hystrix):feign集成hystrix进行服务降级配置

Author: coderqianlq

api-gateway/src/main/resources/application.properties

@@ -15,5 +15,7 @@ zuul.ignoredServices='*'
 zuul.routes.api-c.path=/feign/**
 zuul.routes.api-c.serviceId=feign-server
 
+#请求连接的超时时间
 #ribbon.ConnectTimeout=6000
+#请求处理的超时时间
 #ribbon.ReadTimeout=6000

eureka-order/src/main/java/com/coderqian/eurekaorder/controller/TestController.java

@@ -4,6 +4,7 @@
 import io.swagger.annotations.ApiOperation;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
@@ -19,7 +20,7 @@ public class TestController {
 
     @ApiOperation(value = "返回用户输入的结果", notes = "返回用户输入的结果")
     @RequestMapping(value = "/result", method = RequestMethod.GET)
-    public String test(String text) {
+    public String test(@RequestParam(value = "text") String text) {
         return text;
     }
 }

feign-server/pom.xml

@@ -37,6 +37,16 @@
 			<artifactId>spring-cloud-starter-feign</artifactId>
 		</dependency>
 
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-hystrix</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
+		</dependency>
+
 		<dependency>
 			<groupId>org.springframework.cloud</groupId>
 			<artifactId>spring-cloud-starter-eureka</artifactId>

feign-server/src/main/java/com/coderqian/feginserver/FeignServerApplication.java

@@ -2,13 +2,17 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.feign.EnableFeignClients;
+import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
 
 
 @SpringBootApplication
 @EnableEurekaClient
 @EnableFeignClients
+@EnableHystrixDashboard
+@EnableCircuitBreaker
 public class FeignServerApplication {
 
     public static void main(String[] args) {

feign-server/src/main/java/com/coderqian/feginserver/configuration/FeignServerConfiguration.java

@@ -0,0 +1,28 @@
+package com.coderqian.feginserver.configuration;
+
+import com.netflix.hystrix.HystrixCommand;
+import feign.Feign;
+import feign.hystrix.HystrixFeign;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Scope;
+
+/**
+ * @author qianliqing
+ * @date 2018-10-16 下午5:29
+ * mail: [email protected]
+ */
+
+//@Configuration
+@ConditionalOnClass({HystrixCommand.class, HystrixFeign.class})
+public class FeignServerConfiguration {
+
+    @Bean
+    @Scope("prototype")
+    @ConditionalOnProperty(name = "feign.hystrix.enabled", matchIfMissing = true)
+    public Feign.Builder feignBuilder() {
+        return Feign.builder();
+    }
+}

feign-server/src/main/java/com/coderqian/feginserver/configuration/fallback/HystrixClientFallback.java

@@ -0,0 +1,19 @@
+package com.coderqian.feginserver.configuration.fallback;
+
+import com.coderqian.feginserver.service.TestCustomerService;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author qianliqing
+ * @date 2018-10-16 下午5:08
+ * mail: [email protected]
+ */
+
+@Component
+public class HystrixClientFallback implements TestCustomerService {
+
+    @Override
+    public String testCustomer(String text) {
+        return "失败:" + text;
+    }
+}

feign-server/src/main/java/com/coderqian/feginserver/service/TestCustomerService.java

@@ -1,6 +1,8 @@
 package com.coderqian.feginserver.service;
 
+import com.coderqian.feginserver.configuration.fallback.HystrixClientFallback;
 import org.springframework.cloud.netflix.feign.FeignClient;
+import org.springframework.stereotype.Service;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
@@ -11,7 +13,8 @@
  * mail: [email protected]
  */
 
-@FeignClient(value = "eureka-customer")
+@FeignClient(value = "eureka-customer", fallback = HystrixClientFallback.class)
+@Service
 public interface TestCustomerService {
 
     @RequestMapping(value = "/test/result", method = RequestMethod.GET)

feign-server/src/main/resources/application.properties

@@ -1,3 +1,10 @@
 spring.application.name=feign-server
 server.port=8765
-eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka
+eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka
+
+feign.hystrix.enabled=true
+
+#请求处理的超时时间
+#ribbon.ReadTimeout=120000
+#请求连接的超时时间
+#ribbon.ConnectTimeout=30000