网站维护要什么做移动端网站软件

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

网站维护要什么,做移动端网站软件,个人简历网页设计代码,市场营销专业课程一、okHttp的同步和异步请求 Call 是 OkHttp 的核心接口#xff0c;代表一个已准备好执行的 HTTP 请求。它支持 同步 和 异步 两种模式#xff1a; enqueue——okHttp异步 OkHttpClient client new OkHttpClient();Request request new Request.Builder().url(…一、okHttp的同步和异步请求 Call 是 OkHttp 的核心接口代表一个已准备好执行的 HTTP 请求。它支持 同步 和 异步 两种模式 enqueue——okHttp异步 OkHttpClient client new OkHttpClient();Request request new Request.Builder().url(https://example.com).build();client.newCall(request).enqueue(new Callback() {Overridepublic void onResponse(Call call, Response response) throws IOException {System.out.println(Response: response.body().string());}Overridepublic void onFailure(Call call, IOException e) {System.err.println(Request failed: e.getMessage());} }); execute——同步请求 特点 阻塞线程 请求发送后当前线程会阻塞直到服务器返回响应或超时。 直接返回结果 通过 execute() 方法直接返回 Response 对象无需回调。 线程管理 不能在主线程中执行否则会触发 NetworkOnMainThreadException 异常。同步请求必须在后台线程中执行可以使用 Thread、ExecutorService 或 RxJava 等工具管理线程。 资源释放 Response 对象实现了 Closeable 接口使用 try-with-resources 语法确保资源释放。 超时设置 默认超时为 10 秒可通过 OkHttpClient.Builder 自定义
OkHttpClient client new OkHttpClient();Request request new Request.Builder().url(https://example.com).build(); try (Response response client.newCall(request).execute()) {if (response.isSuccessful()) {System.out.println(Response: response.body().string());} else {System.err.println(Request failed: response.code());} } catch (IOException e) {System.err.println(Request error: e.getMessage()); } ExecutorService executor Executors.newSingleThreadExecutor(); executor.execute(() - {try (Response response client.newCall(request).execute()) {if (response.isSuccessful()) {System.out.println 特性同步请求execute异步请求enqueue线程阻塞阻塞当前线程直到请求完成不阻塞线程后台执行结果获取直接返回 Response 对象通过 Callback 回调处理结果线程管理需手动管理线程避免主线程阻塞自动在后台线程执行主线程无影响适用场景需立即获取结果的场景如单元测试需异步处理的场景如网络请求 二、okHttpRxjava ObservableResponse observable Observable.create(emitter - {Call call client.newCall(request);call.enqueue(new Callback() {Overridepublic void onResponse(Call call, Response response) {if (!emitter.isDisposed()) {emitter.onNext(response);emitter.onComplete();}}Overridepublic void onFailure(Call call, IOException e) {if (!emitter.isDisposed()) {emitter.onError(e);}}});emitter.setCancellable(call::cancel); });observable.subscribeOn(Schedulers.io()) // 在 IO 线程执行.observeOn(AndroidSchedulers.mainThread()) // 在主线程处理结果.subscribe(new ObserverResponse() {Overridepublic void onSubscribe(Disposable d) {// 订阅时调用}Overridepublic void onNext(Response response) {System.out.println(Response: response.body().string());}Overridepublic void onError(Throwable e) {System.err.println(Error: e.getMessage());}Overridepublic void onComplete() {// 请求完成时调用}}); 二、Retrofit 的同步与异步用法用Call发起请求 Retrofit 内部使用 OkHttp 作为 HTTP 客户端这意味着在 Retrofit 的配置中你可以定制 OkHttp 的各种参数如超时设置、拦截器等。 为了更好地支持异步编程Retrofit 提供了 RxJava 的 CallAdapter。通过这个适配器你可以让 API 接口直接返回 Observable、Single 等 RxJava 类型从而使用 RxJava 的强大操作符来处理请求结果和错误。 public interface ApiService {GET(users)CallListUser getUsers(); } Retrofit retrofit new Retrofit.Builder().baseUrl(https://api.example.com/).addConverterFactory(GsonConverterFactory.create()) // 使用 Gson 进行 JSON 转换.build();ApiService apiService retrofit.create(ApiService.class);Retrofit同步请求 需在子线程中调用否则会触发 NetworkOnMainThreadException new Thread(new Runnable() {Overridepublic void run() {try {CallListUser call apiService.getUsers();ResponseListUser response call.execute();if (response.isSuccessful() response.body() ! null) {ListUser users response.body();// 处理返回的数据} else {Log.e(Retrofit, Response error: response.code());}} catch (IOException e) {e.printStackTrace();}} }).start();Retrofit异步请求 CallListUser call apiService.getUsers(); call.enqueue(new CallbackListUser() {Overridepublic void onResponse(CallListUser call, ResponseListUser response) {if (response.isSuccessful() response.body() ! null) {ListUser users response.body();// 处理返回的数据比如更新 UI} else {// 请求成功但是服务器返回错误码比如 404、500 等Log.e(Retrofit, Response error: response.code());}}Overridepublic void onFailure(CallListUser call, Throwable t) {// 请求失败比如网络错误或解析错误Log.e(Retrofit, Request failed, t);} });三、Retrofit RxJava 的同步/异步与线程统一处理用Observable发起请求 Observable 是 RxJava 的响应式编程模型用于处理异步数据流。其优势包括 链式调用通过操作符如 map、flatMap简化复杂逻辑。线程调度通过 subscribeOn 和 observeOn 控制线程切换。错误处理通过 onErrorReturn 或 retry 实现容错。 同步请求 public interface ApiService {GET(users/{id})ObservableUser getUserRx(Path(id) int id); // 返回 Observable }apiService.getUserRx(1).subscribeOn(Schedulers.io()) // 指定请求线程.observeOn(Schedulers.io()) // 指定响应处理线程.blockingSubscribe(user - {// 同步阻塞获取结果}); 异步请求 // 1. 定义 API 接口使用 RxJava 的 Observable 作为返回类型 public interface ApiService {GET(users)ObservableListUser getUsers(); }// 2. 配置 OkHttp 客户端可添加拦截器、日志打印等 OkHttpClient okHttpClient new OkHttpClient.Builder()// 例如添加日志拦截器// .addInterceptor(new HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BODY)).build();// 3. 配置 Retrofit同时添加 Gson 转换器和 RxJava 适配器 Retrofit retrofit new Retrofit.Builder().baseUrl(https://api.example.com/).client(okHttpClient).addConverterFactory(GsonConverterFactory.create()) // JSON 数据解析.addCallAdapterFactory(RxJava2CallAdapterFactory.create()) // RxJava 适配器.build();// 4. 创建 API 服务实例 ApiService apiService retrofit.create(ApiService.class);// 5. 使用 RxJava 进行网络请求 apiService.getUsers().subscribeOn(Schedulers.io()) // 在 IO 线程执行网络请求.observeOn(AndroidSchedulers.mainThread()) // 在主线程处理返回结果.subscribe(users - {// 成功回调处理用户数据}, throwable - {// 错误回调处理异常情况});方案线程管理代码复杂度适用场景OkHttp 原生手动切换低简单请求、低耦合场景Retrofit 原生手动切换中接口化请求、中等复杂度RetrofitRxJava自动统一管理高复杂异步流、高可维护性 四、具体使用RetrofitRxJava // 1. 定义服务接口 public interface UserService {POST(/user/{userId}/profile)ObservableBaseResponseUserProfile updateProfile(Path(userId) String userId,Body ProfileParams params); }// 2. 发起请求 NetworkApi.createService(UserService.class, ServiceType.User.name()).updateProfile(123, new ProfileParams(Kimi, avatar.jpg)).compose(NetworkApi.applySchedulers()).subscribe(new BaseObserverUserProfile() {Overridepublic void onSuccess(UserProfile profile) {// 更新UI}Overridepublic void onBusinessError(int code, String msg) {// 显示错误提示}}); 设计优势 责任链模式每个方法专注单一职责创建→配置→调度→响应类型安全通过泛型确保数据模型一致性异常隔离BaseObserver集中处理网络/业务异常线程透明applySchedulers()隐藏线程切换细节 该模式常见于需要支持多环境、多服务类型的现代移动应用架构特别适合企业级应用开发中需要统一管理API请求的场景。 这是典型的RetrofitRxJava组合的网络请求链式调用写法结合了工厂模式、建造者模式和响应式编程思想。其核心结构可分为四个关键部分 1.服务实例创建 NetworkApi.createService(ApiService.class, ServiceType.License.name()) NetworkApi是自定义的工厂类封装了Retrofit实例的创建过程createService()方法通过动态代理生成ApiService接口的实现类ServiceType.License.name()指定服务类型通常用于动态配置baseUrl如区分认证服务、业务服务等 2.具体API操作 .action(id, params) action()对应ApiService接口中定义的端点方法 POST(/api/{serviceType}/actions) ObservableBaseResponseT action(Path(serviceType) String serviceType,Body ActionParams params ); id参数可能用于路径替换Path注解params作为请求体Body注解 3.线程调度组合 .compose(NetworkApi.applySchedulers(…)) compose()是RxJava的操作符统一应用线程切换规则applySchedulers()典型实现 4.观察者封装 new BaseObserverBaseResponseAccessConsentRecordDetailBean() 自定义的BaseObserver处理通用逻辑 public abstract class BaseObserverT implements ObserverT {Overridepublic void onError(Throwable e) {// 统一错误处理网络异常、业务异常等}Overridepublic void onNext(T response) {if (response.isSuccess()) {onSuccess(response.getData());} else {onBusinessError(response.getCode(), response.getMessage());}} } 五、Flowable与Observable Flowable与Observable是RxJava中两种核心的响应式数据流类型结合Retrofit使用时需要根据具体场景进行选型。以下是两者的核心区别及在Retrofit中的实践建议 类型特性Retrofit集成场景Observable无背压机制的异步数据流支持同步/异步操作适合轻量级请求简单API调用如获取用户信息、配置数据Flowable支持背压控制的响应式流内置5种策略处理生产消费速度差异大文件传输、实时数据推送等高并发场景 核心区别 1. 背压处理机制 Flowable 通过BackpressureStrategy配置策略ERROR/BUFFER/DROP/LATEST/MISSING在Retrofit中处理大数据流时需显式指定策略 GET(api/sensor-data) FlowableData getSensorData(Query(deviceId) String id); // 默认使用ERROR策略5 Observable 无背压控制Retrofit接口直接返回Observable时需确保数据量可控否则可能引发OOM 2. 线程模型 Flowable 强制异步订阅Retrofit需配合subscribeOn(Schedulers.io())使用 api.getSensorData(DEV001).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) Observable 支持同步调用适合快速响应的本地缓存查询 GET(api/profile) ObservableUser getUserProfile(); // 同步获取用户数据9 3. 性能表现 Flowable 因背压检测机制吞吐量比Observable低约15-30%但内存更安全Observable 无额外性能损耗适合高频低数据量请求如按钮点击事件统计 4.集成实现 BUFFER文件下载需注意内存监控 Flowable.create(emitter - {…}, BackpressureStrategy.BUFFER) DROP实时股票行情推送丢弃过时数据LATEST即时聊天消息保留最新消息 5.错误处理对比 Observable需手动捕获异常 .subscribe(data - {…},error - { // 需处理所有异常 } ) Flowable通过onBackpressureXXX操作符自动处理 .onBackpressureDrop(dropped - log(丢弃数据 dropped)) 性能优化建议 混合使用策略 对核心业务接口使用FlowableBUFFER策略非核心功能使用Observable 动态缓存控制 通过rx2.buffer-size参数调整Flowable缓存池 System.setProperty(rx2.buffer-size, 256); // 默认1287 生命周期管理 使用CompositeDisposable统一释放资源 CompositeDisposable disposables new CompositeDisposable();disposables.add(api.getDataStream().subscribe(data - {…}));
通过合理选择Flowable与Observable可使Retrofit网络层在保证稳定性的同时获得最佳性能。可以在金融交易、物联网等高频场景优先采用Flowable而在常规业务API中使用Observable以降低复杂度。