Giriş
Şu satırı dahil ederiz
import com.hazelcast.instance.impl.Node;
Kod şöyle. HazelcastInstanceImpl sınıfının bir alanıdır. Bazı servisler bu sınıfın içindedir. Bazı servisler de NodeEngineImpl içindedir.
public class Node { // name of property used to inject ClusterTopologyIntentTracker in Discovery Service public static final String DISCOVERY_PROPERTY_CLUSTER_TOPOLOGY_INTENT_TRACKER = "hazelcast.internal.discovery.cluster.topology.intent.tracker"; private static final int THREAD_SLEEP_DURATION_MS = 500; private static final String GRACEFUL_SHUTDOWN_EXECUTOR_NAME = "hz:graceful-shutdown"; public final HazelcastInstanceImpl hazelcastInstance; public final DynamicConfigurationAwareConfig config; public final NodeEngineImpl nodeEngine; public final ClientEngine clientEngine; public final InternalPartitionServiceImpl partitionService; public final ClusterServiceImpl clusterService; public final MulticastService multicastService; public final DiscoveryService discoveryService; public final TextCommandService textCommandService; public final LoggingServiceImpl loggingService; public final Server server; /** * Member-to-member address only. * When the Node is configured with multiple endpoints, this address still * represents ProtocolType.MEMBER * For accessing a full address-map, see AddressPicker.getPublicAddressMap() */ public final Address address; public final SecurityContext securityContext; final ClusterTopologyIntentTracker clusterTopologyIntentTracker; private final ILogger logger; private final AtomicBoolean shuttingDown = new AtomicBoolean(false); private final NodeShutdownHookThread shutdownHookThread; private final MemberSchemaService schemaService; private final InternalSerializationService serializationService; private final InternalSerializationService compatibilitySerializationService; private final ClassLoader configClassLoader; private final NodeExtension nodeExtension; private final HazelcastProperties properties; private final BuildInfo buildInfo; private final HealthMonitor healthMonitor; private final Joiner joiner; private final LocalAddressRegistry localAddressRegistry; private ManagementCenterService managementCenterService; // it can be changed on cluster service reset //see: ClusterServiceImpl#resetLocalMemberUuid private volatile UUID thisUuid; private volatile NodeState state = NodeState.STARTING; ... }
start metodu
NodeEngineImpl nesnesini ve servisleri başlatır
Hiç yorum yok:
Yorum Gönder