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的内容是限流降级后的操作方法
两个方法返回类型要一致