Wie man mit Java eine verteilte Anwendung basierend auf Akka Cluster entwickelt

So verwenden Sie Java, um eine verteilte Anwendung basierend auf Akka Cluster zu entwickeln

Einführung:
Mit der Entwicklung von Cloud Computing und Big Data wird die Nachfrage nach verteilten Anwendungen immer wichtiger. Akka Cluster ist eine verteilte Computerlösung, die auf dem Akka-Framework basiert und eine einfache Möglichkeit bietet, verteilte Anwendungen zu entwickeln und bereitzustellen. In diesem Artikel wird erläutert, wie Sie mithilfe von Java eine verteilte Anwendung basierend auf Akka Cluster entwickeln, und es werden spezifische Codebeispiele bereitgestellt.

1. Voraussetzungen:
Bevor Sie beginnen, müssen Sie einige Vorbereitungen treffen:

1. Installieren Sie das Java Development Kit (JDK)
2. Installieren Sie das Akka-Framework
3. Stellen Sie sicher, dass Sie mit der Programmiersprache Java und den grundlegenden Parallelfunktionen vertraut sind Programmierkonzepte.

2. Erstellen Sie ein Basisprojekt:
Bevor wir mit der eigentlichen Entwicklung beginnen, müssen wir ein Basisprojekt erstellen, das die folgenden Dateien und Ordner enthält:

1. Eine pom.xml-Datei eines Maven-Projekts, die zum Verwalten von Projektabhängigkeiten verwendet wird.
2. Ein Ordner src/main/java, der zum Speichern von Java-Quellcode verwendet wird.
3. Ein Ordner src/main/resources zum Speichern von Konfigurationsdateien.
   Fügen Sie zunächst die folgenden Abhängigkeiten im Verzeichnis „pom“ hinzu.
import akka.actor.ActorSelection;

import akka.actor.Props;
import akka.cluster.Cluster;

import akka.cluster.ClusterEvent.MemberJoined;
import akka.cluster.ClusterEvent.MemberUp;

import akka.cluster.ClusterEvent.MemberEvent;
import akka.japi.pf.ReceiveBuilder;

public class Main {

<groupId>com.typesafe.akka</groupId>
<artifactId>akka-actor_2.12</artifactId>
<version>2.5.25</version>

<groupId>com.typesafe.akka</groupId>
<artifactId>akka-cluster_2.12</artifactId>
<version>2.5.25</version>

ActorSystem system = ActorSystem.create("cluster-system");
ActorRef master = system.actorOf(Props.create(MasterActor.class), "master");
ActorRef worker1 = system.actorOf(Props.create(WorkerActor.class), "worker1");
ActorRef worker2 = system.actorOf(Props.create(WorkerActor.class), "worker2");

@override

cluster.subscribe(getSelf(), ClusterEvent.MemberEvent.class);

öffentlich empfangen Createreceice () {

}

Da wir nun ein grundlegendes Akka-Cluster-Projekt erstellt haben, müssen wir die Anwendung ausführen, um ihre verteilte Funktionalität zu testen. Zuerst müssen wir drei unabhängige Java-Prozesse starten, um die Master- und Worker-Knoten im Cluster zu simulieren.

Führen Sie in der Konsole jeweils die folgenden Befehle aus: