튜토리얼: Spring 데이터를 사용하여 Spring Boot에서 샤딩 구현하기

전제 조건 확인

시작하기 전에 다음 항목이 있는지 확인하세요.

• MongoDB 계정. 샤딩을 활성화하려면 M30 이상 클러스터가 필요합니다.

• Java 17 이상

• Maven 버전 3.9.6 이상

• Spring Data MongoDB 및 Spring 웹 종속성이 있는 Spring Boot 프로젝트 입니다. Spring Initializr를 사용하여 프로젝트 생성할 수 있습니다.

• MongoDB Shell

MongoDB Atlas 에서 샤딩된 클러스터 설정

클러스터 생성하려면 다음 조치를 수행합니다.

1. M30 이상의 클러스터 클러스터 에서 Additional Settings로 이동합니다.

2. Sharding 을(를) 선택하고 켭니다.

3. 배포 할 샤드 수를 설정합니다. 프로덕션 애플리케이션의 경우 둘 이상의 샤드 사용합니다. 1 와(과) 70 샤드 간에 배포 할 수 있습니다. 자세한 학습 은 Atlas 설명서에서 샤드 클러스터 배포 를 참조하세요.

4. 샤딩된 클러스터 생성되면 Load Sample Dataset 을 선택하여 샘플 데이터를 로드합니다.

컬렉션 에 대한 샤딩 구성

Spring Data MongoDB 컬렉션에 대한 샤딩 자동으로 구성하지 않습니다. 이러한 작업은 mongosh를 사용하여 수동으로 수행해야 합니다.

클러스터 에 연결하고 샤딩 구성하려면 터미널에서 다음 명령을 실행 .

mongosh "mongodb+srv://<username>:<password>@<cluster-url>/admin"

<username>, <password> 및 <cluster-url> 자리 표시자를 MongoDB Atlas 자격 증명 및 연결 문자열 로 바꿉니다.

email 필드 기준으로 users 컬렉션 샤드 하려면 다음 명령을 실행 .

sh.shardCollection("sample_mflix.users", { email: 1 })

샤딩 활성화되어 있고 컬렉션 이 샤딩된 있는지 확인하려면 다음 명령을 실행 .

sh.status()

Spring Boot 애플리케이션 구현

Spring Boot 애플리케이션 구현 하려면 엔터티, 리포지토리, 서비스 및 컨트롤러 계층을 정의해야 합니다.

1. 샤딩 사용하여 엔터티 클래스를 정의하려면 @Sharded 주석을 사용하여 샤드 키 필드를 지정합니다. 다음 코드는 email 필드 샤드 키 사용하는 예시 User 엔터티를 보여줍니다.

   import org.springframework.data.annotation.Id;
   import org.springframework.data.mongodb.core.mapping.Document;
   import org.springframework.data.mongodb.core.mapping.Field;
   import org.springframework.data.mongodb.core.mapping.Sharded;
   @Document("users")
   @Sharded(shardKey = { "email" })
   public class User {
       @Id
       private String id;
       private String name;
       @Field("email")
       private String email;
       private String password;
       // Getters and Setters
   }

   @Sharded 주석은 Spring Data MongoDB 샤딩된 환경에서 작업을 최적화하는 데 도움이 됩니다. replaceOne 쿼리에 업서트 중에 샤드 키 포함되도록 합니다.

2. User 엔터티에 대한 리포지토리 만들려면 MongoRepository을 확장하는 인터페이스를 정의합니다. 다음 코드는 UserRepository 인터페이스 예시 보여줍니다.

   import org.springframework.data.mongodb.repository.MongoRepository;
   import com.mongodb.sharded.model.User;
   public interface UserRepository extends MongoRepository<User, String> {
   }

3. 비즈니스 로직을 처리하다 하려면 리포지토리 와 상호 작용하는 서비스 클래스를 만듭니다. 다음 코드는 UserService 클래스 예시 보여줍니다.

   import java.util.List;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.stereotype.Service;
   import com.mongodb.sharded.model.User;
   import com.mongodb.sharded.repository.UserRepository;
   @Service
   public class UserService {
       @Autowired
       private UserRepository userRepository;
       public List<User> getAllUsers() {
           return userRepository.findAll();
       }
       public User saveUser(User user) {
           return userRepository.save(user);
       }
   }

4. User 엔터티에 대한 REST 엔드포인트를 노출하려면 컨트롤러 클래스를 만듭니다. 다음 코드는 UserController 클래스 예시 보여줍니다.

   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.web.bind.annotation.*;
   import java.util.List;
   @RestController
   @RequestMapping("/users")
   public class UserController {
       @Autowired
       private UserService userService;
       @GetMapping
       public List<User> getAllUsers() {
           return userService.getAllUsers();
       }
       @PostMapping
       public User createUser(@RequestBody User user) {
           return userService.saveUser(user);
       }
   }

Spring Boot 애플리케이션 구성

Spring Boot 애플리케이션 을 MongoDB Atlas 에 연결하려면 application.properties 또는 application.yml 파일 에 MongoDB 연결 URI를 추가합니다. 다음 코드는 예시 구성을 보여줍니다.

spring.data.mongodb.uri=mongodb+srv://<username>:<password>@<cluster-url>/myDatabase?retryWrites=true&w=majority

<username>, <password> 및 <cluster-url> 자리 표시자를 MongoDB Atlas 자격 증명 및 연결 문자열 로 바꿉니다.