Android架構: MVC 模式加載數據 前臺顯示

由于項目的需要,最近研究了一下需要連接網絡項目的MVC架構,參考了一下一個新浪微博的開發架構

大體描述如下

需求:項目中接口很多,聯網操作在Activity中處理會非常浩大且那一維護

解決方案:將數據提供層和表現層分開,數據層請求接口的數據 , Activity只處理從數據層來的數據,

 

那我們看一下Activity的實現:

首先定義了一個接口用于規范將來的activty中的方法

package com.testaijialogic;

public interface IAijiaActivity {

    void init();// 初始化數據

    void initView();// 初始化界面控件

    void refresh(Object... param);// 刷新 內容 不知道可變參數的可以再去學習下coreJva

}

然后是Activity

package com.testaijialogic;

/**
 * MVC
 * M 提供數據
 * V 顯示給用戶
 * C 把M的數據顯示到視圖
 */
import java.util.HashMap;
import java.util.List;

import com.testaijialogic.domain.PersonEntity;
import com.testaijialogic.widget.PersonAdapter;

import android.app.Activity;
import android.app.ProgressDialog;

import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.ListView;

public class TestAijiaLogicActivity extends Activity implements IAijiaActivity {
    private Context context;
    private ListView listView;
    private ProgressDialog progressDialog;
    private Button button;
    private ListView listView2;

    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        context = TestAijiaLogicActivity.this;
        Intent intent = new Intent("com.testaijialogic.MainService");// 在首個Activity開啟服務
        startService(intent);
        initView();
        init();
        Log.i("Create", "=====");

    }

    protected void onPause() {

        super.onPause();
        Log.i("onPause", "=====");
    }

    protected void onResume() {

        super.onResume();
        Log.i("onResume", "=====");
    }

    protected void onDestroy() {

        super.onDestroy();
        android.os.Process.killProcess(android.os.Process.myPid());

    }

    @Override
    public void init() {// 初始化list的數據
        @SuppressWarnings("rawtypes")
        HashMap param = new HashMap();
        param.put("product", "testTask");
        // 加載搜索頁面微博信息的任務
        MainService.addActivity(TestAijiaLogicActivity.this);
        Task task = new Task(Task.GETPRODUCT, param, context);
        MainService.newTask(task);// 添加新任務
        progressDialog.show();

    }

    @Override
    public void refresh(Object... param) {
        @SuppressWarnings("unchecked")
        HashMap map = (HashMap) param[0];// 獲取map的數據

        List<PersonEntity> personlist = (List<PersonEntity>) map.get("product");
        PersonAdapter personAdapter = new PersonAdapter(context, personlist);
        listView.setAdapter(personAdapter);

        List<PersonEntity> subpersonlist = (List<PersonEntity>) map// 加載第二個listview
                .get("subproduct");
        PersonAdapter subpersonAdapter = new PersonAdapter(context,
                subpersonlist);
        listView2.setAdapter(subpersonAdapter);
        progressDialog.dismiss();
        Log.i("測試", "setadapter");

    }

    public void initView() {
        listView = (ListView) findViewById(R.id.listView1);
        listView2 = (ListView) findViewById(R.id.listView2);
        button = (Button) findViewById(R.id.button1);
        button.setOnClickListener(new View.OnClickListener() {

            @Override
            public void onClick(View v) {
                init();
            }
        });
        progressDialog = new ProgressDialog(this);
        progressDialog.setMessage("正在獲取數據");

    }
}

可以看到,表現層只是把數據展示到xml中,沒有牽扯到請求接口

 

下面是數據請求層

 

package com.testaijialogic;
/**
 * 任務實體,由于儲存認為信息
 */
import java.util.HashMap;

import android.content.Context;

public class Task {

    public static final int GETPRODUCT = 1;
    public static final int GETPRODUCT2 = 5;
    public static final int MSGACTIVITY = 4;
    public static final int NEWWEIBO = 7;
    public static final int HOMEREFRESH = 3;
    public static final int VIEWWEIBO = 8;
    private int taskId;
    private HashMap taskParams;
    private Context ctx;

    public Task(int taskId, HashMap taskParams, Context ctx) {
        super();
        this.taskId = taskId;
        this.taskParams = taskParams;
        this.ctx = ctx;  
    }

    public int getTaskId() {
        return taskId;
    }

