[type:refactor] Optimize code for assert keyword #5967 (#5968)

yqw570994511 · Aias00 · web-flow · commit b9444302397e · 2025-03-27T10:41:24.000+08:00
* [type:refactor] Optimize code for assert keyword #5967 Replace the code that uses the assert keyword for validation with a more commonly used approach. * [type:refactor] Optimize code for assert keyword #5967 Replace the code that uses the assert keyword for validation with a more commonly used approach. --------- Co-authored-by: yuqianwei <qq120405> Co-authored-by: aias00 <liuhongyu@apache.org>
diff --git a/shenyu-alert/src/main/java/org/apache/shenyu/alert/strategy/DingTalkRobotAlertNotifyStrategy.java b/shenyu-alert/src/main/java/org/apache/shenyu/alert/strategy/DingTalkRobotAlertNotifyStrategy.java
@@ -56,7 +56,7 @@ public void send(final AlertReceiverDTO receiver, final AlarmContent alert) {
             ResponseEntity<CommonRobotNotifyResp> responseEntity = getRestTemplate().postForEntity(webHookUrl,
                     httpEntity, CommonRobotNotifyResp.class);
             if (responseEntity.getStatusCode() == HttpStatus.OK) {
-                assert Objects.nonNull(responseEntity.getBody());
+                Objects.requireNonNull(responseEntity.getBody());
                 if (responseEntity.getBody().getErrCode() == 0) {
                     log.debug("Send dingTalk webHook: {} Success", webHookUrl);
                 } else {
diff --git a/shenyu-common/src/main/java/org/apache/shenyu/common/utils/GsonUtils.java b/shenyu-common/src/main/java/org/apache/shenyu/common/utils/GsonUtils.java
@@ -357,7 +357,7 @@ public Map<T, U> deserialize(final JsonElement json, final Type type, final Json
             }
             
             Map<T, U> resultMap = null;
-            assert Objects.nonNull(mapClass);
+            Objects.requireNonNull(mapClass);
             if (Objects.requireNonNull(mapClass).isInterface()) {
                 resultMap = new LinkedHashMap<>();
             } else {
diff --git a/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/AiProxyPlugin.java b/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/AiProxyPlugin.java
@@ -63,7 +63,7 @@ protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPlu
             aiProxyConfig = new AiProxyConfig();
         }
         final ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         
         // Get selector handle from cache
         AiProxyHandle selectorHandle = AiProxyPluginHandler.SELECTOR_CACHED_HANDLE.get()
diff --git a/shenyu-plugin/shenyu-plugin-ai-token-limiter/src/main/java/org/apache/shenyu/plugin/ai/token/limiter/redis/RedisConnectionFactory.java b/shenyu-plugin/shenyu-plugin-ai-token-limiter/src/main/java/org/apache/shenyu/plugin/ai/token/limiter/redis/RedisConnectionFactory.java
@@ -92,7 +92,7 @@ private GenericObjectPoolConfig<?> getPoolConfig(final RedisConfigProperties red
     protected final RedisStandaloneConfiguration redisStandaloneConfiguration(final RedisConfigProperties redisConfigProperties) {
         RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
         String[] parts = StringUtils.split(redisConfigProperties.getUrl(), ":");
-        assert Objects.nonNull(parts);
+        Objects.requireNonNull(parts);
         config.setHostName(parts[0]);
         config.setPort(Integer.parseInt(parts[1]));
         if (Objects.nonNull(redisConfigProperties.getPassword())) {
diff --git a/shenyu-plugin/shenyu-plugin-api/src/main/java/org/apache/shenyu/plugin/api/ShenyuPlugin.java b/shenyu-plugin/shenyu-plugin-api/src/main/java/org/apache/shenyu/plugin/api/ShenyuPlugin.java
@@ -97,7 +97,7 @@ default boolean skip(ServerWebExchange exchange, RpcTypeEnum... rpcTypes) {
             return false;
         }
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         return Arrays.stream(rpcTypes).anyMatch(type -> Objects.equals(shenyuContext.getRpcType(), type.getName()));
     }
 
diff --git a/shenyu-plugin/shenyu-plugin-api/src/main/java/org/apache/shenyu/plugin/api/utils/RequestUrlUtils.java b/shenyu-plugin/shenyu-plugin-api/src/main/java/org/apache/shenyu/plugin/api/utils/RequestUrlUtils.java
@@ -48,7 +48,7 @@ public static URI buildRequestUri(final ServerWebExchange exchange, final String
             path = path + rewriteUri;
         } else {
             ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-            assert Objects.nonNull(shenyuContext);
+            Objects.requireNonNull(shenyuContext);
             String realUrl = shenyuContext.getRealUrl();
             if (StringUtils.isNoneBlank(realUrl)) {
                 path = path + realUrl;
@@ -63,7 +63,7 @@ public static URI buildRequestUri(final ServerWebExchange exchange, final String
             if (StringUtils.isNotEmpty(uri.getQuery())) {
                 path = path + "?" + uri.getQuery();
             }
-            assert Objects.nonNull(path);
+            Objects.requireNonNull(path);
             return UriComponentsBuilder.fromUriString(path).build(false).toUri();
         }
     }
diff --git a/shenyu-plugin/shenyu-plugin-api/src/main/java/org/apache/shenyu/plugin/api/utils/WebFluxResultUtils.java b/shenyu-plugin/shenyu-plugin-api/src/main/java/org/apache/shenyu/plugin/api/utils/WebFluxResultUtils.java
@@ -64,7 +64,7 @@ public static Mono<Void> result(final ServerWebExchange exchange, final Object r
         }
         exchange.getResponse().getHeaders().setContentType(mediaType);
         final Object responseData = shenyuResult.result(exchange, resultData);
-        assert Objects.nonNull(responseData);
+        Objects.requireNonNull(responseData);
         final byte[] bytes = (responseData instanceof byte[])
                 ? (byte[]) responseData : responseData.toString().getBytes(StandardCharsets.UTF_8);
         return exchange.getResponse().writeWith(Mono.just(exchange.getResponse()
diff --git a/shenyu-plugin/shenyu-plugin-cache/shenyu-plugin-cache-redis/src/main/java/org/apache/shenyu/plugin/cache/redis/RedisConnectionFactory.java b/shenyu-plugin/shenyu-plugin-cache/shenyu-plugin-cache-redis/src/main/java/org/apache/shenyu/plugin/cache/redis/RedisConnectionFactory.java
@@ -92,7 +92,7 @@ private GenericObjectPoolConfig<?> getPoolConfig(final RedisConfigProperties red
     protected final RedisStandaloneConfiguration redisStandaloneConfiguration(final RedisConfigProperties redisConfigProperties) {
         RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
         String[] parts = StringUtils.split(redisConfigProperties.getUrl(), ":");
-        assert Objects.nonNull(parts);
+        Objects.requireNonNull(parts);
         config.setHostName(parts[0]);
         config.setPort(Integer.parseInt(parts[1]));
         if (Objects.nonNull(redisConfigProperties.getPassword())) {
diff --git a/shenyu-plugin/shenyu-plugin-context-path/src/main/java/org/apache/shenyu/plugin/context/path/ContextPathPlugin.java b/shenyu-plugin/shenyu-plugin-context-path/src/main/java/org/apache/shenyu/plugin/context/path/ContextPathPlugin.java
@@ -50,7 +50,7 @@ public class ContextPathPlugin extends AbstractShenyuPlugin {
     @Override
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         ContextMappingRuleHandle ruleHandle = buildRuleHandle(rule);
         if (Objects.isNull(ruleHandle)) {
             LOG.error("context path rule configuration is null ：{}", rule);
diff --git a/shenyu-plugin/shenyu-plugin-fault-tolerance/shenyu-plugin-hystrix/src/main/java/org/apache/shenyu/plugin/hystrix/HystrixPlugin.java b/shenyu-plugin/shenyu-plugin-fault-tolerance/shenyu-plugin-hystrix/src/main/java/org/apache/shenyu/plugin/hystrix/HystrixPlugin.java
@@ -55,7 +55,7 @@ public class HystrixPlugin extends AbstractShenyuPlugin {
     @Override
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         final ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         final HystrixHandle hystrixHandle = HystrixPluginDataHandler.CACHED_HANDLE.get().obtainHandle(CacheKeyUtils.INST.getKey(rule));
         String groupKey = hystrixHandle.getGroupKey();
         if (StringUtils.isBlank(hystrixHandle.getGroupKey())) {
diff --git a/shenyu-plugin/shenyu-plugin-fault-tolerance/shenyu-plugin-sentinel/src/main/java/org/apache/shenyu/plugin/sentinel/SentinelPlugin.java b/shenyu-plugin/shenyu-plugin-fault-tolerance/shenyu-plugin-sentinel/src/main/java/org/apache/shenyu/plugin/sentinel/SentinelPlugin.java
@@ -54,7 +54,7 @@ public SentinelPlugin(final FallbackHandler fallbackHandler) {
     @Override
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         final ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         String resourceName = CacheKeyUtils.INST.getKey(rule);
         SentinelHandle sentinelHandle = SentinelRuleHandle.CACHED_HANDLE.get().obtainHandle(resourceName);
         sentinelHandle.checkData();
diff --git a/shenyu-plugin/shenyu-plugin-httpclient/src/main/java/org/apache/shenyu/plugin/httpclient/AbstractHttpClientPlugin.java b/shenyu-plugin/shenyu-plugin-httpclient/src/main/java/org/apache/shenyu/plugin/httpclient/AbstractHttpClientPlugin.java
@@ -74,7 +74,7 @@ public abstract class AbstractHttpClientPlugin<R> implements ShenyuPlugin {
     @Override
     public final Mono<Void> execute(final ServerWebExchange exchange, final ShenyuPluginChain chain) {
         final ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         final URI uri = exchange.getAttribute(Constants.HTTP_URI);
         if (Objects.isNull(uri)) {
             Object error = ShenyuResultWrap.error(exchange, ShenyuResultEnum.CANNOT_FIND_URL);
diff --git a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-common/src/main/java/org/apache/shenyu/plugin/logging/common/body/LoggingServerHttpResponse.java b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-common/src/main/java/org/apache/shenyu/plugin/logging/common/body/LoggingServerHttpResponse.java
@@ -127,7 +127,7 @@ public Mono<Void> writeWith(@NonNull final Publisher<? extends DataBuffer> body)
     @NonNull
     private Flux<? extends DataBuffer> appendResponse(final Publisher<? extends DataBuffer> body) {
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         if (Objects.nonNull(getStatusCode())) {
             logInfo.setStatus(getStatusCode().value());
         }
@@ -196,7 +196,7 @@ private void logResponse(final ShenyuContext shenyuContext, final BodyWriter wri
      */
     private String getUpstreamIp() {
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         if (RpcTypeEnum.HTTP.getName().equals(shenyuContext.getRpcType())) {
             URI uri = exchange.getAttribute(Constants.HTTP_URI);
             if (Objects.nonNull(uri)) {
@@ -242,13 +242,13 @@ public void logError(final Throwable throwable) {
         final ShenyuResult<?> shenyuResult = ShenyuResultWrap.shenyuResult();
         Object resultData = shenyuResult.format(exchange, result);
         final Object responseData = shenyuResult.result(exchange, resultData);
-        assert Objects.nonNull(responseData);
+        Objects.requireNonNull(responseData);
         final byte[] bytes = (responseData instanceof byte[])
                 ? (byte[]) responseData
                 : responseData.toString().getBytes(StandardCharsets.UTF_8);
         logInfo.setResponseContentLength(bytes.length);
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         logInfo.setTimeLocal(shenyuContext.getStartDateTime().format(DATE_TIME_FORMATTER));
         logInfo.setModule(shenyuContext.getModule());
         long costTime = DateUtils.acquireMillisBetween(shenyuContext.getStartDateTime(), LocalDateTime.now());
diff --git a/shenyu-plugin/shenyu-plugin-metrics/src/main/java/org/apache/shenyu/plugin/metrics/MetricsPlugin.java b/shenyu-plugin/shenyu-plugin-metrics/src/main/java/org/apache/shenyu/plugin/metrics/MetricsPlugin.java
@@ -44,7 +44,7 @@ public class MetricsPlugin implements ShenyuPlugin {
     public Mono<Void> execute(final ServerWebExchange exchange, final ShenyuPluginChain chain) {
         MetricsReporter.counterIncrement(LabelNames.REQUEST_TOTAL);
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         setMetricsCallbacks(exchange);
         MetricsReporter.counterIncrement(LabelNames.REQUEST_TYPE_TOTAL, new String[]{exchange.getRequest().getURI().getRawPath(), shenyuContext.getRpcType()});
         LocalDateTime startDateTime = Optional.of(shenyuContext).map(ShenyuContext::getStartDateTime).orElseGet(LocalDateTime::now);
diff --git a/shenyu-plugin/shenyu-plugin-modify-response/src/main/java/org/apache/shenyu/plugin/modify/response/ModifyResponsePlugin.java b/shenyu-plugin/shenyu-plugin-modify-response/src/main/java/org/apache/shenyu/plugin/modify/response/ModifyResponsePlugin.java
@@ -61,7 +61,7 @@ public class ModifyResponsePlugin extends AbstractShenyuPlugin {
     @Override
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         ModifyResponseRuleHandle ruleHandle = ModifyResponsePluginDataHandler.CACHED_HANDLE.get().obtainHandle(CacheKeyUtils.INST.getKey(rule));
         if (Objects.isNull(ruleHandle)) {
             return chain.execute(exchange);
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-divide/src/main/java/org/apache/shenyu/plugin/divide/DividePlugin.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-divide/src/main/java/org/apache/shenyu/plugin/divide/DividePlugin.java
@@ -70,7 +70,7 @@ protected String getRawPath(final ServerWebExchange exchange) {
     @Override
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         DivideRuleHandle ruleHandle = buildRuleHandle(rule);
         if (ruleHandle.getHeaderMaxSize() > 0) {
             long headerSize = exchange.getRequest().getHeaders().values()
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-divide/src/test/java/org/apache/shenyu/plugin/divide/DividePluginTest.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-divide/src/test/java/org/apache/shenyu/plugin/divide/DividePluginTest.java
@@ -163,9 +163,9 @@ public void doExecuteTest() {
         loadBalancerFactoryMockedStatic.when(() -> LoadBalancerFactory.selector(any(), any(), any()))
                 .thenReturn(null);
         dividePlugin.doExecute(exchange, chain, selectorData, ruleData);
-        // hit `assert shenyuContext != null`
+        // hit `Objects.requireNonNull(shenyuContext)`
         exchange.getAttributes().remove(Constants.CONTEXT);
-        assertThrows(AssertionError.class, () -> dividePlugin.doExecute(exchange, chain, selectorData, ruleData));
+        assertThrows(NullPointerException.class, () -> dividePlugin.doExecute(exchange, chain, selectorData, ruleData));
     }
 
     /**
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-dubbo/shenyu-plugin-dubbo-common/src/main/java/org/apache/shenyu/plugin/dubbo/common/AbstractDubboPlugin.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-dubbo/shenyu-plugin-dubbo-common/src/main/java/org/apache/shenyu/plugin/dubbo/common/AbstractDubboPlugin.java
@@ -94,7 +94,7 @@ public Mono<Void> doExecute(final ServerWebExchange exchange,
                                    final RuleData rule) {
         String param = exchange.getAttribute(Constants.PARAM_TRANSFORM);
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         MetaData metaData = exchange.getAttribute(Constants.META_DATA);
         if (!checkMetaData(metaData)) {
             LOG.error(" path is : {}, meta data have error : {}", shenyuContext.getPath(), metaData);
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-grpc/src/main/java/org/apache/shenyu/plugin/grpc/GrpcPlugin.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-grpc/src/main/java/org/apache/shenyu/plugin/grpc/GrpcPlugin.java
@@ -71,7 +71,7 @@ protected String getRawPath(final ServerWebExchange exchange) {
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         final String param = exchange.getAttribute(Constants.PARAM_TRANSFORM);
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         MetaData metaData = exchange.getAttribute(Constants.META_DATA);
 
         if (!checkMetaData(metaData)) {
@@ -80,7 +80,7 @@ protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPlu
             Object error = ShenyuResultWrap.error(exchange, ShenyuResultEnum.META_DATA_ERROR);
             return WebFluxResultUtils.result(exchange, error);
         }
-        assert Objects.nonNull(metaData);
+        Objects.requireNonNull(metaData);
         if (StringUtils.isNoneBlank(metaData.getParameterTypes()) && StringUtils.isBlank(param)) {
             exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
             Object error = ShenyuResultWrap.error(exchange, ShenyuResultEnum.GRPC_HAVE_BODY_PARAM);
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-motan/src/main/java/org/apache/shenyu/plugin/motan/MotanPlugin.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-motan/src/main/java/org/apache/shenyu/plugin/motan/MotanPlugin.java
@@ -69,10 +69,10 @@ protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPlu
                                    final SelectorData selector, final RuleData rule) {
         String param = exchange.getAttribute(Constants.PARAM_TRANSFORM);
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         MetaData metaData = exchange.getAttribute(Constants.META_DATA);
         if (!checkMetaData(metaData)) {
-            assert Objects.nonNull(metaData);
+            Objects.requireNonNull(metaData);
             LOG.error("path is :{}, meta data have error.... {}", shenyuContext.getPath(), metaData);
             exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
             Object error = ShenyuResultWrap.error(exchange, ShenyuResultEnum.META_DATA_ERROR);
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-sofa/src/main/java/org/apache/shenyu/plugin/sofa/SofaPlugin.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-sofa/src/main/java/org/apache/shenyu/plugin/sofa/SofaPlugin.java
@@ -70,10 +70,10 @@ protected String getRawPath(final ServerWebExchange exchange) {
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         String param = exchange.getAttribute(Constants.PARAM_TRANSFORM);
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         MetaData metaData = exchange.getAttribute(Constants.META_DATA);
         if (!checkMetaData(metaData)) {
-            assert Objects.nonNull(metaData);
+            Objects.requireNonNull(metaData);
             LOG.error(" path is :{}, meta data have error.... {}", shenyuContext.getPath(), metaData);
             exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
             Object error = ShenyuResultWrap.error(exchange, ShenyuResultEnum.META_DATA_ERROR);
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-sofa/src/main/java/org/apache/shenyu/plugin/sofa/param/SofaParamResolveServiceImpl.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-sofa/src/main/java/org/apache/shenyu/plugin/sofa/param/SofaParamResolveServiceImpl.java
@@ -28,6 +28,7 @@
 import org.apache.shenyu.common.utils.GsonUtils;
 import org.apache.shenyu.common.utils.ParamCheckUtils;
 import org.springframework.lang.NonNull;
+import org.springframework.util.Assert;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -73,7 +74,7 @@ private Object convertToParameterValue(final Object value, final String[] parame
                 // no generic info
                 return mapValue;
             }
-            assert parameterType.length == 3;
+            Assert.state(parameterType.length == 3, "parameterType length must be 3.");
             // generic map
             final GenericMap genericMap = new GenericMap(parameterType[2]);
             mapValue.replaceAll((k, v) -> convertToGenericObject(parameterType[2], mapValue.get(k)));
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-tars/src/main/java/org/apache/shenyu/plugin/tars/TarsPlugin.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-tars/src/main/java/org/apache/shenyu/plugin/tars/TarsPlugin.java
@@ -64,10 +64,10 @@ protected String getRawPath(final ServerWebExchange exchange) {
     protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPluginChain chain, final SelectorData selector, final RuleData rule) {
         String body = exchange.getAttribute(Constants.PARAM_TRANSFORM);
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         MetaData metaData = exchange.getAttribute(Constants.META_DATA);
         if (!checkMetaData(metaData)) {
-            assert Objects.nonNull(metaData);
+            Objects.requireNonNull(metaData);
             LOG.error(" path is :{}, meta data have error.... {}", shenyuContext.getPath(), metaData);
             exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
             Object error = ShenyuResultWrap.error(exchange, ShenyuResultEnum.META_DATA_ERROR);
diff --git a/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-tars/src/main/java/org/apache/shenyu/plugin/tars/cache/ApplicationConfigCache.java b/shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-tars/src/main/java/org/apache/shenyu/plugin/tars/cache/ApplicationConfigCache.java
@@ -216,7 +216,7 @@ public void initPrx(final MetaData metaData) {
      * @see ReentrantLock
      */
     private void tryLockedLoadMetaData(final MetaData metaData) throws ClassNotFoundException {
-        assert Objects.nonNull(LOCK);
+        Objects.requireNonNull(LOCK);
         if (LOCK.tryLock()) {
             try {
                 if (StringUtils.isEmpty(metaData.getRpcExt())) {
diff --git a/shenyu-plugin/shenyu-plugin-response/src/main/java/org/apache/shenyu/plugin/response/ResponsePlugin.java b/shenyu-plugin/shenyu-plugin-response/src/main/java/org/apache/shenyu/plugin/response/ResponsePlugin.java
@@ -48,7 +48,7 @@ public ResponsePlugin(final Map<String, MessageWriter> writerMap) {
     @Override
     public Mono<Void> execute(final ServerWebExchange exchange, final ShenyuPluginChain chain) {
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         return writerMap.get(shenyuContext.getRpcType()).writeWith(exchange, chain);
     }
 
diff --git a/shenyu-plugin/shenyu-plugin-rewrite/src/main/java/org/apache/shenyu/plugin/rewrite/RewritePlugin.java b/shenyu-plugin/shenyu-plugin-rewrite/src/main/java/org/apache/shenyu/plugin/rewrite/RewritePlugin.java
@@ -57,7 +57,7 @@ protected String getRawPath(final ServerWebExchange exchange) {
         }
         // match the new selector/rule of RewritePlugin
         ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
         return rewriteContextPath + shenyuContext.getRealUrl();
     }
     
@@ -90,7 +90,7 @@ protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPlu
                     attributes.put(Constants.META_DATA, metaData);
                 }
                 ShenyuContext context = exchange.getAttribute(Constants.CONTEXT);
-                assert Objects.nonNull(context);
+                Objects.requireNonNull(context);
                 if (Objects.nonNull(metaData) && Boolean.TRUE.equals(metaData.getEnabled())) {
                     context.setRpcType(metaData.getRpcType());
                 } else {
diff --git a/shenyu-plugin/shenyu-plugin-security/shenyu-plugin-sign/src/main/java/org/apache/shenyu/plugin/sign/service/ComposableSignService.java b/shenyu-plugin/shenyu-plugin-security/shenyu-plugin-sign/src/main/java/org/apache/shenyu/plugin/sign/service/ComposableSignService.java
@@ -104,7 +104,7 @@ public VerifyResult signatureVerify(final ServerWebExchange exchange) {
     private VerifyResult signatureVerify(final ServerWebExchange exchange, final BiFunction<String, SignParameters, String> signFunction) {
 
         final ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);
-        assert Objects.nonNull(shenyuContext);
+        Objects.requireNonNull(shenyuContext);
 
         SignParameters signParameters = extractor.extract(exchange.getRequest());
 

Original file line number	Diff line number	Diff line change
`@@ -357,7 +357,7 @@ public Map<T, U> deserialize(final JsonElement json, final Type type, final Json`
`357`	`357`	`}`
`358`	`358`
`359`	`359`	`Map<T, U> resultMap = null;`
`360`		`- assert Objects.nonNull(mapClass);`
	`360`	`+ Objects.requireNonNull(mapClass);`
`361`	`361`	`if (Objects.requireNonNull(mapClass).isInterface()) {`
`362`	`362`	`resultMap = new LinkedHashMap<>();`
`363`	`363`	`} else {`
Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ protected Mono<Void> doExecute(final ServerWebExchange exchange, final ShenyuPlu`
`63`	`63`	`aiProxyConfig = new AiProxyConfig();`
`64`	`64`	`}`
`65`	`65`	`final ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);`
`66`		`- assert Objects.nonNull(shenyuContext);`
	`66`	`+ Objects.requireNonNull(shenyuContext);`
`67`	`67`
`68`	`68`	`// Get selector handle from cache`
`69`	`69`	`AiProxyHandle selectorHandle = AiProxyPluginHandler.SELECTOR_CACHED_HANDLE.get()`
Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ default boolean skip(ServerWebExchange exchange, RpcTypeEnum... rpcTypes) {`
`97`	`97`	`return false;`
`98`	`98`	`}`
`99`	`99`	`ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);`
`100`		`- assert Objects.nonNull(shenyuContext);`
	`100`	`+ Objects.requireNonNull(shenyuContext);`
`101`	`101`	`return Arrays.stream(rpcTypes).anyMatch(type -> Objects.equals(shenyuContext.getRpcType(), type.getName()));`
`102`	`102`	`}`
`103`	`103`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ public static URI buildRequestUri(final ServerWebExchange exchange, final String`
`48`	`48`	`path = path + rewriteUri;`
`49`	`49`	`} else {`
`50`	`50`	`ShenyuContext shenyuContext = exchange.getAttribute(Constants.CONTEXT);`
`51`		`- assert Objects.nonNull(shenyuContext);`
	`51`	`+ Objects.requireNonNull(shenyuContext);`
`52`	`52`	`String realUrl = shenyuContext.getRealUrl();`
`53`	`53`	`if (StringUtils.isNoneBlank(realUrl)) {`
`54`	`54`	`path = path + realUrl;`
`@@ -63,7 +63,7 @@ public static URI buildRequestUri(final ServerWebExchange exchange, final String`
`63`	`63`	`if (StringUtils.isNotEmpty(uri.getQuery())) {`
`64`	`64`	`path = path + "?" + uri.getQuery();`
`65`	`65`	`}`
`66`		`- assert Objects.nonNull(path);`
	`66`	`+ Objects.requireNonNull(path);`
`67`	`67`	`return UriComponentsBuilder.fromUriString(path).build(false).toUri();`
`68`	`68`	`}`
`69`	`69`	`}`
Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ public static Mono<Void> result(final ServerWebExchange exchange, final Object r`
`64`	`64`	`}`
`65`	`65`	`exchange.getResponse().getHeaders().setContentType(mediaType);`
`66`	`66`	`final Object responseData = shenyuResult.result(exchange, resultData);`
`67`		`- assert Objects.nonNull(responseData);`
	`67`	`+ Objects.requireNonNull(responseData);`
`68`	`68`	`final byte[] bytes = (responseData instanceof byte[])`
`69`	`69`	`? (byte[]) responseData : responseData.toString().getBytes(StandardCharsets.UTF_8);`
`70`	`70`	`return exchange.getResponse().writeWith(Mono.just(exchange.getResponse()`