Reactive Couchbase repository
Introduction
本章描述了 Couchbase 的响应式存储库支持。这是对在 Couchbase repositories 中解释的核心存储库支持的构建。因此，请确保你透彻地理解该部分解释的基本概念。
Reactive Composition Libraries
Couchbase Java SDK 3.x 已从 RxJava 转移到 Reactor，因此它与响应式的 Spring 生态系统非常相容。
响应式的 Couchbase 存储库提供 project Reactor 封装类型，并且可以通过简单地从其中一个特定库的存储库接口进行扩展来使用：
-
ReactiveCrudRepository
-
ReactiveSortingRepository
Usage
让我们创建一个简单的实体以开始：
Example 1. Sample Person entity
public class Person {
@Id
private String id;
private String firstname;
private String lastname;
private Address address;
// … getters and setters omitted
}相应的存储库实现可能如下所示：
Example 2. Basic repository interface to persist Person entities
public interface ReactivePersonRepository extends ReactiveSortingRepository<Person, Long> {
Flux<Person> findByFirstname(String firstname);
Flux<Person> findByFirstname(Publisher<String> firstname);
Flux<Person> findByFirstnameOrderByLastname(String firstname, Pageable pageable);
Mono<Person> findByFirstnameAndLastname(String firstname, String lastname);
}对于 JavaConfig，请使用 @EnableReactiveCouchbaseRepositories 注释。该注释包含与命名空间元素完全相同的属性。如果未配置基本包，则该基础架构将扫描带有注释的配置类的包。
另外要注意的是，如果你在 Spring Boot 设置中使用它，你可能会省略该注释，因为它会为你自动配置。
Example 3. JavaConfig for repositories
@Configuration
@EnableReactiveCouchbaseRepositories
class ApplicationConfig extends AbstractCouchbaseConfiguration {
// ... (see configuration for details)
}由于我们的域域存储库扩展了 ReactiveSortingRepository，因此它为你提供了 CRUD 操作以及用于对实体进行分类访问的方法。使用存储库实例只是将其通过依赖性注入到客户端的问题。
Example 4. Sorted access to Person entities
public class PersonRepositoryTests {
@Autowired
ReactivePersonRepository repository;
@Test
public void sortsElementsCorrectly() {
Flux<Person> persons = repository.findAll(Sort.by(new Order(ASC, "lastname")));
assertNotNull(perons);
}
}