akka学习教程(五) inbox消息收件箱

我不是女神ヾ 2022-07-13 14:14 296阅读 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]

我们知道，整个akka的actor系统是通过消息进行传递的，之前的几个教程都是通过一个actor来给另一个actor发消息。其实还可以使用inbox消息收件箱来给某个actor发消息，并且可以进行交互。

package akka;
    
    import akka.actor.*;
    import akka.event.Logging;
    import akka.event.LoggingAdapter;
    import com.typesafe.config.ConfigFactory;
    import scala.concurrent.duration.Duration;
    
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    /** * Created by liubenlong on 2017/1/12. */
    public class InboxTest extends UntypedActor { 
    
        private final LoggingAdapter log = Logging.getLogger(getContext().system(), this);
    
        public enum Msg{
            WORKING, DONE, CLOSE;
        }
    
        @Override
        public void onReceive(Object o) throws Throwable {
            if(o == Msg.WORKING){
                log.info("i am working.");
            }else if(o == Msg.DONE){
                log.info("i am done");
            }else if(o == Msg.CLOSE){
                log.info("i am close.");
                getSender().tell(Msg.CLOSE, getSelf());//告诉消息发送者我要关闭了。
                getContext().stop(getSelf());//关闭自己
            }else{
                unhandled(o);
            }
        }
    
        public static void main(String [] args){
            ActorSystem system = ActorSystem.create("inbox", ConfigFactory.load("akka.conf"));
            ActorRef inboxTest = system.actorOf(Props.create(InboxTest.class), "InboxTest");
    
            Inbox inbox = Inbox.create(system);
            inbox.watch(inboxTest);//监听一个actor
    
            //通过inbox来发送消息
            inbox.send(inboxTest, Msg.WORKING);
            inbox.send(inboxTest, Msg.DONE);
            inbox.send(inboxTest, Msg.CLOSE);
    
            while(true){
                try {
                    Object receive = inbox.receive(Duration.create(1, TimeUnit.SECONDS));
                    if(receive == Msg.CLOSE){
       //收到的inbox的消息
                        System.out.println("inboxTextActor is closing");
                    }else if(receive instanceof  Terminated){
       //中断 ，和线程一个概念
                        System.out.println("inboxTextActor is closed");
                        system.shutdown();
                        break;
                    }else {
                        System.out.println(receive);
                    }
                } catch (TimeoutException e) {
                    e.printStackTrace();
                }
            }
        }
    }

输出结果：

[INFO] [01/12/2017 14:35:24.207] [inbox-akka.actor.default-dispatcher-2] [akka://inbox/user/InboxTest] i am working.
    [INFO] [01/12/2017 14:35:24.223] [inbox-akka.actor.default-dispatcher-2] [akka://inbox/user/InboxTest] i am done
    [INFO] [01/12/2017 14:35:24.223] [inbox-akka.actor.default-dispatcher-2] [akka://inbox/user/InboxTest] i am close.
    inboxTextActor is closing
    inboxTextActor is closed

# 参考资料 #

*  书籍《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
[AKKA]: http://akka.io/docs/