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 {@Overridepublic R getSkuSeckillInfo(Long skuId) {return R.error(500,方法调用失败);}
}

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

@Overridepublic 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() {@Overridepublic 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")@Overridepublic List<SecKillSkuRedisTo> getCurrentSeckillSkus() {return null;}

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

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

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

两个方法返回类型要一致

5.整合sentine和gateway

引入依赖

<!--        sentinel和gateway整合--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId><version>2.1.0.RELEASE</version></dependency>

版本需要和common中的阿里依赖一致

<dependencyManagement><dependencies><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>2.1.0.RELEASE</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

config文件

@Configuration
public class SentinelGatewayConfig {public SentinelGatewayConfig(){GatewayCallbackManager.setBlockHandler(new BlockRequestHandler() {@Overridepublic Mono<ServerResponse> handleRequest(ServerWebExchange serverWebExchange, Throwable throwable) {R error = R.error(BizCodeEnum.TO_MANY_REQUEST.getCode(), BizCodeEnum.TO_MANY_REQUEST.getMsg());String jsonString = JSON.toJSONString(error);Mono<ServerResponse> body = ServerResponse.ok().body(Mono.just(jsonString), String.class);return body;}});}
}

也可以配置相关的信息

配置网关返回的状态码
spring.cloud.sentinel.scg.fallback.response-status=400