如何发布GSON解析大json文件的进度

dw1jzc5e 于 2022-11-23 发布在其他

关注(0)|答案(1)|浏览(198)

亲爱的斯塔克弗弗劳尔斯：
我目前正在从我的原始资源中解析一个大的json文件。我不得不将逐行阅读改为结合使用一个Reader对象和gson，以避免内存不足的异常。到目前为止，一切都很好。
现在，这一切都发生在一个异步任务中，我希望通过使用publishProgress()，在某种加载屏幕中通知用户进度。

InputStream raw = getResources().openRawResource(R.raw.json);
Reader rd = new BufferedReader(new InputStreamReader(raw));
Gson gson = new Gson();
mReadObjects = gson.fromJson(rd, ReadObjectList.class);

这是我目前阅读文件的方式，但我不知道是否（以及如何）可以从GSON或Reader对象获得任何类型的进度更新。
任何帮助都将不胜感激！

Gson

来源：https://stackoverflow.com/questions/27890287/how-to-publish-progress-for-large-json-file-parsing-with-gson

1条答案

按热度按时间

ehxuflar1#

您必须编写一个围绕InputStream（或Reader）的 Package 器。
应该可以这样做：

public class ProgressInputStream extends FilterInputStream {
    private final int size;
    private long bytesRead;
    private int percent;
    private List<Listener> listeners = new ArrayList<>();

    public ProgressInputStream(InputStream in) {
        super(in);
        try {
            size = available();
            if (size == 0) throw new IOException();
        } catch (IOException e) {
            throw new RuntimeException("This reader can only be used on InputStreams with a known size", e);
        }
        bytesRead = 0;
        percent = 0;
    }

    public void addListener(Listener listener) {
        listeners.add(listener);
    }

    public void removeListener(Listener listener) {
        listeners.remove(listener);
    }

    @Override
    public int read() throws IOException {
        int b = super.read();
        updateProgress(1);
        return b;
    }

    @Override
    public int read(@NonNull byte[] b) throws IOException {
        return updateProgress(super.read(b));
    }

    @Override
    public int read(@NonNull byte[] b, int off, int len) throws IOException {
        return updateProgress(super.read(b, off, len));
    }

    @Override
    public long skip(long n) throws IOException {
        return updateProgress(super.skip(n));
    }

    @Override
    public void mark(int readLimit) {
        throw new UnsupportedOperationException();
    }

    @Override
    public void reset() throws IOException {
        throw new UnsupportedOperationException();
    }

    @Override
    public boolean markSupported() {
        return false;
    }

    private <T extends Number> T updateProgress(T numBytesRead) {
        if (numBytesRead.longValue() > 0) {
            bytesRead += numBytesRead.longValue();
            if (bytesRead * 100 / size > percent) {
                percent = (int) (bytesRead * 100 / size);
                for (Listener listener : listeners) {
                    listener.onProgressChanged(percent);
                }
            }
        }
        return numBytesRead;
    }

    public interface Listener {
        void onProgressChanged(int percentage);
    }
}

使用方法：

ProgressInputStream raw = new ProgressInputStream(getResources().openRawResource(R.raw.json));
raw.addListener(new ProgressInputStream.Listener() {
    @Override
    public void onProgressChanged(int percentage) {
        publishProgress(percentage);
    }
});
Reader rd = new BufferedReader(new InputStreamReader(raw));

赞(0）回复(0）举报 2022-11-23

我来回答

如何发布GSON解析大json文件的进度

1条答案

相关问题

热门标签

最新问答