本文我們將探討如何在  Spring Boot 應用程序中使用 Jackson 的流式  API（JsonParser）高效處理大型 JSON 對象。通過增量反序列化大型 JSON 對象,，可以避免內存和性能瓶頸,。本文將通過一個實時示例，演示如何處理大型 JSON 負載,，并實現(xiàn)數(shù)據(jù)的增量處理和過濾,。我們將實現(xiàn)一個 Spring Boot 控制器來處理大型 JSON 輸入,，并使用 Postman 進行測試，提供示例輸入和輸出,。該解決方案確保低內存消耗和高性能,，特別適用于包含數(shù)百萬條記錄的 JSON 文件,。

為了在 Spring Boot 應用程序中使用 Jackson 的 JsonParser（流式 API）高效處理大型 JSON 對象,，我們可以實現(xiàn)一種增量反序列化的解決方案，以避免性能和內存消耗問題,。我將通過一個實時示例為您講解,，并展示如何使用 Postman 進行測試。

場景

假設我們正在處理一個包含數(shù)百萬條產品詳細信息的大型 JSON 文件,，如果一次性加載整個文件,，可能會導致內存問題。我們希望增量處理該文件,，并僅返回部分數(shù)據(jù)（例如,，符合特定條件的產品）給客戶端。

實現(xiàn)步驟

1. Spring Boot 配置

Maven 依賴
在 pom.xml 中添加以下 Jackson 依賴：

<dependencies>
    <!-- Jackson for JSON Processing -->
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-core</artifactId>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
    </dependency>
</dependencies>

2. 處理 JSON 流式數(shù)據(jù)的控制器

創(chuàng)建一個  Spring Boot 控制器來處理傳入的請求,。

@RestController
@RequestMapping("/api/products")
public class ProductController {
    @PostMapping("/process-large-json")
    public ResponseEntity<List<Product>> processLargeJson(@RequestBody InputStream inputStream) {
        List<Product> matchingProducts = new ArrayList<>();
        try (JsonParser jsonParser = new JsonFactory().createParser(inputStream)) {
            // Start parsing JSON
            if (jsonParser.nextToken() == JsonToken.START_ARRAY) {
                while (jsonParser.nextToken() != JsonToken.END_ARRAY) {
                    Product product = readProduct(jsonParser);
                    // Filter logic - Example: Only process products with price > 100
                    if (product != null && product.getPrice() > 100) {
                        matchingProducts.add(product);
                    }
                }
            }
        } catch (IOException e) {
            return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(null);
        }
        return ResponseEntity.ok(matchingProducts);
    }
    // Utility method to read each product incrementally
    private Product readProduct(JsonParser jsonParser) throws IOException {
        Product product = new Product();
        while (jsonParser.nextToken() != JsonToken.END_OBJECT) {
            String fieldName = jsonParser.getCurrentName();
            jsonParser.nextToken(); // move to value
            if ("id".equals(fieldName)) {
                product.setId(jsonParser.getIntValue());
            } else if ("name".equals(fieldName)) {
                product.setName(jsonParser.getText());
            } else if ("price".equals(fieldName)) {
                product.setPrice(jsonParser.getDoubleValue());
            }
        }
        return product;
    }
}

3. 產品模型

創(chuàng)建一個簡單的 Product 類來保存解析后的數(shù)據(jù),。

public class Product {
    private int id;
    private String name;
    private double price;
    // Getters and setters
    public int getId() { return id; }
    public void setId(int id) { this.id = id; }
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
    public double getPrice() { return price; }
    public void setPrice(double price) { this.price = price; }
}

4. 用于測試的大型 JSON 輸入示例

以下是一個大型 JSON 輸入示例（包含多個產品對象）。您可以將其保存到文件中,，或直接在 Postman 中輸入,。

[
    { "id": 1, "name": "Product 1", "price": 50 },
    { "id": 2, "name": "Product 2", "price": 150 },
    { "id": 3, "name": "Product 3", "price": 200 },
    { "id": 4, "name": "Product 4", "price": 80 },
    { "id": 5, "name": "Product 5", "price": 120 }
]

5. 使用 Postman 進行測試

端點： POST /api/products/process-large-json

請求體： Raw JSON 數(shù)據(jù)

在 Postman 中，按照以下步驟操作：

1. 選擇 POST 方法,。

2. 設置 URL 為 http://localhost:8080/api/products/process-large-json,。

3. 在 Body 選項卡中，選擇 raw,，然后選擇 JSON,。

4. 粘貼大型 JSON 數(shù)組（示例見上文）。

5. 點擊 Send,。

預期輸出：

價格大于 100 的產品將被返回,。以下是過濾后的輸出示例：

[
    { "id": 2, "name": "Product 2", "price": 150 },
    { "id": 3, "name": "Product 3", "price": 200 },
    { "id": 5, "name": "Product 5", "price": 120 }
]

解釋

• JsonParser： 流式  API（JsonParser）逐個處理 JSON 令牌，而無需將整個文件加載到內存中,，非常適合處理大型數(shù)據(jù),。

• 增量處理： Product 對象被增量反序列化。僅符合特定條件（例如,，價格 > 100）的對象會被存儲在內存中并返回,，從而減少內存使用。

• InputStream： 傳入的請求體作為 InputStream 處理,，使我們能夠直接處理大型 JSON 對象,。

該解決方案高效處理大型 JSON 負載,，同時確保內存使用保持在較低水平。

歡迎關注 SpringForAll社區(qū)（spring4all.com）,，專注分享關于Spring的一切,！關注公眾號：SpringForAll社區(qū)，回復“加群”還可加入Spring技術交流群,！

給大家推薦我們團隊開發(fā)的Chrome插件：YouTube中文配音,。如果您跟我們一樣，熱愛看國外的視頻學習前沿知識或者其他內容,，該插件可以很好的幫助您講外語視頻一鍵轉化為中文視頻,，官網(wǎng)：https://www./