Tutorial: Integração com o Spring Boot

Verifique os pré-requisitos

Antes de iniciar este tutorial, verifique se você tem os seguintes componentes preparados:

• Conta do MongoDB Atlas com um cluster configurado. Para saber como criar um cluster, consulte o guia de Introdução ao MongoDB .

• curl.

• Java 21 ou posterior.

• Maven. 3 5 ou posterior.

Baixe o aplicação de exemplo

Clone o aplicação de exemplo do repositório do MongoDB Developer GitHub executando o seguinte comando:

git clone git@github.com:mongodb-developer/mdb-spring-boot-reactive.git

Este repositório contém um aplicação reativo Spring Boot que usa o Spring Data MongoDB para interagir com um banco de dados MongoDB .

Configurar sua conexão MongoDB

Navegue até o arquivo src/main/resources/application.properties no diretório do aplicação de exemplo . Neste arquivo, defina a propriedade spring.data.mongodb.uri para seu URI de conexão do Atlas , conforme mostrado no código a seguir:

spring.data.mongodb.uri=<connection URI>

Substitua o espaço reservado <connection URI> pelo URI de conexão do Atlas .

Habilitar validação de esquema

No diretório raiz, execute o seguinte comando para configurar a validação de esquema para seu aplicação:

mongosh "<connection URI>" --file setup.js

Este comando cria uma restrição que garante que o saldo da conta bancária nunca fique abaixo de 0. Substitua o espaço reservado <connection URI> pelo URI de conexão do Atlas .

Revise os endpoints de gerenciamento de contas

O arquivo AccountController.java contém endpoints da API REST para criar e buscar contas. O arquivo define um endpoint de método POST que insere um documento na coleção txn-demo.accounts e um endpoint de método GET que encontra um documento com base em seu valor de accountNum. O seguinte código mostra estes métodos:

@RestController
public class AccountController {
   //...
   @PostMapping("/account")
   public Mono<Account> createAccount(@RequestBody Account account) {
       return accountRepository.save(account);
   }
   @GetMapping("/account/{accountNum}")
   public Mono<Account> getAccount(@PathVariable String accountNum) {
       return accountRepository.findByAccountNum(accountNum)
           .switchIfEmpty(Mono.error(new AccountNotFoundException()));
   }
   //...
}

Cada endpoint retorna um tipo Mono<Account> de AccountRepository, uma interface ReactiveMongoRepository que atua como uma abstração do driver Java Reactive Streams subjacente.

Revise os endpoints da transação de saldo

A classe AccountController também inclui os seguintes endpoints de transação:

• Um endpoint .../debit que adiciona ao saldo de uma conta

• Um endpoint .../credit que subtrai de um saldo de conta

• Um endpoint .../transfer que executa uma transferência de uma conta para outra

Esses endpoints têm as seguintes definições:

@RestController
public class AccountController {
   //...
   @PostMapping("/account/{accountNum}/debit")
   public Mono<Txn> debitAccount(@PathVariable String accountNum,
                                 @RequestBody Map<String, Object> requestBody) {
       //...
       txn.addEntry(new TxnEntry(accountNum, amount));
       return txnService.saveTransaction(txn).flatMap(txnService::executeTxn);
   }
   @PostMapping("/account/{accountNum}/credit")
   public Mono<Txn> creditAccount(@PathVariable String accountNum,
                                  @RequestBody Map<String, Object> requestBody) {
       //...
       txn.addEntry(new TxnEntry(accountNum, -amount));
       return txnService.saveTransaction(txn).flatMap(txnService::executeTxn);
   }
   @PostMapping("/account/{from}/transfer")
   public Mono<Txn> transfer(@PathVariable String from,
                             @RequestBody TransferRequest transferRequest) {
       //...
       txn.addEntry(new TxnEntry(from, -amount));
       txn.addEntry(new TxnEntry(to, amount));
       return txnService.saveTransaction(txn).flatMap(txnService::executeTxn);
   }
   //...
}

Um objeto TxnEntry representa uma alteração em uma única conta, e um Txn pode consistir em um ou vários objetos TxnEntry. No código de amostra, os endpoints de crédito e crédito criam um novo objeto TxnEntry, e o endpoint de transferência cria dois objetos TxnEntry.

Revise os métodos de query personalizada

A interface do AccountRepository estende o ReactiveMongoRepository e define os seguintes métodos de query:

public interface AccountRepository extends ReactiveMongoRepository<Account, String> {
   @Query("{accountNum:'?0'}")
   Mono<Account> findByAccountNum(String accountNum);
   @Update("{'$inc':{'balance': ?1}}")
   Mono<Long> findAndIncrementBalanceByAccountNum(String accountNum, double increment);
}

Os códigos usam as seguintes anotações que permitem usar espaços reservados ao executar query do MongoDB, que são dinamicamente substituídos por argumentos do método:

