天天看點

Android網絡架構選用(示例,已實際運作)Retrofit,okhttp,volley

依赖

implementation files('libs/retrofit-2.9.0.jar')
    implementation("com.squareup.okhttp3:okhttp:4.8.1")
    // https://mvnrepository.com/artifact/com.android.volley/volley
    compile group: 'com.android.volley', name: 'volley', version: '1.1.1'
      

Retrofit(底层封装okhttp)

package com.wintec.netframworktest;

import android.os.Bundle;
import android.util.Log;

import androidx.appcompat.app.AppCompatActivity;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;
import retrofit2.Retrofit;

public class MainActivity extends AppCompatActivity {
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        TestRetrofit();


    }



    private void TestRetrofit() {
        Retrofit mRetrofit= new Retrofit.Builder()
                .baseUrl("https://wap.peopleapp.com/article/")
                .build();
        BookService mBookService = mRetrofit.create(BookService.class);
        Call mBookCall = mBookService.getBook(5852020);
//        Log.e("wy","服务器请求数据数据: "+   mBookCall.request().body().toString());
        mBookCall.enqueue(new Callback() {
            @Override
            public void onResponse(final Call mCall, final Response mResponse) {

                Log.e("wy","服务器响应数据: "+  mResponse.toString());
            }

            @Override
            public void onFailure(final Call mCall, final Throwable mThrowable) {
                Log.e("wy","网络异常原因: "+ mThrowable);

            }
        });
    }
}

      
package com.wintec.netframworktest;

import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.http.GET;
import retrofit2.http.Path;

public interface BookService {
    @GET("5933922/{id}")
    Call getBook(@Path("id") int id);

}

      
package com.wintec.netframworktest;

import android.os.Bundle;
import android.util.Log;

import java.io.IOException;

import androidx.appcompat.app.AppCompatActivity;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;


public class OkhttpTestActivity extends AppCompatActivity {
    OkHttpClient client;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        Request request = new Request.Builder()
                .url("https://wap.peopleapp.com/article/5933922/5852020")
                .build();

         client = new OkHttpClient();
//         OkHttp的同步请求会阻塞当前线程,因此不能在UI线程中请求,需要开启子线程,在子线程中发送请求。

//         new Thread(new Runnable() {
//             @Override
//             public void run() {
//                 try {
//                     Log.e("wy","okhttp同步请求返回: "+ client.newCall(request).execute().toString());
//                 } catch (IOException mE) {
//                     mE.printStackTrace();
//                 }
//             }
//         }).start();

//         异步请求
        Call call=client.newCall(request);
        call.enqueue(new Callback() {

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                Log.e("wy","okhttp异步请求response返回:"+response.toString());
            }
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e("wy","okhttp异步请求异常:"+e);
            }
        });

    }

}

      
package com.wintec.netframworktest;

import android.os.Bundle;
import android.util.Log;

import com.android.volley.NetworkResponse;
import com.android.volley.Request;
import com.android.volley.RequestQueue;
import com.android.volley.Response;
import com.android.volley.VolleyError;
import com.android.volley.toolbox.StringRequest;
import com.android.volley.toolbox.Volley;

import androidx.appcompat.app.AppCompatActivity;

public class VolleyTestActivity extends AppCompatActivity {
    RequestQueue mQueue;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
         mQueue = Volley.newRequestQueue(getApplicationContext());
        loadGetStr("https://wap.peopleapp.com/article/5933922/5852020");

    }

    private void loadGetStr(String url) {

        StringRequest srReq = new StringRequest(Request.Method.GET, url,
                new StrListener(), new StrErrListener()) {

            protected final String TYPE_UTF8_CHARSET = "charset=UTF-8";

            // 重写parseNetworkResponse方法改变返回头参数解决乱码问题
            // 主要是看服务器编码,如果服务器编码不是UTF-8的话那么就需要自己转换,反之则不需要
            @Override
            protected Response parseNetworkResponse(
                    NetworkResponse response) {
//                try {
//                    String type = response.headers.get(HTTP.CONTENT_TYPE);
//                    if (type == null) {
//                        type = TYPE_UTF8_CHARSET;
//                        response.headers.put(HTTP.CONTENT_TYPE, type);
//                    } else if (!type.contains("UTF-8")) {
//                        type += ";" + TYPE_UTF8_CHARSET;
//                        response.headers.put(HTTP.CONTENT_TYPE, type);
//                    }
//                } catch (Exception e) {
//                }
                return super.parseNetworkResponse(response);
            }
        };
        srReq.setShouldCache(true); // 控制是否缓存
        startVolley(srReq);
    }
    // 添加及开始请求
    private void startVolley(Request req) {

        // 设置超时时间
        // req.setRetryPolicy(new DefaultRetryPolicy(20 * 1000, 1, 1.0f));
        // 将请求加入队列
        mQueue.add(req);
        // 开始发起请求
        mQueue.start();
    }
    // Str请求成功回调
    private class StrListener implements Response.Listener {

        @Override
        public void onResponse(String arg0) {
            Log.e("wy","volley请求成功返回: "+ arg0);
        }

    }


    // 共用失败回调
    private class StrErrListener implements Response.ErrorListener {

        @Override
        public void onErrorResponse(VolleyError arg0) {
            Log.e("wy","volley请求错误返回: "+ arg0);
        }

    }
}