SpringCloud-day09-Feign与Hystrix整合

8.5.Feign 与 Hystrix整合

　　服务熔断服务降级彻底解耦

前面的代码，用@HystrixCommand fallbackMethod是很不好的，因为和业务代码耦合度太高，不利于维护，所以需要解耦。

首先我们将Feign与 Hystrix整合。

第一，microservice-ticket-provider-hystrix-1004项目修改

按照正常的逻辑来写；

TicketService加新的接口方法lockTicket()：

     /**

      * 锁票业务

      * @return

      */

     public Map<String,Object> lockTicket();

TicketServiceImpl写具体实现：

  @Override

     public Map<String, Object> lockTicket() {

         try {

             //模拟超时用

             Thread.sleep(2000);

         } catch (InterruptedException e) {

             e.printStackTrace();

         }

         Map<String,Object> map=new HashMap<String,Object>();

         map.put("code", 200);

         map.put("msg", "锁定的车票数据xxxxx3000");

         return map;

     }

TicketProviderController正常调用service方法：

注意：注释部分是之前的那种方法写的，为了便于学习对比，注释保留

  /**

      * 锁票业务

      *

      * @return

      * @throws InterruptedException

      */

     @ResponseBody

     @GetMapping(value = "/lockTicket")

    // @HystrixCommand(fallbackMethod = "lockTicketFallback")

     public Map<String, Object> lockTicket() throws InterruptedException {

         // Thread.sleep(2000);

         // Map<String,Object> map=new HashMap<String,Object>();

         // map.put("code", 200);

         // map.put("msg", "锁定的车票数据xxxxx3000");

         // return map;

         return ticketService.lockTicket();

     }

     /**

      * 模拟锁票超时 或者 系统故障的回调函数

      * @return

      * @throws InterruptedException

      */

     // public Map<String,Object> lockTicketFallback() throws InterruptedException{

     //     Map<String,Object> map=new HashMap<String,Object>();

     //     map.put("code", 500);

     //     map.put("msg", "系统出错，稍后重试");

     //     return map;

     // }

第二步：microservice-common项目新建FallbackFactory类，解耦服务熔断服务降级

TicketClientService接口，新增lockTicket()方法；

     /**

      * 索票业务

      * @return

      */

     @GetMapping(value="/ticket/lockTicket")

     public Map<String,Object> lockTicket();

新建 TicketClientFallbackFactory 类，实现FallbackFactory<TicketClientService>接口；

 package com.wfd360.service;

 import com.wfd360.model.Ticket;

 import feign.hystrix.FallbackFactory;

 import org.springframework.web.bind.annotation.PathVariable;

 import java.util.HashMap;

 import java.util.List;

 import java.util.Map;

 /**

  * Created by 姿势帝-博客园 on 2019/4/1.

  * 欢迎添加笔者wx(851298348)共同探讨、学习！

  */

 public class TicketClientFallbackFactory implements FallbackFactory<TicketClientService> {

     @Override

     public TicketClientService create(Throwable throwable) {

         return new TicketClientService() {

             @Override

             public Ticket get(@PathVariable("id") Integer id) {

                 // 服务超时或者出错时 返回的业务逻辑

                 return null;

             }

             @Override

             public List<Ticket> list() {

                 // 服务超时或者出错时 返回的业务逻辑

                 return null;

             }

             @Override

             public boolean save(Ticket ticket) {

                 // 服务超时或者出错时 返回的业务逻辑

                 return false;

             }

             @Override

             public boolean delete(@PathVariable("id") Integer id) {

                 // 服务超时或者出错时 返回的业务逻辑

                 return false;

             }

             @Override

             public Map<String, Object> lockTicket() {

                 Map<String, Object> map = new HashMap<String, Object>();

                 map.put("code", 500);

                 map.put("msg", "系统出错，稍后重试");

                 return map;

             }

         };

     }

 }

TicketClientService接口的@FeignClient注解加下 fallbackFactory属性

@FeignClient(value="MICROSERVICE-STUDENT",fallbackFactory=TicketClientFallbackFactory.class)

这类我们实现了降级处理方法实现；

第三步：microservice-ticket-consumer-feign-80修改支持Hystrix

TicketConsumerFeignController新增方法调用

  /**

      * 索票

      * @return

      */

     @GetMapping(value="/lockTicket")

     @ResponseBody

     public Map<String,Object> lockTicket(){

         System.out.println("------调用锁票业务------------");

         return ticketClientService.lockTicket();

     }

application.yml加上hystrix支持

feign:

hystrix:

enabled: true

=======================

feign与hystrix 服务熔断服务降级彻底解耦完成，测试与之前一样！

8.6.Feign Hystrix整合之超时时间配置

Feign Hystrix整合后，hystrix超时时间配置的话这里要配置到消费端。

也就是 microservice-ticket-provider-hystrix-1004 的 yml里的

hystrix:

command:

default:

execution:

isolation:

thread:

timeoutInMilliseconds: 3000

这个配置放到 microservice-ticket-consumer-feign-80 的yml里

但是放进去后大伙测试依然无效。

这里因为还有一个 feign 也有一个超时时间的设置，当然feign底层是 ribbon的封装，所以直接配置ribbon，ribbon默认超时也是1秒。

所以这里都是强制要求，ribbon的超时时间要大于hystrix的超时时间，否则 hystrix自定义的超时时间毫无意义。

所以还得加个 ribbon超时时间设置

ribbon:

ReadTimeout: 50000

ConnectTimeout: 6000

测试与之前一样，大家可以设定设置超时间后，在调整睡眠时间进行测试！

hystrix 的应用暂时讲到这里，本案例代码可以下载 V8版本！

巴特西

SpringCloud-day09-Feign与Hystrix整合

8.5.Feign 与 Hystrix整合

8.6.Feign Hystrix整合之超时时间配置

最新文章

热门文章