1024程序员节特辑 | Spring Boot实战 之 MongoDB分片或复制集操作

news2024/11/26 13:51:30

Spring实战系列文章：

Spring实战 | Spring AOP核心秘笈之葵花宝典

Spring实战 | Spring IOC不能说的秘密？

国庆中秋特辑系列文章：

国庆中秋特辑（八）Spring Boot项目如何使用JPA

国庆中秋特辑（七）Java软件工程师常见20道编程面试题

国庆中秋特辑（六）大学生常见30道宝藏编程面试题

国庆中秋特辑（五）MySQL如何性能调优？下篇

国庆中秋特辑（四）MySQL如何性能调优？上篇

国庆中秋特辑（三）使用生成对抗网络（GAN）生成具有节日氛围的画作，深度学习框架 TensorFlow 和 Keras 来实现

国庆中秋特辑（二）浪漫祝福方式 使用生成对抗网络（GAN）生成具有节日氛围的画作

国庆中秋特辑（一）浪漫祝福方式 用循环神经网络（RNN）或长短时记忆网络（LSTM）生成祝福诗词

目录

  • 1. Spring Boot 项目整合 MongoDB 可以通过以下步骤完成：
  • 2、对 MongoDB 进行分片或复制集操作

在这里插入图片描述

1. Spring Boot 项目整合 MongoDB 可以通过以下步骤完成：

  1. 添加依赖
    在项目的 pom.xml 文件中添加 MongoDB 驱动和 Spring Data MongoDB 的依赖，如下：
<dependencies>  
   <!-- MongoDB 驱动 -->  
   <dependency>  
       <groupId>org.mongodb</groupId>  
       <artifactId>mongodb-driver-sync</artifactId>  
       <version>4.4.0</version>  
   </dependency>  
   <!-- Spring Data MongoDB -->  
   <dependency>  
       <groupId>org.springframework.boot</groupId>  
       <artifactId>spring-boot-starter-data-mongodb</artifactId>  
       <version>2.6.2</version>  
   </dependency>  
</dependencies>
  1. 配置 MongoDB 连接
    在 application.properties 文件中配置 MongoDB 的连接信息，如下：
spring.data.mongodb.uri=mongodb://username:password@localhost:27017/myDatabase
  1. 创建实体类
    创建一个实体类，并使用注解来定义文档结构和映射关系。例如：
import org.springframework.data.annotation.Id;  
import org.springframework.data.mongodb.core.mapping.Document;
@Document(collection = "users")  
public class User {  
   @Id  
   private String id;  
   private String name;  
   private int age;
   // Getters and setters  
}
  1. 创建 Repository 接口
    创建一个继承自 JpaRepository 的接口，并为其添加方法。例如：
import org.springframework.data.repository.CrudRepository;  
import org.springframework.stereotype.Repository;
@Repository  
public interface UserRepository extends CrudRepository<User, String> {  
}
  1. 在 Service 层使用 Repository
    在 Service 层，注入 UserRepository 并使用它来进行 CRUD 操作。例如：
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Service;
@Service  
public class UserService {  
   @Autowired  
   private UserRepository userRepository;
   public User save(User user) {  
       return userRepository.save(user);  
   }
   public User findById(String id) {  
       return userRepository.findById(id).orElse(null);  
   }
   // 其他 CRUD 方法  
}
  1. 在 Controller 层处理 HTTP 请求
    在 Controller 层，注入 UserService 并处理 HTTP 请求。例如：
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.web.bind.annotation.GetMapping;  
import org.springframework.web.bind.annotation.PostMapping;  
import org.springframework.web.bind.annotation.RequestBody;  
import org.springframework.web.bind.annotation.RequestMapping;  
import org.springframework.web.bind.annotation.RestController;
@RestController  
@RequestMapping("/users")  
public class UserController {  
   @Autowired  
   private UserService userService;
   @PostMapping  
   public User save(@RequestBody User user) {  
       return userService.save(user);  
   }
   @GetMapping("/{id}")  
   public User findById(@PathVariable String id) {  
       return userService.findById(id);  
   }  
}

注意事项：

  1. 请确保 MongoDB 服务已经启动并正确配置。
  2. 实体类中的属性要与 MongoDB 数据库中的字段对应。
  3. 如果需要对 MongoDB 进行分片或者复制集操作，请参考 Spring Data MongoDB 的官方文档。
    通过以上步骤，一个简单的 Spring Boot 项目就完成了与 MongoDB 的整合。在实际项目中，还可以根据需求添加更多的配置和操作方法。

