背景

我們在開發的過程中可能會在內存中操作數據，但是可能會遇到突然服務器斷電、網線被挖等情況。這就需要將內存中的數據持久化，在程序重啟的時候依然能夠恢復。

AKKA介紹

Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala

Akka是一個用于為Java和Scala構建高度并發，分布式和彈性的消息驅動應用程序的工具包

雖然AKKA不是專門用來持久化的，但是其中的持久化部分可以拿出來使用。

本文參照AKKA官方文檔，展示了AKKA持久化的一個樣例。

第一步：配置JDK和Maven環境

這里推薦JDK1.8和Maven3

第二步：創建Maven工程

本人習慣采用IDEA

如果創建完工程有提示

第三步：添加依賴

修改pom.xml文件，其實只有兩個依賴就夠用了。

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>TestAkka</groupId><artifactId>TestAkka</artifactId><version>1.0-SNAPSHOT</version><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>8</source><target>8</target></configuration></plugin></plugins></build><dependencies><dependency><groupId>com.typesafe.akka</groupId><artifactId>akka-actor_2.12</artifactId><version>2.5.22</version></dependency><dependency><groupId>org.iq80.leveldb</groupId><artifactId>leveldb</artifactId><version>0.7</version></dependency></dependencies></project>

第四步：編寫代碼

總共需要四個文件

（1）MyData 這個類是用來封裝數據的，也就是說，我們希望進行持久化的數據可以封裝到這個里面。需要注意的是，這個類必須要實現Serializable接口

import java.io.Serializable;public class MyData implements Serializable {private static final long serialVersionUID = 1L;private String name;public MyData(String name){this.name= name;}@Overridepublic String toString() {return "MyData{" +"name='" + name + '\'' +'}';} }

（2）Actor類

這個類要繼承AbstractPersistentActor類，并能覆蓋其中三個方法。

import akka.persistence.AbstractPersistentActor; import akka.persistence.SnapshotOffer;import java.util.ArrayList; import java.util.List;public class MyPersistentActor extends AbstractPersistentActor {private List<MyData> state = new ArrayList<MyData>();@Overridepublic String persistenceId() {return "Kangyucheng";}@Overridepublic Receive createReceiveRecover() {return receiveBuilder().match(MyData.class, e -> state.add(e)).match(SnapshotOffer.class, ss -> state = (List<MyData>) ss.snapshot()).build();}@Overridepublic Receive createReceive() {return receiveBuilder().match(MyData.class, c -> {persist(c, event -> state.add(event));}).matchEquals("snap", s -> saveSnapshot(new ArrayList<>(state))).matchEquals("print", s -> System.out.println(state)).build();}}

（3）Main測試類

import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.actor.Props;public class Main {public static void main(String... args) throws Exception {//1.創建 persistentActor,注意MyPersistentActor對應的是我們自己創建的Actorfinal ActorSystem system = ActorSystem.create();final ActorRef persistentActor = system.actorOf(Props.create(MyPersistentActor.class));//2.調用tell方法String random = String.valueOf((int)(Math.random()*100));persistentActor.tell(new MyData("kangyucheng"+random), null);persistentActor.tell(new MyData("kyc"), null);persistentActor.tell("snap", null);persistentActor.tell("print", null);//3.由于系統是異步持久化，所以要等一下Thread.sleep(10000);system.terminate();} }

（4） AKKA配置類application.conf這個文件放在了resources文件下面

主要是配置持久化文件的存儲位置

akka.persistence.journal.plugin = "akka.persistence.journal.leveldb" akka.persistence.snapshot-store.plugin = "akka.persistence.snapshot-store.local"akka.persistence.journal.leveldb.dir = "target/example/journal" akka.persistence.snapshot-store.local.dir = "target/example/snapshots"# DO NOT USE THIS IN PRODUCTION !!! akka.persistence.journal.leveldb.native = false

第五步：運行程序

（1）第一次運行

發現target文件夾下出現了配置文件中的目錄，這個目錄存儲的就是持久化的文件

?控制臺打出來了List

?

（2）第二次運行

可以看見第一次運行存儲在內存中的

（3）第三次運行

可見前兩次運行的結果

?

總結

以上是生活随笔為你收集整理的AKKA框架持久化入门样例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。