|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Data Elasticsearch 5.5.2！ |
路由值
当 Elasticsearch 将文档存储在具有多个分片的索引中时，它会根据文档的 ID 确定要使用的分片。 有时需要预先定义多个文档应在同一分片上建立索引（联接类型，更快地搜索相关数据）。 为此，Elasticsearch 提供了定义路由的可能性，该路由是应用于计算分片的值，而不是 id。
Spring Data Elasticsearch支持通过以下方式存储和检索数据的路由定义：
连接类型的路由
当使用 join-types 时（请参阅 Join-Type 实现），Spring Data Elasticsearch 将自动使用parent实体的属性JoinField属性作为路由的值。
这对于父子关系只有一个级别的所有用例都是正确的。 如果它更深，例如子-父母-祖父母关系 - 如上面的示例，从投票→回答→问题 - 那么路由需要使用下一节中描述的技术显式指定（投票需要 question.id 作为路由值）。
自定义路由值
要为实体定义自定义路由，Spring Data Elasticsearch 提供了一个@Routing注释（重用Statement从上面上课）：
@Document(indexName = "statements")
@Routing("routing") (1)
public class Statement {
@Id
private String id;
@Field(type = FieldType.Text)
private String text;
@JoinTypeRelations(
relations =
{
@JoinTypeRelation(parent = "question", children = {"answer", "comment"}),
@JoinTypeRelation(parent = "answer", children = "vote")
}
)
private JoinField<String> relation;
@Nullable
@Field(type = FieldType.Keyword)
private String routing; (2)
// getter/setter...
}| 1 | 这将“路由”定义为路由规范 |
| 2 | 名称为 routing 的属性 |
如果routing注释的规范是一个普通字符串，而不是 SpEL 表达式，它被解释为实体属性的名称，在示例中它是路由属性。
然后，此属性的值将用作使用该实体的所有请求的路由值。
我们也可以在@Document注解如下：
@Document(indexName = "statements")
@Routing("@myBean.getRouting(#entity)")
public class Statement{
// all the needed stuff
}在这种情况下，用户需要提供一个名称为 myBean 的 bean，该 bean 具有一个方法String getRouting(Object).要引用实体“#entity”必须在 SpEL 表达式中使用，并且返回值必须是null或路由值作为字符串。
如果普通属性的名称和 SpEL 表达式不足以自定义路由定义，则可以定义提供RoutingResolver接口。然后可以在ElasticOperations实例：
RoutingResolver resolver = ...;
ElasticsearchOperations customOperations= operations.withRouting(resolver);这withRouting()函数返回原始副本ElasticsearchOperations实例。
当将路由存储在 Elasticsearch 中时，在实体上定义了路由，则在执行获取或删除作时必须提供相同的值。对于不使用实体的方法 - 如get(ID)或delete(ID)-这ElasticsearchOperations.withRouting(RoutingResolver)方法可以这样使用：
String id = "someId";
String routing = "theRoutingValue";
// get an entity
Statement s = operations
.withRouting(RoutingResolver.just(routing)) (1)
.get(id, Statement.class);
// delete an entity
operations.withRouting(RoutingResolver.just(routing)).delete(id);| 1 | RoutingResolver.just(s)返回一个解析器，该解析器将仅返回给定的字符串。 |