بضع كلمات حول R2DBC و PostgreSQL

• البرمجة التفاعلية أكثر صعوبة في التصحيح
• إن تطوير الأنظمة التفاعلية أكثر صعوبة من الأنظمة الكلاسيكية المحجوبة ؛ إذا قمت بحظر الخيط دون قصد ، فقد انتهيت. لهذا السبب ظهر المشروع (أحد المؤلفين -bsideup )
• البرمجة التفاعلية ، ولا سيما المرونة ، مطلوبة بشكل أساسي عند الأحمال العالية a la Netflix. إذا كان لديك 100 RPS ، فمن المحتمل أن تكتب رمزًا بأسلوب الحظر - فهي أرخص وأسهل

1. https://github.com/jasync-sql/jasync-sql - برنامج تشغيل غير متزامن لـ PostgreSQL ، مكتوب بلغة Kotlin ، حيث Netty هو وسيلة النقل
2. الحل الذي يستخدمه Vert.x هو https://github.com/mauricio/postgresql-async . من الجدير بالذكر أن المشروع مؤرشف ، وأن برنامج تشغيل jasync-sql السابق يعيد الكتابة بنفس الطريقة (على الرغم من أن الأصل مكتوب في Scala ، والحل الجديد مكتوب في Kotlin).
   تحديث تم تصحيح لي في التعليقات ، العميل من Vert.x على قيد الحياة ويشعر بالارتياح في المعايير .
   
3. السائق من فريق الربيع هو https://github.com/r2dbc/r2dbc-postgresql . يوفر برنامج التشغيل هذا على الفور واجهة برمجة تطبيقات تفاعلية (وليست متزامنة) ، ويتم استخدام Netty للنقل ، كما هو الحال في 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);
    }
}