SSH服务器与Android通信(2)--Android客户端接收数据

基本原理是Android客户端通过HttpClient向服务器发出请求，服务器向Android客户端返回JSON字符串，Android客户端解析JSON字符串获得数据。

1. 新建一个Android项目，主要文件如下：

其中MainActivity是UI，CommThread是通信线程，负责和服务器通信，Util是工具类，Var存放变量。

2. Var.java:

package com.hzhi.school.util;

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

public class Var {
    
    // 访问的URL
    public static String strHost = new String("http://192.168.1.100:8080/School/");
    public static String strAct = new String("aclasquery");
    public static String strURL = strHost + strAct;
    
    // 列表
    public static List lstId = new ArrayList();
    public static List lstName = new ArrayList();
    public static List lstComm = new ArrayList();
    
    // 屏幕的尺寸
    public static int wid_scr;
    public static int hei_scr;
    
    // 消息类型
    public static final int msg_connect = 1;
    public static final int msg_error = 2;
    public static final int msg_con_start = 3;
    public static final int msg_con_stop = 4;

}

3. Util.java:

package com.hzhi.school.util;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;

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

import android.util.Log;

public class Util {
    
    // 构造类
    public Util(){
        
    }
    
    // 将InputStream格式转化为StringBuilder格式
    public static StringBuilder is2sb (InputStream is) {
        
        String ln = "";
        StringBuilder sb = new StringBuilder();
        BufferedReader br = new BufferedReader(new InputStreamReader(is));
        try{
            while ((ln=br.readLine()) != null){
                sb.append(ln);
            }
            
        }catch(Exception e){
            e.printStackTrace();
        }
        return sb;
        
    }
    
    // JSON转换成List
    public static void json2list(String strJson) throws JSONException {

        JSONObject jsonObject = new JSONObject(strJson);
        JSONArray jsonClas = jsonObject.getJSONArray("Classes");
        for (int i=0; i<jsonClas.length(); i++){
            Var.lstId.add(i, jsonClas.getJSONObject(i).getString("id"));
            Var.lstName.add(i, jsonClas.getJSONObject(i).getString("name"));
            Var.lstComm.add(i, jsonClas.getJSONObject(i).getString("comment"));
        }

    }

}

4. CommThread.java：

package com.hzhi.school.comm;

import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;

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

import com.hzhi.school.MainActivity;
import com.hzhi.school.util.Util;
import com.hzhi.school.util.Var;

public class CommThread extends Thread{    

    // 消息变量
    private Message msg;
    private Bundle bdl;
    
    // 构造函数
    public void run(){
        
        InputStream resIS;
        StringBuilder resSB;
        String resStr;
        
        resIS = getIS(Var.strURL);
        if (resIS == null)
        {
            return;
        }
        else
        {
            resSB = Util.is2sb(resIS);
            resStr = resSB.toString();
            try{
                Util.json2list(resStr);
                sendMessage(Var.msg_connect,"");
            }catch (Exception e){
                e.printStackTrace();
                sendMessage(Var.msg_error,e.toString());
            }
        }
 
    }
    
    // 通过GET方法获取信息
    public InputStream getIS (String url){
        
        InputStream is=null;
        
        try{
            // 取得默认HttpClient实例
            HttpClient hc = new DefaultHttpClient();
            // 连接到服务器
            HttpResponse hr = hc.execute(new HttpGet(url));
            // 获取数据内容
            is = hr.getEntity().getContent();            
        }catch (Exception e){
            e.printStackTrace();
            sendMessage(Var.msg_error,e.toString());
        }
        
        return is;
        
    }
    
    // 发送消息(用于更新UI)
    public void sendMessage(int x, String s){
        
        msg = new Message();
        bdl = new Bundle();    
        bdl.putString("1",s);
        msg.what = x;
        msg.setData(bdl);    
        MainActivity.mainHandler.sendMessage(msg);
        
    }    

}

使用HttpClient向服务器发出请求，服务器返回的是一个InputStream，调用Util里面的函数将InputStream转换成StringBuilder，获得JSON字符串，再解析JSON字符串，获得数据。