在这里插入图片描述

2、对 MongoDB 进行分片或复制集操作

在 Spring Boot 项目中，对 MongoDB 进行分片或复制集操作，主要依赖 spring-data-mongodb 库提供的扩展点。

  1. 分片（Sharding）：
    分片是将数据库的集合（Collection）分散在多个数据库服务器上，以提高查询性能和扩展性。在 Spring Boot 项目中，可以通过以下方式对 MongoDB 进行分片操作：
  • 在application.properties或application.yml中配置分片信息，例如：
spring.data.mongodb.shard-strategy=org.springframework.data.mongodb.core.shard.BackwardCompatibleShardingStrategy  
spring.data.mongodb.target-db-config.default.mongo-uri=mongodb://localhost:27017/mydb  
spring.data.mongodb.target-db-config.default.database=mydb  
spring.data.mongodb.target-db-config.shard-targets={\"ds\"=>0,\"target\"=>\"mydb_${0..199}\"}
  • 创建一个@Configuration类，用于配置分片策略和数据库实例：
@Configuration  
public class MongoDBConfiguration {  
    @Bean  
    public ShardingDataSource shardingDataSource() {  
        // 创建一个分片数据源  
        // ...  
    }
    @Bean  
    public MongoDatabaseFactory mongoDatabaseFactory() {  
        // 创建一个 MongoDatabaseFactory 实例  
        // ...  
    }  
}
  • 在需要进行分片操作的地方，使用@MongoRepository或@MongoUnitOfWork注解：
@Service  
public class MyService {  
    @MongoRepository  
    public MyCollectionRepository myCollectionRepository() {  
        // 创建一个分片集合的仓库  
        // ...  
    }  
}
  1. 复制集（Replica Set）：
    复制集是由多个 MongoDB 实例组成的集合，可以提供数据备份和读写分离。在 Spring Boot 项目中，可以通过以下方式对 MongoDB 进行复制集操作：
  • 在application.properties或application.yml中配置复制集信息，例如：
spring.data.mongodb.replica-set=myReplicaSet  
spring.data.mongodb.host=mongodb://localhost:27017  
spring.data.mongodb.port=27017  
spring.data.mongodb.authentication-database=admin  
spring.data.mongodb.database=mydb
  • 创建一个@Configuration类，用于配置复制集实例：
@Configuration  
public class MongoDBConfiguration {  
    @Bean  
    public MongoClient mongoClient() {  
        // 创建一个 MongoClient 实例  
        // ...  
    }  
}
  • 在需要进行复制集操作的地方，使用@MongoRepository或@MongoUnitOfWork注解：
@Service  
public class MyService {  
    @MongoRepository  
    public MyCollectionRepository myCollectionRepository() {  
        // 创建一个复制集集合的仓库  
        // ...  
    }  
}

需要注意的是，以上操作均需要引入 spring-data-mongodb 依赖。在 pom.xml 中添加以下依赖：

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

并且确保 JDK 版本高于 1.8，以支持分片和复制集功能。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1101062.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

8.19PMP考试成绩已出！（附查询流程）

8.19PMP考试成绩已出！（附查询流程）

之前胖圆给大家分享过&#xff0c;10月16号PMI官网将发布8.19的PMP考试成绩&#xff0c;这两天已经有学员陆陆续续收到考试通过的邮件&#xff0c;还没有收到成绩通知的学员耐心等待&#xff0c;相信努力备考的学员一定都能够顺利通过~ 还没查成绩的宝子们&#xff0c;下面是成…
阅读更多...
英飞凌助攻马自达最新增程序电动车接入富田电机七合一驱动系统 | 百能云芯

英飞凌助攻马自达最新增程序电动车接入富田电机七合一驱动系统 | 百能云芯

在面对气候变迁的挑战下&#xff0c;全球汽车产业正积极迈向电气化转型&#xff0c;这一趋势也为台企厂商带来了巨大的商机&#xff0c;莫不积极发展布局电动车市场。全球半导体领导厂商英飞凌科技股份有限公司凭借其全面性的车用系统解决方案&#xff0c;助力富田电机股份有限…
阅读更多...
通过商品链接查询天猫商品详情数据，可以拿到商品标题，商品价格，商品库存，商品销量，商品sku数据等，天猫API接口

通过商品链接查询天猫商品详情数据，可以拿到商品标题，商品价格，商品库存，商品销量，商品sku数据等，天猫API接口

要通过商品链接查询天猫商品详情数据&#xff0c;可以使用淘宝开放平台的接口查询商品详情。具体步骤如下&#xff1a; 注册并获取App Key和App Secret。使用淘宝开放平台的淘宝客商品详情查询接口&#xff08;taobao.tbk.item.info.get&#xff09;&#xff0c;传入商品链接&…
阅读更多...
Chrome使用本地修改过的js替换原js内容

Chrome使用本地修改过的js替换原js内容

步骤 1.进入开发人员工具&#xff1a;按F12 或 按ctrlshitfi 或 菜单“更多工具”->“开发人员工具” 2.在“源代码/来源”页面找到需要更改的js文件&#xff0c;“右键”->“替换内容” 3.在弹出的标签点击“选择文件夹”来选择一个存放内容的本地文件夹 4.弹出的询问标…
阅读更多...
塑料为什么需要透光率检测？

塑料为什么需要透光率检测？

塑料透光率是指塑料材料对光线的透明程度&#xff0c;是衡量其光学性能的重要指标之一。在实际应用中&#xff0c;塑料透光率的高低对于不同领域具有不同的意义。进行塑料检测可以确保塑料制品的质量和安全性能&#xff0c;对于塑料制造行业来说具有至关重要的意义。 1.建筑领域…
阅读更多...
中国医疗器械在“一带一路”国家贸易状况及贡献度分析

中国医疗器械在“一带一路”国家贸易状况及贡献度分析

完整下载链接&#xff01;https://mp.weixin.qq.com/s?__bizMzU2OTc4ODA4OA&mid2247548624&idx1&snebe429303ee354e94d3a39ba9df76973&chksmfcfb2d07cb8ca41126a40ff04628dc2edc278e9514984d713e0e9edf6113655ac23c2fb56db5&token87782696&langzh_CN#…
阅读更多...
LDAP用户密码自服务平台搭建

LDAP用户密码自服务平台搭建

源码地址&#xff1a;https://github.com/ltb-project/self-service-password 官方文档 &#xff1a;https://self-service-password.readthedocs.io/en/latest/ 1.创建配置文件 mkdir -p /opt/ssp cd /opt/ssp vim ssp.conf.php2.在ssp.conf.php其中输入如下配置选项&#…
阅读更多...
【17.19消失的两个数字】

【17.19消失的两个数字】

目录 一、题目描述二、算法原理三、代码实现 一、题目描述 二、算法原理 三、代码实现 class Solution { public:vector<int> missingTwo(vector<int>& nums) {//找到a^bint temp0;for(auto num:nums){temp^num;}for(int i1;i<nums.size()2;i){temp^i;}//找…
阅读更多...
OCP Java17 SE Developers 复习题06

OCP Java17 SE Developers 复习题06

答案 答案 E. Options A and B will not compile because constructors cannot be called without new. Options C and D will compile but will create a new object rather than setting the fields in this one. The result is the program will print 0, not 2, at run…
阅读更多...
E114-经典赛题-操作系统服务端口扫描渗透测试

E114-经典赛题-操作系统服务端口扫描渗透测试

任务实施: E114-经典赛题-操作系统服务端口扫描渗透测试 任务环境说明&#xff1a; 服务器场景&#xff1a;p9_bt5-1&#xff08;用户名&#xff1a;root&#xff1b;密码&#xff1a;toor&#xff09; 服务器场景操作系统&#xff1a;Back Track five 192.168.1.120 服务…
阅读更多...
【LeetCode刷题（数据结构与算法）】：验证二叉树的前序序列化

【LeetCode刷题（数据结构与算法）】：验证二叉树的前序序列化

序列化二叉树的一种方法是使用 前序遍历 。当我们遇到一个非空节点时&#xff0c;我们可以记录下这个节点的值。如果它是一个空节点&#xff0c;我们可以使用一个标记值记录&#xff0c;例如 # 例如&#xff0c;上面的二叉树可以被序列化为字符串 “9,3,4,#,#,1,#,#,2,#,6,#,#…
阅读更多...
Eclipse使用教程

Eclipse使用教程

一、前期准备 JDK环境变量得配置好&#xff08;java需要先安装好&#xff09; 【下载Eclipse解压包&#xff0c;可选择去Eclipse官网下载】 Eclipse的安装方式&#xff1a; 下载后解压直接点击进入选择工作区间就可运行 二、Eclipse基本概述&#xff1a; 工作区&#xff08;w…
阅读更多...
2023年全国职业院校技能大赛软件测试赛题第10套

2023年全国职业院校技能大赛软件测试赛题第10套

2023年全国职业院校技能大赛 软件测试赛题第10套 目录 任务一 环境搭建及系统部署 任务二 单元测试 任务三 测试文档 任务四 功能测试 任务五 自动化测试 任务六 性能测试 任务七 接口测试 有问题可私信我 赛项名称&#xff1a; 软件测试 英文名称&…
阅读更多...
LockSupport-park和unpark编码实战

LockSupport-park和unpark编码实战

package com.nanjing.gulimall.zhouyimo.test;import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.LockSupport;/*** author zhou* version 1.0* date 2023/10/16 9:11 下午*/ public class LockSupportDemo {public static void main(String[] args) {…
阅读更多...
ZC-CLS381RGB颜色识别+8x8点阵指示——WS2812点阵驱动（中）

ZC-CLS381RGB颜色识别+8x8点阵指示——WS2812点阵驱动（中）

文章目录 前言一、WS2812简介二、WS2812配置说明三、波形图绘制1.配置模块2.控制模块 总结 前言 RGB888点阵是一个由64个WS2812 RGB LED灯珠组成的点阵显示屏&#xff0c;可以用于艺术装饰、玩具和游戏、时钟计时器和状态指示器等各种场景。   本文将向各位读者展示&#xff…
阅读更多...
漏洞复现--安恒明御安全网关文件上传

漏洞复现--安恒明御安全网关文件上传

免责声明&#xff1a; 文章中涉及的漏洞均已修复&#xff0c;敏感信息均已做打码处理&#xff0c;文章仅做经验分享用途&#xff0c;切勿当真&#xff0c;未授权的攻击属于非法行为&#xff01;文章中敏感信息均已做多层打马处理。传播、利用本文章所提供的信息而造成的任何直…
阅读更多...
思维训练1

思维训练1

题目描述2 Problem - A - Codeforces ​ 题目分析 思路一&#xff1a; 由于是连续的数&#xff0c;我们可以使用f1, f2, f3来记录连续数的开头数字&#xff0c;只可能有三种情况 ①开头数为第一个数-1 ②开头数为第一个数 ③开头数为第一个数1 分别观察这三个情况&…
阅读更多...
osWorkflow-1——osWorkflow官网例子部署启动简单使用（版本：OSWorkflow-2.8.0）

osWorkflow-1——osWorkflow官网例子部署启动简单使用（版本：OSWorkflow-2.8.0）

osWorkflow-1——osWorkflow官网例子部署启动简单使用&#xff08;版本&#xff1a;OSWorkflow-2.8.0&#xff09; 1. 前言——准备工作1.1 下载相关资料1.2 安装翻译插件 2. 开始搞项目2.1 解压 .zip文件2.2 简单小测&#xff08;war包放入tomcat&#xff09;2.3 导入项目到 I…
阅读更多...
2023年信息科学与工程学院学生科协第一次软件培训

2023年信息科学与工程学院学生科协第一次软件培训

2023年信息科学与工程学院学生科协第一次软件培训 文章目录 2023年信息科学与工程学院学生科协第一次软件培训运行第一个代码&#xff08;“Hello World&#xff01;”&#xff09;初识C语言代码的具体结构头文件(主)函数 输入与输出scanf函数printf函数转义字符 变量的定义进一…
阅读更多...
如何选择全面型企业备份软件以提高数据可用性？

如何选择全面型企业备份软件以提高数据可用性？

通常&#xff0c;备份数据是指服务器正在运行的工作负载所需的所有数据。这可以包括文档、媒体文件、配置文件、机器映像、操作系统和注册表文件。本质上&#xff0c;您想要保留的任何数据都可以存储为备份数据。 在日益数字化的商业环境中&#xff0c;数据备份对于组织的生存…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023