Quelques mots sur R2DBC et PostgreSQL

• La programmation réactive est plus difficile à déboguer
• Le développement de systèmes réactifs est plus difficile que les systèmes classiques, bloquants; si vous bloquez involontairement le fil, vous avez terminé. C’est pourquoi le projet est apparu (l’un des auteurs -bsideup )
• Une programmation réactive, et en particulier l'élasticité, est nécessaire principalement à des charges élevées à la Netflix. Si vous avez 100 RPS, vous devriez probablement écrire du code dans un style de blocage - c'est moins cher et plus facile

1. https://github.com/jasync-sql/jasync-sql - pilote asynchrone pour PostgreSQL, écrit en Kotlin, où Netty est le transport
2. La solution utilisée par Vert.x est https://github.com/mauricio/postgresql-async . Il est à noter que le projet est archivé et que le pilote jasync-sql précédent réécrit tout de même (cependant, l'original est écrit en Scala et la nouvelle solution est écrite en Kotlin).
   Mise à jour J'ai été corrigé dans les commentaires, le client de Vert.x est vivant et se sent bien dans les benchmarks .
   
3. Le pilote de l'équipe Spring est https://github.com/r2dbc/r2dbc-postgresql . Ce pilote fournit immédiatement une API réactive (et non asynchrone), et Netty est utilisée pour le transport, comme dans 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);
    }
}