一个应用程序会在许多地方使用网络功能,而发送HTTP请求代码基本都是相同的,所以我们不会每次都去编写一遍发送HTTP请求的代码。
我们将这些通用的网络操作提取到一个公共的类里,并提取一个静态方法,当想要发起网络请求的时候,只需调用这个方法即可
public class HttpUtil {
public static String sendHttpRequest(String address){
HttpURLConnection connection = null;
try {
URL url = new URL(address);
connection = (HttpURLConnection)url.openConnection();
connection.setRequestMethod("GET");
connection.setConnectTimeout(10000);
connection.setReadTimeout(10000);
connection.setDoInput(true);
connection.setDoOutput(true);
InputStream in = connection.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
StringBuilder response = new StringBuilder();
String line;
while ((line = reader.readLine())!=null){
response.append(line);
}
return response.toString();
}catch (Exception e){
e.printStackTrace();
return e.getMessage();
}finally {
if (connection!=null){
connection.disconnect()
}
}
}
}
这样调用
String address = "https://www.baidu.com";
String response = HttpUtil.sendHttpRequest(address);
再回去到服务器相应的数据后,我们就可以对它进行解析和处理了。但是网络请求通常都是耗时操作,而sendHttpRequest方法的内部并没有开启线程,这样就可能导致在调用sendHttpRequest方法的时候使得主线程阻塞。
于是我们定义了一个接口,只需要使用Java回调机制
public interface HttpCallbackListener {
void onFinish(String response);
void onError(Exception e);
}
我们在接口中定义了两个方法,onFinish方法表示当服务器成功相应我们的请求时调用,onError表示当网络操作出现错误时调用。这两个方法都要有参数,onFinish方法中的参数代表着服务器返回的数据,eronError方法中的参数记录者错误的详细信息。
public class HttpUtil {
public static void sendHttpRequest(final String address, final HttpCallbackListener listener){
new Thread(new Runnable() {
@Override
public void run() {
HttpURLConnection connection = null;
try {
URL url = new URL(address);
connection = (HttpURLConnection)url.openConnection();
connection.setRequestMethod("GET");
connection.setConnectTimeout(10000);
connection.setReadTimeout(10000);
connection.setDoInput(true);
connection.setDoOutput(true);
InputStream in = connection.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
StringBuilder response = new StringBuilder();
String line;
while ((line = reader.readLine())!=null){
response.append(line);
}
if (listener != null){
listener.onFinish(response.toString());
}
}catch (Exception e){
if (listener != null){
listener.onError(e);
}
}finally {
if (connection!=null){
connection.disconnect();
}
}
}
}).start();
}
}
我们首先给sendHttpRequest方法添加了一个HttpCallbackListener参数,并在方法的内部开启了一个子线程,然后在子线程里去执行具体的放落操作,注意,子线程终是无法通过return语句来返回数据的,因此这里我们将服务器相应的数据传入了HttpCallbackListener的onFinish方法当中,如果出现了异常就将异常传入onError中。
在上述使用HttpURLConnection的写法总体来说还是比较复杂的,而使用OkHttp会变的简单
在OkHttp中加入一个sendOkHttpRequest方法
public static void sendOkHttpRequest(String address, Callback callback){
OkHttpClient client = new OkHttpClient();
Request request = new Request.Builder()
.url(address)
.build();
client.newCall(request).enqueue(callback);
}
sendOkHttpRequest方法中有一个okhttp3包中的Callback参数,这个是OkHttp库中自带的一个回调接口,类似于我们自己编写的HttpCallbackListener,然后client.newCall()之后没有像之前那样一直调用execute方法,而是调用了一个enqueue()方法,并把okhttp3.Callback参数传入,OkHttp在enqueue方法的内部已经帮我们开好子线程,然后执行HTTP请求,并将最终的请求结果回调到OKhttp3.Callback当中
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
HttpUtil.sendOkHttpRequest("http://www.baidu.com",new Callback(){
@Override
public void onFailure(Call call, IOException e) {
}
@Override
public void onResponse(Call call, Response response)throws IOException {
String responseData = response.body().string();
}
});
}
}
需要注意,无论使用哪个,最终的回调结果都是在子线程中运行的,因此我们不可以在这里执行任何UI操作,除非借助runOnUiThread方法来进行线程转换