Akka事件驱动新选择入门

java复制代码import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;

public class HelloWorld extends AbstractActor {

    static public Props props() {
        return Props.create(HelloWorld.class, () -> new HelloWorld());
    }

    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(String.class, s -> {
                    System.out.println("Received message: " + s);
                })
                .build();
    }

    public static void main(String[] args) {
        final ActorSystem system = ActorSystem.create("hello-world-system");
        final ActorRef actor = system.actorOf(HelloWorld.props(), "hello-world-actor");

        actor.tell("Hello, world!", ActorRef.noSender());

        system.terminate();
    }
}