com.hazelcast.instance.Node.isLiteMember()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(10.0k)|赞(0)|评价(0)|浏览(107)

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

Node.isLiteMember介绍

暂无

代码示例

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

int getMemberGroupsSize() {
  int size = memberGroupsSize;
  if (size > 0) {
    return size;
  }
  // size = 0 means service is not initialized yet.
  // return 1 if current node is a data member since there should be at least one member group
  return node.isLiteMember() ? 0 : 1;
}

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

int getMemberGroupsSize() {
  int size = memberGroupsSize;
  if (size > 0) {
    return size;
  }
  // size = 0 means service is not initialized yet.
  // return 1 if current node is a data member since there should be at least one member group
  return node.isLiteMember() ? 0 : 1;
}

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

if (node.isLiteMember()) {
  return true;

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

if (node.isLiteMember()) {
  return true;

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

/**
 * Send a {@link WhoisMasterOp} to designated address.
 *
 * @param toAddress the address to which the operation will be sent.
 * @return {@code true} if the operation was sent, otherwise {@code false}.
 */
public boolean sendMasterQuestion(Address toAddress) {
  checkNotNull(toAddress, "No endpoint is specified!");
  BuildInfo buildInfo = node.getBuildInfo();
  final Address thisAddress = node.getThisAddress();
  JoinMessage joinMessage = new JoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), node.getVersion(),
      thisAddress, clusterService.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
  return nodeEngine.getOperationService().send(new WhoisMasterOp(joinMessage), toAddress);
}

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

/**
 * Send a {@link WhoisMasterOp} to designated address.
 *
 * @param toAddress the address to which the operation will be sent.
 * @return {@code true} if the operation was sent, otherwise {@code false}.
 */
public boolean sendMasterQuestion(Address toAddress) {
  checkNotNull(toAddress, "No endpoint is specified!");
  BuildInfo buildInfo = node.getBuildInfo();
  final Address thisAddress = node.getThisAddress();
  JoinMessage joinMessage = new JoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), node.getVersion(),
      thisAddress, clusterService.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
  return nodeEngine.getOperationService().send(new WhoisMasterOp(joinMessage), toAddress);
}

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

private void handleActiveAndJoined(JoinMessage joinMessage) {
  if (!(joinMessage instanceof JoinRequest)) {
    logDroppedMessage(joinMessage);
    return;
  }
  ClusterServiceImpl clusterService = node.getClusterService();
  Address masterAddress = clusterService.getMasterAddress();
  if (clusterService.isMaster()) {
    JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
        node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
    node.multicastService.send(response);
  } else if (joinMessage.getAddress().equals(masterAddress)) {
    MemberImpl master = node.getClusterService().getMember(masterAddress);
    if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
      String message = "New join request has been received from current master. Suspecting " + masterAddress;
      logger.warning(message);
      // I just make a local suspicion. Probably other nodes will eventually suspect as well.
      clusterService.suspectMember(master, message, false);
    }
  }
}

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

private void handleActiveAndJoined(JoinMessage joinMessage) {
  if (!(joinMessage instanceof JoinRequest)) {
    logDroppedMessage(joinMessage);
    return;
  }
  ClusterServiceImpl clusterService = node.getClusterService();
  Address masterAddress = clusterService.getMasterAddress();
  if (clusterService.isMaster()) {
    JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
        node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
    node.multicastService.send(response);
  } else if (joinMessage.getAddress().equals(masterAddress)) {
    MemberImpl master = node.getClusterService().getMember(masterAddress);
    if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
      String message = "New join request has been received from current master. Suspecting " + masterAddress;
      logger.warning(message);
      // I just make a local suspicion. Probably other nodes will eventually suspect as well.
      clusterService.suspectMember(master, message, false);
    }
  }
}

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

public TimedMemberState createTimedMemberState() {
  MemberStateImpl memberState = new MemberStateImpl();
  Collection<StatisticsAwareService> services = instance.node.nodeEngine.getServices(StatisticsAwareService.class);
  TimedMemberState timedMemberState = new TimedMemberState();
  createMemberState(memberState, services);
  timedMemberState.setMaster(instance.node.isMaster());
  timedMemberState.setMemberList(new ArrayList<String>());
  if (timedMemberState.isMaster()) {
    Set<Member> memberSet = instance.getCluster().getMembers();
    for (Member member : memberSet) {
      MemberImpl memberImpl = (MemberImpl) member;
      Address address = memberImpl.getAddress();
      timedMemberState.getMemberList().add(address.getHost() + ":" + address.getPort());
    }
  }
  timedMemberState.setMemberState(memberState);
  GroupConfig groupConfig = instance.getConfig().getGroupConfig();
  timedMemberState.setClusterName(groupConfig.getName());
  SSLConfig sslConfig = instance.getConfig().getNetworkConfig().getSSLConfig();
  timedMemberState.setSslEnabled(sslConfig != null && sslConfig.isEnabled());
  timedMemberState.setLite(instance.node.isLiteMember());
  SocketInterceptorConfig interceptorConfig = instance.getConfig().getNetworkConfig().getSocketInterceptorConfig();
  timedMemberState.setSocketInterceptorEnabled(interceptorConfig != null && interceptorConfig.isEnabled());
  boolean scriptingEnabled = instance.node.getProperties().getBoolean(GroupProperty.SCRIPTING_ENABLED);
  timedMemberState.setScriptingEnabled(scriptingEnabled);
  return timedMemberState;
}

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

