|
|
相关文章推荐
|
纯真的石榴 · Spring Batch未反序列化日期开发者社区· 3 周前 · |
|
|
憨厚的课本 · 学习曲线的横纵轴是指什么？ - 知乎· 1 年前 · |
|
|
打酱油的柿子 · 如何用django ...· 2 年前 · |
|
|
悲伤的橙子 · selenium之键盘操作详解 - ...· 2 年前 · |
Spring Batch未反序列化日期
问
Spring Batch未反序列化日期
EN
EN
Stack Overflow用户
提问于
2018-11-02 18:21:28
回答 3
查看 1.5K
关注 0
票数 1
我在spring batch的JobExecution上下文中添加了一个对象，其中包含一个
Instant
字段。
它的序列化如下所示：
代码语言：
javascript
运行
复制
{
"startFrom": {
"nano": 0,
"epochSecond": 1541116800
}然而，Spring Batch似乎无法对其进行反序列化。
代码语言：
javascript
运行
复制
Caused by: java.lang.IllegalArgumentException: Unable to deserialize the execution context
at org.springframework.batch.core.repository.dao.JdbcExecutionContextDao$ExecutionContextRowMapper.mapRow(JdbcExecutionContextDao.java:325)
at org.springframework.batch.core.repository.dao.JdbcExecutionContextDao$ExecutionContextRowMapper.mapRow(JdbcExecutionContextDao.java:309)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:93)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:60)
at org.springframework.jdbc.core.JdbcTemplate$1.doInPreparedStatement(JdbcTemplate.java:667)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:605)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:657)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:688)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:700)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:756)
at org.springframework.batch.core.repository.dao.JdbcExecutionContextDao.getExecutionContext(JdbcExecutionContextDao.java:112)
at org.springframework.batch.core.explore.support.SimpleJobExplorer.getJobExecutionDependencies(SimpleJobExplorer.java:202)
at org.springframework.batch.core.explore.support.SimpleJobExplorer.getJobExecutions(SimpleJobExplorer.java:83)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:564)
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:343)
at org.springframework.aop.framework.ReflectiveMethod
在做一些研究时，我发现Jackson有一个序列化/反序列化
Instant
和其他date类的
JavaTimeModule
。但是，在
Jackson2ExecutionContextStringSerializer
类中，它按如下方式创建
ObjectMapper
，而不是注册正确的模块：
代码语言：
javascript
运行
复制
public Jackson2ExecutionContextStringSerializer() {
this.objectMapper = new ObjectMapper();
this.objectMapper.configure(MapperFeature.DEFAULT_VIEW_INCLUSION, false);
this.objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, true);
this.objectMapper.enableDefaultTyping();
this.objectMapper.registerModule(new JobParametersModule());
}
Spring Batch不使用自动连接的ObjectMapper有什么原因吗？或者是他们不注册
JavaTimeModule
的原因？有没有解决这个问题的办法？
谢谢!
编辑：
我已经找到了如何重写这个对象映射器：
代码语言：
javascript
运行
复制
@Bean
public JobRepository createJobRepository() throws Exception {
ObjectMapper objectMapper = new ObjectMapper().registerModule(new JavaTimeModule()).findAndRegisterModules();
Jackson2ExecutionContextStringSerializer defaultSerializer = new Jackson2ExecutionContextStringSerializer();
defaultSerializer.setObjectMapper(objectMapper);
JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
factory.setDataSource(dataSource);
factory.setTransactionManager(transactionManager);
factory.setSerializer(defaultSerializer);
factory.afterPropertiesSet();
return factory.getObject();
}然而，即使这样，这个问题仍然存在。
EN
回答 3
Stack Overflow用户
发布于 2020-12-04 21:19:39
下面的方法对我很有效。我正在扩展Mahmoud Ben Hassine上面的答案，这个答案对Nicolas Widart不起作用。(我没有足够的名气来评论)。
代码语言：
javascript
运行
复制
@Bean
public BatchConfigurer configurer(DataSource dataSource, PlatformTransactionManager transactionManager,
ObjectMapper objectMapper) {
return new DefaultBatchConfigurer(dataSource) {
final Jackson2ExecutionContextStringSerializer serializer = new Jackson2ExecutionContextStringSerializer();
@Override
protected JobRepository createJobRepository() throws Exception {
serializer.setObjectMapper(objectMapper);
JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
factory.setDataSource(dataSource);
factory.setTransactionManager(transactionManager);
factory.setSerializer(serializer);
factory.afterPropertiesSet();
return factory.getObject();
@Override
protected JobExplorer createJobExplorer() throws Exception {
serializer.setObjectMapper(objectMapper);
JobExplorerFactoryBean jobExplorerFactoryBean = new JobExplorerFactoryBean();
jobExplorerFactoryBean.setSerializer(serializer);
jobExplorerFactoryBean.setDataSource(dataSource);
jobExplorerFactoryBean.afterPropertiesSet();
return jobExplorerFactoryBean.getObject();
}
(我在另一个
@Configuration
类中定义了一个
ObjectMapper
bean。)这里重要的是覆盖
createJobExplorer()
方法并在那里设置正确的
ExecutionContextSerializer
，因为此方法将在
JobExplorerFactoryBean
上调用
getTarget()
，如果没有设置，则将设置一个普通的
ExecutionContextSerializer
，这会导致您描述的错误。
票数 1
EN
Stack Overflow用户
发布于 2018-11-02 22:22:19
您显示的代码是序列化程序的默认初始化。您可以通过提供一个自定义对象映射器来覆盖它，该映射器预先配置了所需的模块。下面是一个示例：
代码语言：
javascript
运行
复制
@Bean
public JobRepository jobRepository() throws Exception {
ObjectMapper objectMapper = null; // configure the object mapper as required
Jackson2ExecutionContextStringSerializer serializer = new Jackson2ExecutionContextStringSerializer();
serializer.setObjectMapper(objectMapper);