Tutorial: Implementar fragmentação na inicialização da Spring usando dados da Spring

Verifique os pré-requisitos

Antes de começar, verifique se você tem o seguinte:

• Uma conta MongoDB. Você precisa de um cluster M30 ou superior para habilitar a fragmentação.

• Java 17 ou posterior

• Maven versão 3.9.6 ou posterior

• Um projeto Spring Boot com dependências do Spring Data MongoDB e do Spring Web. Você pode criar um projeto usando Spring Initializr.

• MongoDB Shell

Configurar um cluster fragmentado no MongoDB Atlas

Para criar um cluster fragmentado, execute as seguintes ações:

1. Nas configurações de cluster do seu cluster M30 ou superior, navegue até Additional Settings.

2. Selecione Sharding e ative-o.

3. Defina o número de fragmentos a serem implantados. Para aplicativos de produção, use mais de um fragmento. Você pode implantar entre 1 e 70 fragmentos. Para saber mais, consulte Implantar um cluster fragmentado na documentação do Atlas.

4. Após criar o cluster fragmentado , selecione Load Sample Dataset para carregar os dados de amostra.

Configurar fragmentação para uma coleção

O Spring Data MongoDB não configura automaticamente a fragmentação para coleções. Você deve executar estas operações manualmente usando mongosh.

Para se conectar ao cluster e configurar a fragmentação, execute o seguinte comando no terminal:

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

Substitua os placeholders <username>, <password> e <cluster-url> pelas suas credenciais do MongoDB Atlas e string de conexão.

Para fragmentar a coleção users pelo campo email , execute o seguinte comando:

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

Para verificar se a fragmentação está habilitada e a coleção está fragmentado, executar o seguinte comando:

sh.status()

Implementar o aplicativo Spring Boot

Para implementar o aplicativo Spring Boot, você deve definir as camadas de entidade, repositório, serviço e controlador.

1. Para definir uma classe de entidade com fragmentação, use a anotação @Sharded para especificar os campos da chave de fragmento. O código a seguir mostra um exemplo de entidade User com o campo email como a chave de fragmento:

   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
   }

   A anotação @Sharded ajuda o Spring Data MongoDB a otimizar as operações em um ambiente fragmentado. Ele garante que as queries do replaceOne incluam a chave de fragmento durante os upserts.

2. Para criar um repositório para a entidade User, defina uma interface que se estenda MongoRepository. O seguinte código mostra um exemplo de interface UserRepository:

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

3. Para lidar com a lógica de negócios, crie uma classe de serviço que interaja com o repositório. O código a seguir mostra um exemplo da classe 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. Para expor pontos de extremidade REST para a entidade User, crie uma classe de controlador. O código a seguir mostra um exemplo da classe 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);
       }
   }

Configurar o aplicativo Spring Boot

Para conectar seu aplicativo Spring Boot ao MongoDB Atlas, adicione o URI de conexão do MongoDB ao seu arquivo application.properties ou application.yml. O seguinte código mostra um exemplo de configuração:

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

Substitua os placeholders <username>, <password> e <cluster-url> pelas suas credenciais do MongoDB Atlas e string de conexão.