tx

熊猫不是猫QAQ

平平无奇小熊猫
612,240
将 Spring Boot 应用程序与 Amazon DocumentDB 集成 将 Spring Boot 应用程序与 Amazon DocumentDB 集成
panda 6个月前
技术分享

Amazon DocumentDB（与 MongoDB 兼容）是一种可扩展、高度持久和完全托管的数据库服务，用于操作任务关键型 MongoDB 工作负载。在 Amazon DocumentDB 上，您可以使用相同的 MongoDB 应用程序代码、驱动程序和工具来运行、管理和扩展工作负载，无需关心管理底层基础设施。 更多精彩免费产品欢迎到“亚马逊云科技 ”探索体验哦

Spring Boot 提供了简单快速的方法，可基于 Spring 框架来构建生产级的应用程序。为了做到这一点，Spring Boot 预先打包自动配置模块，用于通常与 Spring Framework 一起使用的大多数库。简而言之，开源 Spring Boot 遵循有关配置的惯例，在 Spring 框架之上添加了自动配置功能。

在这篇文章中，您将探索使用 Spring Data MongoDB API，将 Spring Boot 应用程序集成到 Amazon DocumentDB 的基础知识。您还可以创建示例数据模型和存储库类用于执行数据库操作。

解决方案概览

Spring Boot 和 Amazon DocumentDB 的配置相对简单，只涉及几个配置步骤。

Spring Boot 允许应用程序使用MongoTemplate类和MongoRepository接口，与 Amazon DocumentDB 交互。MongoTemplate遵循 Spring 中的标准模板模式，为底层持久性引擎提供了现成的基本 API。MongoTemplate 为聚合、流式处理、更新和自定义查询等操作提供了直接可用的 API。MongoRepository 遵循以 Spring Data 为中心的方法，基于所有 Spring Data 项目中广为人知的创建、读取、更新和删除（CRUD，Create, Read, Update, and Delete）访问模式，提供了更灵活、更简单的 API 操作。

对于这两个选项，您首先要在pom.xml中为 Maven 项目定义依赖项。

这篇文章重点介绍如何使用MongoRepository与 Amazon DocumentDB 交互。

先决条件

您需要满足以下先决条件：

您的账户中可能会产生与 Amazon DocumentDB 和 Amazon Cloud9 资源相关的费用。您可以使用亚马逊云科技定价计算器来估计此费用（https://calculator.aws/）。

使用 Spring Initializr

创建 Spring Boot 应用程序

使用以下步骤，创建一个支持 Spring Data MongoDB 的新 Spring Boot 应用程序项目。作为替代方法，您可以使用 GitHub 存储库中的spring-boot-docdb-sample应用程序。（https://github.com/aws-samples/amazon-documentdb-samples/tree/master/blogs/docdb-springboot）

  1. 浏览到https://start.spring.io/。
  2. 指定以下选项：
  3. 选择Maven project（Maven 项目），且Language（语言）为Java。
  4. 选择 Spring Boot 的版本 3.0.0。
  5. 为应用程序指定组和构件名称。
  6. 指定 Java 版本 17。
  7. 选择ADD DEPENDENCIES（添加依赖项），然后搜索并选择Spring Data MongoDB。您可以使用 Spring Data MongoDB 依赖项，从此应用程序与 Amazon DocumentDB 集群进行交互。
  8. 选择GENERATE（生成）以生成一个 Spring Boot 项目，其中包含引导所需的全部文件。
  9. 将 ZIP 文件下载到本地计算机上的路径并解压缩文件。

如果您使用的是 Amazon Cloud9 IDE，请将 ZIP 文件上传到 Amazon Cloud9 环境并解压缩文件。

验证 Maven 依赖项

在应用程序的目录中找到pom.xml文件，然后验证是否已按如下方式添加 Spring Data MongoDB 依赖项：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

定义数据模型

要在 Amazon DocumentDB 数据库中存储和检索数据，我们先创建一个 POJO 模型或实体类。该实体代表 Amazon DocumentDB 中的集合，并使用注释来定义集合名称、属性、键和其他方面。

