Android
RxJava로 Retrofit2
수색…
RxJava로 Retrofit2
먼저 build.gradle 파일에 관련 종속성을 추가하십시오.
dependencies {
....
compile 'com.squareup.retrofit2:retrofit:2.3.0'
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
compile 'com.squareup.retrofit2:adapter-rxjava:2.3.0'
....
}
그런 다음 수신하려는 모델을 만드십시오.
public class Server {
public String name;
public String url;
public String apikey;
public List<Site> siteList;
}
원격 서버와 데이터를 교환하는 데 사용되는 메소드를 포함하는 인터페이스를 작성하십시오.
public interface ApiServerRequests {
@GET("api/get-servers")
public Observable<List<Server>> getServers();
}
그런 다음 Retrofit 인스턴스를 만듭니다.
public ApiRequests DeviceAPIHelper ()
{
Gson gson = new GsonBuilder().create();
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("http://example.com/")
.addConverterFactory(GsonConverterFactory.create(gson))
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.build();
api = retrofit.create(ApiServerRequests.class);
return api;
}
그런 다음 코드에서 아무 곳이나 메서드 호출 :
apiRequests.getServers()
.subscribeOn(Schedulers.io()) // the observable is emitted on io thread
.observerOn(AndroidSchedulers.mainThread()) // Methods needed to handle request in background thread
.subscribe(new Subscriber<List<Server>>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(List<Server> servers) {
//A list of servers is fetched successfully
}
});
데이터를 비동기 적으로 가져 오는 RxJava로 개조
RxJava의 GitHub 레포 에서 RxJava는 관찰 가능한 시퀀스를 사용하여 비동기 및 이벤트 기반 프로그램을 구성하는 라이브러리 인 Reactive Extensions의 Java VM 구현입니다. 관찰자 패턴을 확장하여 데이터 / 이벤트 시퀀스를 지원하고 선언적으로 함께 시퀀스를 작성하고 저레벨 스레딩, 동기화, 스레드 안전성 및 동시 데이터 구조와 같은 것에 대한 우려를 없애는 연산자를 추가합니다.
Retrofit 은 Android 및 Java 용 유형 안전 HTTP 클라이언트입니다.이를 사용하면 개발자가 모든 네트워크 작업을 훨씬 쉽게 할 수 있습니다. 예를 들어 JSON을 다운로드하여 RecyclerView에 목록으로 표시합니다.
시작하기:
RxJava, RxAndroid 및 Retrofit 종속성을 앱 수준 build.gradle 파일에 추가합니다. compile "io.reactivex:rxjava:1.1.6"
compile "io.reactivex:rxandroid:1.2.1"
compile "com.squareup.retrofit2:adapter-rxjava:2.0.2"
compile "com.google.code.gson:gson:2.6.2"
compile "com.squareup.retrofit2:retrofit:2.0.2"
compile "com.squareup.retrofit2:converter-gson:2.0.2"
ApiClient 및 ApiInterface를 정의하여 서버에서 데이터 교환
public class ApiClient {
private static Retrofit retrofitInstance = null;
private static final String BASE_URL = "https://api.github.com/";
public static Retrofit getInstance() {
if (retrofitInstance == null) {
retrofitInstance = new Retrofit.Builder()
.baseUrl(BASE_URL)
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.build();
}
return retrofitInstance;
}
public static <T> T createRetrofitService(final Class<T> clazz, final String endPoint) {
final Retrofit restAdapter = new Retrofit.Builder()
.baseUrl(endPoint)
.build();
return restAdapter.create(clazz);
}
public static String getBaseUrl() {
return BASE_URL;
}}
공용 인터페이스 ApiInterface {
@GET("repos/{org}/{repo}/issues")
Observable<List<Issue>> getIssues(@Path("org") String organisation,
@Path("repo") String repositoryName,
@Query("page") int pageNumber);}
getRepos ()는 문제 목록뿐만 아니라 Observable을 반환한다는 점에 유의하십시오.
모델 정의
이에 대한 예가 표시됩니다. JsonSchema2Pojo 또는 이와 같은 무료 서비스를 사용할 수 있습니다.
public class Comment {
@SerializedName("url")
@Expose
private String url;
@SerializedName("html_url")
@Expose
private String htmlUrl;
//Getters and Setters
}
개조 인스턴스 생성
ApiInterface apiService = ApiClient.getInstance().create(ApiInterface.class);
그런 다음이 인스턴스를 사용하여 서버에서 데이터를 가져옵니다.
Observable<List<Issue>> issueObservable = apiService.getIssues(org, repo, pageNumber);
issueObservable.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.map(issues -> issues) //get issues and map to issues list
.subscribe(new Subscriber<List<Issue>>() {
@Override
public void onCompleted() {
Log.i(TAG, "onCompleted: COMPLETED!");
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "onError: ", e);
}
@Override
public void onNext(List<Issue> issues) {
recyclerView.setAdapter(new IssueAdapter(MainActivity.this, issues, apiService));
}
});
이제 Retrofit 및 RxJava를 사용하여 서버에서 데이터를 성공적으로 가져 왔습니다.
중첩 된 요청 예 : 여러 요청, 결과 결합
단일 요청 ( getAllPets )에서 객체 메타 데이터를 가져올 수있는 API와 단일 리소스의 전체 데이터 ( getSinglePet )가있는 다른 요청을 가질 수 있다고 가정 해 보겠습니다. 단일 체인에서 어떻게 모든 쿼리를 수행 할 수 있습니까?
public class PetsFetcher {
static class PetRepository {
List<Integer> ids;
}
static class Pet {
int id;
String name;
int weight;
int height;
}
interface PetApi {
@GET("pets") Observable<PetRepository> getAllPets();
@GET("pet/{id}") Observable<Pet> getSinglePet(@Path("id") int id);
}
PetApi petApi;
Disposable petsDisposable;
public void requestAllPets() {
petApi.getAllPets()
.doOnSubscribe(new Consumer<Disposable>() {
@Override public void accept(Disposable disposable) throws Exception {
petsDisposable = disposable;
}
})
.flatMap(new Function<PetRepository, ObservableSource<Integer>>() {
@Override
public ObservableSource<Integer> apply(PetRepository petRepository) throws Exception {
List<Integer> petIds = petRepository.ids;
return Observable.fromIterable(petIds);
}
})
.flatMap(new Function<Integer, ObservableSource<Pet>>() {
@Override public ObservableSource<Pet> apply(Integer id) throws Exception {
return petApi.getSinglePet(id);
}
})
.toList()
.toObservable()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<List<Pet>>() {
@Override public void accept(List<Pet> pets) throws Exception {
//use your pets here
}
}, new Consumer<Throwable>() {
@Override public void accept(Throwable throwable) throws Exception {
//show user something goes wrong
}
});
}
void cancelRequests(){
if (petsDisposable!=null){
petsDisposable.dispose();
petsDisposable = null;
}
}
}