java - 使用 MongoRepository 保存/插入时出现 StackOverflowError
问题描述
我正在尝试使用 mongo 存储库将包装键值类保存/插入到我的 mongoDB 中。
我要保存的模型是:
@Data
@AllArgsConstructor
@Document(collection = "futureTask")
public class FutureTask {
@Id
private Configuration configuration;
private ScheduledFuture<?> future;
}
存储库实现如下:
public interface FutureTaskRepository extends MongoRepository<FutureTask, Configuration> {
FutureTask findByConfiguration(Configuration configuration);
boolean existsByConfiguration(Configuration configuration);
}
FutureTaskRepository 的调用如下:
ScheduledFuture<?> future = this.schedule(new RunnableTask(configuration), new CronTrigger(configuration.getCron()));
FutureTask futureTask = new FutureTask(configuration, future);
futureTaskRepository.insert(futureTask);
我收到以下错误:
java.lang.StackOverflowError: null
at java.base/java.util.concurrent.locks.ReentrantReadWriteLock$Sync.tryReleaseShared(ReentrantReadWriteLock.java:427) ~[na:na]
at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.releaseShared(AbstractQueuedSynchronizer.java:1382) ~[na:na]
at java.base/java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock(ReentrantReadWriteLock.java:897) ~[na:na]
at org.springframework.data.mapping.context.AbstractMappingContext.getPersistentEntity(AbstractMappingContext.java:244) ~[spring-data-commons-2.3.5.RELEASE.jar:2.3.5.RELEASE]
at org.springframework.data.mapping.context.AbstractMappingContext.getPersistentEntity(AbstractMappingContext.java:206) ~[spring-data-commons-2.3.5.RELEASE.jar:2.3.5.RELEASE]
at org.springframework.data.mapping.context.AbstractMappingContext.getPersistentEntity(AbstractMappingContext.java:90) ~[spring-data-commons-2.3.5.RELEASE.jar:2.3.5.RELEASE]
at org.springframework.data.mapping.context.MappingContext.getRequiredPersistentEntity(MappingContext.java:73) ~[spring-data-commons-2.3.5.RELEASE.jar:2.3.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writePropertyInternal(MappingMongoConverter.java:694) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeProperties(MappingMongoConverter.java:620) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeInternal(MappingMongoConverter.java:596) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writePropertyInternal(MappingMongoConverter.java:700) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeProperties(MappingMongoConverter.java:620) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeInternal(MappingMongoConverter.java:596) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writePropertyInternal(MappingMongoConverter.java:700) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeProperties(MappingMongoConverter.java:620) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeInternal(MappingMongoConverter.java:596) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writePropertyInternal(MappingMongoConverter.java:700) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeProperties(MappingMongoConverter.java:620) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeInternal(MappingMongoConverter.java:596) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writePropertyInternal(MappingMongoConverter.java:700) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeProperties(MappingMongoConverter.java:620) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeInternal(MappingMongoConverter.java:596) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writePropertyInternal(MappingMongoConverter.java:700) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeProperties(MappingMongoConverter.java:620) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeInternal(MappingMongoConverter.java:596) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writePropertyInternal(MappingMongoConverter.java:700) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeProperties(MappingMongoConverter.java:620) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
at org.springframework.data.mongodb.core.convert.MappingMongoConverter.writeInternal(MappingMongoConverter.java:596) ~[spring-data-mongodb-3.0.5.RELEASE.jar:3.0.5.RELEASE]
解决方案
monoDB 似乎存在这样的持久对象问题。通过创建具有 synchronizedCollection 存储的自定义存储库进行了解决。现在不使用 mongoDB 或任何其他数据库。
@Repository
public class FutureTaskRepository {
// collection of futureTasks
private Collection<FutureTask> futureTasks = Collections.synchronizedCollection(new ArrayList<FutureTask>());
public Collection<FutureTask> findAll() {
return this.futureTasks;
}
public FutureTask find(FutureTask futureTask) {
Optional<FutureTask> optional = this.futureTasks.stream().filter(task -> task.equals(futureTask)).findFirst();
return optional.orElse(null);
}
public FutureTask findByConfiguration(Configuration configuration) {
Optional<FutureTask> optional = this.futureTasks.stream().filter(task -> task.getConfiguration()
.equals(configuration)).findFirst();
return optional.orElse(null);
}
public void insert(FutureTask futureTask) {
this.futureTasks.add(futureTask);
}
public void deleteAll() {
this.futureTasks.clear();
}
public void delete(FutureTask futureTask) {
FutureTask task = this.find(futureTask);
this.futureTasks.remove(task);
}
public boolean exists(FutureTask futureTask) {
return this.futureTasks.contains(futureTask);
}
public boolean existsByConfiguration(Configuration configuration) {
FutureTask futureTask = this.findByConfiguration(configuration);
return this.exists(futureTask);
}
}
推荐阅读
- elasticsearch - 弹性搜索如何使 query_string 匹配精确的短语
- vb.net - 为什么使用格式化选项将日期时间转换为字符串会返回整数?
- audio - WEBAUDIO17014:解码错误:在 Edge 浏览器中使用 audioCtx.decodeAudioData() 时提供的流已损坏或不受支持
- laravel - 当 route/{id} 中的 {id} 不存在时显示 404
- python - 即使路径中存在 Python 模块,也找不到它
- jquery - 如何在jquery中合并两个具有相同键名的对象?
- c# - AKS 中的 EF Core DbContext 错误,但不在容器中本地
- encryption - Aurora - 存储桶加密时从 s3 加载数据
- python - 如何与 chrome 扩展进行交互?
- docker - aerospike:Docker 容器中无法识别的服务?