在此示例中，您创建一个产品集合和对应的模型对象，该对象将产品的详细信息存储在目录数据库中。您创建具有六个属性的产品模型：id、name、sku、description、inventory和category。

Amazon DocumentDB 在集合中存储数据。默认情况下，Spring Data 将产品的类或模型映射到名为product的集合。如果要更改集合的名称，您可以在类上使用 Spring Data MongoDB 的@Document注释。在以下示例中，我们使用@Document(collection = "products")来将集合名称指定为products。

您可以使用@Id注释指定文档的主键_id。如果您未指定任何内容，Amazon DocumentDB 将在创建文档时生成_id字段。其他属性不添加注释。这会假设它们映射到与属性本身具有相同名称的字段。在项目的目录中，创建一个Product.java文件，其中具有以下内容：

   @Id
    private String id;    
    
    /** 
     * 设置对应于 products 集合中字段的数据成员
     */
     
    private String name;
    private String sku;
    private String description;
    private int inventory;
    private String category;
    

    /**
     * @param id
     * @param name
     * @param sku
     * @param description
     * @param inventory
     * @param category
     */
    public Product(String name, String sku, String description, int inventory, String category) {
        
        this.name = name;
        this.sku = sku;
        this.description = description;
        this.inventory = inventory;
        this.category = category;
    }
}

为每个属性添加 getter 和 setter 方法。您可以使用特定于 IDE 的快捷方式生成 getter 和 setter 方法。例如，右键单击代码编辑器窗格，选择Refactoring（重构），然后选择Generate Getter and Setter in Cloud9（在 Cloud9 中生成 Getter 和 Setter）。

此外，建议覆盖toString方法来输出对象，例如，右键单击代码编辑器窗格，选择Refactoring（重构），然后选择Generate toString() in Cloud9（在 Cloud9 中生成 toString()）

在启用 TLS 的情况下进行连接

要从基于 Java 的 Spring Boot 应用程序连接到启用了 TLS 的 Amazon DocumentDB 集群，您的程序必须使用亚马逊云科技提供的证书颁发机构（CA，Certificate Authority）文件来验证连接。要使用 Amazon RDS CA 证书，请执行以下操作：

  1. 在tmp文件夹下创建一个临时certs文件夹。您可以根据组织的安全策略来创建用于存储证书的文件夹。本文中，在tmp下创建certs文件夹：

Bash

mkdir /tmp/certs/
  1. 运行以下命令，使用包含在文件中的 CA 证书创建信任存储。请确保更新。以下 shell 脚本示例将证书捆绑包导入 Linux 操作系统上的信任存储。有关其他选项，请参阅启用了 TLS 的情况下的连接（https://docs.aws.amazon.com/documentdb/latest/developerguide/connect_programmatically.html#connect_programmatically-tls_enabled）。
mydir=/tmp/certs
truststore=${mydir}/rds-truststore.jks
storepassword=<truststorePassword>

curl -sS "https://s3.amazonaws.com/rds-downloads/rds-combined-ca-bundle.pem" > ${mydir}/rds-combined-ca-bundle.pem
awk 'split_after == 1 {n++;split_after=0} /-----END CERTIFICATE-----/ {split_after=1}{print > "rds-ca-" n ".pem"}' < ${mydir}/rds-combined-ca-bundle.pem

for CERT in rds-ca-*; do
  alias=$(openssl x509 -noout -text -in $CERT | perl -ne 'next unless /Subject:/; s/.*(CN=|CN = )//; print')
  echo "Importing $alias"
  keytool -import -file ${CERT} -alias "${alias}" -storepass ${storepassword} -keystore ${truststore} -noprompt
  rm $CERT
done

rm ${mydir}/rds-combined-ca-bundle.pem

echo "Trust store content is: "

keytool -list -v -keystore "$truststore" -storepass ${storepassword} | grep Alias | cut -d " " -f3- | while read alias 
do
   expiry=`keytool -list -v -keystore "$truststore" -storepass ${storepassword} -alias "${alias}" | grep Valid | perl -ne 'if(/until: (.*?)\n/) { print "$1\n"; }'`
   echo " Certificate ${alias} expires in '$expiry'" 
done

数据库和连接配置

