java akka是什么,讓我們一起了解一下?
Akka是JAVA虛擬機(jī)JVM平臺(tái)上構(gòu)建高并發(fā)、分布式和容錯(cuò)應(yīng)用的工具包和運(yùn)行時(shí)。Akka用Scala語(yǔ)言寫成,同時(shí)提供了Scala和JAVA的開發(fā)接口。
那么java集成Akka是怎樣使用的?
實(shí)戰(zhàn)操作:簡(jiǎn)單使用 (A 發(fā)消息給 B)
第一步,引入pom.xml依賴。
???? com.typesafe.akka ????akka-actor_2.12 ????2.6.14
第二步,自定義Actor,用于接收消息并處理的。
/** ?*?自定義一個(gè)Actor,接收String類數(shù)據(jù)并處理 ?*/ public?class?MyActor?extends?AbstractActor?{ ????public?Receive?createReceive()?{ ????????return?receiveBuilder().match(String.class,?result?->?{ ????????????//處理業(yè)務(wù)邏輯 ????????????System.out.println("123"); ????????}).build(); ????} }
第三步,給自定義的Actor發(fā)消息。
public?static?void?main(String[]?args)?{ ????//定義一個(gè)Actor管理倉(cāng)庫(kù) ????ActorSystem?system?=?ActorSystem.create("sys"); ????//將自定義的Actor放入倉(cāng)庫(kù)并起個(gè)名字 ????ActorRef?actorDemo?=?system.actorOf(Props.create(MyActor.class),?"actorDemo"); ????//發(fā)送消息 ????actorDemo.tell("你好",ActorRef.noSender()); }
以上就是小編今天的分享了,希望可以幫助到大家。