189 8069 5689

spring-data-elasticsearch和Jackson配合使用有什么bug

本篇内容介绍了“spring-data-elasticsearch和Jackson配合使用有什么bug”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

十年的梓潼网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。营销型网站的优势是能够根据用户设备显示端的尺寸不同,自动调整梓潼建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。成都创新互联从事“梓潼网站设计”,“梓潼网站推广”以来,每个客户项目都认真落实执行。

下面先简单描述项目。

项目依赖:

dependencies {
  implementation group: 'org.springframework.boot', name: 'spring-boot-starter-data-elasticsearch', version: '2.1.0.RELEASE'

  testImplementation group: 'org.springframework.boot', name: 'spring-boot-starter-test', version: '2.1.0.RELEASE'
  testCompile group: 'junit', name: 'junit', version: '4.12'
}

ES索引结构:

{
	"test_log": {
		"mappings": {
			"_doc": {
				"properties": {
					"id": {
						"type": "keyword"
					},
					"log_type": {
						"type": "keyword"
					}
				}
			}
		}
	}
}

注意如果不加 @JsonProperty 注解,保存时会向 ES 添加新的 'logType' 字段(视 mapping 的 dynamic 配置而定,默认是true)。POJO如下:

@Document(indexName="test_log", type="_doc")
public class TestLog {
  @Id
  private long id;

  @JsonProperty("log_type")
  private String logType;

 // setters & getters
}

TestLogRepository:

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface TestLogRepository extends ElasticsearchRepository {}

测试用例很简单:

@Test
public void testSave() {
  testLogRepository.save(new TestLog(System.currentTimeMillis(), "test name 1"));
}

测试结果是虽然向ES添加了一条新的记录,但 log_type 字段为空。

郁闷了一会后开始跟踪源码。先将整个过程分为初始化、序列化、写入三个阶段。写入肯定没有问题,因为是 ES client 直接向ES写生成好的JSON,那么问题就出在前边。

先来看初始化过程,其关键调用链描述如下:

1. spring 扫描自定义的 Repository;

2. 使用 ElasticsearchRepositoryFactoryBean 来初始化 TestLogReposity 的实例;

3. 在 AbstractMappingContext 的 addPersistentEntity 方法中将类型信息(TestLog)添加到 MappingContext( AbstractMappingContext )的 persistentEntities 的私有属性中(HashMap结构,里边的变量是 SimpleElasticsearchPersistentEntity 实例)。

4. 第3步中会在写 persistentEntities 时遍历 TestLog 所有 properties,将字段名保存到 PersitentEntity 的 propertyCache(ArrayList)中。我们需要关注的结构就是 context-> persistentEntities -> propertyCache, 这个 propertyCache 先简单表示为 ['id', 'logType']

JSON序列化过程中关键调用链如下:

1. 调用 DefaultEntityMapper 的 mapToString;

2. 调用 ObjectMapper 的 writeValueAsString;

3. 调用 DefaultSerializerProvider 的 serializeValue;

4. 序列化 TestLog 时, Jackson发现从各种缓存中都找不到序列化器,只好构造一个,即调用 BeanSerializerFactory 的 createSerializer;

5. createSerializer 时会扫描 TestLog 中各式注解,如 @JsonProperty、@JsonSetter、@JsonGetter 以及 @JsonNaming,使用注解的值来构造要序列化的属性列表。如果没有注解,就直接使用字段名。本例中的 props 列表形为 ['id', 'log_type']

6. 到第5步还一切OK,但是最后 Jackson 会回调 SpringDataSerializerModifier 对 props 进行修改,SpringDataSerializerModifier 直接从上面我们初始化好的 context-> persistentEntities -> propertyCache 一路查下来,发现 log_type 匹配不到 propertyCache 列表中的任何值,直接删掉。。。返回待序列化的字段列表只包含 [ 'id' ] 一个值!关键代码就在 BeanSerializerFactory 的 constructBeanSerializer,和 SpringDataSerializerModifier 的 changeProperties 方法中。源码就不贴了,有兴趣的同学自己去查。

到这里已经真相大白了,笔者特意去查了 spring-data-elasticsearch 的 issue 列表。发现还真有此类问题:DATAES-550、DATAES-562。

要补充的是试过 springboot 2.1.0.RELEASE、2.1.5.RELEASE、2.1.9.RELEASE都不行,官方的解决方案是使用 spring-data-elasticsearch 3.2.x以上版本。但一来此版本要求的ES是6.8以上,二来是和项目中其它地方有奇怪的冲突,尝试了一段时间遂放弃。最后还是使用了自定义的 ObjectMapper 和 ElasticsearchTemplate 来手动写入:

public void save(TestLog log) {
  IndexQuery indexQuery = new IndexQueryBuilder().withIndexName("test_log").withType("_doc").withId(log.getId()).withSource(objectMapper.writeValueAsString(log)).build();
  elasticsearchTemplate.index(indexQuery);
}

“spring-data-elasticsearch和Jackson配合使用有什么bug”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!


网站标题:spring-data-elasticsearch和Jackson配合使用有什么bug
文章网址:http://cdxtjz.cn/article/ieeggg.html

其他资讯