R2DBC और PostgreSQL के बारे में कुछ शब्द

• प्रतिक्रियाशील प्रोग्रामिंग डिबग करना अधिक कठिन है
• प्रतिक्रियाशील प्रणालियों को विकसित करना क्लासिक की तुलना में अधिक कठिन है, उन्हें अवरुद्ध करना; यदि आप अनजाने में धागे को अवरुद्ध करते हैं, तो आप समाप्त कर रहे हैं। यही कारण है कि परियोजना दिखाई दी (लेखकों में से एक -bsideup )
• प्रतिक्रियाशील प्रोग्रामिंग, और विशेष रूप से लोच में, मुख्य रूप से उच्च भार पर ला नेटफ्लिक्स की आवश्यकता होती है। यदि आपके पास 100 आरपीएस हैं, तो आपको संभवतः अवरुद्ध शैली में कोड लिखना चाहिए - यह सस्ता और आसान है

1. https://github.com/jasync-sql/jasync-sql - PostgreSQL के लिए अतुल्यकालिक ड्राइवर, कोटलिन में लिखा गया है, जहां नेटी परिवहन है
2. समाधान Vert.x का उपयोग करता है https://github.com/mauricio/postgresql-async । यह उल्लेखनीय है कि परियोजना को संग्रहीत किया गया है, और पिछले jasync-sql ड्राइवर को फिर से वही लिखा जाता है (हालांकि, मूल को स्काला में लिखा गया है, और नया समाधान कोटलिन में लिखा गया है)।
   अपडेट करें मुझे टिप्पणियों में सही किया गया था, वर्ट.एक्स से क्लाइंट जीवित है और बेंचमार्क में अच्छा महसूस करता है ।
   
3. स्प्रिंग टीम का ड्राइवर https://github.com/r2dbc/r2dbc-postgresql है । यह ड्राइवर तुरंत एक प्रतिक्रियाशील एपीआई (और एसिंक्रोनस नहीं) प्रदान करता है, और नेट्टी का उपयोग परिवहन के लिए किया जाता है, जैसे कि जसुंक-एसक्यूएल में।

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