设置连接详细信息和 SSL 信任存储需要两个配置文件。首先，在application.properties中定义您的 Amazon DocumentDB 连接参数，例如数据库、URI 或主机、端口、用户名和密码。然后在配置类中设置密钥库。

配置 Spring Boot 应用程序属性文件

要将 Spring Boot 应用程序连接到 Amazon DocumentDB，我们需要在application.properties文件中定义数据库配置。您需要配置数据库 URI、数据库名称或主机名、用户名、密码等属性，以及其他与连接相关的属性。要连接到 Amazon DocumentDB 集群，您需要在位于src/main/resources文件夹的application.properties文件中指定连接 URI 字符串。

要检索您的 Amazon DocumentDB 集群端点并配置application.properties，请完成以下步骤：

  1. 在 Amazon DocumentDB 控制台的导航窗格中，选择Clusters（集群）。
  2. 找到您的集群并选择区域集群标识符。
  3. 在Connectivity & security（连接和安全性）选项卡上，复制用于通过 application.

连接到集群的命令。

  1. 从复制的连接字符串中删除&ssl_ca_certs=rds-combined-ca-bundle.pem，因为您已经将亚马逊云科技提供的 CA 文件导入了信任存储。
  2. 将连接 URI 添加到位于您的项目src/main/resources文件夹的application.properties文件中。连接 URI 的键为spring.data.mongodb.uri。确保复制的连接字符串格式如下：
spring.data.mongodb.uri=mongodb://<用户名>:<密码>@<集群端点>: 27017/?ssl=true&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false

或者，您可以单独提供连接详细信息，包括主机名、端口、用户名和密码以及对应的属性键，例如spring.data.mongodb.host或spring.data.mongodb.port。有关可用的 Spring Boot 参数配置选项的完整列表，请参阅 Common Application Properties（常用应用程序属性）下的 Data Properties（数据属性）（https://docs.spring.io/spring-boot/docs/current/reference/html/application-properties.html#appendix.application-properties.data）。

  1. 您也可以选择在application.properties文件中指定数据库名称：
spring.data.mongodb.database=catalog

创建配置类并设置密钥库

现在属性配置已经完成，您需要定义配置类来设置密钥库属性，以便建立安全连接。

要在应用程序中使用密钥库，请在配置类中设置以下系统属性：

javax.net.ssl.trustStore: <truststore>
javax.net.ssl.trustStorePassword: <truststorePassword>

请参阅以下示例配置类。使用@Configuration注释将该类标记为配置类。具有@Configuration注释的类由 Spring 容器用作 bean 定义的来源。

 @Bean
        public MongoClientSettings mongoClientSettings() { 
             setSslProperties();
       return MongoClientSettings.builder()
                    .applyToSslSettings(builder -> builder.enabled(true))
                    .build();
  }

        private static void setSslProperties() { 
            System.setProperty("javax.net.ssl.trustStore", KEY_STORE_TYPE);
            System.setProperty("javax.net.ssl.trustStorePassword",          
                    DEFAULT_KEY_STORE_PASSWORD);
        }
  @Bean
        public MongoPropertiesClientSettingsBuilderCustomizer mongoPropertiesCustomizer(final MongoProperties properties) {
      return new MongoPropertiesClientSettingsBuilderCustomizer(properties);
  }
}

以上是 Spring Boot 中 Amazon DocumentDB 配置的全部内容现在，您可以通过扩展MongoRepository开始定义基于接口的存储库类。

配置存储库接口

现在，您可以使用MongoRepository访问数据库中的数据。MongoRepository提供常用功能，例如创建、读取、更新和删除（CRUD，Create, Read, Update, and Delete）操作。它充当模型与数据库之间的链接。它获取域类（Product）进行管理，并获取域类的 ID 类型作为类型参数。您可以编写几种方法，由存储库为您生成查询。

创建查询Product文档的存储库接口，如下所示：

public interface ProductRepository extends MongoRepository<Product, String> {

}

ProductRepository扩展MongoRepository接口。此接口包含许多操作，包括标准的 CRUD 操作。您将在下一节中定义其他自定义操作。

定义服务类

服务类利用了 Spring Data 存储库接口。我们通过引用您在上一步中创建的存储库来定义它：

