الصفحة الرئيسية>المتعلقة بالبرمجة>شفرة المصدر الأخرى
تنزيل

RxHttp

الإنجليزية | 中文文档

(RxHttp 3.0 أحدث، تم تطويره)

عميل HTTP الآمن للنوع لنظام Android. مكتوب على أساس OkHttp

انتظر تدفق RxJava
(كوتلين)		 RxJava
(جافا)
() .await() //or awaitResult return kotlin.Result RxHttp.get("/server/..") .add("key", "value") .toAwait() .awaitResult { //Success }.onFailure { //Failure } " style=";text-align:right;direction:rtl">
 //await return User
//tryAwait return User?
val user = RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toAwait < User >()
    . await () 

//or awaitResult return kotlin.Result
RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toAwait < User >()  
    . awaitResult { 
        //Success
    }. onFailure {  
        //Failure
    }
() .catch { //Failure }.collect { //Success } " style=";text-align:right;direction:rtl">
 RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toFlow < User >()  
    . catch { 
        //Failure
    }. collect {  
        //Success
    }
() .subscribe({ //Success }, { //Failure }) " style=";text-align:right;direction:rtl">
 RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toObservable < User >()  
    . subscribe ({ 
        //Success
    }, {  
        //Failure
    })
{ //Success }, throwable -> { //Failure }) " style=";text-align:right;direction:rtl">
 RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toObservable ( User . class )  
    . subscribe ( user - > { 
        //Success
    }, throwable -> {  
        //Failure
    })

1 、 الميزة

  • دعم coroutines kotlin، RxJava2، RxJava3

  • دعم Gson وXml وProtoBuf وFastJson وأدوات تحليل بيانات الطرف الثالث الأخرى

  • يدعم الإغلاق التلقائي للطلبات في FragmentActivity وFragment وView وViewModel وأي فئة

  • دعم التشفير وفك التشفير العالمي، وإضافة معلمات ورؤوس مشتركة، وذاكرة التخزين المؤقت للشبكة، وكلها تدعم طلبًا تم إعداده بشكل منفصل

2 、 الاستخدام

1 、 إضافة التبعيات والتكوينات

مطلوب

1、أضف jitpack إلى build.gradle الخاص بك 
 allprojects {
    repositories {
        maven { url "https://jitpack.io" }
    }
}
2 、 جافا 8 أو أعلى 
 android {
    compileOptions {
        sourceCompatibility JavaVersion . VERSION_1_8
        targetCompatibility JavaVersion . VERSION_1_8
    }
}
3 、 إضافة تبعية RxHttp 
plugins {
    // kapt/ksp choose one
    // id 'kotlin-kapt'
    id ' com.google.devtools.ksp ' version ' 1.9.23-1.0.19 '
}
    
dependencies {
    def rxhttp_version = ' 3.3.0 '
    implementation ' com.squareup.okhttp3:okhttp:4.12.0 '  
    implementation " com.github.liujingxing.rxhttp:rxhttp: $rxhttp_version "
    // ksp/kapt/annotationProcessor choose one
    ksp " com.github.liujingxing.rxhttp:rxhttp-compiler: $rxhttp_version "
 }

خياري

1 、 محول 

implementation " com.github.liujingxing.rxhttp:converter-serialization: $rxhttp_version "
implementation " com.github.liujingxing.rxhttp:converter-fastjson: $rxhttp_version "
implementation " com.github.liujingxing.rxhttp:converter-jackson: $rxhttp_version "
implementation " com.github.liujingxing.rxhttp:converter-moshi: $rxhttp_version "
implementation " com.github.liujingxing.rxhttp:converter-protobuf: $rxhttp_version "
implementation " com.github.liujingxing.rxhttp:converter-simplexml: $rxhttp_version "

2-آر إكس جافا

آر إكس هتب + آر إكس جافا 3 
 implementation 'io.reactivex.rxjava3:rxjava:3.1.6'
implementation 'io.reactivex.rxjava3:rxandroid:3.0.2'
implementation 'com.github.liujingxing.rxlife:rxlife-rxjava3:2.2.2' //RxJava3, Automatic close request
آر إكس هتب + آر إكس جافا 2 
 implementation 'io.reactivex.rxjava2:rxjava:2.2.8'
implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
implementation 'com.github.liujingxing.rxlife:rxlife-rxjava2:2.2.2' //RxJava2, Automatic close request
ksp يمرر إصدار RxJava 
 ksp {
    arg ( "rxhttp_rxjava" , "3.1.6" )
}
Kapt يمرر إصدار RxJava 
 kapt {
    arguments {
        arg ( "rxhttp_rxjava" , "3.1.6" )
    }
}
javaCompileOptions يمرر إصدار RxJava 
 android {
    defaultConfig {
        javaCompileOptions {
            annotationProcessorOptions {
                arguments = [
                    rxhttp_rxjava : '3.1.6' , 
                ]
            }
        }
    }
}

3. قم بتعيين اسم حزمة فئة RxHttp

اسم حزمة تمرير ksp 
 ksp {
     arg ( "rxhttp_package" , "rxhttp.xxx" )
}
اسم الحزمة kapt pass 
 kapt {
    arguments {
       arg ( "rxhttp_package" , "rxhttp.xxx" ) 
    }
}
javaCompileOptions يمرر اسم الحزمة 
 android {
    defaultConfig {
        javaCompileOptions {
            annotationProcessorOptions {
                arguments = [
                    rxhttp_package : 'rxhttp.xxx'
                ]
            }
        }
    }
}

وأخيرا، إعادة بناء المشروع، وهو أمر ضروري

2، تهيئة SDK

هذه الخطوة اختيارية 

 RxHttpPlugins . init ( OkHttpClient )  
    . setDebug ( boolean )  
    . setOnParamAssembly ( Consumer )
    ....

3-التكوين BaseUrl

هذه الخطوة اختيارية 

 public class Url {

    //Add the @defaultDomain annotation to BASE_URL
    @ DefaultDomain
    public static BASE_URL = "https://..."
}

4- تنفيذ المطلوب

{ //3、Subscribing observer //Success callback，Default IO thread }, throwable -> { //Abnormal callback }); // kotlin RxHttp.postForm("/service/...") //post FormBody .add("key", "value") //add param to body .addQuery("key1", "value1") //add query param .addFile("file", File(".../1.png")) //add file to body .toObservable() .subscribe({ student -> //Default IO thread }, { throwable -> }) // kotlin coroutine val students = RxHttp.postJson("/service/...") //1、post {application/json; charset=utf-8} .toAwaitList() //2、Use the toXxx method to determine the return value type, customizable .await() //3、Get the return value, await is the suspend method" style=";text-align:right;direction:rtl">
 // java
RxHttp . get ( "/service/..." )   //1、You can choose get,postFrom,postJson etc
    . addQuery ( "key" , "value" )               //add query param
    . addHeader ( "headerKey" , "headerValue" )  //add request header
    . toObservable ( Student . class )  //2、Use the toXxx method to determine the return value type, customizable
    . subscribe ( student -> {  //3、Subscribing observer
        //Success callback，Default IO thread
    }, throwable -> {
        //Abnormal callback
    });

// kotlin 
RxHttp . postForm ( "/service/..." )          //post FormBody
    . add ( "key" , "value" )                 //add param to body
    . addQuery ( "key1" , "value1" )          //add query param
    . addFile ( "file" , File ( ".../1.png" ))  //add file to body
    . toObservable < Student >()           
    . subscribe ({ student ->       
        //Default IO thread
    }, { throwable ->
        
    })

// kotlin coroutine
val students = RxHttp . postJson ( "/service/..." )  //1、post {application/json; charset=utf-8}
    . toAwaitList < Student >()                          //2、Use the toXxx method to determine the return value type, customizable
    . await ()                                    //3、Get the return value, await is the suspend method

3 、 الاستخدام المتقدم

1- إغلاق الطلب

{ //Default IO thread }, throwable -> { }); //In Rxjava3 , Automatic close request RxHttp.get("/service/...") .toObservableString() .to(RxLife.to(this)) //The Activity destroys and automatically closes the request .subscribe(s -> { //Default IO thread }, throwable -> { }); //In RxJava2/RxJava3, close the request manually Disposable disposable = RxHttp.get("/service/...") .toObservableString() .subscribe(s -> { //Default IO thread }, throwable -> { }); disposable.dispose(); //Close the request at the appropriate time" style=";text-align:right;direction:rtl">
 //In Rxjava2 , Automatic close request
RxHttp . get ( "/service/..." )
    . toObservableString ()
    . as ( RxLife . as ( this ))  //The Activity destroys and automatically closes the request
    . subscribe ( s -> {
        //Default IO thread
    }, throwable -> {

    });

//In Rxjava3 , Automatic close request
RxHttp . get ( "/service/..." )
    . toObservableString ()
    . to ( RxLife . to ( this ))  //The Activity destroys and automatically closes the request
    . subscribe ( s -> {
        //Default IO thread
    }, throwable -> {
        
    });


//In RxJava2/RxJava3, close the request manually
Disposable disposable = RxHttp . get ( "/service/..." )
    . toObservableString ()
    . subscribe ( s -> {
        //Default IO thread
    }, throwable -> {
        
    });

disposable . dispose (); //Close the request at the appropriate time

4 、 بروجارد

إذا كنت تستخدم RxHttp v2.2.8 أو أعلى، فسيتم تضمين قواعد التقليص والتشويش تلقائيًا. وإلا فيجب عليك إضافة الخيارات يدويًا في rxhttp.pro.

5 、 التبرعات

إذا كان هذا المشروع يساعدك كثيرًا وترغب في دعم تطوير المشروع وصيانته، فلا تتردد في مسح رمز الاستجابة السريعة التالي للتبرع. تبرعك محل تقدير كبير. شكرًا لك!

التراخيص 

 Copyright 2019 liujingxing

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
يوسع
معلومات إضافية
تطبيقات ذات صلة
نوصي لك
أخبار ذات صلة الكل
تعليقات المستخدمين