（转）akka Router实例

通常在分布式任务调度系统中会有这样的需求：一组actor提供相同的服务，我们在调用任务的时候只需要选择其中一个actor进行处理即可。 
其实这就是一个负载均衡或者说路由策略，akka作为一个高性能支持并发的actor模型，可以用来作为任务调度集群使用，当然负载均衡就是其本职工作了，akka提供了Router来进行消息的调度。

由于负载均衡原理过于简单，既不多说了，直接上代码(这里借用之前章节的InboxTest类)：

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) {
        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();
            }
        }
    }
}

import akka.actor.*;
import akka.routing.*;
import com.typesafe.config.ConfigFactory;

import java.util.ArrayList;
import java.util.concurrent.atomic.AtomicBoolean;


public class RouterTest extends UntypedActor {

    public Router router;

    {
        ArrayList<Routee> routees = new ArrayList<>();
        for(int i = 0; i < 5; i ++) {
            //借用上面的 inboxActor
            ActorRef worker = getContext().actorOf(Props.create(InboxTest.class), "worker_" + i);
            getContext().watch(worker);//监听
            routees.add(new ActorRefRoutee(worker));
        }
        /**
         * RoundRobinRoutingLogic: 轮询
         * BroadcastRoutingLogic: 广播
         * RandomRoutingLogic: 随机
         * SmallestMailboxRoutingLogic: 空闲
         */
        router = new Router(new RoundRobinRoutingLogic(), routees);
    }

    @Override
    public void onReceive(Object o) {
        if(o instanceof InboxTest.Msg){
            router.route(o, getSender());//进行路由转发
        }else if(o instanceof Terminated){
            router = router.removeRoutee(((Terminated)o).actor());//发生中断，将该actor删除。当然这里可以参考之前的actor重启策略，进行优化，为了简单，这里仅进行删除处理
            System.out.println(((Terminated)o).actor().path() + " 该actor已经删除。router.size=" + router.routees().size());

            if(router.routees().size() == 0){//没有可用actor了
                System.out.print("没有可用actor了，系统关闭。");
                flag.compareAndSet(true, false);
                getContext().system().shutdown();
            }
        }else {
            unhandled(o);
        }

    }


    public  static AtomicBoolean flag = new AtomicBoolean(true);

    public static void main(String[] args) throws InterruptedException {
        ActorSystem system = ActorSystem.create("strategy", ConfigFactory.load("akka.config"));
        ActorRef routerTest = system.actorOf(Props.create(RouterTest.class), "RouterTest");

        int i = 1;
        while(flag.get()){
            routerTest.tell(InboxTest.Msg.WORKING, ActorRef.noSender());

            if(i % 10 == 0) routerTest.tell(InboxTest.Msg.CLOSE, ActorRef.noSender());

            Thread.sleep(500);

            i ++;
        }
    }
}

akka提供了几个RoutingLogic各位可以亲自尝试运行一下，看看效果。

运行结果：