5. MainActivity.java:

package com.hzhi.school;

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

import android.app.ListActivity;
import android.app.ProgressDialog;
import android.content.Context;
import android.graphics.Typeface;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.Gravity;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.ViewGroup;
import android.widget.BaseAdapter;
import android.widget.Button;
import android.widget.LinearLayout;
import android.widget.ListView;
import android.widget.TextView;
import android.widget.Toast;

import com.hzhi.school.comm.CommThread;
import com.hzhi.school.util.Var;

public class MainActivity extends ListActivity{
    
    static list_clas_adaptor myAdaptor;
    static Context mCtx;
    static ProgressDialog progressDialog;
    static Toast toast;
    CommThread myThread;
    static int numGet = 0;
    ListView lv;
    int id;
    item_clas it;
    
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_list_clas);
        mCtx = getApplicationContext();        
        getScreen();        
        myAdaptor = new list_clas_adaptor(this);
        progressDialog = ProgressDialog.show(MainActivity.this, 
                "连接", "正在连接服务器:" + Var.strURL, true, false);
        setListAdapter(myAdaptor);
        
        myThread = new CommThread();
        myThread.start();        
    }
    
    protected void onListItemClick(ListView l, View v, int position, long id) {  
        id = Integer.parseInt((String) myAdaptor.list_data.get(position).txtNum.getText());        
        it = (item_clas) myAdaptor.getItem((int)id);
super.onListItemClick(l, v, position, id);  
    }  
    
    // 获得课程列表
    public static void getData(){    
        myAdaptor.list_data.clear();
        if (Var.lstId.size()>0){    
            for (int i=0; i<Var.lstId.size(); i++){
                myAdaptor.addItem(Var.lstId.get(i).toString(), 
                        Var.lstName.get(i).toString(), Var.lstComm.get(i).toString(), 1);

            }
        }
        numGet++;
    }
    
    // 消息处理Handler
    public static Handler mainHandler = new Handler() {  
        public void handleMessage(Message msg) {   
             switch (msg.what) 
             {   
                 
                 // 出错
                 case  Var.msg_error:
                     toast = Toast.makeText(mCtx, 
                            "错误:" + msg.getData().getString("1"), Toast.LENGTH_LONG);
                     toast.show();
                     break;
                 // 已连接成功
                 case Var.msg_connect:
                     progressDialog.dismiss();
                     getData();
                     myAdaptor.notifyDataSetChanged();
                     toast = Toast.makeText(mCtx, 
                             "连接服务器并返回数据成功!", Toast.LENGTH_LONG);
                      toast.show();
                     break;
                 
             }   
             super.handleMessage(msg);   
        }   
   };
    
    
    // 获得屏幕尺寸
    public void getScreen(){        
        Var.wid_scr = getWindowManager().getDefaultDisplay().getWidth();
        Var.hei_scr = getWindowManager().getDefaultDisplay().getHeight();        
    }
    
}

//课程列表
class list_clas_adaptor extends BaseAdapter implements OnClickListener{
    
    public Context ctx;
    public List<item_clas> list_data;
    public String s1, s2;

    public list_clas_adaptor(Context context){        
        ctx =context;
        list_data = new ArrayList<item_clas>();        
    }
    
    
    @Override
    public int getCount() {
        // TODO Auto-generated method stub
        return list_data.size();
    }

    @Override
    public Object getItem(int id) {
        // TODO Auto-generated method stub 
        s2 = String.valueOf(id);
        for (int i=0; i<list_data.size(); i++){
            s1 = (String) list_data.get(i).txtNum.getText();
            if (s1.equals(s2))
                return list_data.get(i);
        }
        
        return null;
        
    }

    @Override
    public long getItemId(int position) {
        // TODO Auto-generated method stub
        return list_data.indexOf(position);
    }

