???????????????????????????????÷??????в????????????????????.
?????????
?????????MQ???????????????????????????д??????????????

????????????????MQ????м??y?飬?????????????????????????????????????????MQ?У??????????????????????????????д????
??????????????????????????Щ?????????￡??????????????????HashMap????Threadlocal?н??д?????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
??????????
?????????????е?Akka?????????
????Akka?????????
??????????????к???????
??????????Resilient by Design??
????????????????????????/?????м???
???????????High Performance??
??????????????????50000000?????????????С??1GB????п????2500000??actors??
????????????????Elastic — Decentralized??
?????????????????·?????????????
???????????Extensible?? ???????Akka ??????????????
????????????о?Scala??Scala???????????????????????????Scala???????????????Akka??????????á???????????????????????????????????Щ???????????????????????
???????????￡?
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.actor.UntypedActor;
/**
* PROJECT_NAME: akkademo
* DATE:         16/2/27
* CREATE BY:    chao.cheng
**/
public class ToStringActor extends UntypedActor {
@Override
public void onReceive(Object message) {
System.out.println(message.toString());
try {
Thread.sleep(500);
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
ActorSystem system = ActorSystem.create("toStringActor");
final ActorRef toString = system.actorOf(Props.create(ToStringActor.class)??"toString");
for(int i=0;i<10000000;i++) {
toString.tell("test"+i??toString);
}
System.out.println("[????]=======================");
}
}
???????????????
??????????????????????????????????????onReceive??????????????
??????VisualVM???????????????