Algumas palavras sobre R2DBC e PostgreSQL

• A programação reativa é mais difícil de depurar
• Desenvolver sistemas reativos é mais difícil que os clássicos, bloqueadores; se você bloquear inadvertidamente o encadeamento, estará concluído. É por isso que o projeto apareceu (um dos autores -bsideup )
• A programação reativa e, em particular, a elasticidade, são necessárias principalmente em altas cargas no Netflix. Se você possui 100 RPS, provavelmente deve escrever código em um estilo de bloqueio - é mais barato e mais fácil

1. https://github.com/jasync-sql/jasync-sql - driver assíncrono para PostgreSQL, escrito em Kotlin, onde Netty é o transporte
2. A solução usada pelo Vert.x é https://github.com/mauricio/postgresql-async . Vale ressaltar que o projeto foi arquivado e o driver jasync-sql anterior reescreve da mesma forma (no entanto, o original está escrito em Scala e a nova solução em Kotlin).
   Atualizar Fui corrigido nos comentários, o cliente do Vert.x está vivo e se sente bem nos benchmarks .
   
3. O driver da equipe do Spring é https://github.com/r2dbc/r2dbc-postgresql . Esse driver fornece imediatamente uma API reativa (e não assíncrona) e o Netty é usado para transporte, como no jasync-sql.

• https://www.postgresql.org/docs/current/libpq-async.html
• https://www.postgresql.org/docs/current/libpq-notify.html

spring.r2dbc.username=postgres
spring.r2dbc.password=P4$$W0RddD
spring.r2dbc.url=r2dbc:postgresql://localhost:5432/r2dbc
spring.r2dbc.pool.enabled=true
spring.r2dbc.pool.initial-size=10
spring.r2dbc.pool.max-idle-time=1m
spring.r2dbc.pool.max-size=30
spring.data.r2dbc.repositories.enabled=true

public class Customer {
    @Id
    private Long id;

    private String firstName;

    private String lastName;

    public Customer(String firstName, String lastName) {
        this.firstName = firstName;
        this.lastName = lastName;
    }
}

public interface CustomerRepository extends ReactiveCrudRepository<Customer, Long> {
}

@RestController
@RequestMapping("/")
public class CustomerController {

    private CustomerRepository customerRepository;

    @PostMapping("/customer")
    Mono<Void> create(@RequestBody Publisher<Customer> customerFlux) {
        return customerRepository.saveAll(customerFlux).then();
    }

    @GetMapping("/customer")
    public Flux<Customer> list() {
        return customerRepository.findAll();
    }

    @GetMapping("/customer/{id}")
    public Mono<Customer> findById(@PathVariable Long id) {
        return customerRepository.findById(id);
    }
}