com.alipay.sofa.rpc.log.Logger类的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(8.2k)|赞(0)|评价(0)|浏览(194)

本文整理了Java中com.alipay.sofa.rpc.log.Logger类的一些代码示例，展示了Logger类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Logger类的具体详情如下：
包路径：com.alipay.sofa.rpc.log.Logger
类名称：Logger

Logger介绍

[英]Just Logger.
[中]就这么简单。

代码示例

代码示例来源：origin: alipay/sofa-rpc

  1. /**
  2.  * 打印连接失败日志
  3.  *
  4.  * @param interfaceId  接口名称
  5.  * @param providerInfo 服务端
  6.  * @param transport    连接
  7.  */
  8. protected void printFailure(String interfaceId, ProviderInfo providerInfo, ClientTransport transport) {
  9.   if (LOGGER.isInfoEnabled(consumerConfig.getAppName())) {
  10.     LOGGER.infoWithApp(consumerConfig.getAppName(), "Connect to {} provider:{} failure !", interfaceId,
  11.       providerInfo);
  12.   }
  13. }

代码示例来源：origin: alipay/sofa-rpc

  1. @Override
  2.   public void run() {
  3.     if (LOGGER.isWarnEnabled()) {
  4.       LOGGER.warn("SOFA RPC Framework catch JVM shutdown event, Run shutdown hook now.");
  5.     }
  6.     destroy(false);
  7.   }
  8. }, "SOFA-RPC-ShutdownHook"));

代码示例来源：origin: alipay/sofa-rpc

  1. /**
  2.  * 关闭全部客户端连接
  3.  */
  4. public static void closeAll() {
  5.   if (LOGGER.isInfoEnabled()) {
  6.     LOGGER.info("Shutdown all client transport now!");
  7.   }
  8.   try {
  9.     CLIENT_TRANSPORT_HOLDER.destroy();
  10.   } catch (Exception e) {
  11.     LOGGER.error(e.getMessage(), e);
  12.   }
  13. }

代码示例来源：origin: alipay/sofa-rpc

  1. public SnappyRpcCompressor() {
  2.   if (LOGGER.isInfoEnabled()) {
  3.     LOGGER.info("Init Snappy compressor");
  4.   }
  5. }

代码示例来源：origin: alipay/sofa-rpc

  1. /**
  2.  * 反注册一个订阅者
  3.  *
  4.  * @param eventClass 事件类型
  5.  * @param subscriber 订阅者
  6.  */
  7. public static void unRegister(Class<? extends Event> eventClass, Subscriber subscriber) {
  8.   CopyOnWriteArraySet<Subscriber> set = SUBSCRIBER_MAP.get(eventClass);
  9.   if (set != null) {
  10.     set.remove(subscriber);
  11.     if (LOGGER.isDebugEnabled()) {
  12.       LOGGER.debug("UnRegister subscriber: {} of event: {}.", subscriber, eventClass);
  13.     }
  14.   }
  15. }

代码示例来源：origin: alipay/sofa-rpc

  1. static List<String> loadFile(String path) {
  2.   List<String> blackPrefixList = new ArrayList<String>();
  3.   InputStream input = null;
  4.   try {
  5.     input = BlackListFileLoader.class.getResourceAsStream(path);
  6.     if (input != null) {
  7.       readToList(input, "UTF-8", blackPrefixList);
  8.     }
  9.     String overStr = SofaConfigs.getStringValue(SofaOptions.CONFIG_SERIALIZE_BLACKLIST_OVERRIDE, "");
  10.     if (StringUtils.isNotBlank(overStr)) {
  11.       if (LOGGER.isInfoEnabled()) {
  12.         LOGGER.info("Serialize blacklist will override with configuration: {}", overStr);
  13.       }
  14.       overrideBlackList(blackPrefixList, overStr);
  15.     }
  16.   } catch (Exception e) {
  17.     if (LOGGER.isErrorEnabled()) {
  18.       LOGGER.error(e.getMessage(), e);
  19.     }
  20.   } finally {
  21.     closeQuietly(input);
  22.   }
  23.   return blackPrefixList;
  24. }

