java akka

<link rel="stylesheet" href="https://js.how234.com/third-party/SyntaxHighlighter/shCoreDefault.css" type="text/css" /><script type="text/javascript" src="https://js.how234.com/third-party/SyntaxHighlighter/shCore.js"></script><script type="text/javascript"> SyntaxHighlighter.all(); </script>

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

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

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

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

java akka

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

<dependency>    <groupId>com.typesafe.akka</groupId>    <artifactId>akka-actor_2.12</artifactId>    <version>2.6.14</version></dependency>

第二步,自定义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());}