    public void setTaskId(int taskId) {
        this.taskId = taskId;
    }

    public HashMap getTaskParams() {
        return taskParams;
    }

    public void setTaskParams(HashMap taskParams) {
        this.taskParams = taskParams;
    }

    public Context getCtx() {
        return ctx;
    }

    public void setCtx(Context ctx) {
        this.ctx = ctx;
    }
}

Person實體,儲存人員信息

package com.testaijialogic.domain;

public class PersonEntity {
    // {"amount":100,"id":1,"name":"itcastliming"}
    private int id;
    private String name;
    private String amount;

    public PersonEntity(int id, String name, String amount) {
        setId(id);
        setAmount(amount);
        setName(name);
    }

    /**
     * @return the id
     */
    public int getId() {
        return id;
    }

    /**
     * @param id
     *            the id to set
     */
    public void setId(int id) {
        this.id = id;
    }

    /**
     * @return the name
     */
    public String getName() {
        return name;
    }

    /**
     * @param name
     *            the name to set
     */
    public void setName(String name) {
        this.name = name;
    }

    /**
     * @return the amount
     */
    public String getAmount() {
        return amount;
    }

    /**
     * @param amount
     *            the amount to set
     */
    public void setAmount(String amount) {
        this.amount = amount;
    }

}

核心網絡服務,請求項目的所有接口數據

package com.testaijialogic;

/*
 * 獲取服務器信息服務
 *  */

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

import com.testaijialogic.domain.PersonEntity;
import com.testaijialogic.util.WebSender;

import android.app.Activity;
import android.app.AlertDialog;
import android.app.Service;
import android.content.Context;
import android.content.DialogInterface;
import android.content.Intent;
import android.content.DialogInterface.OnClickListener;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.util.Log;

public class MainService extends Service implements Runnable {

    private static ArrayList<IAijiaActivity> allActivity = new ArrayList<IAijiaActivity>();
    private static ArrayList<Task> allTasks = new ArrayList<Task>();
    List<String> p = new ArrayList<String>();// post的參數 注意設置成全局變量后只能一次放松一個Post了
    List<String> v = new ArrayList<String>();// post的數值
    public static boolean isRun = false;

    public static void newTask(Task t) {
        allTasks.add(t);
    }

    public static void addActivity(IAijiaActivity iw) {
        allActivity.add(iw);
    }

    public static void removeActivity(IAijiaActivity iw) {
        allActivity.remove(iw);
    }

    public static IAijiaActivity getActivityByName(String name) {
        for (IAijiaActivity iw : allActivity) {
            if (iw.getClass().getName().indexOf(name) >= 0) {
                return iw;
            }
        }
        return null;
    }

    @Override
    public void onCreate() {
        // TODO Auto-generated method stub
        super.onCreate();

        isRun = true;
        new Thread(this).start();
        Log.e("=============================", "MainService    onCreate()");
    }

    @Override
    public void onDestroy() {
        isRun = false;
        stopSelf();
        super.onDestroy();

    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        while (isRun) {
            try {
                if (allTasks.size() > 0) {
                    // 執行任務,可以遍歷執行多個任務
                    // doTask(allTasks.get(0));
                    for (Task task : allTasks) {
                        doTask(task);
                    }

                } else {
                    try {
                        Thread.sleep(1000);
                    } catch (Exception e) {
                    }

                }
            } catch (Exception e) {
                if (allTasks.size() > 0)
                    allTasks.remove(allTasks.get(0));
                Log.d("error", "------------------" + e);
            }
        }
    }

    private Handler handler = new Handler() {

        @Override
        public void handleMessage(Message msg) {
            // TODO Auto-generated method stub
            super.handleMessage(msg);

            switch (msg.what) {
            case Task.GETPRODUCT:
                MainService.getActivityByName("TestAijiaLogicActivity")
                        .refresh(msg.obj);// 調用TestAijiaLogicActivity的方法刷新控件

                break;
            case Task.GETPRODUCT2:// 個人資料

                break;
            case Task.MSGACTIVITY:

                break;
            case Task.NEWWEIBO:

                break;
            case Task.VIEWWEIBO:

                break;
            default:
                break;
            }
        }

    };

