动手实践 MicroStream：Java 持久性的新方法

分手后的思念是犯贱 2024-03-16 10:18 34阅读 0赞

MicroStream是目前Java领域最有趣的项目之一。它采用一种新的方法来实现 Java 持久性，充当一种无缝的对象持久性数据层。MicroStream 消除了弄清楚如何持久化应用程序的运行时图的摩擦。所以这次我们将直接进入演示。您将首先学习如何将MicroStream与默认文件系统一起使用，然后我们将更新我们的演示程序以使用MariaDB RDBMS。

### 设置 Java 项目 ###

让我们从创建一个新的 Java 项目开始。我们将使用一个简单的 Maven 项目，但任何方法都有效。打开命令行并输入清单 1 中的代码，创建一个具有 Maven 原型的新项目。

清单 1.创建新项目

<code>
 $ mvn archetype:generate -DgroupId=com.infoworld -DartifactId=microstream -DarchetypeArtifactId=maven-archetype-quickstart -DarchetypeVersion=1.4 -Dpackage=com.infoworld -DinteractiveMode=false</code>

请注意，我已将组 ID 设置为 ，项目 ID 设置为 ，包设置为 。`com.infoworld``microstream``com.infoworld`

接下来，打开文件并添加清单 2 中所示的依赖项。我们将使用MicroStream的嵌入式存储库，这是最简单的方法。此外，请确保 Maven 编译器版本设置为 1.8。`/myproject/pom.xml`

![bd2f0f7e6f134245bbdd0d5e60fe7c4f.png][]

0 秒 0 秒的 30 秒卷 0%

清单 2.绒球.xml设置

<code>
 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <maven.compiler.source>1.8</maven.compiler.source>
 <maven.compiler.target>1.8</maven.compiler.target>
 </properties>
 
 <dependency>
 <groupId>one.microstream</groupId>
 <artifactId>microstream-storage-embedded</artifactId>
 <version>07.01.00-MS-GA</version>
 </dependency></code>

现在，我们可以运行 MicroStream 初学者项目并从命令行获取响应，如清单 3 所示。

清单 3.运行微流启动器

<code>
 $ mvn clean package
 $ java -cp target/microstream-1.0-SNAPSHOT.jar com.infoworld.App
 Hello World!</code>

### 添加要持久化的模型 ###

接下来，让我们合并一个可以坚持的简单模型。我们将更改初学者项目的主类，使其采用三个命令行参数并将其保存在 .`String``ArrayList`

清单 4.应用.java与阵列列表模型

我们可以测试数组列表版本，如清单 5 所示。它接受传入的参数并将它们放在 中，然后输出它。`List`

[2024 年 IT 最佳工作场所提名开放][2024 _ IT]

清单 5.使用 ArrayList 模型运行应用.java

<code>
 $ mvn clean package
 $ java -cp target/microstream-1.0-SNAPSHOT.jar com.infoworld.App test test2 test3
 [test, test2, test3]</code>

### 使用微流存储列表 ###

现在，修改此代码以使用MicroStream存储列表。清单 6 显示了它是如何完成的。

清单 6.保存列表

请注意，使用默认值保存状态是多么容易。当我们在没有参数的情况下调用时，它会创建一个具有默认值的新 MicroStream 引擎，包括默认文件存储位置和持久性策略。`EmbeddedStorage.start()`

然后，我们将根对象设置为我们的列表。每个 MicroStream 应用程序都有一个根对象，它是要持久保存的整个对象图的根。`manager.setRoot()`

告诉引擎保持状态。`manager.storeRoot()`

清单 7 显示了该应用程序的完整版本。请注意，它在传入时会保留列表;如果没有，它将检索并显示它。

清单 7.使用默认值保存和恢复对象

<code>
 import one.microstream.storage.embedded.types.EmbeddedStorage;
 import one.microstream.storage.embedded.types.EmbeddedStorageManager;
 
 import java.nio.file.Paths;
 import java.util.ArrayList;
 
 public class App {
 public static void main(String[] args) {
 ArrayList<String> list;
 if (args.length > 0) {
 list = new ArrayList<String>();
 for (int i = 0; i < args.length; i++) {
 list.add(args[i]);
 }
 EmbeddedStorageManager manager = EmbeddedStorage.start();
 manager.setRoot(list);
 manager.storeRoot();
 System.out.println("Saved: " + list);
 } else {
 EmbeddedStorageManager storageEngine = EmbeddedStorage.start();
 list = (ArrayList<String>) storageEngine.root();
 System.out.println("Loaded: " + list);
 }
 System.exit(0);
 }
 }</code>

你会注意到，如果你使用参数运行程序，它会保存字符串列表，如果你在没有参数的情况下运行它，它会从存储中提取它们并显示它们。清单 8 具有这两个选项。

清单 8.保存并加载程序

<code>
 $ mvn clean package exec:java -Dexec.mainClass="com.infoworld.App" -Dexec.args="test test2 test3
 Saved: [test, test2, test3]
 $ mvn clean package exec:java -Dexec.mainClass="com.infoworld.App"
 Loaded: [test, test2, test3]</code>

