@ -12,7 +12,7 @@ import reactor.core.publisher.Mono;
@@ -12,7 +12,7 @@ import reactor.core.publisher.Mono;
/ * *
* 自定义限流异常处理
*
*
* @author ruoyi
* /
public class SentinelFallbackHandler implements WebExceptionHandler
@ -21,7 +21,7 @@ public class SentinelFallbackHandler implements WebExceptionHandler
@@ -21,7 +21,7 @@ public class SentinelFallbackHandler implements WebExceptionHandler
{
ServerHttpResponse serverHttpResponse = exchange . getResponse ( ) ;
serverHttpResponse . getHeaders ( ) . add ( "Content-Type" , "application/json;charset=UTF-8" ) ;
byte [ ] datas = "{\"status\":429,\"message \":\"请求超过最大数,请稍后再试\"}" . getBytes ( StandardCharsets . UTF_8 ) ;
byte [ ] datas = "{\"code\":429,\"msg \":\"请求超过最大数,请稍后再试\"}" . getBytes ( StandardCharsets . UTF_8 ) ;
DataBuffer buffer = serverHttpResponse . bufferFactory ( ) . wrap ( datas ) ;
return serverHttpResponse . writeWith ( Mono . just ( buffer ) ) ;
}