快速實現一個Http回調組件

一、前情回顧

? 我們平時在使用一些庫的時候，會遇到一些看起來很舒服的寫法，用起來感覺很簡單，而且寫法也很優雅，比如OkHttp，或者是Java Swing的事件模式。

? 我們先看看Java的事件是怎么寫的：

public static void main(String[] args) {JFrame jf = new JFrame("事件監聽測試");jf.setVisible(true);jf.setSize(100, 200);JButton jb = new JButton("觸發事件");jf.add(jb);jb.addActionListener(new ActionListener() {@Overridepublic void actionPerformed(ActionEvent e) {// 進行邏輯處理即可System.out.println("觸發了事件");}});}

? 我們看到Swing的寫法是直接給組件添加了一個監聽器，然后回調里面的參數，這種寫法看起來仿佛就是組件自帶了某種動作一樣。

? 我們接下來也實現一個簡單的Http get請求回調。

二、組件設計

1.回調接口

public interface HttpRequestHandler {void onSuccess(String result);void onException(Exception e);}

2.處理器

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;public class HttpRequestProxy {private HttpRequestHandler httpRequestHandler;public HttpRequestProxy(HttpRequestHandler httpRequestHandler) {this.httpRequestHandler = httpRequestHandler;}/*** 模擬GET** @param urlString* @return*/public String get(String urlString) {HttpURLConnection connection = null;InputStream is = null;BufferedReader br = null;String result = null;// 返回結果字符串try {// 創建遠程url連接對象URL url = new URL(urlString);// 通過遠程url連接對象打開一個連接，強轉成httpURLConnection類connection = (HttpURLConnection) url.openConnection();// 設置連接方式：getconnection.setRequestMethod("GET");// 設置連接主機服務器的超時時間：15000毫秒connection.setConnectTimeout(15000);// 設置讀取遠程返回的數據時間：60000毫秒connection.setReadTimeout(60000);// 發送請求connection.connect();// 通過connection連接，獲取輸入流if (connection.getResponseCode() == 200) {is = connection.getInputStream();// 封裝輸入流is，并指定字符集br = new BufferedReader(new InputStreamReader(is, "UTF-8"));// 存放數據StringBuffer sbf = new StringBuffer();String temp;while ((temp = br.readLine()) != null) {sbf.append(temp);sbf.append("\r\n");}result = sbf.toString();this.httpRequestHandler.onSuccess(result);}} catch (IOException e) {this.httpRequestHandler.onException(e);} finally {// 關閉資源if (null != br) {try {br.close();} catch (IOException e) {e.printStackTrace();}}if (null != is) {try {is.close();} catch (IOException e) {e.printStackTrace();}}assert connection != null;connection.disconnect();// 關閉遠程連接}return result;}
}

3.調用

public class Main {public static void main(String[] args) {new HttpRequestProxy(new HttpRequestHandler() {@Overridepublic void onSuccess(String result) {System.out.println(result);}@Overridepublic void onException(Exception e) {e.printStackTrace();}}).get("http://www.baidu.com");}
}