com.hazelcast.nio.Address类的使用及代码示例

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

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

Address介绍

[英]Represents an address of a member in the cluster.
[中]表示群集中成员的地址。

代码示例

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

  1. private Member newMember(String name) {
  2.   Member member = mock(Member.class, Mockito.RETURNS_MOCKS);
  3.   when(member.getStringAttribute(HazelcastMember.Attribute.NODE_NAME.getKey())).thenReturn(name);
  4.   when(member.getAddress()).thenReturn(new Address(AN_ADDRESS, 6789));
  5.   return member;
  6.  }
  7. }

代码示例来源：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: hazelcast/hazelcast-jet

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

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

  1. @Override
  2. protected void readInternal(final ObjectDataInput in) throws IOException {
  3.   masterAddress = new Address();
  4.   masterAddress.readData(in);
  5. }

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

  1. private Map<Address, Address> parseResponse(InputStream is) throws IOException {
  2.   JsonValue jsonValue = Json.parse(readInputStream(is));
  3.   List<JsonValue> response = jsonValue.asArray().values();
  4.   Map<Address, Address> privateToPublicAddresses = new HashMap<Address, Address>();
  5.   for (JsonValue value : response) {
  6.     String privateAddress = value.asObject().get(PRIVATE_ADDRESS_PROPERTY).asString();
  7.     String publicAddress = value.asObject().get(PUBLIC_ADDRESS_PROPERTY).asString();
  8.     Address publicAddr = createAddress(publicAddress);
  9.     privateToPublicAddresses.put(new Address(privateAddress, publicAddr.getPort()), publicAddr);
  10.   }
  11.   return privateToPublicAddresses;
  12. }

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

  1. private static int[] arrangeLocalPartitions(Address[] partitionOwners, Address thisAddress) {
  2.   return IntStream.range(0, partitionOwners.length)
  3.       .filter(partitionId -> thisAddress.equals(partitionOwners[partitionId]))
  4.       .toArray();
  5. }

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

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

代码示例来源：origin: com.hazelcast.simulator/tests-hz38

  1. public MockIOService(Address thisAddress, LoggingService loggingService) throws Exception {
  2.   this.thisAddress = thisAddress;
  3.   this.loggingService = loggingService;
  4.   serverSocketChannel = ServerSocketChannel.open();
  5.   ServerSocket serverSocket = serverSocketChannel.socket();
  6.   serverSocket.setReuseAddress(true);
  7.   serverSocket.setSoTimeout(1000);
  8.   serverSocket.bind(new InetSocketAddress("0.0.0.0", thisAddress.getPort()));
  9.   this.serializationService = new DefaultSerializationServiceBuilder().build();
  10. }

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

  1. protected AbstractMember(Address address, MemberVersion version, String uuid, Map<String, Object> attributes,
  2.              boolean liteMember) {
  3.   assert address != null : "Address is required!";
  4.   this.address = address;
  5.   this.version = version;
  6.   this.uuid = uuid != null ? uuid : "<" + address.toString() + ">";
  7.   if (attributes != null) {
  8.     this.attributes.putAll(attributes);
  9.   }
  10.   this.liteMember = liteMember;
  11. }

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

  1. public InetSocketAddress getInetSocketAddress() throws UnknownHostException {
  2.   return new InetSocketAddress(getInetAddress(), port);
  3. }

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

  1. private MemberImpl createMember(MemberInfo memberInfo, Map<String, Object> attributes) {
  2.   Address address = memberInfo.getAddress();
  3.   Address thisAddress = node.getThisAddress();
  4.   String ipV6ScopeId = thisAddress.getScopeId();
  5.   address.setScopeId(ipV6ScopeId);
  6.   boolean localMember = thisAddress.equals(address);
  7.   return new MemberImpl(address, memberInfo.getVersion(), localMember, memberInfo.getUuid(), attributes,
  8.       memberInfo.isLiteMember(), memberInfo.getMemberListJoinVersion(), node.hazelcastInstance);
  9. }

代码示例来源：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. @Override
  2. protected void readInternal(ObjectDataInput in) throws IOException {
  3.   newTargetAddress = new Address();
  4.   newTargetAddress.readData(in);
  5. }

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

  1. private Map<Address, Address> parseResponse(InputStream is) throws IOException {
  2.   JsonValue jsonValue = Json.parse(readInputStream(is));
  3.   List<JsonValue> response = jsonValue.asArray().values();
  4.   Map<Address, Address> privateToPublicAddresses = new HashMap<Address, Address>();
  5.   for (JsonValue value : response) {
  6.     String privateAddress = value.asObject().get(PRIVATE_ADDRESS_PROPERTY).asString();
  7.     String publicAddress = value.asObject().get(PUBLIC_ADDRESS_PROPERTY).asString();
  8.     Address publicAddr = createAddress(publicAddress);
  9.     privateToPublicAddresses.put(new Address(privateAddress, publicAddr.getPort()), publicAddr);
  10.   }
  11.   return privateToPublicAddresses;
  12. }

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

  1. @Override
  2. public boolean isOwnerOrBackup(Address address) {
  3.   if (address == null) {
  4.     return false;
  5.   }
  6.   for (int i = 0; i < MAX_REPLICA_COUNT; i++) {
  7.     if (address.equals(getAddress(replicas[i]))) {
  8.       return true;
  9.     }
  10.   }
  11.   return false;
  12. }

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

  1. private static void printMemberPort(HazelcastInstance hz) throws Exception {
  2.     String printPort = System.getProperty("print.port");
  3.     if (printPort != null) {
  4.       PrintWriter printWriter = null;
  5.       try {
  6.         printWriter = new PrintWriter("ports" + File.separator + printPort, "UTF-8");
  7.         printWriter.println(hz.getCluster().getLocalMember().getAddress().getPort());
  8.       } finally {
  9.         closeResource(printWriter);
  10.       }
  11.     }
  12.   }
  13. }

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

  1. protected AbstractMember(Address address, MemberVersion version, String uuid, Map<String, Object> attributes,
  2.              boolean liteMember) {
  3.   assert address != null : "Address is required!";
  4.   this.address = address;
  5.   this.version = version;
  6.   this.uuid = uuid != null ? uuid : "<" + address.toString() + ">";
  7.   if (attributes != null) {
  8.     this.attributes.putAll(attributes);
  9.   }
  10.   this.liteMember = liteMember;
  11. }

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

  1. public InetSocketAddress getInetSocketAddress() throws UnknownHostException {
  2.   return new InetSocketAddress(getInetAddress(), port);
  3. }

代码示例来源：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 void readData(ObjectDataInput in)
  3.     throws IOException {
  4.   super.readData(in);
  5.   address = new Address();
  6.   address.readData(in);
  7. }

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

Address

相关文章

    查看更多

    热门标签

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

    最新文章

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