R2DBC的特点在于其支持非阻塞的、异步的数据库操作，能够显著提高系统的性能和响应速度，特别适用于高并发和低延迟的应用场景。

我们为什么选择R2DBC？

• 非阻塞I/O: R2DBC支持非阻塞的数据库操作，这意味着在等待数据库响应时，应用程序线程不会被阻塞。这对于处理大量并发请求的高频交易系统至关重要。

• 背压机制: R2DBC内置了背压机制，能够有效地管理数据流的速度，防止内存溢出和其他性能瓶颈。

• 快速响应: 由于采用了非阻塞和异步的操作模式，用户可以更快地获得查询结果，提升了整体用户体验。

• 稳定性: 在高负载情况下，系统仍然能够保持稳定的性能表现，减少因数据库操作导致的延迟和错误。

• 反应式编程: R2DBC与Spring WebFlux无缝集成，支持反应式编程模型。这种编程模型非常适合构建高吞吐量、低延迟的应用程序。

• 函数式风格: 反应式编程允许以声明式的方式处理数据流，代码更加简洁和易于维护。

• 异步数据访问: R2DBC提供了异步的数据访问方法，使得应用程序能够在等待数据库操作完成的同时继续执行其他任务，提高了整体系统的效率。

• 事件驱动: 基于事件驱动的架构能够更好地应对突发的大流量请求，确保系统的稳定性和可靠性。

• 多种数据库支持: R2DBC支持多种关系型数据库，包括PostgreSQL、MySQL、Microsoft SQL Server等。这为我们提供了灵活性，可以根据需要选择最适合的数据库解决方案。

• 标准规范: R2DBC遵循一套标准化的API规范，便于开发人员学习和使用，同时也为未来的扩展和迁移提供了便利。

哪些公司使用了R2DBC？

• Netflix : 通过R2DBC，Netflix能够更好地管理大量的数据库请求，提高系统的响应速度和吞吐量。

• Zalando : 是一家大型电子商务公司，R2DBC帮助Zalando减少了数据库连接池的压力，提高了系统的整体性能和稳定性。

• 德国证券交易所集团: R2DBC的高性能特性满足了高频交易对低延迟和高吞吐量的需求。

• Adyen: 是一家全球领先的支付解决方案提供商，他们在后端系统中使用R2DBC，帮助Adyen处理大规模的支付交易，确保系统的高效性和可靠性。

• Oracle: 在其数据库产品中提供了对R2DBC的支持。Oracle通过R2DBC增强了其数据库产品的现代性和竞争力。

代码实操

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-r2dbc</artifactId>
    </dependency>
    <dependency>
        <groupId>io.r2dbc</groupId>
        <artifactId>r2dbc-postgresql</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
    </dependency>

application.properties

spring.r2dbc.url=r2dbc:postgresql://localhost:5432/trading_db
spring.r2dbc.username=postgres
spring.r2dbc.password=password
spring.datasource.driver-class-name=org.postgresql.Driver

实体类

package com.example.demo.model;

import org.springframework.data.annotation.Id;
import org.springframework.data.relational.core.mapping.Table;

// 定义订单实体类，映射到数据库中的orders表
@Table("orders")
publicclass Order {
    @Id// 标记id字段为主键
    private Long id; // 订单ID
    private String symbol; // 交易符号（如股票代码）
    privateint quantity; // 数量
    privatedouble price; // 单价

    // Getter和Setter方法
    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getSymbol() {
        return symbol;
    }

    public void setSymbol(String symbol) {
        this.symbol = symbol;
    }

    public int getQuantity() {
        return quantity;
    }

    public void setQuantity(int quantity) {
        this.quantity = quantity;
    }

    public double getPrice() {
        return price;
    }

    public void setPrice(double price) {
        this.price = price;
    }
}

Repository

package com.example.demo.repository;

import com.example.demo.model.Order;
import org.springframework.data.repository.reactive.ReactiveCrudRepository;
import reactor.core.publisher.Flux;

public interface OrderRepository extends ReactiveCrudRepository<Order, Long> {
    Flux<Order> findBySymbol(String symbol);
}

Service

package com.example.demo.service;

import com.example.demo.model.Order;
import com.example.demo.repository.OrderRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

// 定义订单服务类，处理业务逻辑
@Service
publicclass OrderService {
    @Autowired// 注入OrderRepository
    private OrderRepository orderRepository;

    // 保存订单的方法，返回Mono<Order>
    public Mono<Order> saveOrder(Order order) {
        return orderRepository.save(order); // 调用repository的save方法
    }

    // 查找所有订单的方法，返回Flux<Order>
    public Flux<Order> findAllOrders() {
        return orderRepository.findAll(); // 调用repository的findAll方法
    }

    // 按symbol查找订单的方法，返回Flux<Order>
    public Flux<Order> findOrdersBySymbol(String symbol) {
        return orderRepository.findBySymbol(symbol); // 调用自定义的findBySymbol方法
    }
}

Controller

package com.example.demo.controller;

import com.example.demo.model.Order;
import com.example.demo.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

// 定义订单控制器类
@RestController
@RequestMapping("/api/orders")
publicclass OrderController {
    @Autowired// 注入OrderService
    private OrderService orderService;

    // 创建订单的POST请求处理方法
    @PostMapping("/")
    public Mono<Order> createOrder(@RequestBody Order order) {
        return orderService.saveOrder(order); 
    }

    // 获取所有订单的GET请求处理方法
    @GetMapping("/")
    public Flux<Order> getAllOrders() {
        return orderService.findAllOrders(); 
    }

    // 按symbol获取订单的GET请求处理方法
    @GetMapping("/{symbol}")
    public Flux<Order> getOrdersBySymbol(@PathVariable String symbol) {
        return orderService.findOrdersBySymbol(symbol);
    }
}

Application

package com.example.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

测试

创建订单

curl -X POST http://localhost:8080/api/orders/ \
-H "Content-Type: application/json" \
-d '{"symbol": "AAPL", "quantity": 10, "price": 150.75}'

Respons:

{
    "id": 1,
    "symbol": "AAPL",
    "quantity": 10,
    "price": 150.75
}

获取所有订单

curl http://localhost:8080/api/orders/

Respons:

[
    {
        "id": 1,
        "symbol": "AAPL",
        "quantity": 10,
        "price": 150.75
    }
]

按symbol获取订单

curl http://localhost:8080/api/orders/AAPL

Respons:

[
    {
        "id": 1,
        "symbol": "AAPL",
        "quantity": 10,
        "price": 150.75
    }
]

关注我，送Java福利

/**
 * 这段代码只有Java开发者才能看得懂！
 * 关注我微信公众号之后，
 * 发送:"666"，
 * 即可获得一本由Java大神一手面试经验诚意出品
 * 《Java开发者面试百宝书》Pdf电子书
 * 福利截止日期为2025年02月28日止
 * 手快有手慢没！！！
*/
System.out.println("请关注我的微信公众号：");
System.out.println("Java知识日历");