Şu satırı dahil ederiz. Node nesnesinin bir üye alanıdır
import com.hazelcast.spi.discovery.multicast.MulticastDiscoveryStrategy;
DiscoveryStrategy arayüzünü gerçekleştirir. Şöyledir
DiscoveryStrategy AbstractDiscoveryStrategy HazelcastKubernetesDiscoveryStrategy AwsDiscoveryStrategy MulticastDiscoveryStrategy AzureDiscoveryStrategy GcpDiscoveryStrategy
Kendi içinde bir MulticastDiscoverySender nesnesi vardır. Ayrıca MulticastSocket nesnesini de yaratır. Kod şöyle. IPv4 multicast için tasarlanmış
public class MulticastDiscoveryStrategy extends AbstractDiscoveryStrategy { private static final int DEFAULT_MULTICAST_PORT = 54327; private static final String DEFAULT_MULTICAST_GROUP = "224.2.2.3"; private DiscoveryNode discoveryNode; private MulticastSocket multicastSocket; private Thread thread; private MulticastDiscoveryReceiver multicastDiscoveryReceiver; private MulticastDiscoverySender multicastDiscoverySender; private ILogger logger; private boolean isClient; ... }
start metodu
Kod şöyle. MulticastSocket nesnesini de yaratır.. Varsayılan port 54327
@Override public void start() { initializeMulticastSocket(); if (!isClient) { thread = new Thread(multicastDiscoverySender); thread.start(); } }
Hiç yorum yok:
Yorum Gönder