[dubbo] branch 3.1 updated: Update RouterChain.java (#10516)

[albumenj]

This is an automated email from the ASF dual-hosted git repository.

albumenj pushed a commit to branch 3.1
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.1 by this push:
     new 09582dd421 Update RouterChain.java (#10516)
09582dd421 is described below

commit 09582dd4218b9139d0deb2e7e37d401bea9279f9
Author: xin gu <418294...@qq.com>
AuthorDate: Mon Aug 29 10:59:54 2022 +0800

    Update RouterChain.java (#10516)
    
    faq建设，修改为ErrorTypeAwareLogger。
---
 .../main/java/org/apache/dubbo/rpc/cluster/RouterChain.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/RouterChain.java 
b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/RouterChain.java
index 9c283ff0b8..0b91f518f7 100644
--- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/RouterChain.java
+++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/RouterChain.java
@@ -19,7 +19,7 @@ package org.apache.dubbo.rpc.cluster;
 import org.apache.dubbo.common.URL;
 import org.apache.dubbo.common.Version;
 import org.apache.dubbo.common.config.ConfigurationUtils;
-import org.apache.dubbo.common.logger.Logger;
+import org.apache.dubbo.common.logger.ErrorTypeAwareLogger;
 import org.apache.dubbo.common.logger.LoggerFactory;
 import org.apache.dubbo.common.utils.CollectionUtils;
 import org.apache.dubbo.common.utils.Holder;
@@ -49,7 +49,7 @@ import static 
org.apache.dubbo.rpc.cluster.Constants.ROUTER_KEY;
  * Router chain
  */
 public class RouterChain<T> {
-    private static final Logger logger = 
LoggerFactory.getLogger(RouterChain.class);
+    private static final ErrorTypeAwareLogger logger = 
LoggerFactory.getErrorTypeAwareLogger(RouterChain.class);
 
     /**
      * full list of addresses from registry, classified by method name.
@@ -297,7 +297,7 @@ public class RouterChain<T> {
                 if (routerSnapshotSwitcher.isEnable()) {
                     routerSnapshotSwitcher.setSnapshot(message);
                 }
-                logger.warn(message);
+                logger.warn("2-2","No provider available after route for the 
service","",message);
             }
         } else {
             if (logger.isInfoEnabled()) {
@@ -345,7 +345,7 @@ public class RouterChain<T> {
             try {
                 router.stop();
             } catch (Exception e) {
-                logger.error("Error trying to stop router " + 
router.getClass(), e);
+                logger.error("2-3","route stop failed","","Error trying to 
stop router " + router.getClass(),e);
             }
         }
         routers = Collections.emptyList();
@@ -355,7 +355,7 @@ public class RouterChain<T> {
             try {
                 router.stop();
             } catch (Exception e) {
-                logger.error("Error trying to stop stateRouter " + 
router.getClass(), e);
+                logger.error("2-3","StateRouter stop failed","","Error trying 
to stop StateRouter " + router.getClass(),e);
             }
         }
         stateRouters = Collections.emptyList();