本文整理了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

/**
 * 打印连接失败日志
 *
 * @param interfaceId  接口名称
 * @param providerInfo 服务端
 * @param transport    连接
 */
protected void printFailure(String interfaceId, ProviderInfo providerInfo, ClientTransport transport) {
  if (LOGGER.isInfoEnabled(consumerConfig.getAppName())) {
    LOGGER.infoWithApp(consumerConfig.getAppName(), "Connect to {} provider:{} failure !", interfaceId,
      providerInfo);
  }
}

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

@Override
  public void run() {
    if (LOGGER.isWarnEnabled()) {
      LOGGER.warn("SOFA RPC Framework catch JVM shutdown event, Run shutdown hook now.");
    }
    destroy(false);
  }
}, "SOFA-RPC-ShutdownHook"));

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

/**
 * 关闭全部客户端连接
 */
public static void closeAll() {
  if (LOGGER.isInfoEnabled()) {
    LOGGER.info("Shutdown all client transport now!");
  }
  try {
    CLIENT_TRANSPORT_HOLDER.destroy();
  } catch (Exception e) {
    LOGGER.error(e.getMessage(), e);
  }
}

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

public SnappyRpcCompressor() {
  if (LOGGER.isInfoEnabled()) {
    LOGGER.info("Init Snappy compressor");
  }
}

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

/**
 * 反注册一个订阅者
 *
 * @param eventClass 事件类型
 * @param subscriber 订阅者
 */
public static void unRegister(Class<? extends Event> eventClass, Subscriber subscriber) {
  CopyOnWriteArraySet<Subscriber> set = SUBSCRIBER_MAP.get(eventClass);
  if (set != null) {
    set.remove(subscriber);
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug("UnRegister subscriber: {} of event: {}.", subscriber, eventClass);
    }
  }
}

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

static List<String> loadFile(String path) {
  List<String> blackPrefixList = new ArrayList<String>();
  InputStream input = null;
  try {
    input = BlackListFileLoader.class.getResourceAsStream(path);
    if (input != null) {
      readToList(input, "UTF-8", blackPrefixList);
    }
    String overStr = SofaConfigs.getStringValue(SofaOptions.CONFIG_SERIALIZE_BLACKLIST_OVERRIDE, "");
    if (StringUtils.isNotBlank(overStr)) {
      if (LOGGER.isInfoEnabled()) {
        LOGGER.info("Serialize blacklist will override with configuration: {}", overStr);
      }
      overrideBlackList(blackPrefixList, overStr);
    }
  } catch (Exception e) {
    if (LOGGER.isErrorEnabled()) {
      LOGGER.error(e.getMessage(), e);
    }
  } finally {
    closeQuietly(input);
  }
  return blackPrefixList;
}

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

if (LOGGER.isWarnEnabled()) {
    LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
            if (LOGGER.isWarnEnabled()) {
              LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
        if (LOGGER.isWarnEnabled()) {
          LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  if (LOGGER.isWarnEnabled()) {
    LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
if (LOGGER.isErrorEnabled()) {
  LOGGER.error("Can't get valid host, will use 127.0.0.1 instead.");

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

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

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

/**
 * @param path path必须以/结尾
 */
protected synchronized void loadFromFile(String path) {
  if (LOGGER.isDebugEnabled()) {
    LOGGER.debug("Loading extension of extensible {} from path: {}", interfaceName, path);
  }
  // 默认如果不指定文件名字，就是接口名
  String file = StringUtils.isBlank(extensible.file()) ? interfaceName : extensible.file().trim();
  String fullFileName = path + file;
  try {
    ClassLoader classLoader = ClassLoaderUtils.getClassLoader(getClass());
    loadFromClassLoader(classLoader, fullFileName);
  } catch (Throwable t) {
    if (LOGGER.isErrorEnabled()) {
      LOGGER.error("Failed to load extension of extensible " + interfaceName + " from path:" + fullFileName,
        t);
    }
  }
}

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

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

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

@Override
  public void run() {
    try {
      doReconnect();
    } catch (Throwable e) {
      LOGGER.errorWithApp(consumerConfig.getAppName(),
        "Exception when retry connect to provider", e);
    }
  }
}, reconnect, reconnect, TimeUnit.MILLISECONDS).start();

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

LOGGER.errorWithApp(appName, "Server deserialize error, request from "
          + channel.remoteAddress(), e);
        response = MessageBuilder.buildSofaErrorResponse("Server deserialize error, "
  LOGGER.errorWithApp(appName, "Server Processor Error!", e);
  throwable = e;
  response = MessageBuilder.buildSofaErrorResponse(e.getMessage());
if (LOGGER.isErrorEnabled(appName)) {
  LOGGER.errorWithApp(appName, e.getMessage(), e);

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

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

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

protected void initClientTransport(String interfaceId, ProviderInfo providerInfo, ClientTransport transport) {
  try {
    transport.connect();
    if (doubleCheck(interfaceId, providerInfo, transport)) {
      printSuccess(interfaceId, providerInfo, transport);
      addAlive(providerInfo, transport);
    } else {
      printFailure(interfaceId, providerInfo, transport);
      addRetry(providerInfo, transport);
    }
  } catch (Exception e) {
    if (LOGGER.isDebugEnabled(consumerConfig.getAppName())) {
      LOGGER.debugWithApp(consumerConfig.getAppName(), "Failed to connect " + providerInfo, e);
    }
    printDead(interfaceId, providerInfo, transport, e);
    addRetry(providerInfo, transport);
  }
}

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

@Override
  public String echoStr(String arg) {
    LOGGER.info(arg);
    return arg;
  }
}

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

public SnappyRpcCompressor() {
  if (LOGGER.isInfoEnabled()) {
    LOGGER.info("Init Snappy compressor");
  }
}

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

/**
 * 反注册一个订阅者
 *
 * @param eventClass 事件类型
 * @param subscriber 订阅者
 */
public static void unRegister(Class<? extends Event> eventClass, Subscriber subscriber) {
  CopyOnWriteArraySet<Subscriber> set = SUBSCRIBER_MAP.get(eventClass);
  if (set != null) {
    set.remove(subscriber);
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug("UnRegister subscriber: {} of event: {}.", subscriber, eventClass);
    }
  }
}

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

static List<String> loadFile(String path) {
  List<String> blackPrefixList = new ArrayList<String>();
  InputStream input = null;
  try {
    input = BlackListFileLoader.class.getResourceAsStream(path);
    if (input != null) {
      readToList(input, "UTF-8", blackPrefixList);
    }
    String overStr = SofaConfigs.getStringValue(SofaOptions.CONFIG_SERIALIZE_BLACKLIST_OVERRIDE, "");
    if (StringUtils.isNotBlank(overStr)) {
      if (LOGGER.isInfoEnabled()) {
        LOGGER.info("Serialize blacklist will override with configuration: {}", overStr);
      }
      overrideBlackList(blackPrefixList, overStr);
    }
  } catch (Exception e) {
    if (LOGGER.isErrorEnabled()) {
      LOGGER.error(e.getMessage(), e);
    }
  } finally {
    closeQuietly(input);
  }
  return blackPrefixList;
}

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

if (LOGGER.isWarnEnabled()) {
    LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
            if (LOGGER.isWarnEnabled()) {
              LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
        if (LOGGER.isWarnEnabled()) {
          LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
  if (LOGGER.isWarnEnabled()) {
    LOGGER.warn("Error when retrieving ip address: " + e.getMessage(), e);
if (LOGGER.isErrorEnabled()) {
  LOGGER.error("Can't get valid host, will use 127.0.0.1 instead.");

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

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