public TimedMemberState createTimedMemberState() {
  MemberStateImpl memberState = new MemberStateImpl();
  Collection<StatisticsAwareService> services = instance.node.nodeEngine.getServices(StatisticsAwareService.class);
  TimedMemberState timedMemberState = new TimedMemberState();
  createMemberState(memberState, services);
  timedMemberState.setMaster(instance.node.isMaster());
  timedMemberState.setMemberList(new ArrayList<String>());
  if (timedMemberState.isMaster()) {
    Set<Member> memberSet = instance.getCluster().getMembers();
    for (Member member : memberSet) {
      MemberImpl memberImpl = (MemberImpl) member;
      Address address = memberImpl.getAddress();
      timedMemberState.getMemberList().add(address.getHost() + ":" + address.getPort());
    }
  }
  timedMemberState.setMemberState(memberState);
  GroupConfig groupConfig = instance.getConfig().getGroupConfig();
  timedMemberState.setClusterName(groupConfig.getName());
  SSLConfig sslConfig = instance.getConfig().getNetworkConfig().getSSLConfig();
  timedMemberState.setSslEnabled(sslConfig != null && sslConfig.isEnabled());
  timedMemberState.setLite(instance.node.isLiteMember());
  SocketInterceptorConfig interceptorConfig = instance.getConfig().getNetworkConfig().getSocketInterceptorConfig();
  timedMemberState.setSocketInterceptorEnabled(interceptorConfig != null && interceptorConfig.isEnabled());
  ManagementCenterConfig managementCenterConfig = instance.node.getConfig().getManagementCenterConfig();
  timedMemberState.setScriptingEnabled(managementCenterConfig.isScriptingEnabled());
  return timedMemberState;
}

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

@Override
  public void run(DiagnosticsLogWriter writer) {
    writer.startSection("HazelcastInstance");

    writer.writeKeyValueEntry("thisAddress", nodeEngine.getNode().getThisAddress().toString());
    writer.writeKeyValueEntry("isRunning", nodeEngine.getNode().isRunning());
    writer.writeKeyValueEntry("isLite", nodeEngine.getNode().isLiteMember());
    writer.writeKeyValueEntry("joined", nodeEngine.getNode().getClusterService().isJoined());
    NodeState state = nodeEngine.getNode().getState();
    writer.writeKeyValueEntry("nodeState", state == null ? "null" : state.toString());

    writer.writeKeyValueEntry("clusterId", nodeEngine.getClusterService().getClusterId());
    writer.writeKeyValueEntry("clusterSize", nodeEngine.getClusterService().getSize());
    writer.writeKeyValueEntry("isMaster", nodeEngine.getClusterService().isMaster());
    Address masterAddress = nodeEngine.getClusterService().getMasterAddress();
    writer.writeKeyValueEntry("masterAddress", masterAddress == null ? "null" : masterAddress.toString());

    writer.startSection("Members");
    for (Member member : nodeEngine.getClusterService().getMemberImpls()) {
      writer.writeEntry(member.getAddress().toString());
    }
    writer.endSection();

    writer.endSection();
  }
}

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

@Override
  public void run(DiagnosticsLogWriter writer) {
    writer.startSection("HazelcastInstance");

    writer.writeKeyValueEntry("thisAddress", nodeEngine.getNode().getThisAddress().toString());
    writer.writeKeyValueEntry("isRunning", nodeEngine.getNode().isRunning());
    writer.writeKeyValueEntry("isLite", nodeEngine.getNode().isLiteMember());
    writer.writeKeyValueEntry("joined", nodeEngine.getNode().getClusterService().isJoined());
    NodeState state = nodeEngine.getNode().getState();
    writer.writeKeyValueEntry("nodeState", state == null ? "null" : state.toString());

    writer.writeKeyValueEntry("clusterId", nodeEngine.getClusterService().getClusterId());
    writer.writeKeyValueEntry("clusterSize", nodeEngine.getClusterService().getSize());
    writer.writeKeyValueEntry("isMaster", nodeEngine.getClusterService().isMaster());
    Address masterAddress = nodeEngine.getClusterService().getMasterAddress();
    writer.writeKeyValueEntry("masterAddress", masterAddress == null ? "null" : masterAddress.toString());

    writer.startSection("Members");
    for (Member member : nodeEngine.getClusterService().getMemberImpls()) {
      writer.writeEntry(member.getAddress().toString());
    }
    writer.endSection();

    writer.endSection();
  }
}

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

Node

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    Node类方法

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