您可能想知道MicroStream将存储文件放在哪里。缺省情况下，它使用 Java 项目的工作[目录][Link 1]。在我们的演示中，它把它放在项目的根目录。如果你看那里，你会看到一个.`/microstream/microstream``/my-storage-folder`

如果需要更改存储文件的位置，可以使用参数对其进行配置，如清单 9 所示。在这里，我们在两个启动调用上设置了一个文件位置。请注意，我们导入了标准的 Path Java 库来处理 \[what？\]。`start()`

清单 9.设置备用目录

### MicroStream with MariaDB ###

现在，让我们看看如何使用备用存储系统。我们将研究如何使用本地 MariaDB 社区实例。就我而言（在 Ubuntu 上），我请参阅说明）。运行 MariaDB 后，我们可以修改应用程序以使用数据库来保存状态，如清单 10 所示。

清单 10.该应用程序的MariaDB版本

<code>
 package com.infoworld;
 
 import org.mariadb.jdbc.MariaDbDataSource;
 import one.microstream.afs.sql.types.SqlFileSystem;
 import one.microstream.afs.sql.types.SqlConnector;
 import one.microstream.afs.sql.types.SqlProviderMariaDb;
 import one.microstream.storage.embedded.types.EmbeddedStorage;
 import one.microstream.storage.embedded.types.EmbeddedStorageManager;
 import java.util.ArrayList;
 
 public class App {
 public static void main(String[] args) {
 try {
 MariaDbDataSource dataSource = new MariaDbDataSource();
 dataSource.setUrl("jdbc:mysql://localhost:3306/mydb");
 dataSource.setUser("admin");
 dataSource.setPassword("password");
 SqlFileSystem fileSystem = SqlFileSystem.New(SqlConnector.Caching(SqlProviderMariaDb.New(dataSource)));
 
 EmbeddedStorageManager manager = EmbeddedStorage.start(fileSystem.ensureDirectoryPath("microstream_storage"));
 
 ArrayList<String> list;
 if (args.length > 0) {
 list = new ArrayList<String>();
 for (int i = 0; i < args.length; i++) {
 list.add(args[i]);
 }
 manager.setRoot(list);
 manager.storeRoot();
 System.out.println("Saved: " + list);
 } else {
 list = (ArrayList<String>) manager.root();
 System.out.println("Loaded: " + list);
 }
 } catch (Exception e){
 System.err.println("error: "+ e);
 throw new RuntimeException(e);
 }
 }
 }</code>

清单 10 提供了使用 MariaDB 本地实例而不是默认文件系统的应用程序的完整版本。此版本假定 MariaDB 正在侦听本地主机端口 3306。管理员用户密码为“密码”。

请注意调用的行;它传递了参数.其效果是将**microstream\_storage**表添加到 **mydb** 数据库中（如果它还没有）。`EmbeddedStorage.start()``fileSystem.ensureDirectoryPath("microstream_storage")`

顺便说一下，这里的错误处理只是一个令牌。在实际应用中，我们需要更加认真地处理错误。

软件包中的“afs”代表抽象文件系统。目的是让应用程序使用 MicroStream 来保存对象图，而不必过多担心它的实现方式。因此，像 AWS S3 这样的数据库、文件系统或云对象存储都可以像使用 MariaDB 一样使用，除了存储的配置方式。NoSQL和MongoDB一样，也受支持，尽管它是一个企业功能。`one.microstream.afs.sql`

要运行此示例，我们需要将 MariaDB 驱动程序和 JAR 文件添加到 l 依赖项中：`one.microstream.afs``pom.xm`

清单 11.添加 MariaDB 依赖项

<code>
 <dependency>
 <groupId>org.mariadb.jdbc</groupId>
 <artifactId>mariadb-java-client</artifactId>
 <version>2.7.1</version>
 </dependency>
 <dependency>
 <groupId>one.microstream</groupId>
 <artifactId>microstream-afs-sql</artifactId>
 <version>07.01.00-MS-GA</version>
 </dependency></code>

现在，可以使用清单 8 中所示的相同命令运行应用程序，并将状态持久化到 MariaDB 的本地实例中。

### 结论 ###

MicroStream以不同于大多数Java开发人员习惯的架构方式接近Java持久性。它消除了安装和维护单独的独立组件来处理数据存储的要求。但是，您已经看到，如果您愿意，您仍然可以使用 RDBMS。

MicroStream类似于ORM（如Hibernate），但更加无缝。它开辟了在对象的心理领域内思考数据持久性的可能性。您仍然需要考虑保存或加载的内容和时间，但您不必搁置业务模型并进入数据层作为不同的阶段。

MicroStream对Java持久性采取了一种新的方法，这可能是Java正在进行的复兴的一个关键特征。

[bd2f0f7e6f134245bbdd0d5e60fe7c4f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/3c4765387780402b83c4afaae6b97e9e.png
[2024 _ IT]: https://survey.researchresults.com/survey/selfserve/53b/s00643290501?ctry=1&ver=8
[Link 1]: https://mkyong.com/java/how-to-get-the-current-working-directory-in-java/