Algunas palabras sobre R2DBC y PostgreSQL

• La programación reactiva es más difícil de depurar.
• El desarrollo de sistemas reactivos es más difícil que los clásicos, bloqueantes; Si bloquea el hilo involuntariamente, habrá terminado. Por eso apareció el proyecto (uno de los autores -Bsideup )
• La programación reactiva, y en particular la elasticidad, se necesita principalmente a altas cargas a la Netflix. Si tiene 100 RPS, probablemente debería escribir código en un estilo de bloqueo: es más barato y más fácil

1. https://github.com/jasync-sql/jasync-sql - controlador asíncrono para PostgreSQL, escrito en Kotlin, donde Netty es el transporte
2. La solución que utiliza Vert.x es https://github.com/mauricio/postgresql-async . Es de destacar que el proyecto está archivado, y el controlador jasync-sql anterior reescribe de la misma manera (sin embargo, el original está escrito en Scala y la nueva solución en Kotlin).
   Actualizar Me corrigieron los comentarios, el cliente de Vert.x está vivo y se siente bien en los puntos de referencia .
   
3. El controlador del equipo de Spring es https://github.com/r2dbc/r2dbc-postgresql . Este controlador proporciona inmediatamente una API reactiva (y no asíncrona), y Netty se usa para el transporte, como en 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);
    }
}