feign 熔斷工廠 fallbackFactory的簡單實現

普通的熔斷方法實現方式    是實現接口,當有錯誤響應是無法獲取response信息

現在有一個方法就是熔斷工廠,再也不用實現接口就能捕獲錯誤接口的返回信息了

1.引入jar包

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
                
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
              
            </dependency>

2.啟動類加啟動feign注解

@SpringBootApplication
@EnableFeignClients
public class TestApplication {
}

3.請求接口實現

package com.ylz.service.remote;

import com.ylz.base.BaseResult;
import com.ylz.pojo.MenuPojo;
import com.ylz.service.remote.impl.UserMenuFeignFallBackFactory;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

/**
 * @Description:feign
 * @Author: 
 * @Date: 2020/12/15
 * @Time: 11:11
 **/
@FeignClient(name = "userFeign",url = "${rest.service.user-server-host}",fallbackFactory = UserMenuFeignFallBackFactory.class)
public interface UserMenuFeign {

    /*
     * @Author LCW
     * @Description 新增或者修改用戶中心菜單
     * @Date 2021/1/20 14:19
     * @param menuPojoReq :
     * @return com.ylz.base.BaseResult<java.lang.Object>
     **/
    @RequestMapping(method = RequestMethod.POST,value = "/menuController/addOrUpdateMenu",consumes  = MediaType.APPLICATION_JSON_VALUE)
    BaseResult<Object> addOrUpdateMenu(@RequestHeader("Cookie") String cookie, @RequestBody MenuPojo menuPojoReq);

    /*
     * @Author LCW
     * @Description 刪除菜單
     * @Date 2021/1/20 14:19
     * @param menuPojoReq :
     * @return com.ylz.base.BaseResult<java.lang.Object>
     **/
    @RequestMapping(method = RequestMethod.POST,value = "/menuController/deleteMenu",consumes  = MediaType.APPLICATION_JSON_VALUE)
    BaseResult<Object> deleteMenu(@RequestHeader("Cookie") String cookie, @RequestBody MenuPojo menuPojoReq);

    /*
     * @Author LCW
     * @Description  根據條件查詢指定菜單
     * @Date 2021/1/20 14:39
     * @param cookie :
     * @param menuPojoReq :
     * @return com.ylz.base.BaseResult<java.lang.Object>
     **/
    @RequestMapping(method = RequestMethod.POST,value = "/menuController/queryMenuListByCondition",consumes  = MediaType.APPLICATION_JSON_VALUE)
    BaseResult<Object> queryMenuListByCondition(@RequestHeader("Cookie") String cookie, @RequestBody MenuPojo menuPojoReq);

    /*
     * @Author LCW
     * @Description 新增或修改菜單和權限賦予
     * @Date 2021/1/20 14:19
     * @param menuPojoReq :
     * @return com.ylz.base.BaseResult<java.lang.Object>
     **/
    @RequestMapping(method = RequestMethod.POST,value = "/menuController/addOrUpdateMenuAndRole",consumes  = MediaType.APPLICATION_JSON_VALUE)
    BaseResult<Object> addOrUpdateMenuAndRole(@RequestHeader("Cookie") String cookie, @RequestBody MenuPojo menuPojoReq);

    /*
     * @Author LCW
     * @Description 刪除菜單和刪除角色賦予權限
     * @Date 2021/1/20 14:19
     * @param menuPojoReq :
     * @return com.ylz.base.BaseResult<java.lang.Object>
     **/
    @RequestMapping(method = RequestMethod.POST,value = "/menuController/deleteMenuAndRole",consumes  = MediaType.APPLICATION_JSON_VALUE)
    BaseResult<Object> deleteMenuAndRole(@RequestHeader("Cookie") String cookie, @RequestBody MenuPojo menuPojoReq);
}

4.熔斷接口實現

package com.ylz.service.remote.impl;

import com.ylz.base.BaseResult;
import com.ylz.base.BaseResultGenerator;
import com.ylz.pojo.MenuPojo;
import com.ylz.service.remote.UserMenuFeign;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @Description: 熔斷工廠
 * @ClassName: FallBackFactory
 * @Author: 
 * @Date: 2021/1/20 16:23
 * @Version: 1.0
 */
@Slf4j
@Component
public class UserMenuFeignFallBackFactory implements FallbackFactory<UserMenuFeign> {
    @Override
    public UserMenuFeign create(Throwable throwable) {
        log.error("請求用戶中心出錯:" + throwable.getMessage());
        return new UserMenuFeign() {
            @Override
            public BaseResult<Object> addOrUpdateMenu( String cookie,MenuPojo menuPojoReq) {
                log.error("cookieValue:" + cookie);
                log.error(throwable.getMessage());
                log.error("創建菜單失敗,登錄失敗,請重新登錄");
                return BaseResultGenerator.failureLoginOut("創建菜單失敗,登錄失敗,請重新登錄");
            }

            @Override
            public BaseResult<Object> deleteMenu(String cookie, MenuPojo menuPojoReq) {
                log.error("cookieValue:" + cookie);
                log.error(throwable.getMessage());
                log.error("刪除失敗,登錄失敗,請重新登錄");
                return BaseResultGenerator.failureLoginOut("刪除失敗,登錄失敗,請重新登錄");
            }

            @Override
            public BaseResult<Object> queryMenuListByCondition(String cookie, MenuPojo menuPojoReq) {
                log.error("cookieValue:" + cookie);
                log.error(throwable.getMessage());
                log.error("獲取菜單失敗,登錄失敗,請重新登錄");
                return BaseResultGenerator.failureLoginOut("獲取菜單失敗,登錄失敗,請重新登錄");
            }

            @Override
            public BaseResult<Object> addOrUpdateMenuAndRole(String cookie, MenuPojo menuPojoReq) {
                log.error("cookieValue:" + cookie);
                log.error(throwable.getMessage());
                log.error("創建菜單失敗,服務異常!請聯系管理員");
                return BaseResultGenerator.failureLoginOut("創建菜單失敗,服務異常!請聯系管理員");
            }

            @Override
            public BaseResult<Object> deleteMenuAndRole(String cookie, MenuPojo menuPojoReq) {
                log.error("cookieValue:" + cookie);
                log.error(throwable.getMessage());
                log.error("刪除菜單失敗,服務異常");
                return BaseResultGenerator.failureLoginOut("刪除菜單失敗,服務異常!請聯系管理員");
            }
        };
    }
}

 

通過feign注解的fallbackFactory 屬性找到指定的熔斷實現方法

@FeignClient(name = "userFeign",url = "${rest.service.user-server-host}",fallbackFactory = UserMenuFeignFallBackFactory.class)

在方法 UserMenuFeignFallBackFactory 重寫相對應的錯誤熔斷返回即可;

在這里我們可以通過  throwable.getMessage()   獲取到其他服務響應的錯誤信息反饋;