• @Query: Anota o método findByAccountNum() e especifica os critérios de query para localizar documentos. O espaço reservado ?0 é substituído pelo valor de parâmetro accountNum .

• @Update: anota o método findAndIncrementBalanceByAccountNum() e especifica a operação de atualização a ser executada nos documentos correspondentes. O espaço reservado ?1 é substituído pelo valor do parâmetro increment para aumentar o equilíbrio usando o operador $inc do MongoDB.

Entender o serviço de transações

A classe TxnService lida com a execução da transação. Esta classe inclui o seguinte código:

@Service
public class TxnService {
   //...
   public Mono<Txn> saveTransaction(Txn txn) {
       return txnTemplate.save(txn);
   }
   public Mono<Txn> executeTxn(Txn txn) {
       return updateBalances(txn)
           .onErrorResume(DataIntegrityViolationException.class
               /*lambda expression to handle error*/)
           .onErrorResume(AccountNotFoundException.class
               /*lambda expression to handle error*/)
           .then(txnTemplate.findAndUpdateStatusById(txn.getId(), TxnStatus.SUCCESS));
   }
   public Flux<Long> updateBalances(Txn txn) {
       Flux<Long> updatedCounts = Flux.fromIterable(txn.getEntries()).concatMap(
           entry -> accountRepository.findAndIncrementBalanceByAccountNum(
               entry.getAccountNum(), entry.getAmount())
       );
       return updatedCounts.handle(/*...*/);
   }
}

A classe TxnService inclui os seguintes métodos:

• saveTransaction(): salva um documento Txn na coleção transactions

• executeTxn(): chama o método updateBalances() e atualiza o status da transação no documento Txn

• updateBalances(): Itera por cada TxnEntry e faz as atualizações correspondentes a cada documento account

Revise o modelo de transação

Os métodos saveTransaction() e executeTxn() descritos na etapa anterior usam métodos definidos na classe TxnTemplate . Esses métodos têm as seguintes definições:

@Service
public class TxnTemplate {
   //...
   public Mono<Txn> save(Txn txn) {
       return template.save(txn);
   }
   public Mono<Txn> findAndUpdateStatusById(String id, TxnStatus status) {
      Query query = query(where("_id").is(id));
      Update update = update("status", status);
      FindAndModifyOptions options = FindAndModifyOptions.options().returnNew(true);
      return template.findAndModify(query, update, options, Txn.class);
   }
   //...
}

Estes métodos interagem com MongoDB utilizando o ReactiveMongoTemplate.

Configurar transações multidocumento

Ao transferir dinheiro entre contas, você pode usar uma transação com vários documentos. As atualizações em duas contas devem ser atômicas, e as transações garantem a atomicidade dos dados.

Para acessar o suporte a transações do Spring, o aplicação de amostra adiciona o ReactiveMongoTransactionManager bean ao arquivo ReactiveMongoConfig.java:

@Configuration
public class ReactiveMongoConfig extends AbstractReactiveMongoConfiguration {
   //...
   @Bean
   ReactiveMongoTransactionManager transactionManager(ReactiveMongoDatabaseFactory dbFactory) {
       return new ReactiveMongoTransactionManager(dbFactory);
   }
}

Você pode definir o escopo de uma transação usando um objeto TransactionalOperator ou a anotação @Transactional. A classe TxnService mostra ambas as abordagens.

Execute o aplicativo

Para iniciar o aplicação, execute os seguintes comandos no diretório raiz do projeto:

mvn spring-boot:run

Após iniciar o aplicação, você pode acessá-lo em http://localhost:8080. Em seguida, você pode usar os endpoints da API REST para criar contas e executar transações.

Criar uma conta

Para criar uma nova conta bancária que tenha um número de conta de 12345, execute o seguinte comando na sua shell:

curl --location 'localhost:8080/account' \
--header 'Content-Type: application/json' \
--data '{
   "accountNum": "12345"
}'

Este comando envia uma solicitação POST para o endpoint /account para criar um novo documento de conta bancária na coleção accounts.

Aumente o saldo da sua conta

Para devolver o valor à conta criada na etapa anterior, execute o seguinte comando em seu shell:

curl --location 'localhost:8080/account/12345/debit' \
--header 'Content-Type: application/json' \
--data '{
   "amount": 1000
}'

Este comando envia uma solicitação ao endpoint .../debit para aumentar o valor amount do documento account correspondente em 1000.

Transferir dinheiro entre contas

Para transferir dinheiro de uma conta para outra, crie uma nova conta que tenha um número de conta de 67890:

curl --location 'localhost:8080/account' \
--header 'Content-Type: application/json' \
--data '{
   "accountNum": "67890"
}'

Em seguida, transfira 500 dólares para esta nova conta executando o seguinte comando:

curl --location 'localhost:8080/account/12345/transfer' \
--header 'Content-Type: application/json' \
--data '{
   "to": "67890",
   "amount": 500
}'

Este comando envia uma solicitação para o endpoint .../transfer para concluir a transferência de saldo.