• 作者:老汪软件技巧
  • 发表时间:2024-09-15 10:01
  • 浏览量:

1.什么是Akka remoting?

Akka-Remoting一种ActorSystem之间Actor对Actor点对点的沟通协议.通过Akka-Remoting来实现一个ActorSystem中的一个Actor与另一个ActorSystem中的另一个Actor之间的沟通

Akka Remoting限制:Akka提供了种方式来使用Remoting功能:

下面看一下Remoting系统中故障恢复模型(Failure Recovery Model),如下图所示:

上图中,连接到一个远程系统的过程中,包括上面4种状态:在进行任何通信之前,系统处于Idle状态;当第一次一个消息尝试向远程系统发送,或者当远程系统连接过来,这时系统状态变为Active;当两个系统通信失败,连接丢失,这时系统变为Gated状态;当系统通信过程中,由于参与通信的系统的状态不一致导致系统无法恢复,这时远程系统变为Quarantined状态,只有重新启动系统才能恢复,重启后系统变为Active状态。

Akka Remoting功能:

Akka将remoting完全配置化了,使用时几乎只需要修改配置文件,除非自定义,否则不需要动一行代码。 remoting包提供了两个功能:

2.代码管理实验目标

实现客户端和服务端通信

pom.xml


<dependency>
    <groupId>com.typesafe.akkagroupId>
    <artifactId>akka-stream_2.13artifactId>
    <version>2.6.0version>
dependency>

集成设置__集成步骤

server

server.conf

akka {
  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }
  remote {
    artery {
      enabled = on
      transport = tcp
      canonical.hostname = "127.0.0.1"
      canonical.port = 2552
    }
  }
}
package com.et.akka.remoting;
import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import com.typesafe.config.ConfigFactory;
public class ServerApp {
    static class ServerActor extends AbstractActor {
        @Override
        public Receive createReceive() {
            return receiveBuilder()
                    .match(String.class, msg -> {
                        System.out.println("Server received message: " + msg);
                        getSender().tell("Hello from Server", getSelf());
                    })
                    .build();
        }
    }
    public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("RemoteSystem", ConfigFactory.load("server"));
        ActorRef serverActor = system.actorOf(Props.create(ServerActor.class), "serverActor");
        System.out.println("Server is running...");
    }
}

client

client.conf

akka {
  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }
  remote {
    artery {
      enabled = on
      transport = tcp
      canonical.hostname = "127.0.0.1"
      canonical.port = 0
    }
  }
}
package com.et.akka.remoting;
import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSelection;
import akka.actor.ActorSystem;
import akka.actor.Props;
import com.typesafe.config.ConfigFactory;
public class ClientApp {
    static class ClientActor extends AbstractActor {
        private final String serverActorPath;
        public ClientActor(String serverActorPath) {
            this.serverActorPath = serverActorPath;
        }
        @Override
        public void preStart() {
            ActorSelection serverActor = getContext().actorSelection(serverActorPath);
            serverActor.tell("Hello from Client", getSelf());
        }
        @Override
        public Receive createReceive() {
            return receiveBuilder()
                    .match(String.class, msg -> {
                        System.out.println("Client received message: " + msg);
                    })
                    .build();
        }
    }
    public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("RemoteSystem", ConfigFactory.load("client"));
        String serverPath = "akka://RemoteSystem@127.0.0.1:2552/user/serverActor";
        ActorRef clientActor = system.actorOf(Props.create(ClientActor.class, serverPath), "clientActor");
        System.out.println("Client is running...");
    }
}

以上只是一些关键代码,所有代码请参见下面代码仓库

代码仓库3.测试启动server启动client产看日志

server

Server is running...
Server received message: Hello from Client

client

Client is running...
Client received message: Hello from Server

4.引用