ดาวน์โหลด rxhttp - ดาวน์โหลดซอร์สโค้ด rxhttp

rxhttp

ซอร์สโค้ดอื่น ๆ

3.3.1

ดาวน์โหลด

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 } "> //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 } "> RxHttp . get ( "/server/.." ) . add ( "key" , "value" ) . toFlow < User >() . catch { //Failure }. collect { //Success }	() .subscribe({ //Success }, { //Failure }) "> RxHttp . get ( "/server/.." ) . add ( "key" , "value" ) . toObservable < User >() . subscribe ({ //Success }, { //Failure })	{ //Success }, throwable -> { //Failure }) "> RxHttp . get ( "/server/.." ) . add ( "key" , "value" ) . toObservable ( User . class ) . subscribe ( user - > { //Success }, throwable -> { //Failure })

รอก่อน

ไหล

RxJava
(คอตลิน)

RxJava
(ชวา)

()
    .await() 

//or awaitResult return kotlin.Result
RxHttp.get("/server/..")
    .add("key", "value")
    .toAwait()  
    .awaitResult { 
        //Success
    }.onFailure {  
        //Failure
    } "> //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 } ">

 RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toFlow < User >()  
    . catch { 
        //Failure
    }. collect {  
        //Success
    }

() .subscribe({ //Success }, { //Failure }) ">

 RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toObservable < User >()  
    . subscribe ({ 
        //Success
    }, {  
        //Failure
    })

{ //Success }, throwable -> { //Failure }) ">

 RxHttp . get ( "/server/.." )
    . add ( "key" , "value" )
    . toObservable ( User . class )  
    . subscribe ( user - > { 
        //Success
    }, throwable -> {  
        //Failure
    })

1、คุณสมบัติ

สนับสนุน kotlin coroutines, 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.RxJava

RxHttp + RxJava3

 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

RxHttp + RxJava2

 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 pass

 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"> // 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">

 //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 เวอร์ชัน 2.2.8 หรือสูงกว่า กฎการย่อและการสร้างความสับสนจะถูกรวมไว้โดยอัตโนมัติ มิฉะนั้นคุณจะต้องเพิ่มตัวเลือกใน rxhttp.pro ด้วยตนเอง

5、การบริจาค

หากโครงการนี้ช่วยคุณได้มากและคุณต้องการสนับสนุนการพัฒนาและบำรุงรักษาโครงการนี้ โปรดสแกนรหัส QR ต่อไปนี้เพื่อบริจาค การบริจาคของคุณได้รับการชื่นชมอย่างมาก ขอบคุณ!

ใบอนุญาต

 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.

ขยาย

ข้อมูลเพิ่มเติม