Java基于API接口爬取商品数据的示例代码

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
public class APICaller {
    public static String callAPI(String apiUrl) {
        try {
            URL url = new URL(apiUrl);
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            connection.setRequestMethod("GET");
            connection.setRequestProperty("Accept", "application/json");
            int responseCode = connection.getResponseCode();
            if (responseCode == HttpURLConnection.HTTP_OK) {
                BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
                String line;
                StringBuilder response = new StringBuilder();
                while ((line = reader.readLine()) != null) {
                    response.append(line);
                }
                reader.close();
                return response.toString();
            } else {
                return null;
            }
        } catch (Exception e) {
            return null;
        }
    }
}

import com.google.gson.Gson;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import java.util.Map;
public class JSONParser {
    public static Map<String, String> parseJSON(String jsonString) {
        JsonParser parser = new JsonParser();
        JsonElement jsonElement = parser.parse(jsonString);
        JsonObject jsonObject = jsonElement.getAsJsonObject();
        Gson gson = new Gson();
        Map<String, String> map = gson.fromJson(jsonObject, Map.class);
        return map;
    }
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Map;
```java

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Map;   public class ProductCrawler {   public static void main(String[] args) {       String apiUrl = "https://api.example.com/products";       String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";       String username = "root";       String password = "password";       try {           // 请求API接口获取商品数据           String jsonString = APICaller.callAPI(apiUrl);           // 解析JSON数据           Map<String, String> productMap = JSONParser.parseJSON(jsonString);           // 存储数据到MySQL数据库           Connection connection = DriverManager.getConnection(jdbcUrl, username, password);           String sql = "INSERT INTO products