gpt4 book ai didi

org.springframework.cloud.zookeeper.discovery.ZookeeperServer类的使用及代码示例

转载 作者:知者 更新时间:2024-03-20 02:32:31 27 4
gpt4 key购买 nike

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

ZookeeperServer介绍

[英]A Zookeeper version of a Server
[中]Zookeeper版本的服务器

代码示例

代码示例来源:origin: Nepxion/Discovery

@Override
  public Map<String, String> getServerMetadata(Server server) {
    if (server instanceof ZookeeperServer) {
      ZookeeperServer zookeeperServer = (ZookeeperServer) server;

      return zookeeperServer.getInstance().getPayload().getMetadata();
    }

    throw new DiscoveryException("Server instance isn't the type of ZookeeperServer");
  }
}

代码示例来源:origin: org.apache.camel/camel-spring-cloud-zookeeper

@Override
  public ServiceDefinition convert(ZookeeperServer source) {
    return new DefaultServiceDefinition(
      source.getId(),
      source.getHost(),
      source.getPort(),
      source.getInstance().getPayload().getMetadata()
    );
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-zookeeper

@SuppressWarnings("unchecked")
  protected List<ZookeeperServer> getServers() {
    try {
      if (this.serviceDiscovery == null) {
        return Collections.EMPTY_LIST;
      }
      Collection<ServiceInstance<ZookeeperInstance>> instances = this.serviceDiscovery
          .queryForInstances(this.serviceId);
      if (instances == null || instances.isEmpty()) {
        return Collections.EMPTY_LIST;
      }
      List<ZookeeperServer> servers = new ArrayList<>();
      for (ServiceInstance<ZookeeperInstance> instance : instances) {
        String instanceStatus = null;
        if (instance.getPayload() != null && instance.getPayload().getMetadata() != null) {
          instanceStatus = instance.getPayload().getMetadata().get(INSTANCE_STATUS_KEY);
        }
        if (!StringUtils.hasText(instanceStatus) // backwards compatibility
            || instanceStatus.equalsIgnoreCase(STATUS_UP)) {
          servers.add(new ZookeeperServer(instance));
        }
      }
      return servers;
    }
    catch (Exception e) {
      rethrowRuntimeException(e);
    }
    return Collections.EMPTY_LIST;
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-zookeeper

@Override
public boolean isSecure(Server server) {
  if (server instanceof ZookeeperServer) {
    ZookeeperServer zookeeperServer = (ZookeeperServer) server;
    Integer sslPort = zookeeperServer.getInstance().getSslPort();
    return sslPort != null && sslPort > 0;
  }
  return super.isSecure(server);
}

代码示例来源:origin: com.nepxion/discovery-plugin-framework-zookeeper

@Override
  public Map<String, String> getServerMetadata(Server server) {
    if (server instanceof ZookeeperServer) {
      ZookeeperServer zookeeperServer = (ZookeeperServer) server;

      return zookeeperServer.getInstance().getPayload().getMetadata();
    }

    throw new DiscoveryException("Server instance isn't the type of ZookeeperServer");
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-zookeeper

@Override
  public Map<String, String> getMetadata(Server server) {
    if (server instanceof ZookeeperServer) {
      ZookeeperServer zookeeperServer = (ZookeeperServer) server;
      ServiceInstance<ZookeeperInstance> instance = zookeeperServer.getInstance();
      if (instance != null && instance.getPayload() != null) {
        return instance.getPayload().getMetadata();
      }
    }
    return super.getMetadata(server);
  }
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com