implementation 'com.squareup.okhttp3:okhttp:3.11.0'
    implementation 'com.squareup.retrofit2:retrofit:2.4.0'
    implementation 'io.reactivex.rxjava2:rxjava:2.2.5'
    implementation 'io.reactivex.rxjava2:rxandroid:2.1.0'

package app.bxvip.com.rxjavaretrofit.imple;

import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.http.GET;
public interface MyApi {
  @GET("api/data/Android/10/1")
  Call<ResponseBody> getAndroidInfo();
    /**
     * 這里使用到了 Okhttp3 和retrofit2，我們通過(guò)導(dǎo)入的包就知道
     * 估計(jì)會(huì)有人對(duì)上面的寫法表示不理解，接下來(lái)我們慢慢理解：
     * @GET 這個(gè)表示的是GET請(qǐng)求，想必不用不多說(shuō)
     * "api/data/Android/10/1"可以理解為接口url， 一般url分為兩個(gè)部分，前面一部分是不會(huì)變化的，就像前面提到的http://gank.io/api/data/Android/10/1這個(gè)接口
     * http://gank.io/這個(gè)是不會(huì)改變的，俗稱baseurl，后面的就是接口url部分
     * Call<ResponseBody>是retrofit2中的對(duì)象，等會(huì)我們就知道他的用處
     */
}

public class MainActivity extends AppCompatActivity implements View.OnClickListener{
    private Button bt_send;
    private TextView tv_result;
    public Retrofit retrofit;
    public  MyApi api;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        bt_send =findViewById(R.id.bt_send);
        tv_result =findViewById(R.id.result);
        bt_send.setOnClickListener(this);
        //實(shí)例化相關(guān)對(duì)象
        initObject();
    }

    private void initObject() {
    	//這里是構(gòu)建對(duì)象，將之前的接口url和baseurl拼接
        retrofit = new Retrofit.Builder().baseUrl("http://gank.io/").build();
        api = retrofit.create(MyApi.class);
        
    }

    @Override
    public void onClick(View view) {
        switch (view.getId()){
            case R.id.bt_send:
                send();
                break;
            default:
                break;
        }
    }

    private void send() {
    //發(fā)出請(qǐng)求，并接受回調(diào)信息
        Call<ResponseBody> call = api.getAndroidInfo();
        call.enqueue(new Callback<ResponseBody>() {
            @Override
            public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
                Log.i("request return :","success");
                tv_result.setText(response.body().toString());
            }

            @Override
            public void onFailure(Call<ResponseBody> call, Throwable t) {
                Log.i("request return :","faild");
                tv_result.setText(t.getMessage());
            }
        });
    }
}

//這里提供兩個(gè)接口一個(gè)是天氣接口，一個(gè)是豆瓣的接口
https://www.sojson.com/open/api/weather/json.shtml?city=廣州
https://api.douban.com/v2/book/search?q=金瓶梅

	//接著上面的 MyApi后面繼續(xù)寫，這里是訪問(wèn)程序接口
    @GET("open/api/weater/json.shtml")
    Observable<WeatherBean> getWeather(@Query("city")String city);
	//@Query("city")String city是需要傳遞的參數(shù)用問(wèn)好隔開
    @GET("book/search")
    Observable<BookBean> getBook(@Query("a")String name);

// Retrofit 通過(guò)okhttp訪問(wèn)接口
  Retrofit retrofit = new Retrofit.Builder()
                .baseUrl("http://t.weather.sojson.com/api/weather/city/")
                .client(getOkHttpClient())
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .build();
        api = retrofit.create(MyApi.class);
 public OkHttpClient getOkHttpClient() {
        if (okHttpClient==null){
            okHttpClient = new OkHttpClient.Builder()
                    .retryOnConnectionFailure(true)
                    .connectTimeout(3000, TimeUnit.SECONDS)
                    .addInterceptor(new Interceptor() {
                        @Override
                        public okhttp3.Response intercept(Chain chain) throws IOException {
                            Request request = chain.request()
                                    .newBuilder()
                                    //刪除原始的請(qǐng)求頭
                                    .removeHeader("User-Agent")
                                    //添加新的 User-Agent
                                    .addHeader("User-Agent","Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:0.9.4)")
                                    .build();
                            return chain.proceed(request);
                        }
                    })
                    .build();

        }
        return okHttpClient;
    }

GsonConverterFactory
RxJava2CallAdapterFactory
//需要導(dǎo)入兩個(gè)依賴
    implementation 'com.squareup.retrofit2:converter-gson:2.4.0'
    implementation 'com.squareup.retrofit2:adapter-rxjava2:2.4.0'

 private void sendWeather(){
        //返回的是一個(gè)Obserable對(duì)象
        api.getWeather("廣州").subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<WeatherBean>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(WeatherBean weatherBean) {
                        Log.i("hb","ad"+weatherBean.getCity());
                        if (weatherBean==null){
                            Log.i("hb",weatherBean.getCity());
                        }
                        //這里我們可以使用回調(diào)的方式，發(fā)給其他的類
                        //如 listern.send(weatherBean)
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.i("hb",e.getMessage());
                    }

                    @Override
                    public void onComplete() {
                        Log.i("hb","sdf");
                    }
                });
    }