از سری مقالات آموزش RxAndroid, می‌خواهیم با استفاده از Retrofit, ارتباط با Server را برقرار کنیم.

Retrofit یک ابزار امن برای ارتباط با Server از طریق Http است. همانطور که در مقالات قبل نیز بررسی شد, ابزار هایی برای تسهیل کار با Server در اندروید وجود دارند و سعی شد تا مبانی ارتباط با Server را توضیح دهیم. اکنون زمان آن رسیده است که با ابزار قدرتمند دیگری آشنا شویم. یکی از ویژگی های بسیار مهم Retrofit این است که آدرس دهی RESTful API در آن بسیار آسان تر صورت می‌پذیرد. اهمیت آدرس دهی API در مقالات مرتبط با آن بررسی شده است. در نتیجه استفاده از Retrofit برای ارتباط با RESTful Web Services بسیار مناسب است.

همانطور که می‌دانید, برای ارتباط با Server نیاز است تا از یک Thread, غیر از Main Thread استفاده کنید. استفاده از AsyncTask بسیار رایج می‌باشد. اما در مقاله قبل به مزیت استفاده از RxAndroid پرداختیم و از این پس RxAndroid را جایگزین AsyncTask خواهیم کرد.

در این مقاله قصد داریم تا به یک API متصل شویم و مطالب را بر اساس دسته بندی آنها دریافت کنیم. در مقاله قبل RxAndroid و RxJava را به پروژه اضافه کردیم. اکنون نیاز است تا Retrofit Gradle Dependency را به پروژه اضافه کنیم:

compile 'com.squareup.retrofit2:retrofit:2.3.0'

در مرحله اول نیاز است تا یک Java Interface ایجاد کنیم. Retrofit به صورت خودکار, Http API را به این Interface تبدیل می‌کند:

public interface PostAPIModel {

    @GET("users/{subject}")
    Observable<PostModel> getPosts(@Path("subject") String subject);
}

در این Interface, با استفاده از متد Http Get, درخواست را به API ارسال می‌کند و مقدار نتیجه را در Observable قرار می‌دهد. مقداری که به عنوان String دریافت می‌کند, مقداری است که بجای {subject} قرار می‌دهد.

کلاس مدل Post را اینطور پیاده می‌کنیم:

public class PostModel {
    private String postTitle;
    private String PostID;
    private String postBody;
    private String postImage;

    public String getPostTitle() {
        return postTitle;
    }

    public String getPostID() {
        return PostID;
    }

    public String getPostBody() {
        return postBody;
    }

    public String getPostImage() {
        return postImage;
    }
}

در مرحله بعد باید یک متد static ایجاد کنیم تا وظیفه ارسال درخواست را بر عهده داشته باشد.

public class RetrofitFactory<T> {
    private final static String mainUrl = "https://api.zerotohero.ir";
    public static <T> T createRequest(final Class<T> tClass) {
        final Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(mainUrl)
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create())
                .build();
        return retrofit.create(tClass);

    }
}

در اینجا ابتدا آدرس API را مشخص می‌کنیم. این کلاس Generic است. به این معنا که می‌تواند متغیر هارا بدون در نظر گرفتن نوع آنها دریافت کند. برای مثال List یک نوع کلاس Generic است. یعنی List<String>, یک لیست از String و List<Integer>, یک لیست از اعداد را ایجاد می‌کند. همانطور که مشخص است, مهم نیست متغیر های درون لیست از چه نوع باشد. این خاصیت کلاس های Generic است.

ابتدا یک Instance از کلاس Retrofit ایجاد می‌کنیم. addCallAdapterFactory متدی است که RxJava را برای Retrofit تعریف می‌کند. سپس با استفاده از addConverterFactory یک Instance از Gson را برای تبدیل Json به کلاس مدل, تعریف می‌کنیم.

    private void makeServerRequset(String subject) {
        PostAPIModel postAPIModel = RetrofitFactory.createRequest(PostAPIModel.class);
            postAPIModel.getPosts(subject)
                    .subscribeOn(Schedulers.newThread())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(this::onDataReceived,this::onError,this::onComplete);
        
    }
    private void onDataReceived(PostModel postModel) {
cardAdapter.add(postModel);
    }
    private void onComplete() {
        Log.i("Post Info", " Received Completely");
    }

    private void onError(Throwable throwable) {
        Log.e("Post Error : ", throwable.getMessage());
    }

متد makeServerRequest, برای ایجاد درخواست است. با استفاده از متد createRequest, یک Instance از PostAPIModel می‌سازیم. متغیر subject را به متد getPosts ارسال می‌کنیم واز متد هایی که در Observable استفاده می‌کنیم. پردازش را در یک Thread جدید قرار می‌دهیم و نتیجه را در Main Thread قرار می‌دهیم. زیرا بروز رسانی User Interface, تنها از طریق Main Thread امکان پذیر است. سپس از subscribe استفاده می‌کنیم. متغیر اول OnDataReceived است و به عنوان OnNext تعریف می‌کنیم. تعریف این متد ها با استفاده از Lambda است.

اکنون متد را اینطور فراخوانی می‌کنیم:

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        ButterKnife.bind(this);
    }
    @OnClick(R.id.search)
    public void search() {
        makeServerRequset(searchEditText.getText().toString());
    }

در اینجا برای بروز رسانی User Interface, از Butter Knife استفاده کرده‌ایم.

در این مقاله سعی بر این شد تا با استفاده از RxAndroid و Retrofit یک درخواست به API ارسال کنیم.

سری مقالات آموزش اندروید ادامه دارد.

با ما همراه باشید.