优化 Java Cassandra PreparedStatementCache

Question

我使用 org.springframework.data.cassandra.core.cql.support.PreparedStatementCache 来缓存preparedStatement。 但是需要很多内存。 看起来如果我仍然使用 PreparedStatement，缓存永远不会清理并增加（尽管我们使用相同的 cql 查询！！！）。 如果我不再给他打电话，记忆就会减少。

我的应用程序使用 springboot /cassandra dse 我们都在 tomcat 中测试（windows 和 linux 服务器，超过 500 req/s）。

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-cassandra</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>com.datastax.dse</groupId>
                    <artifactId>dse-java-driver-core</artifactId>
                </exclusion>
            </exclusions>
        </dependency>



private final PreparedStatementCache cache = PreparedStatementCache.create();

public Channel findByIdChannel(String idChannel) {

        List<Channel> listChannel = cassandraTemplate
                .getCqlOperations()
                .query(
                        findByIdChannelQuery(idChannel),
                        (row, rowNum) -> cassandraTemplate.getConverter().read(Channel.class, row));
        if (listChannel.isEmpty()) {
            return null;
        }
        return listChannel.get(0);
    }

    private BoundStatement findByIdChannelQuery(String idChannel) {
        String cql = "select * from channel where idchannel = '" + idChannel + "'";
        return CachedPreparedStatementCreator.of(
                cache, cql).createPreparedStatement(session)
                .bind();
    }

任何提高性能的建议（不是关于使应用程序缓存和方法级别）？ 我们如何修复preparedStatementCache的大小？

非常感谢。

Answer 1

不要为每个 idChannel 都准备好声明。创建一个准备好的语句并绑定 id ，它不必为每个查询创建一个新的（这非常昂贵）。喜欢

  return CachedPreparedStatementCreator.of(
          cache,
          select()
              .all()
              .from("channel")
              .where(eq("idchannel", bindMarker("idchannel")))
      .createPreparedStatement(session)
      .bind()
      .setString("idchannel", idchannel));