Akka入门学习

news/2024/11/7 9:33:30/

akka基础学习

Akka是用Scala创建的，但由于Scala和Java一样，都是java虚拟机上的语言，本质上说，两者并没有什么不同，因此，我们也可以在Java中使用Akka。我们知道，写出一个正确的、高性能并且可扩展的并发程序是相当困难的，那么是否有一个好的框架可以帮助我们轻松构建这么一个应用呢？这就是Akka。

Akka的好处

首先，Akka提供了一种名为Actor的并发模型，其粒度比线程小，这意味着可以在系统中启用大量的Acotr。
其次，Akka中提供了一套容错机制，允许在Acotr出现异常时，进行一些恢复或者重置操作。
再次，通过Akka不仅可以在单机上构建高并发程序，也可以在网络中构建分布式程序，并提供位置透明的Actor定位服务。

在这里插入图片描述

新并发模型：Actor

对于并发程序来说，线程始终是并发程序的基本执行单元。但在Akka中，我们可以完全忘记线程了。当使用Akka时，我们就有一个全新的执行单元----Actor。
在Actor模型中，我们失去了对象的方法调用，我们并不能通过调用Actor对象的某一个方法来告诉Actor你需要做什么，而是给Actor发送一条消息。当一个Actor收到消息后，它有可能会根据消息的内容做出某些行为，包括更改自身状态。在这种情况下，这个状态的更改是Actor自己进行的，并不是由外界被迫进行的。

Akka之Hello World

第一个Actor

public class Greeter extends UntypedAbstractActor {public static enum Msg{GREET,DONE;//定义了消息类型}@Overridepublic void onReceive(Object message) throws Throwable {if(message==Msg.GREET){System.out.println("Hello World");getSender().tell(Msg.DONE,getSelf());}else{unhandled(message);}}
}

与Greeter交流的另一个Actor

public class HelloWorld extends UntypedAbstractActor {ActorRef greeter;@Overridepublic void preStart() throws Exception {//回调方法greeter=getContext().actorOf(Props.create(Greeter.class),"greeter");//创建了Greeter的实例System.out.println("Greeter Actor Path:"+greeter.path());greeter.tell(Greeter.Msg.GREET,getSelf());//向Greeter发送消息}@Overridepublic void onReceive(Object message) throws Throwable {//消息处理函数if(message==Greeter.Msg.DONE){greeter.tell(Greeter.Msg.GREET,getSelf()); //向Greeter发送消息getContext().stop(getSelf());//停止}else {unhandled(message);}}public static void main(String[] args) {ActorSystem system=ActorSystem.create("Hello");//创建ActorSystem,用来维护和管理Actor的系统ActorRef a=system.actorOf(Props.create(HelloWorld.class),"helloWorld");System.out.println("HelloWorld Acotr Paht:"+a.path());}
}