Java

@Service
public class ProductService {
    
    @Autowired
    private ProductRepository productRepo;
}

在下一节中，您将在此类上通过添加其他方法进行构建，该节还介绍了 CRUD 示例。

使用 CrudRepository

使用扩展了CrudRepository的MongoRepository时，您的存储库可以从CrudRepository接口的实施类访问基本功能，包括save、count、findAll和delete方法。您的ProductRepository接口扩展了MongoRepository，并可以访问所有基本 CRUD 操作。

我们来逐个探索和测试这些操作。

保存或创建

首先，您使用save方法向集合中添加一些文档。save方法获取 Product 对象作为输入，并将产品文档保存到 Amazon DocumentDB 集合中。将以下代码片段添加到您的服务类中：

public void saveProducts() {
 
  productRepo.save(new Product("RayBan Sunglass Pro", "1590234","RayBan Sunglasses for professional sports people", 100, "fashion"));
  productRepo.save(new Product("GUCCI Handbag", "3451290", "Fashion Hand bags for all ages", 75, "fashion"));
  productRepo.save(new Product("Round hat", "8976045", "", 200, "fashion"));
  productRepo.save(new Product("Polo shirt", "6497023", "Cool shirts for hot summer", 25, "cloth"));
  productRepo.save(new Product("Swim shorts", "8245352", "Designer swim shorts for athletes", 200, "cloth"));
  productRepo.save(new Product("Running shoes", "3243662", "Shoes for work out and trekking", 20, "footware"));
  
  System.out.println(" Save complete ");
        
}

计数

在下一个示例中，如果存储库中没有任何方法，则调用服务类中的count()方法，对集合中的文档进行计数。

public long getCount() {
    long count = productRepo.count();
    System.out.println(" Total number of products : "+count);
    return count;
}

读取

在此示例中，您执行三种不同的读取操作。您可以按名称或 SKU 提取产品，然后根据类别查找产品列表。

您在存储库（ProductRepository）中添加了三种简单方法。第一种方法findProductByName根据name属性查询集合。查询筛选条件使用注释@Query定义，在本例中，注释为@Query("{name:'?0'}")。第二种方法findProductBySKU根据sku属性查询集合，并在查询响应中仅输出name和inventory属性。第三种方法findAll检索特定类别的所有文档。请参阅以下代码：

public interface ProductRepository extends MongoRepository<Product, String> {
    
    @Query("{name:'?0'}")
    Product findProductByName(String name);
    
    @Query(value="{sku:'?0'}", fields="{'name' : 1, 'inventory' : 1}")
    Product findProductBySKU (String sku);   

    @Query("{category:'?0'}")
    List<Product> findAllByCategory(String category);
                                                        
}

您可以从存储库在服务类中调用这三种方法，按名称、SKU 和类别查找文档。

public Product getProductByName(String name) {
  System.out.println(" Getting product by name : " + name);
  Product product = productRepo.findProductByName(name);
  System.out.println(product);
  return product; 
}

public Product getProductBySKU(String sku) {
  System.out.println(" Getting product by SKU : " + sku);
  Product product = productRepo.findProductBySKU(sku);
  System.out.println(product);
   return product; 
}

public List<Product> findAllProductsByCategory(String category) {
  List<Product> productList = productRepo.findAllByCategory(category);
  productList.forEach(product -> System.out.println(product));
  return productList;
}

更新

您可以通过传递更新后的实体对象，使用save方法来更新现有文档。在此示例中，您按 SKU 查询现有产品并将库存增加 10。将以下方法添加到您的服务中：

public void updateInventory(String sku) {
  Product product =  getProductBySKU(sku);
  System.out.println(" Updating Inventory for product by sku: " + sku);  
  product.setInventory(product.getInventory()+10);
  Product updatedProd = productRepo.save(product);
}

删除

在本示例中，您将创建两个删除操作。首先，您按照 ID 删除一个产品；在第二种方法中，您将删除集合中的所有文档（products）。将以下方法添加到您的服务类中：

public void deleteProduct(String id) {
   productRepo.deleteById(id);
  System.out.println("Product with id " + id + " deleted");
}

