当前位置：首页 > article >正文

使用Java爬虫获取京东JD.item_sku API接口数据

article 2025/2/19 14:50:29

在电商领域，商品的SKU（Stock Keeping Unit）信息是运营和管理的关键数据。SKU信息包括商品的规格、价格、库存等，对于商家的库存管理、定价策略和市场分析至关重要。京东作为国内领先的电商平台，提供了丰富的API接口，允许开发者获取商品的详细信息，包括SKU数据。本文将详细介绍如何使用Java编写爬虫程序，调用京东的JD.item_sku接口获取商品的SKU信息。

一、京东`JD.item_sku`接口概述

京东的JD.item_sku接口允许开发者获取商品的SKU信息，包括但不限于以下内容：

商品名称：商品的标题或名称。
商品图片：商品的主图URL。
价格：商品的当前价格。
库存：商品的库存数量。
SKU编号：每个SKU的唯一标识符。

二、准备工作

1. 注册京东开放平台账号

在使用API接口之前，需要在京东开放平台注册一个开发者账号，并创建应用以获取必要的API密钥（AppKey和AppSecret）。

2. 阅读API文档

详细了解京东提供的API接口文档，包括请求参数、响应格式和调用限制等。

3. 添加Java依赖

在Java项目中，可以使用HttpClient库来发送HTTP请求。可以通过Maven添加以下依赖：

xml

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.13</version>
</dependency>

三、Java代码实现

以下是一个完整的Java代码示例，展示如何调用京东JD.item_sku接口并解析返回的数据。

（一）生成签名

京东API接口通常需要签名验证，以下代码展示了如何生成签名：

java

import java.security.MessageDigest;
import java.util.*;

public class JDSignUtil {
    public static String generateSign(Map<String, String> params, String appSecret) {
        List<String> keys = new ArrayList<>(params.keySet());
        Collections.sort(keys);

        StringBuilder sb = new StringBuilder();
        for (String key : keys) {
            sb.append(key).append(params.get(key));
        }
        sb.append(appSecret);

        try {
            MessageDigest md = MessageDigest.getInstance("MD5");
            byte[] bytes = md.digest(sb.toString().getBytes("UTF-8"));
            StringBuilder hexString = new StringBuilder();
            for (byte b : bytes) {
                String hex = Integer.toHexString(0xff & b);
                if (hex.length() == 1) {
                    hexString.append('0');
                }
                hexString.append(hex);
            }
            return hexString.toString().toUpperCase();
        } catch (Exception e) {
            throw new RuntimeException("MD5加密失败", e);
        }
    }
}

（二）获取SKU信息

以下代码展示了如何调用JD.item_sku接口获取商品的SKU信息：

java

import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class JDItemSKUCrawler {
    private static final String API_URL = "https://api.jd.com/routerjson";
    private static final String APP_KEY = "YOUR_APP_KEY"; // 替换为你的AppKey
    private static final String APP_SECRET = "YOUR_APP_SECRET"; // 替换为你的AppSecret

    public static void main(String[] args) throws IOException {
        String itemId = "10335871600"; // 示例商品ID
        Map<String, String> skuInfo = getItemSKU(itemId);
        if (skuInfo != null) {
            System.out.println("商品名称: " + skuInfo.get("name"));
            System.out.println("商品图片URL: " + skuInfo.get("img"));
            System.out.println("价格: " + skuInfo.get("price"));
            System.out.println("库存: " + skuInfo.get("quantity"));
            System.out.println("SKU编号: " + skuInfo.get("sku_id"));
        }
    }

    public static Map<String, String> getItemSKU(String itemId) throws IOException {
        Map<String, String> params = new HashMap<>();
        params.put("app_key", APP_KEY);
        params.put("method", "jd.item.sku.info.get");
        params.put("v", "2.0");
        params.put("sign_method", "md5");
        params.put("timestamp", String.valueOf(System.currentTimeMillis()));
        params.put("item_id", itemId);

        String sign = JDSignUtil.generateSign(params, APP_SECRET);
        params.put("sign", sign);

        String url = buildRequestUrl(params);
        String response = sendHttpGetRequest(url);

        ObjectMapper objectMapper = new ObjectMapper();
        JsonNode rootNode = objectMapper.readTree(response);
        JsonNode itemNode = rootNode.path("item");

        Map<String, String> skuInfo = new HashMap<>();
        if (itemNode.has("name")) {
            skuInfo.put("name", itemNode.get("name").asText());
        }
        if (itemNode.has("img")) {
            skuInfo.put("img", itemNode.get("img").asText());
        }
        if (itemNode.has("price")) {
            skuInfo.put("price", itemNode.get("price").asText());
        }
        if (itemNode.has("quantity")) {
            skuInfo.put("quantity", itemNode.get("quantity").asText());
        }
        if (itemNode.has("sku_id")) {
            skuInfo.put("sku_id", itemNode.get("sku_id").asText());
        }

        return skuInfo;
    }

    private static String buildRequestUrl(Map<String, String> params) {
        StringBuilder urlBuilder = new StringBuilder(API_URL + "?");
        for (Map.Entry<String, String> entry : params.entrySet()) {
            urlBuilder.append(entry.getKey()).append("=").append(entry.getValue()).append("&");
        }
        return urlBuilder.toString();
    }

    private static String sendHttpGetRequest(String url) throws IOException {
        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
            HttpGet httpGet = new HttpGet(url);
            return httpClient.execute(httpGet, httpResponse -> EntityUtils.toString(httpResponse.getEntity()));
        }
    }
}