java akka

作者:原创时间:2022-03-23
文档

java akka是什么,让我们一起了解一下?

Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行时。Akka用Scala语言写成,同时提供了Scala和JAVA的开发接口。

那么java集成Akka是怎样使用的?

实战操作:简单使用 (A 发消息给 B)

第一步,引入pom.xml依赖。


    com.typesafe.akka
    akka-actor_2.12
    2.6.14

第二步,自定义Actor,用于接收消息并处理的。

/**
 * 自定义一个Actor,接收String类数据并处理
 */
public class MyActor extends AbstractActor {
    public Receive createReceive() {
        return receiveBuilder().match(String.class, result -> {
            //处理业务逻辑
            System.out.println("123");
        }).build();
    }
}

第三步,给自定义的Actor发消息。

public static void main(String[] args) {
    //定义一个Actor管理仓库
    ActorSystem system = ActorSystem.create("sys");
    //将自定义的Actor放入仓库并起个名字
    ActorRef actorDemo = system.actorOf(Props.create(MyActor.class), "actorDemo");
    //发送消息
    actorDemo.tell("你好",ActorRef.noSender());
}

以上就是小编今天的分享了,希望可以帮助到大家。

显示全文
ipad2是哪年的 java algorithm iphone呼叫失败是什么原因 java android java annotation java ant java apns 苹果13蓝牙搜索不到设备怎么办 java append java application java apriori java archive java arcsin java arccos java arctan java args java arrays.sort java ascii java asmx java aspectj java aggregation java aes加密 java advice java addall java add java actuator 西北五省是哪五省 java activity java activiti 瓮安县属于哪个市 java active 茉莉花茶是绿茶吗 java a++和++a的区别 熊猫只有中国才有的吗 idea新建一个java项目 java 32bit java -xms idea新建java项目 祁连山在哪个省境内 行程码带*号什么意思