public void deleteAll() {
  productRepo.deleteAll();
  System.out.println("All Products deleted.");
}

构建 Spring Boot 应用程序

默认的 Spring Boot 应用程序已经由 Spring Initializr 在根程序包（例如com.example.documentdb）中创建。在 IDE 中打开默认应用程序：

@SpringBootApplication
public class DocumentdbApplication {

  public static void main(String[] args) {
    SpringApplication.run(DocumentdbApplication.class, args);
  }
}

CommandLineRunner接口表明，当 bean 包含在SpringApplication中时应该运行，以便在控制台上查看输出。实施CommandLineRunner接口并为 run 方法提供植入方法。我们使用@Autowired注释定义对您服务的引用。Spring 使用@SpringBootApplication注释来初始化应用程序上下文：

@Override
  public void run(String... args) throws Exception {
    
    System.out.printf("%n Insert few products : %n");
    prodService.saveProducts();
    
    System.out.printf("%n Count all products : %n");
    prodService.getCount();
    
    
    System.out.printf("%n Get product by name : %n");
    prodService.getProductByName("GUCCI Handbag");
    
    System.out.printf("%n Get product by sku : %n");
    prodService.getProductBySKU("8976045");
    
    System.out.printf("%n Get all products by category : %n");
    prodService.findAllProductsByCategory("fashion");
    
    System.out.printf("%n Update Inventory for Product by sku :  %n");
    prodService.updateInventory("3451290");
    
    System.out.printf("%n Delete product id  %n");
    prodService.deleteProduct("639a0046efe46b7343dd5004"); 
    
    System.out.printf("%n Deleting all products/documents  %n");
    prodService.deleteAll(); 
  }
}

运行并测试您的应用程序

使用以下 Maven 命令运行 Spring Boot 应用程序：

Bash

mvn spring-boot:run

以下屏幕截图是 Spring Boot 应用程序的示例输出。

您做到了！ 您已成功从 Spring Boot 应用程序连接到 Amazon DocumentDB。

总结

在这篇文章中，您了解了如何通过简单的应用程序将 Amazon DocumentDB 与 Spring Boot 应用程序集成，该应用程序使用 Spring Data MongoDB 将对象保存到数据库以及从数据库中提取对象，所有这些过程都无需编写具体的存储库实施，而且配置简单。亚马逊云科技

这篇文章中使用的示例在 GitHub 上作为示例项目提供（https://github.com/aws-samples/amazon-documentdb-samples/tree/master/blogs/docdb-springboot）。

Original URL:

https://aws.amazon.com/cn/blogs/database/integrate-your-spring-boot-application-with-amazon-documentdb/

版权声明 ▶ 本文作者：panda
▶ 本文链接：https://panda995.xyz/network/4931.html
▶ 本网站的文章部分内容可能来源于网络，仅供大家学习与参考，如有侵权，请联系站长进行核实删除。
▶ 转载本站文章需要遵守：商业转载请联系站长，非商业转载请注明出处！！
0
787
分享:
0 条评论
user 编辑评论信息
插入图片
链接

隐私评论

公告

php2kWAyE.png

随机一言

:D 获取中...
文章目录

最新评论

网友小宋 好腿。
过路人一只小白菜 看着挺不错的，这耳机 😂
H 名称：H Blog描述：分享NAS教程、Dokcer Compose链接: https://www.huanhq.com/图标: https://www.huanhq.com/upload/favicon.png已添加贵站友链，请多多指教
Kevin's Space 首次来访~~留下评论
Kevin's Space free？么

随机文章

时代的眼泪，用NAS搭建Discuz X2论坛引擎，找找失去的记忆 807 浏览 - 2023/10/03
告别噪音，拥抱宁静！索尼WF-1000XM5，你的舒适降噪新选择！ 440 浏览 - 2024/05/23
有感而发！国产厂商正在将NAS送入千家万户，深度体验绿联DX4600 1331 浏览 - 2023/04/15
我发现人越到中年越喜欢极简风，用docker部署了一个极简导航页 892 浏览 - 2023/09/26
《邪恶冥刻》：真正的互动式艺术 1743 浏览 - 2021/09/30

微信公众号

php2kWAyE.png