OkHttp+Retrofit 使用示例

1dependencies {2	...3 	// rxandroid4    api 'io.reactivex.rxjava2:rxandroid:2.1.1'5    api 'io.reactivex.rxjava2:rxjava:2.2.19'6    // okhttp7    api 'com.squareup.okhttp3:okhttp:4.11.0'8    api 'com.squareup.okio:okio:3.2.0'9    api 'com.squareup.okhttp3:logging-interceptor:4.12.0'10    // retrofit11    api 'com.squareup.retrofit2:retrofit:2.9.0'12    api 'com.squareup.retrofit2:converter-moshi:2.9.0'13    api 'com.squareup.retrofit2:adapter-rxjava2:2.9.0'14    api 'com.squareup.retrofit2:converter-gson:2.9.0'15}

1/**2 * @Des OkHttp 配置3 * @Author lipengfei4 * @Date 2023/11/27 18:065 */6public class OkHttpFamily {7    private static final String TAG = OkHttpFamily.class.getSimpleName();8    private static volatile OkHttpClient API;9 10    private OkHttpFamily() {11    }12 13    public static OkHttpClient API() {14        if (null == API) {15            synchronized (TAG) {16                if (null == API) {17                    HttpLoggingInterceptor logging = new HttpLoggingInterceptor();18                    logging.setLevel(HttpLoggingInterceptor.Level.BODY);19                    OkHttpClient.Builder builder = new OkHttpClient.Builder();20                    builder.connectTimeout(15L, TimeUnit.SECONDS)21                            .writeTimeout(15L, TimeUnit.SECONDS)22                            .readTimeout(15L, TimeUnit.SECONDS);23                    builder.addInterceptor(logging);24                    for (Interceptor interceptor : HttpConfig.INSTANCE.getConfig().getInterceptors()) {25                        builder.addInterceptor(interceptor);26                        Log.i(TAG, "addInterceptor" + interceptor.getClass().getSimpleName());27                    }28                    API = builder.build();29                }30            }31        }32        return API;33    }34}

1/**2 * @Des Retrofit 配置 [单例]3 * @Author lipengfei4 * @Date 2023/11/27 18:065 */6public class RetrofitFamily {7 8    private static Retrofit retrofit;9    // 使用 map 缓存已存在的10    private static final Map<Class<?>, Object> SERVICE_MAP = new ConcurrentHashMap<>();11 12    private RetrofitFamily() {13    }14 15    public static synchronized Retrofit getInstance() {16        if (null == retrofit) {17            retrofit = new Retrofit.Builder()18                    .client(OkHttpFamily.API())19                    .baseUrl(HttpConfig.INSTANCE.getConfig().getBaseUrl())20                    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())21                    .addConverterFactory(GsonConverterFactory.create())22                    .build();23        }24        return retrofit;25    }26 27    /**28     * 创建 Retrofit service。29     */30    public static <T> T createService(@NonNull Class<T> service) {31        T serviceImpl = (T) SERVICE_MAP.get(service);32        if (null == serviceImpl) {33            serviceImpl = createService(getInstance(), service);34            SERVICE_MAP.put(service, serviceImpl);35        }36        return serviceImpl;37    }38 39    private static <T> T createService(Retrofit retrofit, Class<T> service) {40        return retrofit.create(service);41    }42 43    /**44     * 切换环境后重置45     */46    static synchronized void reset() {47        retrofit = null;48        SERVICE_MAP.clear();49    }50}51 52 

1/**2 * @Des 请求配置统一管理3 * @Author lipengfei4 * @Date 2023/11/27 18:065 */6object HttpConfig {7 8    var config: Config? = null9 10    fun initConfig(config: Config) {11        this.config = config12    }13 14    class Config private constructor(val baseUrl: String, val interceptors: ArrayList<Interceptor>) {15        companion object {16            inline fun build(block: Builder.() -> Unit) = Builder().apply(block).build()17        }18 19        class Builder {20            var baseUrl: String = ""21            private val interceptors: ArrayList<Interceptor> = ArrayList()22            fun addInterceptor(interceptor: Interceptor) {23                interceptors.add(interceptor)24            }25 26            fun build() = Config(baseUrl, interceptors)27        }28    }29}

1class MyApplication : Application() {2    override fun onCreate() {3        super.onCreate()4        initHttpConfig()5    }6 7    private fun initHttpConfig() {8        val config = HttpConfig.Config.build {9			// 设置 baseUrl10            this.baseUrl = ConfigC.PEXELS_BASE_URL11			// 设置 拦截器12            this.addInterceptor(CommonInterceptor())13        }14		// 需要在第一个接口请求发起之前配置，也可以做延迟处理15        HttpConfig.initConfig(config)16    }17}

1class RPhotosViewModel : BaseViewModel() {2    val photosLiveData = MutableLiveData<Result<List<Photo>>>()3    fun searchPhotos() {4        if (photosLiveData.value is Result.Loading) {5            return6        }7        photosLiveData.value = Result.Loading8        compositeDisposable.add(9            RetrofitFamily.createService(PexelsApi::class.java)10                .searchPhotos("art", 1, ConstC.PAGE_COUNT_TEN).subscribeOn(Schedulers.io())11                .observeOn(AndroidSchedulers.mainThread())12                .subscribe({13                    debug("success: photos.size=${it.photos.size}")14                    photosLiveData.value = Result.Success(it.photos)15                }) { onError: Throwable? ->16                    error("fail:", onError)17                    photosLiveData.value = Result.Error(null, onError?.message)18                })19    }20}

1 viewModel.photosLiveData.observe(this) {2            when (it) {3                is Result.Loading -> {4                    showLoading()5                }6                is Result.Success -> {7                    hideLoading()8                    photoAdapter.setDatas(it.value)9                }10                is Result.Error, Result.NetworkError -> {11                    hideLoading()12                    toast("error")13                }14            }15        }