响应式弹性搜索作

响应式弹性搜索作是通过ReactiveElasticsearchClient.spring-doc.cadn.net.cn

这ReactiveElasticsearch模板是 的默认实现响应式弹性搜索作.spring-doc.cadn.net.cn

要开始响应式弹性搜索作需要了解实际的客户端情况。有关客户端的详细信息及配置方法，请参见响应式休止客户端。spring-doc.cadn.net.cn

响应式作的使用

响应式弹性搜索作它允许你保存、查找和删除你的域对象，并将这些对象映射到存储在 ElasticSearch 中的文档。spring-doc.cadn.net.cn

请考虑以下几点：spring-doc.cadn.net.cn

示例1。使用ReactiveElasticsearchOperations。
@Document(indexName = "marvel")
public class Person {

  private @Id String id;
  private String name;
  private int age;
  // Getter/Setter omitted...
}
ReactiveElasticsearchOperations operations;

// ...

operations.save(new Person("Bruce Banner", 42))                    (1)
  .doOnNext(System.out::println)
  .flatMap(person -> operations.get(person.id, Person.class))      (2)
  .doOnNext(System.out::println)
  .flatMap(person -> operations.delete(person))                    (3)
  .doOnNext(System.out::println)
  .flatMap(id -> operations.count(Person.class))                   (4)
  .doOnNext(System.out::println)
  .subscribe();                                                    (5)

上面的作在控制台上输出了以下序列。spring-doc.cadn.net.cn

> Person(id=QjWCWWcBXiLAnp77ksfR, name=Bruce Banner, age=42)
> Person(id=QjWCWWcBXiLAnp77ksfR, name=Bruce Banner, age=42)
> QjWCWWcBXiLAnp77ksfR
> 0
1 插入一个新的人记录到漫威索引中。 这身份证在服务器端生成并设置到返回的实例中。
2 查一下人配合身份证在漫威索引中。
3 删除人配合身份证，从该实例中提取，出现在漫威索引中。
4 统计漫威索引中文件的总数。
5 别忘了订阅（）。