运行以下代码会导致有关 Java 堆空间的异常。

来自 .NET 并掌握了 GC 的工作原理，我想知道在尝试运行以下命令时，在内存管理方面是否需要考虑一些事情:

public static void main(String[] args) throws NumberFormatException, ParseException, IOException {

    Jedis jedis = new Jedis("<HostName>");

    TimeSeriesPoints retrieved = null;

    while(!finished) {

        try {

            finished = true;

            List<String> keys = getNextFiftyKeys();

            String[] cacheKeys = new String[keys.size()];

            List<String> cacheResults = jedis.mget(keys.toArray(cacheKeys));

            List<TimeSeries> cachedTimeSeries = new ArrayList<TimeSeries>();

            for(String cacheResult : cacheResults){
                try {
                    retrieved = TimeSeriesPoints.parseFrom(cacheResult.getBytes());

                    TimeSeries timeSeries = new TimeSeries(retrieved.getName(), retrieved.getPointsList());

                    cachedTimeSeries.add(timeSeries);
                } 
                catch (InvalidProtocolBufferException e) {
                    e.printStackTrace();
                }
            }

            long pointsCount = 0;
            for(TimeSeries timeSeries : cachedTimeSeries){
                pointsCount += timeSeries.points.length;
            }

            System.out.println("retrieved: " + cachedTimeSeries.size());
            System.out.println("points:" + pointsCount);            
    }
}

异常在 TimeSeriesPoints.parseFrom 处抛出，堆栈跟踪如下。不确定为什么。

Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
    at java.util.Arrays.copyOf(Unknown Source)
    at java.util.Arrays.copyOf(Unknown Source)
    at java.util.ArrayList.ensureCapacity(Unknown Source)
    at java.util.ArrayList.add(Unknown Source)
    at com.wimiro.caching.TimeSeriesProtos$TimeSeriesPoints.<init>(TimeSeriesProtos.java:115)
    at com.wimiro.caching.TimeSeriesProtos$TimeSeriesPoints.<init>(TimeSeriesProtos.java:82)
    at com.wimiro.caching.TimeSeriesProtos$TimeSeriesPoints$1.parsePartialFrom(TimeSeriesProtos.java:151)
    at com.wimiro.caching.TimeSeriesProtos$TimeSeriesPoints$1.parsePartialFrom(TimeSeriesProtos.java:1)
    at com.google.protobuf.AbstractParser.parsePartialFrom(AbstractParser.java:141)
    at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:176)
    at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:188)
    at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:193)
    at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:49)
    at com.wimiro.caching.TimeSeriesProtos$TimeSeriesPoints.parseFrom(TimeSeriesProtos.java:958)
    at program.main(program.java:77)

这会在尝试读取 800 个时间序列(每个都有约 4000 个数据点)时失败。由于在此示例中我一次只处理 50 个时间序列，因此我预计内存占用量不会显着增长。

在 .NET 中，我可以毫不费力地做到这一点。是时候学习一些 Java 了。我需要阅读什么？

最佳答案

您正在尝试从调用 redis(C 字符 8 位编码)的 jedis(使用 SafeEncoder 将 UTF-16 转换为 bytearray)获取 java String (UTF-16) 中的字节数组。我认为这是您问题的根源，您的 java String 可能不正确，这导致 protobuf 失败。

您应该尝试使用来自 jedis 的字节数组签名:

final List<byte[]> mget = jedis.mget(byteArray1, byteArray2, ...);

然后尝试在字节数组上使用 protobuf。还要检查如何使用 jedis 在 redis 中插入数据，在所有情况下，建议使用二进制数据的字节数组签名。

关于java - 使用 Protocol Buffers 时，这里可能会导致 java.lang.OutOfMemoryError 的原因是什么？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22299678/