Beberapa kata tentang R2DBC dan PostgreSQL

• Pemrograman reaktif lebih sulit untuk di-debug
• Mengembangkan sistem reaktif lebih sulit daripada yang klasik, menghalangi; jika Anda tidak sengaja memblokir utas, Anda selesai. Itu sebabnya proyek muncul (salah satu penulis -Bsideup )
• Pemrograman reaktif, dan khususnya elastisitas, diperlukan terutama pada beban tinggi seperti Netflix. Jika Anda memiliki 100 RPS, Anda mungkin harus menulis kode dengan gaya pemblokiran - lebih murah dan lebih mudah

1. https://github.com/jasync-sql/jasync-sql - driver asinkron untuk PostgreSQL, ditulis di Kotlin, di mana Netty adalah transpornya
2. Solusi yang digunakan Vert.x adalah https://github.com/mauricio/postgresql-async . Perlu dicatat bahwa proyek ini diarsipkan, dan driver jasync-sql sebelumnya menulis ulang sama (meskipun, yang asli ditulis dalam Scala, dan solusi baru ditulis di Kotlin).
   Memperbarui Saya dikoreksi dalam komentar, klien dari Vert.x hidup dan merasa baik dalam benchmark .
   
3. Pengemudi dari tim Spring adalah https://github.com/r2dbc/r2dbc-postgresql . Pengemudi ini segera menyediakan API reaktif (dan tidak asinkron), dan Netty digunakan untuk transportasi, seperti pada 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);
    }
}