"D:Program FilesJavajdk1.8.0_111injava" -Didea.launcher.port=7533 "-Didea.launcher.bin.path=D:Program Files (x86)ideaIU-2016.2.5in" -Dfile.encoding=UTF-8 -classpath "D:Program FilesJavajdk1.8.0_111jrelibcharsets.jar;D:Program FilesJavajdk1.8.0_111jrelibdeploy.jar;D:Program FilesJavajdk1.8.0_111jrelibextaccess-bridge-64.jar;D:Program FilesJavajdk1.8.0_111jrelibextcldrdata.jar;D:Program FilesJavajdk1.8.0_111jrelibextdnsns.jar;D:Program FilesJavajdk1.8.0_111jrelibextjaccess.jar;D:Program FilesJavajdk1.8.0_111jrelibextjfxrt.jar;D:Program FilesJavajdk1.8.0_111jrelibextlocaledata.jar;D:Program FilesJavajdk1.8.0_111jrelibext
ashorn.jar;D:Program FilesJavajdk1.8.0_111jrelibextsunec.jar;D:Program FilesJavajdk1.8.0_111jrelibextsunjce_provider.jar;D:Program FilesJavajdk1.8.0_111jrelibextsunmscapi.jar;D:Program FilesJavajdk1.8.0_111jrelibextsunpkcs11.jar;D:Program FilesJavajdk1.8.0_111jrelibextzipfs.jar;D:Program FilesJavajdk1.8.0_111jrelibjavaws.jar;D:Program FilesJavajdk1.8.0_111jrelibjce.jar;D:Program FilesJavajdk1.8.0_111jrelibjfr.jar;D:Program FilesJavajdk1.8.0_111jrelibjfxswt.jar;D:Program FilesJavajdk1.8.0_111jrelibjsse.jar;D:Program FilesJavajdk1.8.0_111jrelibmanagement-agent.jar;D:Program FilesJavajdk1.8.0_111jrelibplugin.jar;D:Program FilesJavajdk1.8.0_111jrelib
esources.jar;D:Program FilesJavajdk1.8.0_111jrelib
t.jar;D:workspace_git_idealuffi-masterluffi	arget	est-classes;D:workspace_git_idealuffi-masterluffi	argetclasses;D:LocalRepositorycommons-fileuploadcommons-fileupload1.3.2commons-fileupload-1.3.2.jar;D:LocalRepositorycommons-iocommons-io2.2commons-io-2.2.jar;D:LocalRepositoryorgapachehttpcomponentshttpmime4.3.1httpmime-4.3.1.jar;D:LocalRepositoryorgapachehttpcomponentshttpclient4.3.1httpclient-4.3.1.jar;D:LocalRepositoryorgapachehttpcomponentshttpcore4.3httpcore-4.3.jar;D:LocalRepositorycommons-loggingcommons-logging1.1.3commons-logging-1.1.3.jar;D:LocalRepositorycommons-codeccommons-codec1.6commons-codec-1.6.jar;D:LocalRepositorycomalibabafastjson1.2.17fastjson-1.2.17.jar;D:LocalRepositorycomletvopenapiopenapi-sdk-java1.0.0-SNAPSHOTopenapi-sdk-java-1.0.0-20160721.094717-1.jar;D:LocalRepositoryorgslf4jslf4j-api1.7.5slf4j-api-1.7.5.jar;D:workspace_git_idealuffi-masterluffi-api	argetclasses;D:workspace_git_idealuffi-masterluffi-model	argetclasses;D:LocalRepositoryorgapachecommonscommons-lang33.1commons-lang3-3.1.jar;D:LocalRepositoryjavaxvalidationvalidation-api1.1.0.Finalvalidation-api-1.1.0.Final.jar;D:LocalRepositoryjavaxeljavax.el-api2.2.4javax.el-api-2.2.4.jar;D:LocalRepositoryorgglassfishwebjavax.el2.2.4javax.el-2.2.4.jar;D:LocalRepositoryorghibernatehibernate-validator5.2.4.Finalhibernate-validator-5.2.4.Final.jar;D:LocalRepositoryorgprojectlomboklombok-maven-plugin1.12.2.0lombok-maven-plugin-1.12.2.0.jar;D:LocalRepositorycomgithubpagehelperpagehelper4.1.1pagehelper-4.1.1.jar;D:LocalRepositorycomgithubjsqlparserjsqlparser.9.4jsqlparser-0.9.4.jar;D:LocalRepositoryorgapache	hriftlibthrift.9.3libthrift-0.9.3.jar;D:LocalRepositoryjavaxservletjavax.servlet-api3.1.0javax.servlet-api-3.1.0.jar;D:LocalRepositoryjavaxws
sjavax.ws.rs-api2.0.1javax.ws.rs-api-2.0.1.jar;D:LocalRepositoryjavaxannotationjavax.annotation-api1.2javax.annotation-api-1.2.jar;D:workspace_git_idealuffi-masterluffi-repository	argetclasses;D:LocalRepository	kmybatismapper3.3.8mapper-3.3.8.jar;D:LocalRepositoryjavaxpersistencepersistence-api1.0persistence-api-1.0.jar;D:LocalRepositoryorgmybatisspringootmybatis-spring-boot-starter1.1.1mybatis-spring-boot-starter-1.1.1.jar;D:LocalRepositoryorgmybatisspringootmybatis-spring-boot-autoconfigure1.1.1mybatis-spring-boot-autoconfigure-1.1.1.jar;D:LocalRepositoryorgmybatismybatis3.4.0mybatis-3.4.0.jar;D:LocalRepositoryorgmybatismybatis-spring1.3.0mybatis-spring-1.3.0.jar;D:LocalRepositoryorgspringframeworkootspring-boot1.3.6.RELEASEspring-boot-1.3.6.RELEASE.jar;D:LocalRepositoryorgspringframeworkootspring-boot-autoconfigure1.3.6.RELEASEspring-boot-autoconfigure-1.3.6.RELEASE.jar;D:LocalRepositoryorgspringframeworkootspring-boot-starter-jdbc1.3.3.RELEASEspring-boot-starter-jdbc-1.3.3.RELEASE.jar;D:LocalRepositoryorgspringframeworkootspring-boot-starter1.3.6.RELEASEspring-boot-starter-1.3.6.RELEASE.jar;D:LocalRepositoryorgapache	omcat	omcat-jdbc8.0.32	omcat-jdbc-8.0.32.jar;D:LocalRepositoryorgapache	omcat	omcat-juli8.0.32	omcat-juli-8.0.32.jar;D:LocalRepositoryorgspringframeworkspring-jdbc4.2.5.RELEASEspring-jdbc-4.2.5.RELEASE.jar;D:LocalRepositoryorgspringframeworkspring-beans4.2.4.RELEASEspring-beans-4.2.4.RELEASE.jar;D:LocalRepositoryorgspringframeworkspring-core4.2.4.RELEASEspring-core-4.2.4.RELEASE.jar;D:LocalRepositoryorgspringframeworkspring-tx4.2.5.RELEASEspring-tx-4.2.5.RELEASE.jar;D:workspace_git_idealuffi-masterluffi-common	argetclasses;D:LocalRepositoryorgapachezookeeperzookeeper3.4.8zookeeper-3.4.8.jar;D:LocalRepositoryjlinejline.9.94jline-0.9.94.jar;D:LocalRepositoryio
etty
etty3.7.0.Final
etty-3.7.0.Final.jar;D:LocalRepositorycom101teczkclient.9zkclient-0.9.jar;D:LocalRepositorylog4jlog4j1.2.15log4j-1.2.15.jar;D:LocalRepositoryjavaxmailmail1.4mail-1.4.jar;D:LocalRepositoryjavaxactivationactivation1.1activation-1.1.jar;D:LocalRepositorycomalibabadubbo2.8.4.lehidubbo-2.8.4.lehi.jar;D:LocalRepositoryorgspringframeworkspring-context4.2.4.RELEASEspring-context-4.2.4.RELEASE.jar;D:LocalRepositoryorgspringframeworkspring-aop4.2.4.RELEASEspring-aop-4.2.4.RELEASE.jar;D:LocalRepositoryorgspringframeworkspring-expression4.2.4.RELEASEspring-expression-4.2.4.RELEASE.jar;D:LocalRepositoryaopallianceaopalliance1.0aopalliance-1.0.jar;D:LocalRepositoryorgapachelogginglog4jlog4j-core2.5log4j-core-2.5.jar;D:LocalRepositoryorgapachelogginglog4jlog4j-api2.5log4j-api-2.5.jar;D:LocalRepositoryorgjavassistjavassist3.15.0-GAjavassist-3.15.0-GA.jar;D:LocalRepositoryorgspringframeworkspring-web4.2.4.RELEASEspring-web-4.2.4.RELEASE.jar;D:LocalRepositorycommons-langcommons-lang2.6commons-lang-2.6.jar;D:LocalRepositorycommons-poolcommons-pool1.6commons-pool-1.6.jar;D:LocalRepositoryorgapachecuratorcurator-framework2.5.0curator-framework-2.5.0.jar;D:LocalRepositoryorgapachecuratorcurator-client2.5.0curator-client-2.5.0.jar;D:LocalRepositorycomgoogleguavaguava16.0.1guava-16.0.1.jar;D:LocalRepositoryorgyamlsnakeyaml1.16snakeyaml-1.16.jar;D:LocalRepositoryorgspringframeworkootspring-boot-starter-web1.3.6.RELEASEspring-boot-starter-web-1.3.6.RELEASE.jar;D:LocalRepositoryorgspringframeworkootspring-boot-starter-validation1.3.6.RELEASEspring-boot-starter-validation-1.3.6.RELEASE.jar;D:LocalRepositoryorgapache	omcatembed	omcat-embed-el8.0.36	omcat-embed-el-8.0.36.jar;D:LocalRepositorycomfasterxmljacksoncorejackson-databind2.6.7jackson-databind-2.6.7.jar;D:LocalRepositorycomfasterxmljacksoncorejackson-annotations2.6.0jackson-annotations-2.6.0.jar;D:LocalRepositorycomfasterxmljacksoncorejackson-core2.6.7jackson-core-2.6.7.jar;D:LocalRepositoryorgspringframeworkspring-webmvc4.2.7.RELEASEspring-webmvc-4.2.7.RELEASE.jar;D:LocalRepositoryorgspringframeworkootspring-boot-starter-log4j21.3.6.RELEASEspring-boot-starter-log4j2-1.3.6.RELEASE.jar;D:LocalRepositoryorgapachelogginglog4jlog4j-slf4j-impl2.4.1log4j-slf4j-impl-2.4.1.jar;D:LocalRepositoryorgslf4jjcl-over-slf4j1.7.21jcl-over-slf4j-1.7.21.jar;D:LocalRepositoryorgslf4jjul-to-slf4j1.7.21jul-to-slf4j-1.7.21.jar;D:LocalRepositorymysqlmysql-connector-java5.1.39mysql-connector-java-5.1.39.jar;D:LocalRepositoryorgjbossloggingjboss-logging3.2.1.Finaljboss-logging-3.2.1.Final.jar;D:LocalRepositorycomfasterxmlclassmate1.1.0classmate-1.1.0.jar;D:LocalRepositoryorgjboss
esteasy
esteasy-jaxrs3.0.9.Final
esteasy-jaxrs-3.0.9.Final.jar;D:LocalRepositoryorgjboss
esteasyjaxrs-api3.0.9.Finaljaxrs-api-3.0.9.Final.jar;D:LocalRepositoryorgjbossspecjavaxannotationjboss-annotations-api_1.1_spec1.0.1.Finaljboss-annotations-api_1.1_spec-1.0.1.Final.jar;D:LocalRepository
etjcipjcip-annotations1.0jcip-annotations-1.0.jar;D:LocalRepositoryorgjboss
esteasy
esteasy-client3.0.9.Final
esteasy-client-3.0.9.Final.jar;D:LocalRepositoryorgjboss
esteasy
esteasy-netty3.0.14.Final
esteasy-netty-3.0.14.Final.jar;D:LocalRepositoryorgjboss
esteasy
esteasy-jdk-http3.0.14.Final
esteasy-jdk-http-3.0.14.Final.jar;D:LocalRepositoryorgjboss
esteasy
esteasy-jackson-provider3.0.14.Final
esteasy-jackson-provider-3.0.14.Final.jar;D:LocalRepositoryorgcodehausjacksonjackson-core-asl1.9.12jackson-core-asl-1.9.12.jar;D:LocalRepositoryorgcodehausjacksonjackson-mapper-asl1.9.12jackson-mapper-asl-1.9.12.jar;D:LocalRepositoryorgcodehausjacksonjackson-jaxrs1.9.12jackson-jaxrs-1.9.12.jar;D:LocalRepositoryorgcodehausjacksonjackson-xc1.9.12jackson-xc-1.9.12.jar;D:LocalRepositoryorgjboss
esteasy
esteasy-jaxb-provider3.0.16.Final
esteasy-jaxb-provider-3.0.16.Final.jar;D:LocalRepositorycomsunxmlindjaxb-impl2.2.7jaxb-impl-2.2.7.jar;D:LocalRepositorycomsunxmlindjaxb-core2.2.7jaxb-core-2.2.7.jar;D:LocalRepositoryjavaxxmlindjaxb-api2.2.7jaxb-api-2.2.7.jar;D:LocalRepositorycomsunistackistack-commons-runtime2.16istack-commons-runtime-2.16.jar;D:LocalRepositorycomsunxmlfastinfosetFastInfoset1.2.12FastInfoset-1.2.12.jar;D:LocalRepositoryjavaxxmlindjsr173_api1.0jsr173_api-1.0.jar;D:LocalRepositoryorgapache	omcatembed	omcat-embed-core8.0.11	omcat-embed-core-8.0.11.jar;D:LocalRepositoryorgapache	omcatembed	omcat-embed-logging-juli8.0.11	omcat-embed-logging-juli-8.0.11.jar;D:LocalRepositoryjunitjunit4.12junit-4.12.jar;D:LocalRepositoryorghamcresthamcrest-core1.3hamcrest-core-1.3.jar;D:LocalRepositoryorgspringframeworkspring-test4.2.4.RELEASEspring-test-4.2.4.RELEASE.jar;D:LocalRepository
edisclientsjedis2.9.0jedis-2.9.0.jar;D:LocalRepositoryorgapachecommonscommons-pool22.4.2commons-pool2-2.4.2.jar;D:LocalRepositoryorgspringframeworkspring-context-support4.2.4.RELEASEspring-context-support-4.2.4.RELEASE.jar;D:LocalRepositoryorgquartz-schedulerquartz2.2.3quartz-2.2.3.jar;D:LocalRepositoryc3p0c3p0.9.1.1c3p0-0.9.1.1.jar;D:LocalRepositorycom	ypesafeakkaakka-actor_2.112.4.14akka-actor_2.11-2.4.14.jar;D:LocalRepositoryorgscala-langscala-library2.11.8scala-library-2.11.8.jar;D:LocalRepositorycom	ypesafeconfig1.3.0config-1.3.0.jar;D:LocalRepositoryorgscala-langmodulesscala-java8-compat_2.11.7.0scala-java8-compat_2.11-0.7.0.jar;D:LocalRepositoryorgapachemavenmaven-plugin-api3.0.4maven-plugin-api-3.0.4.jar;D:LocalRepositoryorgapachemavenmaven-model3.0.4maven-model-3.0.4.jar;D:LocalRepositoryorgcodehausplexusplexus-utils2.0.6plexus-utils-2.0.6.jar;D:LocalRepositoryorgapachemavenmaven-artifact3.0.4maven-artifact-3.0.4.jar;D:LocalRepositoryorgsonatypesisusisu-inject-plexus2.3.0sisu-inject-plexus-2.3.0.jar;D:LocalRepositoryorgcodehausplexusplexus-component-annotations1.5.5plexus-component-annotations-1.5.5.jar;D:LocalRepositoryorgcodehausplexusplexus-classworlds2.4plexus-classworlds-2.4.jar;D:LocalRepositoryorgsonatypesisusisu-inject-bean2.3.0sisu-inject-bean-2.3.0.jar;D:LocalRepositoryorgsonatypesisusisu-guice3.1.0sisu-guice-3.1.0-no_aop.jar;D:LocalRepositoryorgsonatypesisusisu-guava.9.9sisu-guava-0.9.9.jar;D:LocalRepositoryorgprojectlomboklombok1.12.2lombok-1.12.2.jar;D:Program Files (x86)ideaIU-2016.2.5libidea_rt.jar" com.intellij.rt.execution.application.AppMain akka.router.RouterTest
[INFO] [01/16/2017 14:46:44.010] [strategy-akka.actor.default-dispatcher-6] [akka://strategy/user/RouterTest/worker_0] i am working.
[INFO] [01/16/2017 14:46:44.481] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:44.981] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_2] i am working.
[INFO] [01/16/2017 14:46:45.481] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:45.981] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_4] i am working.
[INFO] [01/16/2017 14:46:46.514] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_0] i am working.
[INFO] [01/16/2017 14:46:47.021] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:47.492] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_2] i am working.
[INFO] [01/16/2017 14:46:47.992] [strategy-akka.actor.default-dispatcher-10] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:48.492] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_4] i am working.
[INFO] [01/16/2017 14:46:48.492] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_0] i am close.
[INFO] [01/16/2017 14:46:48.502] [strategy-akka.actor.default-dispatcher-10] [akka://strategy/deadLetters] Message [akka.iInbox.InboxTest$Msg] from Actor[akka://strategy/user/RouterTest/worker_0#-492254864] to Actor[akka://strategy/deadLetters] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
akka://strategy/user/RouterTest/worker_0 该actor已经删除。router.size=4
[INFO] [01/16/2017 14:46:48.992] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_4] i am working.
[INFO] [01/16/2017 14:46:49.507] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:50.035] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_2] i am working.
[INFO] [01/16/2017 14:46:50.507] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:51.007] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_4] i am working.
[INFO] [01/16/2017 14:46:51.507] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:52.011] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_2] i am working.
[INFO] [01/16/2017 14:46:52.536] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:53.036] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_4] i am working.
akka://strategy/user/RouterTest/worker_2 该actor已经删除。router.size=3
[INFO] [01/16/2017 14:46:53.522] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/user/RouterTest/worker_2] i am close.
[INFO] [01/16/2017 14:46:53.522] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:53.522] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/deadLetters] Message [akka.iInbox.InboxTest$Msg] from Actor[akka://strategy/user/RouterTest/worker_2#519939307] to Actor[akka://strategy/deadLetters] was not delivered. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[INFO] [01/16/2017 14:46:54.022] [strategy-akka.actor.default-dispatcher-10] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:54.522] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_4] i am working.
[INFO] [01/16/2017 14:46:55.022] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:55.522] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:56.022] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_4] i am working.
[INFO] [01/16/2017 14:46:56.522] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:57.023] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:57.523] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_4] i am working.
[INFO] [01/16/2017 14:46:58.023] [strategy-akka.actor.default-dispatcher-7] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:46:58.566] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:58.566] [strategy-akka.actor.default-dispatcher-10] [akka://strategy/user/RouterTest/worker_4] i am close.
akka://strategy/user/RouterTest/worker_4 该actor已经删除。router.size=2
[INFO] [01/16/2017 14:46:58.566] [strategy-akka.actor.default-dispatcher-10] [akka://strategy/deadLetters] Message [akka.iInbox.InboxTest$Msg] from Actor[akka://strategy/user/RouterTest/worker_4#50964955] to Actor[akka://strategy/deadLetters] was not delivered. [3] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[INFO] [01/16/2017 14:46:59.076] [strategy-akka.actor.default-dispatcher-4] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:46:59.547] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:00.047] [strategy-akka.actor.default-dispatcher-4] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:47:00.547] [strategy-akka.actor.default-dispatcher-4] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:01.047] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:47:01.582] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:02.091] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_3] i am working.
[INFO] [01/16/2017 14:47:02.562] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:03.062] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_3] i am working.
akka://strategy/user/RouterTest/worker_3 该actor已经删除。router.size=1
[INFO] [01/16/2017 14:47:03.562] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:03.562] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/user/RouterTest/worker_3] i am close.
[INFO] [01/16/2017 14:47:03.563] [strategy-akka.actor.default-dispatcher-3] [akka://strategy/deadLetters] Message [akka.iInbox.InboxTest$Msg] from Actor[akka://strategy/user/RouterTest/worker_3#-667250877] to Actor[akka://strategy/deadLetters] was not delivered. [4] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[INFO] [01/16/2017 14:47:04.062] [strategy-akka.actor.default-dispatcher-10] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:04.597] [strategy-akka.actor.default-dispatcher-10] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:05.099] [strategy-akka.actor.default-dispatcher-4] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:05.570] [strategy-akka.actor.default-dispatcher-4] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:06.070] [strategy-akka.actor.default-dispatcher-4] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:06.570] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:07.070] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:07.611] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:08.112] [strategy-akka.actor.default-dispatcher-4] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:08.583] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_1] i am working.
[INFO] [01/16/2017 14:47:08.583] [strategy-akka.actor.default-dispatcher-5] [akka://strategy/user/RouterTest/worker_1] i am close.
[INFO] [01/16/2017 14:47:08.585] [strategy-akka.actor.default-dispatcher-9] [akka://strategy/deadLetters] Message [akka.iInbox.InboxTest$Msg] from Actor[akka://strategy/user/RouterTest/worker_1#255839262] to Actor[akka://strategy/deadLetters] was not delivered. [5] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
akka://strategy/user/RouterTest/worker_1 该actor已经删除。router.size=0
没有可用actor了，系统关闭。
Process finished with exit code 0

原文地址：http://blog.csdn.net/liubenlong007/article/details/54574064