优化日志打印

Author: 侯锐

dubbo/client.py

@@ -12,7 +12,7 @@
 from dubbo.common.util import parse_url, get_pid, get_ip
 from dubbo.connection.connections import connection_pool
 
-logger = logging.getLogger('dubbo')
+logger = logging.getLogger('python-dubbo')
 
 
 class DubboClient(object):

dubbo/common/loggers.py

@@ -40,7 +40,7 @@ def init_log():
     初始化dubbo的日志配置
     :return:
     """
-    logger = logging.getLogger('dubbo')
+    logger = logging.getLogger('python-dubbo')
     console_handler = logging.StreamHandler(sys.stdout)
     formatter = MyFormatter(
         '%(asctime)s %(levelname)s \033[35m%(process)-5d\033[0m --- [%(threadName)15s] \033[33m%(lineno)-4d\033[0m \033[36m%(filename)s\033[0m: %(message)s')

dubbo/common/util.py

@@ -8,7 +8,7 @@
 
 import logging
 
-logger = logging.getLogger('dubbo')
+logger = logging.getLogger('python-dubbo')
 
 ip = None
 heartbeat_id = 0

dubbo/connection/connections.py

@@ -13,7 +13,7 @@
 from dubbo.common.exceptions import DubboResponseException, DubboRequestTimeoutException
 from dubbo.common.util import get_invoke_id
 
-logger = logging.getLogger('dubbo')
+logger = logging.getLogger('python-dubbo')
 
 
 class BaseConnectionPool(object):
@@ -65,6 +65,7 @@ def get(self, host, request_param, timeout=None):
         result = self.results.pop(invoke_id)
         if isinstance(result, Exception):
             logger.exception(result)
+            logger.error('Exception {} for host {}'.format(result, host))
             raise result
         return result
 
@@ -261,9 +262,8 @@ def _check_conn(self, host):
         if self.client_heartbeats[host] >= TIMEOUT_MAX_TIMES:
             self._new_connection(host)
             self.client_heartbeats[host] = 0
-            logger.debug('{} timeout and reconnected by client'.format(host))
-            # 关闭旧的连接
-            conn.close()
+            conn.close()  # 关闭旧的连接
+            logger.debug('{} timeout and reconnected by client.'.format(host))
 
         # 未达到最大的超时次数，超时次数+1且发送心跳包
         else:
@@ -382,6 +382,7 @@ def close(self):
         关闭连接
         :return:
         """
+        logger.debug('{} closed by client.'.format(self.__host))
         self.__sock.shutdown(socket.SHUT_RDWR)
         self.__sock.close()
 

tests/dubbo_test.py

@@ -9,7 +9,7 @@
 from dubbo.common.exceptions import DubboException
 from dubbo.client import DubboClient, ZkRegister
 
-logger = logging.getLogger('dubbo')
+logger = logging.getLogger('python-dubbo')
 
 
 def pretty_print(value):
@@ -74,7 +74,7 @@ def test(self):
         pretty_print(dubbo.call('echo22'))
         pretty_print(dubbo.call('echo23'))
 
-        log = logging.getLogger('dubbo')
+        log = logging.getLogger('python-dubbo')
         log.debug('1111')
         log.info('22222')