Java中REST API JSON数组的获取与处理实践

import com.google.gson.annotations.Expose;
import com.google.gson.annotations.SerializedName;
import java.io.Serializable;

public class Cosmetic implements Serializable {
    @SerializedName("_id")
    @Expose
    private String id;

    @SerializedName("code")
    @Expose
    private String code;

    // 其他属性...

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getCode() {
        return code;
    }

    public void setCode(String code) {
        this.code = code;
    }

    // 其他属性的getter和setter方法...

    @Override
    public String toString() {
        return "Cosmetic{" +
               "id='" + id + '\'' +
               ", code='" + code + '\'' +
               '}';
    }
}

import io.reactivex.Single;
import java.util.List;
import retrofit2.http.GET;
import retrofit2.http.Query;

public interface CosmeticsService {

    // 获取单个Cosmetic对象（如果API返回单个对象）
    @GET("/prod/beauty/{field}")
    Single<Cosmetic> getByName(@Query("query") String query);

    // 获取Cosmetic对象列表（API返回JSON数组）
    @GET("/prod/beauty/search")
    Single<List<Cosmetic>> searchCosmetics(@Query("query") String query);
}

import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;

public class RetrofitClient {

    private static Retrofit retrofit;
    private static final String BASE_URL = "http://your.api.base.url/"; // 替换为你的API基础URL

    public static Retrofit getRetrofitInstance() {
        if (retrofit == null) {
            retrofit = new Retrofit.Builder()
                    .baseUrl(BASE_URL)
                    .addConverterFactory(GsonConverterFactory.create()) // 添加Gson转换器
                    .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) // 添加RxJava2适配器
                    .build();
        }
        return retrofit;
    }

    public static CosmeticsService getCosmeticsService() {
        return getRetrofitInstance().create(CosmeticsService.class);
    }
}

import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;
import io.reactivex.observers.DisposableSingleObserver;
import io.reactivex.schedulers.Schedulers;
import java.util.List;

public class ApiCaller {

    private CompositeDisposable compositeDisposable = new CompositeDisposable();

    public void fetchCosmeticsArray(String query) {
        CosmeticsService service = RetrofitClient.getCosmeticsService();

        service.searchCosmetics(query)
                .subscribeOn(Schedulers.io()) // 在IO线程执行网络请求
                .observeOn(AndroidSchedulers.mainThread()) // 在主线程观察结果
                .subscribe(new DisposableSingleObserver<List<Cosmetic>>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        compositeDisposable.add(d); // 添加到Disposable管理，以便在不再需要时取消订阅
                    }

                    @Override
                    public void onSuccess(List<Cosmetic> cosmeticList) {
                        System.out.println("API响应成功，获取到 " + cosmeticList.size() + " 个美妆品。");
                        for (Cosmetic cosmetic : cosmeticList) {
                            System.out.println("Cosmetic Code: " + cosmetic.getCode());
                            // 在这里处理每个Cosmetic对象
                        }
                        // 更新UI或进行其他业务逻辑
                    }

                    @Override
                    public void onError(Throwable e) {
                        System.err.println("API请求失败: " + e.getMessage());
                        e.printStackTrace();
                        // 处理错误，例如显示错误消息给用户
                    }
                });
    }

    // 在Activity/Fragment/组件销毁时调用，防止内存泄漏
    public void dispose() {
        if (compositeDisposable != null && !compositeDisposable.isDisposed()) {
            compositeDisposable.dispose();
        }
    }

    public static void main(String[] args) {
        // 示例调用 (在实际Android应用中，这会在Activity/Fragment的生命周期方法中调用)
        ApiCaller caller = new ApiCaller();
        caller.fetchCosmeticsArray("lipstick");
        // 为了演示，这里可能需要一个短暂的等待或者一个模拟的Android Looper
        // 在实际应用中，结果会在onSuccess回调中异步处理
        // caller.dispose(); // 适当的时机调用
    }
}