Sentinel降级操作

发布时间:2024年01月22日

1.通过对feign调用的降级 如果访问失败,则返回另外的信息

正常的feign调用

@FeignClient(value = "gulimall-seckill",fallback = SeckillFeignServiceFallback.class)
public interface SeckillFeignService {

    /**
     * 写给商品服务的接口,查询秒杀服务信息
     * @param skuId
     * @return
     */
    @GetMapping("/currentSeckillSkus/sku/seckill/{skuId}")
    R getSkuSeckillInfo(@PathVariable("skuId") Long skuId);
}

兜底方法返回另外的信息

/**
 * 如果feign调用失败返回的信息
 */
@Component
public class SeckillFeignServiceFallback implements SeckillFeignService {
    @Override
    public R getSkuSeckillInfo(Long skuId) {
        return R.error(500,方法调用失败);
    }
}

2.对代码进行访问控制,在可视化工具中对seckillSkus进行数据设置

@Override
    public List<SecKillSkuRedisTo> getCurrentSeckillSkus() {
        //1.确定当前时间属于哪个秒杀场次
        long time = new Date().getTime();
        try(Entry seckillSkus = SphU.entry("seckillSkus")){
            //正常的业务代码-----
            }
            //然后在可视化工具中对这个代码进行限流控制设置
        }catch (BlockException e){
            System.out.println("资源被限流");
        }
        return null;
    }

3.统一config配置返回降级信息

**
 * 自定义流量控制请求失败后返回信息
 */
@Configuration
public class SeckillSentinelConfig {

    public SeckillSentinelConfig(){
        WebCallbackManager.setUrlBlockHandler(new UrlBlockHandler() {
            @Override
            public void blocked(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws IOException {
                R error = R.error(BizCodeEnum.TO_MANY_REQUEST.getCode(), BizCodeEnum.TO_MANY_REQUEST.getMsg());
                httpServletResponse.setCharacterEncoding("UTF-8");
                httpServletResponse.setContentType("application/json");
                httpServletResponse.getWriter().write(JSON.toJSONString(error));
            }
        });
    }
}

4.使用注解结合可视化操作进行控制

 public List<SecKillSkuRedisTo> blockHandler(BlockException e){
        log.error("getCurrentSeckillSkus被限流了");
        return null;
    }

    /**
     * 返回当前时间段可以参加秒杀的商品信息
     * Entry seckillSkus = SphU.entry("seckillSkus"对代码进行降级
     * @return
     */
    @SentinelResource(value = "getCurrentSeckillSkus",blockHandler = "blockHandler")
    @Override
    public List<SecKillSkuRedisTo> getCurrentSeckillSkus() {
       
       
        return null;
    }

?@SentinelResource(value = "getCurrentSeckillSkus",blockHandler = "blockHandler")

value的名称是可视化页面的限流处理名称

blockHandler的内容是限流降级后的操作方法

两个方法返回类型要一致

文章来源:https://blog.csdn.net/wmd13164306712/article/details/135703786
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。