Este projeto contém uma implementação baseada em Java para a Rinha de backend do 2024/Q1.
Leandro Luque @LinkedIn
Repositório @GitHub
As seguintes tecnologias foram utilizadas no projeto:
Nginxcomo balanceador de carga;Java 21como linguagem de programação;Gradlecomo ferramenta para a compilação e execução do projeto;Micronautcomo framework para a criação de APIs REST;Nettycomo servidor web;GraalVMcomo ferramenta para a compilação do projeto para nativo;PostgreSQLcomo banco de dados.Rediscomo cache.
O diagrama de sequências da UML apresentado a seguir (gerado com PlantUML) ilustra o fluxo geral da arquitetura da solução.
┌─┐
║"│
└┬┘
┌┼┐
│ ┌─────┐ ┌──────────┐ ┌──────────┐ ┌──────────┐
┌┴┐ │Nginx│ │Java API 1│ │Java API 2│ │PostgreSQL│
Cliente └──┬──┘ └────┬─────┘ └────┬─────┘ └────┬─────┘
┌┴┐POST /clientes/[id]/transacoes┌┴┐ │ │ │
│ │ ────────────────────────────>│ │ │ │ │
│ │ │ │ │ │ │
│ │ │ │ │ │ │
│ │ ╔══════╤════╪═╪═════════════════╪═════════════════════╪═════════════════════╪═══════════════╗
│ │ ║ ALT │ "Se API 1 usando estratégia Round Robin" │ │ ║
│ │ ╟──────┘ │ │ │ │ │ ║
│ │ ║ │ │ Send request ┌┴┐ │ │ ║
│ │ ║ │ │ ──────────────> │ │ │ │ ║
│ │ ║ │ │ │ │ │ │ ║
│ │ ║ │ │ │ │ Get data ┌┴┐ ║
│ │ ║ │ │ │ │ ───────────────────────────────────────>│ │ ║
│ │ ║ │ │ │ │ │ └┬┘ ║
│ │ ║ │ │ │ │ │ │ ║
│ │ ║ │ │ │ │ <─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ║
│ │ ║ │ │ └┬┘ │ │ ║
│ │ ║ │ │ │ │ │ ║
│ │ ║ │ │ <─ ─ ─ ─ ─ ─ ─ ─ │ │ ║
│ │ ╠═══════════╪═╪═════════════════╪═════════════════════╪═════════════════════╪═══════════════╣
│ │ ║ ["Se API 2 usando estratégia Round Robin"] │ │ ║
│ │ ║ │ │ Send request ┌┴┐ │ ║
│ │ ║ │ │ ────────────────────────────────────> │ │ │ ║
│ │ ║ │ │ │ │ │ │ ║
│ │ ║ │ │ │ │ │ Get data ┌┴┐ ║
│ │ ║ │ │ │ │ │ ─────────────────>│ │ ║
│ │ ║ │ │ │ │ │ └┬┘ ║
│ │ ║ │ │ │ │ │ │ ║
│ │ ║ │ │ │ │ │ <─ ─ ─ ─ ─ ─ ─ ─ ─ ║
│ │ ║ │ │ │ └┬┘ │ ║
│ │ ║ │ │ │ │ │ ║
│ │ ║ │ │ <─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ │ ║
│ │ ╚═══════════╪═╪═════════════════╪═════════════════════╪═════════════════════╪═══════════════╝
Cl└┬┘te ┌─│ │─┐ ┌────┴─────┐ ┌────┴─────┐ ┌────┴─────┐
┌─┐ │N│ │x│ │Java API 1│ │Java API 2│ │PostgreSQL│
║"│ └─│ │─┘ └──────────┘ └──────────┘ └──────────┘
└┬┘ │ │
┌┼┐ │ │
│ │ │
┌┴┐ │ │
└┬┘
@startuml
autoactivate on
actor "Cliente" as client
participant "Nginx" as loadBalancer
participant "Java API 1" as api1
participant "Java API 2" as api2
participant "PostgreSQL" as db
activate client
client ->loadBalancer : POST /clientes/[id]/transacoes
alt "Se API 1 usando estratégia Round Robin"
loadBalancer -> api1 : Send request
api1 -> db : Get data
api1 <-- db :
loadBalancer <-- api1 :
else "Se API 2 usando estratégia Round Robin"
loadBalancer -> api2 : Send request
api2 -> db : Get data
api2 <-- db :
loadBalancer <-- api2 :
end
deactivate client
@endumlA API Java foi organizada nos seguintes pacotes:
br.com.leandroluque.rinha/
├── Executar.class
├── negocio/
│ ├── servico/
│ │ └── ContaServico.class
│ ├── repositorio/
│ │ ├── dto/
│ │ │ ├── RespostaAtualizacaoSaldo.class
│ │ │ ├── RespostaTransacao.class
│ │ │ └── StatusTransacao.class
│ │ └── Contas.class
│ └── dominio/
│ ├── Conta.class
│ └── Transacao.class
└── adaptador/
└── micronaut/
├── web/
│ ├── dto/
│ │ ├── RealizarTransacaoReq.class
│ │ └── GerarExtratoRes.class
│ └── ContaControladora.class
└── negocio/
├── servico/
│ └── ContaServicoMicronaut.class
└── repositorio/
├── ContasMicronaut.class
├── ContaCache.class
└── ContaRepositorioR2DBC.class
Existem dois pacotes principais: negocio e adaptador. O primeiro contém as classes de domínio e interfaces de serviço/repositório, enquanto o segundo contém a implementação destas interfaces, bem como uma API web implementada com Micronaut.
Optou-se por não utilizar uma arquitetura com muitas classes para não aumentar desnecessariamente o uso de memória do projeto.
@startuml
namespace negocio #DDDDDD {
class "Conta" << record >> {
- idCliente:long
- limiteEmCentavos:long
- saldoInicialEmCentavos:long
- saldoAtualEmCentavos:long
}
class "Transacao" << record >> {
- idCliente:long
- realizadaEm:Instant
- tipo:String
- valorEmCentavos:long
- descricao:String
}
interface Contas << interface >> {
+ obterContaPorIdCliente(long idCliente):Mono<Conta>
+ obterContaPorIdClienteEBloquearParaAtualizacao(idCliente:long):Mono<Conta>
+ atualizar(conta:Conta):Mono<Long>
+ obterTransacoesDaContaParaExtrato(idCliente:long):Flux<Transacao>
+ realizarTransacao(idCliente:long, tipo:String, valorEmCentavos:long, descricao:String):Mono<Long>
}
interface "ContaServico" {
+ obterContaParaGeracaoExtrato(idCliente:long):Mono<Conta>
+ realizarTransacao(idCliente:long, tipo:String, valorEmCentavos:long, descricao:String):Mono<StatusTransacao>
}
class "StatusTransacao" << (R,orchid) record >> {
}
class "RespostaTransacao" << (R,orchid) record >> {
}
}
"Conta" "1" *-- "0..*" "Transacao"
class "ContasMicronaut" << (A,orchid) >> {
}
class "ContaRepositorioR2DBC" {
+ findByIdCliente(idCliente:long):Mono<Conta>
+ obterContaPorIdClienteEBloquearParaAtualizacao(idCliente:long):Mono<Conta>
+ update(conta:Conta):Mono<Long>
+ obterTransacoesDaContaParaExtrato(idCliente:long):Flux<Transacao>
+ realizarTransacao(idCliente:long, tipo:String, valorEmCentavos:long, descricao:String):Mono<Long>
}
Contas <|-- "ContasMicronaut"
"ContasMicronaut" "1" -- "ContaRepositorioR2DBC"
Contas ..> "Conta"
Contas ..> "Transacao"
class "ContaServicoMicronaut" {
}
"ContaServico" <|-- "ContaServicoMicronaut"
"ContaServico" ..> "Conta"
"ContaServico" ..> "StatusTransacao"
"StatusTransacao" "1" -- "RespostaTransacao"
"ContaControladora" "1" -- "ContaServico"
ContaControladora ..> "StatusTransacao"
ContaControladora ..> "GerarExtratoRes"
ContaControladora ..> "RealizarTransacaoReq"
@enduml