狠狠撸

O mnie
鈼� Maciej Puchalski
鈼� Entuzjasta Androida
鈼� Rowerzysta
鈼� SoftwareHUT

Agenda
鈼� Kod bez Retrofita
鈼� Om贸wienie podstaw Retrofita
鈼� Pokazanie wybranych zaawansowanych przyk艂ad贸w
鈼� Jak rozwin膮膰 Retrofita?

Kod do endpointa
String url =
"https://api.github.com/users/sennajavie/repos鈥�;
URL obj = new URL(url);
HttpURLConnection con =
(HttpURLConnection) obj.openConnection();
con.setRequestMethod("GET");

final HashMap<String, String> requestParams =
new HashMap<>();
requestParams.put("User-Agent","Mozilla/5.0");
requestParams.put("Content-Type","message");
Kod do endpointa.

BufferedReader in = new BufferedReader(...);
String data;
StringBuffer response = new StringBuffer();
while ((data = in.readLine()) != null) {
response.append(data);
}
Kod do endpointa鈥� czy to ju偶 koniec?

BufferedReader in = new BufferedReader(...);
String data;
StringBuffer response = new StringBuffer();
while ((data = in.readLine()) != null) {
response.append(data);
}
Kod do endpointa鈥︹€︹€�.
in.close();

Wkracza Retrofit
}
in.close();

Wkracza Retrofit
}@GET("users/{user}/repos")
Call<List<Repository>>
getReposList(@Path("user") String user);
in.close();

jSession #4 - Maciej Puchalski - Zaawansowany retrofit

interface ApiClient {
@GET("users/{user}/repos")
}
Kod do endpointa

GsonConverterFactory.create()
Endpoint - Sk膮d model?

鈼� Gson: com.squareup.retrofit2:converter-gson
鈼� Jackson: com.squareup.retrofit2:converter-jackson
鈼� Moshi: com.squareup.retrofit2:converter-moshi
鈼� Protobuf: com.squareup.retrofit2:converter-protobuf
鈼� Wire: com.squareup.retrofit2:converter-wire
鈼� Simple XML: com.squareup.retrofit2:converter-simplexml
Convertery

users/{user}/repos
vs
/users/{user}/repos
Endpoint - Co z tym URLem?

https://api.github.com/dummy/ + users/{user}/repos =
https://api.github.com/dummy/users/{user}/repos

https://api.github.com/dummy/ + /users/{user}/repos =
https://api.github.com/users/{user}/repos
dummy?

@GET
getReposList(@Url String url,
@Path("user") String user);
}
Endpoint URL bonus!

@FormUrlEncoded
@HTTP(method = "DELETE",
path = "users/{user}/repos",
hasBody = true)
Call<ResponseBody>
deleteRepo(@Body Repository repo,
@Field("Name") String value);
}
Endpoint - DELETE z BODY?!

@FormUrlEncoded
@POST("users/newUser")
Call<ResponseBody>
postNewUser(@Field("id") int id,
@Field("name") String name,
@Field("mail") String mail);
}
Kod do endpointa

@FormUrlEncoded
getReposList(@Path("user") String user,
@Field("id") int id,
@Header("lang") String lang);
}
Zaawansowany kod do endpointa

gson = GsonConverterFactory.create();
Retrofit retrofit = new Retrofit.Builder()
.addConverterFactory(gson)
.baseUrl("https://api.github.com/")
.build();
return retrofit.create(ApiClient.class);
Utworzenie clienta

@Override
public okhttp3.Response intercept(Chain chain)
{
final Request request =
chain.request().newBuilder()
.addHeader("Authorization", "CODE")
.build();
return chain.proceed(request);
}
Client - Modyfikacja requestu

final OkHttpClient client =
new OkHttpClient.Builder()
.addInterceptor(new AuthHeaderInterceptor())
.build();
//..
retrofitBuilder.client(client)
//..
return retrofit.create(ApiClient.class);
Client - Modyfikacja requestu

HttpLoggingInterceptor loggingInterceptor =
new HttpLoggingInterceptor();
loggingInterceptor.setLevel(
HttpLoggingInterceptor.Level.BODY);
Client - Debug

OkHttpClient.Builder()
.addInterceptor(loggingInterceptor)
.addInterceptor(authHeaderInterceptor)
OkHttpClient.Builder()
.addInterceptor(authHeaderInterceptor)
.addInterceptor(loggingInterceptor)
Client - Kolejno艣膰 debugu!
+
-

reposCall=apiClient.getReposList("sennajavie");
reposCall.enqueue((call, response) -> {
List<Repository> repos= response.body();
});
Przyk艂adowe u偶ycie endpointa

Retrofit retrofit =
new Retrofit.Builder()
//...
.addCallAdapterFactory(
RxJavaCallAdapterFactory.create())
//...
.build();
RxJava + Retrofit

Observable<List<Repository>>
}
RxJava + Retrofit

reposObservable =
apiClient.getReposList("sennajavie");
reposObservable
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe((repos) -> {
repositories.get(0);
});
RxJava - Przyk艂adowe u偶ycie

reposObservable.
subscribeOn(Schedulers.io())
reposObservable.
observeOn(AndroidSchedulers.mainThread())
RxJava - Zarz膮dzanie 飞膮迟办补尘颈

IO
Thread
Main
Thread
subscribe()
executeRequest() endOfExecute()
subscriber.onNext()

CompositeSubscription foregroundSub;
public void appStarted() {
foregroundSub = new CompositeSubscription();
}
public void appStopped() {
foregroundSub.unsubscribe();
}
RxJava - Przerwanie dzia艂ania

Subscriber<List<Repository>> reposSub =
(repos) -> {
repos.get(0);
};
foregroundSub.add(reposSub);
//鈥�
reposObservable.subscribe(reposSub);
RxJava - Przerwanie dzia艂ania

IO
Thread
Main
Thread
subscribe()
executeRequest() endOfExecute()
subscriber.onNext()
unsubscribe()

鈼� Kr贸tki kod
鈼� Mo偶liwo艣ci
鈼� Kontrola endpointa
鈼� Integracja z RxJava
Reasumuj膮c...

puchalski.maciej.official@gmail.com
Dzi臋kuj臋

殴r贸d艂a
鈼� https://unsplash.com/photos/PW0-vZD0wis
鈼� https://unsplash.com/photos/AoSAOV2Vtro
鈼� https://unsplash.com/search/elegant?photo=dgOJDAv96s8
鈼� http://www.amphinicy.com/upload/blog/1000/30_rxjava.png
鈼� http://atl.co.ug/big/wp-content/uploads/2015/05/Retrofit.jpg

狠狠撸

jSession #4 - Maciej Puchalski - Zaawansowany retrofit

Recommended

More Related Content

What's hot (20)

Similar to jSession #4 - Maciej Puchalski - Zaawansowany retrofit (14)

Recently uploaded (20)

jSession #4 - Maciej Puchalski - Zaawansowany retrofit