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.ActorSystem;

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

import akka.cluster.ClusterEvent;

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

import akka.cluster.ClusterEvent.MemberRemoved;

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

public class Main {

public static void main(String[] args) {

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

}
}
public class MasterActor erweitert AbstractActor {
private Cluster cluster = Cluster.get(getContext().getSystem());

public MasterActor() {

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

}

Public statische Props props () {

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

public empfangen createReceive () {

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

}
}
Public Class WorkerActor erweitert AbstractActor {

@Overide

öffentlich empfangen Createreceice () {

rrrrrrrree

}

}

3. Verteilte Anwendungen ausführen:

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:

java -jar 599b92ba4d06396da4b111be38dfeb76/target/Ihr_Projektname.jar -Dakka.remote.netty.tcp.port=2551

java -jar 599b92ba4d06396da4b111be38dfeb76/target/ your_project_name .jar -Dakka.remote.netty.tcp.port=2552
java -jar 417eea7e877cad4bcd3784e57ac3af71/target/your_project_name.jar -Dakka.remote.netty.tcp.port=2553

wobei your_project_folder Ihre Projektdatei ist Ordnerpfad, Ihr_Projektname ist Ihr Projektname.

Wenn die drei Java-Prozesse gestartet werden, werden einige Ausgabeinformationen angezeigt, einschließlich der Erstellung von Master Actor und Worker Actor, zum Cluster hinzugefügten Knoteninformationen usw.

4. Fazit:

Dieser Artikel stellt vor, wie man mit Java eine verteilte Anwendung basierend auf Akka Cluster entwickelt, und stellt tatsächliche Codebeispiele bereit. Akka Cluster kann zur einfachen Entwicklung und Bereitstellung verteilter Anwendungen verwendet werden. Es bietet Skalierbarkeit und Fehlertoleranz und kann umfangreiche gleichzeitige und verteilte Aufgaben effektiv bewältigen. Ich hoffe, dass dieser Artikel Ihnen ein grundlegendes Verständnis von Akka Cluster vermittelt und Ihnen hilft, mit der Erstellung Ihrer eigenen verteilten Anwendungen zu beginnen.

Das obige ist der detaillierte Inhalt vonWie man mit Java eine verteilte Anwendung basierend auf Akka Cluster entwickelt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!