akka学习教程(二)HelloWord

绝地灬酷狼 2022-07-13 02:47 255阅读 0赞

# akka系列文章目录 #

*  [akka学习教程(十四) akka分布式实战][akka_ akka]
 *  [akka学习教程(十三) akka分布式][akka_ akka 1]
 *  [akka学习教程(十二) Spring与Akka的集成][akka_ Spring_Akka]
 *  [akka学习教程(十一) akka持久化][akka_ akka 2]
 *  [akka学习教程(十) agent][akka_ agent]
 *  [akka学习教程(九) STM软件事务内存][akka_ STM]
 *  [akka学习教程(八) Actor中的Future-询问模式][akka_ Actor_Future-]
 *  [akka学习教程(七) 内置状态转换Procedure][akka_ _Procedure]
 *  [akka学习教程(六) 路由器Router][akka_ _Router]
 *  [akka学习教程(五) inbox消息收件箱][akka_ inbox]
 *  [akka学习教程(四) actor生命周期][akka_ actor]
 *  [akka学习教程(三) 不可变对象][akka_]
 *  [akka学习教程(二)HelloWord][akka_HelloWord]
 *  [akka学习教程(一)简介][akka]

本示例来自于官方示例（[http://doc.akka.io/docs/akka/2.4.4/intro/getting-started.html][http_doc.akka.io_docs_akka_2.4.4_intro_getting-started.html]）：  
文中找到 Using Akka with Maven 。点击“Akka Main in Java”下载示例。

[http://www.lightbend.com/activator/template/akka-sample-main-java][http_www.lightbend.com_activator_template_akka-sample-main-java]

![77d1dac8-bbf6-4cf2-95e5-7354849dd74c.png][]

> 注意：新版本的akka需要使用jdk8

里面有两个Actor：

package sample.hello;
    
    import akka.actor.Props;
    import akka.actor.UntypedActor;
    import akka.actor.ActorRef;
    
    public class HelloWorld extends UntypedActor { 
    
      @Override
      public void preStart() {
        // create the greeter actor
        final ActorRef greeter = getContext().actorOf(Props.create(Greeter.class), "greeter");
        // tell it to perform the greeting
        greeter.tell(Greeter.Msg.GREET, getSelf());
      }
    
      @Override
      public void onReceive(Object msg) {
        if (msg == Greeter.Msg.DONE) {
          // when the greeter is done, stop this actor and with it the application
          getContext().stop(getSelf());
        } else
          unhandled(msg);
      }
    }

package sample.hello;
    
    import akka.actor.UntypedActor;
    
    public class Greeter extends UntypedActor { 
    
      public static enum Msg {
        GREET, DONE;
      }
    
      @Override
      public void onReceive(Object msg) throws InterruptedException {
        if (msg == Msg.GREET) {
          System.out.println("Hello World!");
          Thread.sleep(1000);
          getSender().tell(Msg.DONE, getSelf());
        } else
          unhandled(msg);
      }
    
    }

main方法

package sample.hello;
    
    public class Main { 
    
      public static void main(String[] args) {
        akka.Main.main(new String[] { HelloWorld.class.getName() });
      }
    }

另一种main写法，通过创建actor的方式

public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("Hello");
        ActorRef a = system.actorOf(Props.create(HelloWorld.class), "helloWorld");
        System.out.println(a.path());
      }

helloWord示例比较简单，不过多解释

# 参考资料 #

*  书籍《java高并发程序设计》
 *  [AKKA官方文档][AKKA]

[akka_ akka]: http://blog.csdn.net/liubenlong007/article/details/54603296
[akka_ akka 1]: http://blog.csdn.net/liubenlong007/article/details/54601998
[akka_ Spring_Akka]: http://blog.csdn.net/liubenlong007/article/details/54601448
[akka_ akka 2]: http://blog.csdn.net/liubenlong007/article/details/54584303
[akka_ agent]: http://blog.csdn.net/liubenlong007/article/details/54576611
[akka_ STM]: http://blog.csdn.net/liubenlong007/article/details/54576412
[akka_ Actor_Future-]: http://blog.csdn.net/liubenlong007/article/details/54575312
[akka_ _Procedure]: http://blog.csdn.net/liubenlong007/article/details/54574878
[akka_ _Router]: http://blog.csdn.net/liubenlong007/article/details/54574064
[akka_ inbox]: http://blog.csdn.net/liubenlong007/article/details/54377820
[akka_ actor]: http://blog.csdn.net/liubenlong007/article/details/54093889
[akka_]: http://blog.csdn.net/liubenlong007/article/details/54093794
[akka_HelloWord]: http://blog.csdn.net/liubenlong007/article/details/53782971
[akka]: http://blog.csdn.net/liubenlong007/article/details/53782966
[http_doc.akka.io_docs_akka_2.4.4_intro_getting-started.html]: http://doc.akka.io/docs/akka/2.4.4/intro/getting-started.html
[http_www.lightbend.com_activator_template_akka-sample-main-java]: http://www.lightbend.com/activator/template/akka-sample-main-java
[77d1dac8-bbf6-4cf2-95e5-7354849dd74c.png]: /images/20220713/9fe0432b346c4a61ba7d598ee51c3ef3.png
[AKKA]: http://akka.io/docs/