    @Override
    public View getView(int position, View convertView, ViewGroup parent) {
        // TODO Auto-generated method stub

        item_clas my_item; 
    if (convertView == null) 
        {  
            my_item = new item_clas(ctx,
              (String)list_data.get(position).txtNum.getText(),
              (String)list_data.get(position).txtName.getText(),
              (String)list_data.get(position).txtComm.getText()
              ,1); 
        }
        else
        {  
            my_item = (item_clas)convertView;  
            my_item.txtNum.setText(list_data.get(position).txtNum.getText());
            my_item.txtName.setText(list_data.get(position).txtName.getText());
            my_item.txtComm.setText(list_data.get(position).txtComm.getText());
        }
        
        // 点击删除按钮
        my_item.btnDel.setOnClickListener(new OnClickListener() {
            @Override
            public void onClick(View v) {
                
                
            }        });
        
        // 点击修改按钮
        my_item.btnMdf.setOnClickListener(new OnClickListener() {
            @Override
            public void onClick(View v) {
                
                
            }
        });

        return my_item; 
    }
    
    public void addItem(String num, String name, String comm, int x)
    {  
        list_data.add(new item_clas(ctx, num, name, comm, x)); 
    }
    

    @Override
    public void onClick(View v) {

        
    }
    
}

// clas列表的一行
class item_clas extends LinearLayout{
    
    public TextView txtNum;  
    public TextView txtName;
    public TextView txtComm;
    public TextView txtMdf;
    public TextView txtDel;
    public Button btnMdf;
    public Button btnDel;

     
    public item_clas(Context ctx, String num, String name, String comm, int x)
    {         
        super(ctx);
        this.setOrientation(HORIZONTAL);
        int hei = 60;
       
        txtNum = new TextView(ctx);
        txtNum.setText(num);
        txtNum.setGravity(Gravity.CENTER);
        txtNum.setTypeface(Typeface.DEFAULT_BOLD, Typeface.BOLD);
        addView(txtNum, new LinearLayout.LayoutParams((int)(Var.wid_scr*0.1),hei));    
     
        txtName = new TextView(ctx);
        txtName.setText(name);
        txtName.setGravity(Gravity.CENTER);
        txtName.setTypeface(Typeface.DEFAULT_BOLD, Typeface.BOLD);
        addView(txtName, new LinearLayout.LayoutParams((int)(Var.wid_scr*0.2),hei));    
     
        txtComm = new TextView(ctx);
        txtComm.setText(comm);
        Gravity g = new Gravity();
        txtComm.setGravity(Gravity.LEFT);
        addView(txtComm, new LinearLayout.LayoutParams((int)(Var.wid_scr*0.4),hei));
        
        if (x==0){            
            txtDel = new TextView(ctx);
            txtDel.setText("删除");
            txtDel.setGravity(Gravity.CENTER);
            addView(txtDel, new LinearLayout.LayoutParams((int)(Var.wid_scr*0.15),hei));
            Log.i("addView", txtDel.getText().toString());
            
            txtMdf = new TextView(ctx);
            txtMdf.setText("更新 ");
            txtMdf.setGravity(Gravity.CENTER);
            addView(txtMdf, new LinearLayout.LayoutParams((int)(Var.wid_scr*0.15),hei));
            Log.i("comm=", comm);
            Log.i("addView", txtMdf.getText().toString());
        }

        else{        
            btnDel = new Button(ctx);
            btnDel.setText("删除");
            btnDel.setGravity(Gravity.CENTER);
            btnDel.setTypeface(Typeface.DEFAULT_BOLD, Typeface.BOLD);
            btnDel.setFocusable(false);
            addView(btnDel, new LinearLayout.LayoutParams((int)(Var.wid_scr*0.15),hei));
        
            btnMdf = new Button(ctx);
            btnMdf.setText("更新");
            btnMdf.setGravity(Gravity.CENTER);
            btnMdf.setTypeface(Typeface.DEFAULT_BOLD, Typeface.BOLD);
            btnMdf.setFocusable(false);
            addView(btnMdf, new LinearLayout.LayoutParams((int)(Var.wid_scr*0.15),hei));
        }
    }
    
}

MainActivity调用CommThread访问服务器，获得数据后通过BaseAdaptor显示出来。在item_clas类中，由于点击每一行会被系统误以为是在点击Button，所以要给Button加上:

setFocusable(false);

运行结果：