代码示例来源：origin: alipay/sofa-rpc

  1. if (LOGGER.isWarnEnabled()) {
  2.     LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  3.             if (LOGGER.isWarnEnabled()) {
  4.               LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  5.         if (LOGGER.isWarnEnabled()) {
  6.           LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  7.   if (LOGGER.isWarnEnabled()) {
  8.     LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  9. if (LOGGER.isErrorEnabled()) {
  10.   LOGGER.error("Can't get valid host, will use 127.0.0.1 instead.");

代码示例来源：origin: alipay/sofa-rpc

  1. if (ProviderHelper.isEmpty(providerGroup)) {
  2.   if (CommonUtils.isNotEmpty(currentProviderList())) {
  3.     if (LOGGER.isInfoEnabled(consumerConfig.getAppName())) {
  4.       LOGGER.infoWithApp(consumerConfig.getAppName(),
  5.         "Clear all providers, may be this consumer has been add to blacklist");
  6. if (LOGGER.isErrorEnabled(consumerConfig.getAppName())) {
  7.   LOGGER.errorWithApp(consumerConfig.getAppName(), "update " + consumerConfig.getInterfaceId() +
  8.     " provider (" + providerGroup
  9.     + ") from list error:", e);

代码示例来源：origin: alipay/sofa-rpc

  1. /**
  2.  * @param path path必须以/结尾
  3.  */
  4. protected synchronized void loadFromFile(String path) {
  5.   if (LOGGER.isDebugEnabled()) {
  6.     LOGGER.debug("Loading extension of extensible {} from path: {}", interfaceName, path);
  7.   }
  8.   // 默认如果不指定文件名字，就是接口名
  9.   String file = StringUtils.isBlank(extensible.file()) ? interfaceName : extensible.file().trim();
  10.   String fullFileName = path + file;
  11.   try {
  12.     ClassLoader classLoader = ClassLoaderUtils.getClassLoader(getClass());
  13.     loadFromClassLoader(classLoader, fullFileName);
  14.   } catch (Throwable t) {
  15.     if (LOGGER.isErrorEnabled()) {
  16.       LOGGER.error("Failed to load extension of extensible " + interfaceName + " from path:" + fullFileName,
  17.         t);
  18.     }
  19.   }
  20. }

代码示例来源：origin: alipay/sofa-rpc

  1. @Override
  2.   public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
  3.     LOGGER.error("Client channel handler get exception!", cause);
  4.   }
  5. }

代码示例来源：origin: alipay/sofa-rpc

  1. @Override
  2.   public void run() {
  3.     try {
  4.       doReconnect();
  5.     } catch (Throwable e) {
  6.       LOGGER.errorWithApp(consumerConfig.getAppName(),
  7.         "Exception when retry connect to provider", e);
  8.     }
  9.   }
  10. }, reconnect, reconnect, TimeUnit.MILLISECONDS).start();

代码示例来源：origin: alipay/sofa-rpc

  1. LOGGER.errorWithApp(appName, "Server deserialize error, request from "
  2.           + channel.remoteAddress(), e);
  3.         response = MessageBuilder.buildSofaErrorResponse("Server deserialize error, "
  4.   LOGGER.errorWithApp(appName, "Server Processor Error!", e);
  5.   throwable = e;
  6.   response = MessageBuilder.buildSofaErrorResponse(e.getMessage());
  7. if (LOGGER.isErrorEnabled(appName)) {
  8.   LOGGER.errorWithApp(appName, e.getMessage(), e);

代码示例来源：origin: alipay/sofa-rpc

  1. @Override
  2. public SofaResponse invoke() {
  3.   if (isCircuitBreakerOpen() && LOGGER.isWarnEnabled(invoker.getConfig().getAppName())) {
  4.     LOGGER.warnWithApp(invoker.getConfig().getAppName(), "Circuit Breaker is opened, method: {}#{}",
  5.       invoker.getConfig().getInterfaceId(), request.getMethodName());
  6.   }
  7.   return execute();
  8. }

代码示例来源：origin: alipay/sofa-rpc

  1. protected void initClientTransport(String interfaceId, ProviderInfo providerInfo, ClientTransport transport) {
  2.   try {
  3.     transport.connect();
  4.     if (doubleCheck(interfaceId, providerInfo, transport)) {
  5.       printSuccess(interfaceId, providerInfo, transport);
  6.       addAlive(providerInfo, transport);
  7.     } else {
  8.       printFailure(interfaceId, providerInfo, transport);
  9.       addRetry(providerInfo, transport);
  10.     }
  11.   } catch (Exception e) {
  12.     if (LOGGER.isDebugEnabled(consumerConfig.getAppName())) {
  13.       LOGGER.debugWithApp(consumerConfig.getAppName(), "Failed to connect " + providerInfo, e);
  14.     }
  15.     printDead(interfaceId, providerInfo, transport, e);
  16.     addRetry(providerInfo, transport);
  17.   }
  18. }

代码示例来源：origin: alipay/sofa-rpc

  1. @Override
  2.   public String echoStr(String arg) {
  3.     LOGGER.info(arg);
  4.     return arg;
  5.   }
  6. }

代码示例来源：origin: alipay/sofa-rpc

  1. public SnappyRpcCompressor() {
  2.   if (LOGGER.isInfoEnabled()) {
  3.     LOGGER.info("Init Snappy compressor");
  4.   }
  5. }

代码示例来源：origin: alipay/sofa-rpc

  1. /**
  2.  * 反注册一个订阅者
  3.  *
  4.  * @param eventClass 事件类型
  5.  * @param subscriber 订阅者
  6.  */
  7. public static void unRegister(Class<? extends Event> eventClass, Subscriber subscriber) {
  8.   CopyOnWriteArraySet<Subscriber> set = SUBSCRIBER_MAP.get(eventClass);
  9.   if (set != null) {
  10.     set.remove(subscriber);
  11.     if (LOGGER.isDebugEnabled()) {
  12.       LOGGER.debug("UnRegister subscriber: {} of event: {}.", subscriber, eventClass);
  13.     }
  14.   }
  15. }

代码示例来源：origin: alipay/sofa-rpc

  1. static List<String> loadFile(String path) {
  2.   List<String> blackPrefixList = new ArrayList<String>();
  3.   InputStream input = null;
  4.   try {
  5.     input = BlackListFileLoader.class.getResourceAsStream(path);
  6.     if (input != null) {
  7.       readToList(input, "UTF-8", blackPrefixList);
  8.     }
  9.     String overStr = SofaConfigs.getStringValue(SofaOptions.CONFIG_SERIALIZE_BLACKLIST_OVERRIDE, "");
  10.     if (StringUtils.isNotBlank(overStr)) {
  11.       if (LOGGER.isInfoEnabled()) {
  12.         LOGGER.info("Serialize blacklist will override with configuration: {}", overStr);
  13.       }
  14.       overrideBlackList(blackPrefixList, overStr);
  15.     }
  16.   } catch (Exception e) {
  17.     if (LOGGER.isErrorEnabled()) {
  18.       LOGGER.error(e.getMessage(), e);
  19.     }
  20.   } finally {
  21.     closeQuietly(input);
  22.   }
  23.   return blackPrefixList;
  24. }

代码示例来源：origin: alipay/sofa-rpc

  1. if (LOGGER.isWarnEnabled()) {
  2.     LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  3.             if (LOGGER.isWarnEnabled()) {
  4.               LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  5.         if (LOGGER.isWarnEnabled()) {
  6.           LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  7.   if (LOGGER.isWarnEnabled()) {
  8.     LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  9. if (LOGGER.isErrorEnabled()) {
  10.   LOGGER.error("Can't get valid host, will use 127.0.0.1 instead.");

代码示例来源：origin: alipay/sofa-rpc

  1. if (ProviderHelper.isEmpty(providerGroup)) {
  2.   if (CommonUtils.isNotEmpty(currentProviderList())) {
  3.     if (LOGGER.isInfoEnabled(consumerConfig.getAppName())) {
  4.       LOGGER.infoWithApp(consumerConfig.getAppName(),
  5.         "Clear all providers, may be this consumer has been add to blacklist");
  6. if (LOGGER.isErrorEnabled(consumerConfig.getAppName())) {
  7.   LOGGER.errorWithApp(consumerConfig.getAppName(), "update " + consumerConfig.getInterfaceId() +
  8.     " provider (" + providerGroup
  9.     + ") from list error:", e);

内容来源于网络，如有侵权，请联系作者删除！

Logger

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com