    @SuppressWarnings("unchecked")
    private void doTask(Task task) throws JSONException {
        // TODO Auto-generated method stub
        Message msg = handler.obtainMessage();
        msg.what = task.getTaskId();

        switch (task.getTaskId()) {
        case Task.GETPRODUCT:// 獲取產品信息
            Log.i("有任務執行", "MainS" + task.getTaskId());
            String urlStr = "http://10.1.49.230/test/testjson.php";
            p.add("product");// 增加post的參數名
            v.add((String) task.getTaskParams().get("product"));// 增加post的參數的值
            String result = WebSender.httpClientSendPost(urlStr, p, v);// 發送httppost請求

            List<PersonEntity> personEntities = new ArrayList<PersonEntity>();
            JSONArray jsonArray = new JSONArray(result);
            for (int i = 0; i < jsonArray.length(); i++) {

                JSONObject jsonObject = jsonArray.getJSONObject(i);
                PersonEntity personEntity = new PersonEntity(
                        jsonObject.getInt("id"), jsonObject.getString("name"),
                        jsonObject.getString("amount"));
                personEntities.add(personEntity);

            }
            /**
             * 第二次請求聯網,返回list , 也可以使用多任務處理,但是當前項目中界面的listview特別多所以使用這樣
             */
            String suburlStr = "http://10.1.49.230/test/testsubjson.php";
            p.add("product");// 增加post的參數名
            v.add((String) task.getTaskParams().get("product"));// 增加post的參數的值
            String subresult = WebSender.httpClientSendPost(suburlStr, p, v);// 發送httppost請求

            List<PersonEntity> subpersonEntities = new ArrayList<PersonEntity>();
            JSONArray subjsonArray = new JSONArray(subresult);
            for (int i = 0; i < jsonArray.length(); i++) {

                JSONObject jsonObject = subjsonArray.getJSONObject(i);
                PersonEntity personEntity = new PersonEntity(
                        jsonObject.getInt("id"), jsonObject.getString("name"),
                        jsonObject.getString("amount"));
                subpersonEntities.add(personEntity);

            }

            @SuppressWarnings("rawtypes")
            HashMap map = new HashMap();
            map.put("product", personEntities);
            map.put("subproduct", subpersonEntities);
            msg.obj = map;
            // msg.obj = personEntities;//如果只需要一個list那用這個就可以
            break;

        default:
            break;
        }
        allTasks.remove(task);
        // 通知主線程更新UI
        handler.sendMessage(msg);
    }

    @Override
    public IBinder onBind(Intent intent) {
        // TODO Auto-generated method stub
        return null;
    }

    /**
     * 退出應用程序
     * 
     * @param context
     */
    public static void exitAPP(Context context) {
        Intent it = new Intent("weibo4android.logic.util.MainService");
        context.stopService(it);// 停止服務
        // 殺死進程 我感覺這種方式最直接了當
        android.os.Process.killProcess(android.os.Process.myPid());

    }

    public static void finshall() {

        for (IAijiaActivity activity : allActivity) {// 遍歷所有activity 一個一個刪除
            ((Activity) activity).finish();
        }
    }

    /**
     * 網絡連接異常
     * 
     * @param context
     */
    public static void AlertNetError(final Context context) {
        AlertDialog.Builder alerError = new AlertDialog.Builder(context);
        alerError.setTitle("網絡錯誤");
        alerError.setMessage("請檢查網絡");
        alerError.setNegativeButton("退出", new OnClickListener() {
            @Override
            public void onClick(DialogInterface dialog, int which) {
                dialog.dismiss();
                exitAPP(context);
            }
        });
        alerError.setPositiveButton("確定", new OnClickListener() {
            @Override
            public void onClick(DialogInterface dialog, int which) {
                dialog.dismiss();
                context.startActivity(new Intent(
                        android.provider.Settings.ACTION_WIRELESS_SETTINGS));
            }
        });
        alerError.create().show();
    }

}

網絡工具類

package com.testaijialogic.util;

/**
 *網絡通信類(已優化)
 * */

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.ResponseHandler;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.BasicResponseHandler;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;

import android.util.Log;

public class WebSender {

