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

Node.getJoiner介绍

暂无

代码示例

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

private void searchForOtherClusters() {
    Joiner joiner = node.getJoiner();
    if (joiner != null) {
      joiner.searchForOtherClusters();
    }
  }
}

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

private void searchForOtherClusters() {
    Joiner joiner = node.getJoiner();
    if (joiner != null) {
      joiner.searchForOtherClusters();
    }
  }
}

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

@Override
public void onSuccessfulConnection(Address address) {
  if (!node.getClusterService().isJoined()) {
    node.getJoiner().unblacklist(address);
  }
}

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

@Override
public void onSuccessfulConnection(Address address) {
  if (!node.getClusterService().isJoined()) {
    node.getJoiner().unblacklist(address);
  }
}

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

public void merge(Address newTargetAddress) {
  node.getJoiner().setTargetAddress(newTargetAddress);
  LifecycleServiceImpl lifecycleService = node.hazelcastInstance.getLifecycleService();
  lifecycleService.runUnderLifecycleLock(new ClusterMergeTask(node));
}

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

public void merge(Address newTargetAddress) {
  node.getJoiner().setTargetAddress(newTargetAddress);
  LifecycleServiceImpl lifecycleService = node.hazelcastInstance.getLifecycleService();
  lifecycleService.runUnderLifecycleLock(new ClusterMergeTask(node));
}

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

@Override
public void onFailedConnection(final Address address) {
  ClusterService clusterService = node.clusterService;
  if (!clusterService.isJoined()) {
    node.getJoiner().blacklist(address, false);
  } else {
    if (clusterService.getMember(address) != null) {
      nodeEngine.getExecutionService().schedule(ExecutionService.IO_EXECUTOR, new ReconnectionTask(address),
          getConnectionMonitorInterval(), TimeUnit.MILLISECONDS);
    }
  }
}

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

@Override
public void onFailedConnection(final Address address) {
  ClusterService clusterService = node.clusterService;
  if (!clusterService.isJoined()) {
    node.getJoiner().blacklist(address, false);
  } else {
    if (clusterService.getMember(address) != null) {
      nodeEngine.getExecutionService().schedule(ExecutionService.IO_EXECUTOR, new ReconnectionTask(address),
          getConnectionMonitorInterval(), TimeUnit.MILLISECONDS);
    }
  }
}

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

private void handleNotActiveOrNotJoined(JoinMessage joinMessage) {
  if (isJoinRequest(joinMessage)) {
    Joiner joiner = node.getJoiner();
    if (joiner instanceof MulticastJoiner) {
      MulticastJoiner multicastJoiner = (MulticastJoiner) joiner;
      multicastJoiner.onReceivedJoinRequest((JoinRequest) joinMessage);
    } else {
      logDroppedMessage(joinMessage);
    }
  } else {
    Address address = joinMessage.getAddress();
    if (node.getJoiner().isBlacklisted(address)) {
      logDroppedMessage(joinMessage);
      return;
    }
    ClusterServiceImpl clusterService = node.getClusterService();
    if (!clusterService.isJoined() && clusterService.getMasterAddress() == null) {
      clusterService.setMasterAddressToJoin(joinMessage.getAddress());
    } else {
      logDroppedMessage(joinMessage);
    }
  }
}

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

private void handleNotActiveOrNotJoined(JoinMessage joinMessage) {
  if (isJoinRequest(joinMessage)) {
    Joiner joiner = node.getJoiner();
    if (joiner instanceof MulticastJoiner) {
      MulticastJoiner multicastJoiner = (MulticastJoiner) joiner;
      multicastJoiner.onReceivedJoinRequest((JoinRequest) joinMessage);
    } else {
      logDroppedMessage(joinMessage);
    }
  } else {
    Address address = joinMessage.getAddress();
    if (node.getJoiner().isBlacklisted(address)) {
      logDroppedMessage(joinMessage);
      return;
    }
    ClusterServiceImpl clusterService = node.getClusterService();
    if (!clusterService.isJoined() && clusterService.getMasterAddress() == null) {
      clusterService.setMasterAddressToJoin(joinMessage.getAddress());
    } else {
      logDroppedMessage(joinMessage);
    }
  }
}

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

@Override
public void run() {
  final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  Node node = nodeEngine.getNode();
  Joiner joiner = node.getJoiner();
  ClusterServiceImpl clusterService = node.getClusterService();
  final ILogger logger = node.getLogger(getClass().getName());
  if (joiner instanceof TcpIpJoiner) {
    TcpIpJoiner tcpIpJoiner = (TcpIpJoiner) joiner;
    final Address endpoint = getCallerAddress();
    final Address masterAddress = clusterService.getMasterAddress();
    approvedAsMaster = !tcpIpJoiner.isClaimingMaster() && !clusterService.isMaster()
        && (masterAddress == null || masterAddress.equals(endpoint));
  } else {
    approvedAsMaster = false;
    logger.warning("This node requires MulticastJoin strategy!");
  }
  if (logger.isFineEnabled()) {
    logger.fine("Sending '" + approvedAsMaster + "' for master claim of node: " + getCallerAddress());
  }
}

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

@Override
public void run() {
  NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  Connection connection = getConnection();
  String message = "Node could not join cluster at node: " + connection.getEndPoint()
      + " Cause: the target cluster has a different group-name";
  connection.close(message, null);
  ILogger logger = nodeEngine.getLogger("com.hazelcast.cluster");
  logger.warning(message);
  Node node = nodeEngine.getNode();
  node.getJoiner().blacklist(getCallerAddress(), true);
}

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

@Override
public void run() {
  final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  Node node = nodeEngine.getNode();
  Joiner joiner = node.getJoiner();
  ClusterServiceImpl clusterService = node.getClusterService();
  final ILogger logger = node.getLogger(getClass().getName());
  if (joiner instanceof TcpIpJoiner) {
    TcpIpJoiner tcpIpJoiner = (TcpIpJoiner) joiner;
    final Address endpoint = getCallerAddress();
    final Address masterAddress = clusterService.getMasterAddress();
    approvedAsMaster = !tcpIpJoiner.isClaimingMastership() && !clusterService.isMaster()
        && (masterAddress == null || masterAddress.equals(endpoint));
  } else {
    approvedAsMaster = false;
    logger.warning("This node requires MulticastJoin strategy!");
  }
  if (logger.isFineEnabled()) {
    logger.fine("Sending '" + approvedAsMaster + "' for master claim of node: " + getCallerAddress());
  }
}

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

@Override
public void run() {
  NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  Connection connection = getConnection();
  String message = "Node could not join cluster at node: " + connection.getEndPoint()
      + " Cause: the target cluster has a different group-name";
  connection.close(message, null);
  ILogger logger = nodeEngine.getLogger("com.hazelcast.cluster");
  logger.warning(message);
  Node node = nodeEngine.getNode();
  node.getJoiner().blacklist(getCallerAddress(), true);
}