<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)
第一步,引入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());}