Ein paar Worte zu R2DBC und PostgreSQL

• Reaktive Programmierung ist schwieriger zu debuggen
• Die Entwicklung reaktiver Systeme ist schwieriger als klassische, blockierende. Wenn Sie den Thread unbeabsichtigt blockieren, sind Sie fertig. Deshalb erschien das Projekt (einer der Autoren -bsideup )
• Reaktive Programmierung und insbesondere Elastizität sind hauptsächlich bei hohen Lasten nach Netflix erforderlich. Wenn Sie 100 RPS haben, sollten Sie wahrscheinlich Code in einem blockierenden Stil schreiben - es ist billiger und einfacher

1. https://github.com/jasync-sql/jasync-sql - asynchroner Treiber für PostgreSQL, geschrieben in Kotlin, wo Netty der Transport ist
2. Die von Vert.x verwendete Lösung lautet https://github.com/mauricio/postgresql-async . Es ist bemerkenswert, dass das Projekt archiviert wird und der vorherige jasync-sql-Treiber trotzdem neu geschrieben wird (das Original ist jedoch in Scala und die neue Lösung in Kotlin geschrieben).
   Aktualisieren Ich wurde in den Kommentaren korrigiert, der Kunde von Vert.x lebt und fühlt sich gut in Benchmarks .
   
3. Der Fahrer aus dem Spring-Team ist https://github.com/r2dbc/r2dbc-postgresql . Dieser Treiber stellt sofort eine reaktive API bereit (und nicht asynchron), und Netty wird wie in jasync-sql für den Transport verwendet.

• 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);
    }
}