Spring 启动 JPA ManyToMany 导致 OutOfMemoryError

Question

我有一个 Spring 启动应用程序，我正在尝试插入一部与国家相关的电影，但几分钟后出现异常。简化实体：

电影：

public class Movie implements Serializable {

    ...

    @ManyToMany(cascade = {
            CascadeType.PERSIST,
            CascadeType.MERGE
    })
    @JoinTable(name = "movies_countries",
        joinColumns = @JoinColumn(name = "id_movie"),
        inverseJoinColumns = @JoinColumn(name = "id_country")
    )
    private Set<Country> countries = new HashSet<>();

    public Set<Country> getCountries() {
        return this.countries;
    }

    public void setCountries(Set<Country> countries) {
        this.countries = countries;
    }

    public void addCountry(Country country) {
        getCountries().add(country);
        country.getMovies().add(this); // Point where it gets blocked
    }
    ...
}

国家：

public class Country implements Serializable {

    ...

    @ManyToMany(mappedBy = "countries")
    private Set<Movie> movies = new HashSet<>();

    public Set<Movie> getMovies() {
            return movies;
    }

    public void setMovies(Set<Movie> movies) {
        this.movies = movies;
    }

    ...

}

以及将电影与国家联系起来的方法：

private void insertCountries(final List<String> countries, final EntityManager entityManager, final Movie movie) {
    for (String strCountry: countries) {
        Country country = this.getCountry(entityManager, strCountry);
        movie.addCountry(country);
    }
}

异常：

Exception in thread "Thread-6" java.lang.OutOfMemoryError: Java heap space
    at io.netty.buffer.PooledDirectByteBuf.newObject(PooledDirectByteBuf.java:35)
    at io.netty.buffer.PooledDirectByteBuf.newObject(PooledDirectByteBuf.java:32)
    at io.netty.util.Recycler.get(Recycler.java:158)
    at io.netty.buffer.PooledDirectByteBuf.newInstance(PooledDirectByteBuf.java:40)
    at io.netty.buffer.PoolArena$DirectArena.newByteBuf(PoolArena.java:786)
    at io.netty.buffer.PoolArena.allocate(PoolArena.java:145)
    at io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:332)
    at io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:185)
    at io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:176)
    at io.netty.channel.nio.AbstractNioChannel.newDirectBuffer(AbstractNioChannel.java:448)
    at io.netty.channel.nio.AbstractNioByteChannel.filterOutboundMessage(AbstractNioByteChannel.java:275)
    at io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:881)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1365)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:816)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:723)
    at io.netty.handler.logging.LoggingHandler.write(LoggingHandler.java:249)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:816)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:723)
    at io.netty.channel.ChannelDuplexHandler.write(ChannelDuplexHandler.java:106)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
    at io.netty.channel.AbstractChannelHandlerContext.access00(AbstractChannelHandlerContext.java:38)
    at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1127)
    at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1174)
    at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1098)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:495)
2020-03-02 12:41:54,741 WARN  [http-nio-8090-exec-2] com.zaxxer.hikari.pool.PoolBase: HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@35e38de8 (No operations allowed after connection closed.). Possibly consider using a shorter maxLifetime value.

为了尝试，我尝试将内存从 1 Gb 增加到 2 Gb，但它仍然发生。并不是所有的电影插播都会出现这种情况。

有什么建议吗？

Answer 1

多对多关系很棘手，不要对它们使用级联配置，级联与保存实体有关，这里你没有实体，只有关联，这个关联由orm 监控底层集合中发生的事情，如果你看一下实现，这个集合实际上是某种包，被工具化以检测其中的变化。保存必须在拥有方完成：没有 mappedBy 注释的一侧。

Answer 2

我终于让它工作了。我已将 Set 修改为 List，现在它不在行 country.getMovies().add(this); 上。

我添加了确切的更改：private Set<Country> countries = new HashSet<>(); by private List<Country> countries = new ArrayList<>();

Spring 启动 JPA ManyToMany 导致 OutOfMemoryError

Spring Boot JPA ManyToMany causes OutOfMemoryError

java

jpa

out-of-memory

spring-boot