|
对于最新稳定版本,请使用Spring Data Elasticsearch 5.5.5! |
响应式弹性搜索作
响应式弹性搜索作是通过ReactiveElasticsearchClient.
这ReactiveElasticsearch模板是 的默认实现响应式弹性搜索作.
要开始响应式弹性搜索作需要了解实际的客户情况。
有关客户端及配置的详细信息,请参见反应静止客户端。
响应式作的使用
响应式弹性搜索作它允许你保存、查找和删除你的域对象,并将这些对象映射到存储在 ElasticSearch 中的文档。
请考虑以下几点:
例子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)
上面的作在控制台上输出了以下序列。
> Person(id=QjWCWWcBXiLAnp77ksfR, name=Bruce Banner, age=42)
> Person(id=QjWCWWcBXiLAnp77ksfR, name=Bruce Banner, age=42)
> QjWCWWcBXiLAnp77ksfR
> 0
| 1 | 插入一个新的人记录到漫威索引中。这身份证在服务器端生成并设置到返回的实例中。 |
| 2 | 查一下人配合身份证在漫威索引中。 |
| 3 | 删除人配合身份证,从该实例中提取,出现在漫威索引中。 |
| 4 | 统计漫威索引中文件的总数。 |
| 5 | 别忘了订阅()。 |