    /*
     * 比較原始的 POST Cookies
     */
    public static String[] sendPost(String urlStr, String[] param,
            String[] value, String cookies) {
        String[] result = { "", "" };
        String paramValue = "";
        StringBuffer buffer = null;
        HttpURLConnection con = null;

        try {
            URL url = new URL(urlStr);
            con = (HttpURLConnection) url.openConnection();
            con.setRequestMethod("POST");
            con.setRequestProperty("Connection", "Keep-Alive");
            con.setRequestProperty("Charset", "UTF-8");
            // con.setRequestProperty("Content-Type", "text/html");

            // set cookies
            if (QHFlag.isNotEmpty(cookies)) {
                con.setRequestProperty("cookie", cookies);
            }

            paramValue = WebSender.getParamStr(param, value);

            con.setDoOutput(true);
            con.setDoInput(true);
            con.setUseCaches(false);
            con.setConnectTimeout(50000);// 設置連接主機超時（單位：毫秒）
            con.setReadTimeout(50000);// 設置從主機讀取數據超時（單位：毫秒）

            con.connect();// connect open

            PrintWriter out = new PrintWriter(con.getOutputStream());// 發送數據
            out.print(paramValue);
            out.flush();
            out.close();

            // get cookies
            String cks = con.getHeaderField("set-cookie");
            if (cks != "" && cks != null)
                result[1] = cks;

            // get status
            int res = 0;
            res = con.getResponseCode();

            // get info response
            if (res == 200 || res == 302) {
                BufferedReader in = new BufferedReader(new InputStreamReader(
                        con.getInputStream(), "UTF-8"));
                buffer = new StringBuffer();
                String line = "";
                while ((line = in.readLine()) != null) {
                    buffer.append(line);
                }
            } else {
                QHFlag.e("Web Response:" + res);
            }

            con.disconnect();// Connect Close!
        } catch (Exception e) {
            // e.printStackTrace();
        }

        if (buffer.length() != 0 && buffer != null) {
            result[0] = buffer.toString();
        }
        return result;
    }

    /*
     * 使用HttpClient對象發送GET請求
     */
    public static String httpClientSendGet(String webUrl) {
        String content = null;
        // DefaultHttpClient
        DefaultHttpClient httpclient = new DefaultHttpClient();
        // HttpGet
        HttpGet httpget = new HttpGet(webUrl);
        // ResponseHandler
        ResponseHandler<String> responseHandler = new BasicResponseHandler();
        try {
            content = httpclient.execute(httpget, responseHandler);
        } catch (Exception e) {
            e.printStackTrace();
        }
        httpclient.getConnectionManager().shutdown();
        return content;
    }

    /*
     * 使用HttpClient對象發送有cookie的GET請求
     */
    public static String httpClientSendGet(String urlStr, String Cookies) {
        String httpUrl = urlStr;
        HttpGet httpGet = new HttpGet(httpUrl);
        try {
            HttpClient httpClient = new DefaultHttpClient();
            httpGet.setHeader("cookie", Cookies);
            // 請求HttpClient，取得HttpResponse
            HttpResponse httpResponse = httpClient.execute(httpGet);

            // 請求成功
            if (httpResponse.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                // 取得返回的字符串
                String strResult = EntityUtils.toString(httpResponse
                        .getEntity());
                return strResult;
            }
        } catch (Exception e) {
        }
        return "0";
    }

    /*
     * 使用HttpClient對象發送POST請求
     */
    public static String httpClientSendPost(String urlStr,
            List<String> paraName, List<String> val) {
        String httpUrl = urlStr;
        // HttpPost對象
        HttpPost httpPost = new HttpPost(httpUrl);

        // 使用NameValuePair來保存要傳遞的Post參數
        List<NameValuePair> params = new ArrayList<NameValuePair>();

        // 添加要傳遞的參數
        System.out.println("====================================");
        for (int i = 0; i < paraName.size(); i++) {
            params.add(new BasicNameValuePair(paraName.get(i), val.get(i)));
            System.out.println(paraName.get(i) + "->" + val.get(i));
        }
        System.out.println("====================================");

        try {
            // 設置字符集
            HttpEntity httpEntity = new UrlEncodedFormEntity(params, "utf-8");
            httpPost.setEntity(httpEntity);

            // httpClient對象
            HttpClient httpClient = new DefaultHttpClient();

            // 請求HttpClient，取得HttpResponse
            HttpResponse httpResponse = httpClient.execute(httpPost);

            // 請求成功
            if (httpResponse.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                // 取得返回的字符串
                String strResult = EntityUtils.toString(httpResponse
                        .getEntity());
                System.out.println(strResult);
                return strResult;
            }
        } catch (Exception e) {
        }
        return "";
    }

