com.hazelcast.nio.Address.getHost()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(109)

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

Address.getHost介绍

暂无

代码示例

代码示例来源：origin: SonarSource/sonarqube

  1. @Override
  2. public Optional<String> getLeaderHostName() {
  3.  String leaderId = (String) hzMember.getAtomicReference(LEADER).get();
  4.  if (leaderId != null) {
  5.   Optional<Member> leader = hzMember.getCluster().getMembers().stream().filter(m -> m.getUuid().equals(leaderId)).findFirst();
  6.   if (leader.isPresent()) {
  7.    return Optional.of(leader.get().getAddress().getHost());
  8.   }
  9.  }
  10.  return Optional.empty();
  11. }

代码示例来源：origin: SonarSource/sonarqube

  1. public Collection<NodeInfo> load() throws InterruptedException {
  2.  Map<String, NodeInfo> nodesByName = new HashMap<>();
  3.  MemberSelector memberSelector = HazelcastMemberSelectors.selectorForProcessIds(ProcessId.WEB_SERVER, ProcessId.COMPUTE_ENGINE);
  4.  DistributedAnswer<ProtobufSystemInfo.SystemInfo> distributedAnswer = hzMember.call(ProcessInfoProvider::provide, memberSelector, DISTRIBUTED_TIMEOUT_MS);
  5.  for (Member member : distributedAnswer.getMembers()) {
  6.   String nodeName = member.getStringAttribute(NODE_NAME.getKey());
  7.   NodeInfo nodeInfo = nodesByName.computeIfAbsent(nodeName, name -> {
  8.    NodeInfo info = new NodeInfo(name);
  9.    info.setHost(member.getAddress().getHost());
  10.    return info;
  11.   });
  12.   completeNodeInfo(distributedAnswer, member, nodeInfo);
  13.  }
  14.  return nodesByName.values();
  15. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public String getScopedHost() {
  2.   return (isIPv4() || hostSet || scopeId == null) ? getHost()
  3.       : getHost() + '%' + scopeId;
  4. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. @Override
  2. public String toUrn() {
  3.   return URN_BASE + (address == null ? "-" : (address.getHost() + ":" + String.valueOf(address.getPort()))) + DESC_SEP
  4.       + String.valueOf(partitionId) + DESC_SEP + schedulerName + DESC_SEP + taskName;
  5. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public static int calculateDataSize(Address address) {
  2.     int dataSize = ParameterUtil.calculateDataSize(address.getHost());
  3.     dataSize += Bits.INT_SIZE_IN_BYTES;
  4.     return dataSize;
  5.   }
  6. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. @Override
  2. public String toUrn() {
  3.   return URN_BASE + (address == null ? "-" : (address.getHost() + ":" + String.valueOf(address.getPort()))) + DESC_SEP
  4.       + String.valueOf(partitionId) + DESC_SEP + schedulerName + DESC_SEP + taskName;
  5. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. @Override
  2. public String toString() {
  3.   return "[" + address.getHost() + "]" + ":" + address.getPort() + " - " + uuid;
  4. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. public static int calculateDataSize(Address address) {
  2.     int dataSize = ParameterUtil.calculateDataSize(address.getHost());
  3.     dataSize += Bits.INT_SIZE_IN_BYTES;
  4.     return dataSize;
  5.   }
  6. }

代码示例来源：origin: com.hazelcast/hazelcast-client-protocol

  1. public static int calculateDataSize(Address address) {
  2.     int dataSize = ParameterUtil.calculateDataSize(address.getHost());
  3.     dataSize += Bits.INT_SIZE_IN_BYTES;
  4.     return dataSize;
  5.   }
  6. }

代码示例来源：origin: bitsofinfo/hazelcast-docker-swarm-discovery-spi

  1. @Override
  2. public InetSocketAddress getBindAddress() {
  3.   Address addr = this.swarmDiscoveryUtil.getMyAddress();
  4.   return new InetSocketAddress(addr.getHost(), addr.getPort());
  5. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. private void writeObject(ObjectOutputStream out) throws IOException {
  2.   out.defaultWriteObject();
  3.   Address address = member.getAddress();
  4.   String host = address.getHost();
  5.   int port = address.getPort();
  6.   out.writeUTF(member.getUuid());
  7.   out.writeUTF(host);
  8.   out.writeInt(port);
  9.   out.writeBoolean(member.isLiteMember());
  10.   out.writeObject(member.getVersion());
  11. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. private void writeObject(ObjectOutputStream out) throws IOException {
  2.   out.defaultWriteObject();
  3.   Address address = member.getAddress();
  4.   String host = address.getHost();
  5.   int port = address.getPort();
  6.   out.writeUTF(member.getUuid());
  7.   out.writeUTF(host);
  8.   out.writeInt(port);
  9.   out.writeBoolean(member.isLiteMember());
  10.   out.writeObject(member.getVersion());
  11. }

代码示例来源：origin: org.sonarsource.sonarqube/sonar-main

  1. @Override
  2. public Optional<String> getLeaderHostName() {
  3.  String leaderId = (String) hzMember.getAtomicReference(LEADER).get();
  4.  if (leaderId != null) {
  5.   Optional<Member> leader = hzMember.getCluster().getMembers().stream().filter(m -> m.getUuid().equals(leaderId)).findFirst();
  6.   if (leader.isPresent()) {
  7.    return Optional.of(leader.get().getAddress().getHost());
  8.   }
  9.  }
  10.  return Optional.empty();
  11. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public void setThisMember(MemberImpl thisMember) {
  2.   this.thisMember = thisMember;
  3.   this.thisAddressString = "[" + thisMember.getAddress().getHost() + "]:"
  4.       + thisMember.getAddress().getPort() + " ";
  5. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. public void setThisMember(MemberImpl thisMember) {
  2.   this.thisMember = thisMember;
  3.   this.thisAddressString = "[" + thisMember.getAddress().getHost() + "]:"
  4.       + thisMember.getAddress().getPort() + " ";
  5. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. private Diagnostics newDiagnostics() {
  2.   Address address = node.getThisAddress();
  3.   String addressString = address.getHost().replace(":", "_") + "_" + address.getPort();
  4.   String name = "diagnostics-" + addressString + "-" + currentTimeMillis();
  5.   return new Diagnostics(
  6.       name,
  7.       loggingService.getLogger(Diagnostics.class),
  8.       getHazelcastInstance().getName(),
  9.       node.getProperties());
  10. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. private Diagnostics newDiagnostics() {
  2.   Address address = node.getThisAddress();
  3.   String addressString = address.getHost().replace(":", "_") + "_" + address.getPort();
  4.   String name = "diagnostics-" + addressString + "-" + currentTimeMillis();
  5.   return new Diagnostics(
  6.       name,
  7.       loggingService.getLogger(Diagnostics.class),
  8.       getHazelcastInstance().getName(),
  9.       node.getProperties());
  10. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. private URL newGetTaskUrl() throws IOException {
  2.   GroupConfig groupConfig = instance.getConfig().getGroupConfig();
  3.   Address localAddress = instance.node.getClusterService().getLocalMember().getAddress();
  4.   String urlString = cleanupUrl(managementCenterUrl) + "getTask.do?member=" + localAddress.getHost()
  5.       + ":" + localAddress.getPort() + "&cluster=" + encode(groupConfig.getName(), "UTF-8");
  6.   return new URL(urlString);
  7. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. private URL newGetTaskUrl() throws IOException {
  2.   GroupConfig groupConfig = instance.getConfig().getGroupConfig();
  3.   Address localAddress = instance.node.getClusterService().getLocalMember().getAddress();
  4.   String urlString = cleanupUrl(managementCenterUrl) + "getTask.do?member=" + localAddress.getHost()
  5.       + ":" + localAddress.getPort() + "&cluster=" + encode(groupConfig.getName(), "UTF-8");
  6.   return new URL(urlString);
  7. }

代码示例来源：origin: com.hazelcast/hazelcast-zookeeper

  1. private void prepareServiceInstance() throws Exception {
  2.   Address privateAddress = thisNode.getPrivateAddress();
  3.   serviceInstance = ServiceInstance.<Void>builder()
  4.       .uriSpec(new UriSpec("{scheme}://{address}:{port}"))
  5.       .address(privateAddress.getHost())
  6.       .port(privateAddress.getPort())
  7.       .name(group)
  8.       .build();
  9. }

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

Address

相关文章

    查看更多

    热门标签

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

    最新文章

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