    /*
     * 使用HttpClient對象發送POST請求
     */
    public static String httpClientSendPost(String urlStr,
            List<String> paraName, List<String> val, String Cookies) {
        String httpUrl = urlStr;
        // HttpPost對象
        HttpPost httpPost = new HttpPost(httpUrl);

        // 使用NameValuePair來保存要傳遞的Post參數
        List<NameValuePair> params = new ArrayList<NameValuePair>();

        // 添加要傳遞的參數
        System.out.println("====================================");
        for (int i = 0; i < paraName.size(); i++) {
            params.add(new BasicNameValuePair(paraName.get(i), val.get(i)));
            System.out.println(paraName.get(i) + "->" + val.get(i));
        }
        System.out.println("====================================");

        try {
            // 設置字符集
            HttpEntity httpEntity = new UrlEncodedFormEntity(params, "utf-8");
            httpPost.setEntity(httpEntity);
            httpPost.setHeader("cookie", Cookies);
            // httpClient對象
            HttpClient httpClient = new DefaultHttpClient();

            // 請求HttpClient，取得HttpResponse
            HttpResponse httpResponse = httpClient.execute(httpPost);

            // 請求成功
            if (httpResponse.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                // 取得返回的字符串
                String strResult = EntityUtils.toString(httpResponse
                        .getEntity());
                System.out.println(strResult);
                return strResult;
            }
        } catch (Exception e) {
        }
        return "";
    }

    public static String uploadBitmap1(String urlString, byte[] imageBytes,
            String cookie) {
        // String boundary = "*****";
        try {
            URL url = new URL(urlString);
            final HttpURLConnection con = (HttpURLConnection) url
                    .openConnection();
            // 允許input、Output,不使用Cache
            con.setDoInput(true);
            con.setDoOutput(true);
            con.setUseCaches(false);

            // 設置傳送的method=POST
            con.setRequestMethod("POST");
            // setRequestProperty
            con.setRequestProperty("Connection", "Keep-Alive");
            con.setRequestProperty("Charset", "UTF-8");
            con.setRequestProperty("Content-Type", "text/html");
            if (cookie != null && cookie != "") {
                Log.i("myEvent", "send cookies value is:" + cookie);
                con.setRequestProperty("cookie", cookie);
            }
            // 從主機讀取數據的超時時間（單位：毫秒）
            con.setReadTimeout(50000);
            // 設置連接主機的超時時間（單位：毫秒）
            con.setConnectTimeout(50000);
            // System.out.println(con.getResponseCode());
            // 設置DataOutputStream
            DataOutputStream dsDataOutputStream = new DataOutputStream(
                    con.getOutputStream());
            // dsDataOutputStream.writeBytes(twoHyphen + boundary + endString);
            // dsDataOutputStream.writeBytes("Content-Disposition:form-data;"
            // + "name=\"file1\";filename=\"" + "11.jpg\"" + endString);
            // dsDataOutputStream.writeBytes(endString);

            dsDataOutputStream.write(imageBytes, 0, imageBytes.length);
            // dsDataOutputStream.writeBytes(endString);
            // dsDataOutputStream.writeBytes(twoHyphen + boundary + twoHyphen
            // + endString);
            dsDataOutputStream.close();
            int cah = con.getResponseCode();
            if (cah == 200) {
                InputStream isInputStream = con.getInputStream();
                int ch;
                StringBuffer buffer = new StringBuffer();
                while ((ch = isInputStream.read()) != -1) {
                    buffer.append((char) ch);
                }
                return buffer.toString();
            } else {
                return "false";
            }
        } catch (Exception e) {
            e.printStackTrace();
            return "false";
        }

    }

    /**
     * 請求字符串
     * */
    public static String getParamStr(String[] param, String[] value) {
        String res = "";
        if (param.length == value.length) {
            for (int i = 0; i < param.length; i++) {
                res += param[i] + "=" + toUTF8(value[i]) + "&";
            }
        }
        return res.substring(0, res.length() - 1);
    }

    public static String toUTF8(String str) {
        String u = str;
        try {
            u = java.net.URLEncoder.encode(u, "UTF-8");
        } catch (Exception e) {

        }
        return u;
    }

}