基于百度云推送的实时通信客户端实现（二）

上一篇说了欢迎和登陆界面的实现，现在来说一下关于聊天界面的搭建，整体界面采用了一个ListView，主要的布局很简单，在这里使用了ListView自定义是Adapter的写法

同时，我构造了一个TaliListInfo的类来和Adapter对应

闲话不多说，直接上代码

package com.demo.Adapter;

import java.util.List;

import com.tuisong.R;

import android.content.Context;
import android.database.DataSetObserver;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.BaseAdapter;
import android.widget.LinearLayout;
import android.widget.TextView;

public class NewAdapterView extends BaseAdapter {

    @SuppressWarnings("unused")
    private static final String TAG = NewAdapterView.class.getSimpleName();

    private List<MessageEnity> coll;

    private Context context;

    // 构造函数
    public NewAdapterView(Context context, List<MessageEnity> list) {
        this.context = context;
        this.coll = list;
    }

    public boolean areAllItemsEnabled() {
        return false;
    }

    public boolean isEnabled(int arg0) {
        return false;
    }

    @Override
    public int getCount() {
        // TODO Auto-generated method stub
        return coll.size();
    }

    @Override
    public Object getItem(int arg0) {
        // TODO Auto-generated method stub
        return coll.get(arg0);
    }

    @Override
    public long getItemId(int arg0) {
        // TODO Auto-generated method stub
        return arg0;
    }

    public int getItemViewType(int position) {
        return position;
    }

    @Override
    public View getView(int positon, View convertView, ViewGroup parent) {
        // TODO Auto-generated method stub
        MessageEnity entity = coll.get(positon);
        int itemLayout = entity.getLayoutID();

        LinearLayout layout = new LinearLayout(context);
        LayoutInflater inflater = (LayoutInflater) context
                .getSystemService(Context.LAYOUT_INFLATER_SERVICE);
        inflater.inflate(itemLayout, layout, true);

        TextView tvName = (TextView) layout.findViewById(R.id.person_name);
        tvName.setText(entity.getfromUser());

        TextView tvData = (TextView) layout.findViewById(R.id.time_say);
        tvData.setText(entity.getTime());

        TextView tvItem = (TextView) layout.findViewById(R.id.item_say);
        tvItem.setText(entity.getItem());

        return layout;
    }

    public int getViewTypeCount() {
        return coll.size();
    }

    public boolean hasStableIds() {
        return false;
    }

    public boolean isEmpty() {
        return false;
    }

    public void registerDataSetObserver(DataSetObserver observer) {
    }

    public void unregisterDataSetObserver(DataSetObserver observer) {
    }

}

Adapter的构造过程

package com.demo.Adapter;

import java.util.ArrayList;
import java.util.List;
import com.tuisong.R;

import android.content.Context;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.BaseAdapter;
import android.widget.TextView;

public class ListAdapter extends BaseAdapter {

    private Context context;
    private List<TalkListInfo> talklist = new ArrayList<TalkListInfo>();
    private LayoutInflater inflater = null;

    public ListAdapter(Context context, List<TalkListInfo> talklist) {
        this.context = context;
        this.talklist = talklist;
        Log.d("create", "!!!");
    }

    @Override
    public int getCount() {
        // TODO Auto-generated method stub
        return talklist.size();
    }

    @Override
    public Object getItem(int arg0) {
        // TODO Auto-generated method stub
        return talklist.get(arg0);
    }

    @Override
    public long getItemId(int arg0) {
        // TODO Auto-generated method stub
        return arg0;
    }

    @Override
    public View getView(int arg0, View arg1, ViewGroup arg2) {
        // TODO Auto-generated method stub

        inflater = LayoutInflater.from(this.context);
        TalkHolder talk = new TalkHolder();
        if (arg1 == null) {
            talk = new TalkHolder();
            arg1 = inflater.inflate(R.layout.talklistadapter, null);
            talk.tv_name = (TextView) arg1.findViewById(R.id.tv_name);
            talk.tv_time = (TextView) arg1.findViewById(R.id.tv_time);
            talk.tv_item = (TextView) arg1.findViewById(R.id.tv_item);
            arg1.setTag(talk);
        } else {
            talk = (TalkHolder) arg1.getTag();
        }

        talk.tv_name.setText(talklist.get(arg0).getName());
        talk.tv_time.setText(talklist.get(arg0).getDate());
        talk.tv_item.setText(talklist.get(arg0).getItem());

        return arg1;
    }

}

class TalkHolder {
    public TextView tv_name;
    public TextView tv_time;
    public TextView tv_item;
}

 同时，还需要写一个对应的布局来作为ListView的Adapter的布局

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="fill_parent"
    android:layout_height="wrap_content"
    android:background="#eeeeee"
    android:orientation="horizontal"
    tools:context="com.baidu.push.example.CustomActivity" >

    <ImageView
        android:layout_width="64dp"
        android:layout_height="64dp"
        android:background="@drawable/retouxiang"
        android:contentDescription="@string/app_name"
        android:scaleType="fitXY" />

    <LinearLayout
        android:layout_width="fill_parent"
        android:layout_height="64dp"
        android:orientation="vertical" >

        <LinearLayout
            android:layout_width="fill_parent"
            android:layout_height="32dp"
            android:orientation="horizontal" >

            <TextView
                android:id="@+id/tv_name"
                android:layout_width="0dp"
                android:layout_height="32dp"
                android:layout_weight="1"
                android:text="@string/app_name"
                android:textColor="#000000" />

            <TextView
                android:id="@+id/tv_time"
                android:layout_width="0dp"
                android:layout_height="32dp"
                android:layout_weight="1"
                android:text="@string/app_name"
                android:textColor="#000000" />
        </LinearLayout>

        <TextView
            android:id="@+id/tv_item"
            android:layout_width="fill_parent"
            android:layout_height="32dp"
            android:text="@string/app_name"
            android:textColor="#000000" />
    </LinearLayout>

</LinearLayout>

同时，因为只是个Demo，我的头像没有下载的功能，采用了一个空白的头像图片，取消了下载功能，效果如图

 同时，因为聊天记录保存在SQLite中，所以，需要自己实现一个DBhelper的类继承SQLiteOpenHelper，代码如下：

package com.tuisong.db;

import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import com.demo.Adapter.MessageEnity;
import com.demo.Adapter.TalkListInfo;

import android.annotation.SuppressLint;
import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;

public class DBHelpter extends SQLiteOpenHelper {

    private final static String DATABASE_NAME = "chat_record_db";
    private final static String TABLE_NAME = "chat_table";
    private final static String FROM_USER = "fromuser";
    private final static String TO_USER = "touser";
    private final static String TIME = "time";
    private final static String CHAT_CONTENT = "content";
    private final static String LAYOUT_ID = "layoutid";
    @SuppressWarnings("unused")
    private final static String CHAT_ID = "id";
    private String openid = null;
    public DBHelpter help;

    @SuppressLint("NewApi")
    public DBHelpter(Context context) {
        super(context, DATABASE_NAME, null, 1);
        System.out.println("the data has been created");
        // TODO Auto-generated constructor stub
    }

    @Override
    public void onCreate(SQLiteDatabase db) {
        // TODO Auto-generated method stub
        String sql = "CREATE TABLE if not exists  chat_table ( id  INTEGER PRIMARY KEY  AUTOINCREMENT, fromuser TEXT,   touser   TEXT,   time  TEXT, content TEXT, layoutid TEXT);";

        db.execSQL(sql);
        System.out.println(sql);
    }
    
    //更新数据库，因为我没有数据的修改，所以不需要实现此方法
    @Override
    public void onUpgrade(SQLiteDatabase db, int arg1, int arg2) {
        // TODO Auto-generated method stub
        // db.execSQL("drop table if exists" + TABLE_NAME);

        // onCreate(db);
    }
    //插入数据
    public void Insert(MessageEnity message) {
        SQLiteDatabase db = this.getWritableDatabase();
        ContentValues value = new ContentValues();
        value.put(FROM_USER, message.getfromUser());
        value.put(TO_USER, message.gettomUser());
        value.put(TIME, message.getTime());
        value.put(CHAT_CONTENT, message.getItem());
        value.put(LAYOUT_ID, message.getLayoutID());

        long ss = db.insert(TABLE_NAME, null, value);
        System.out.println("has been insert in db " + ss);
    }

    // 消息内容
    public List<MessageEnity> findPersonMessage(String openid, String userid) {
        List<MessageEnity> messages = new ArrayList<MessageEnity>();
        SQLiteDatabase db = this.getReadableDatabase();
        System.out.println("dsdfsw" + db.toString());

        String sql = "select * from chat_table where (fromuser='" + openid
                + "' and touser='" + userid + "') or (touser='" + openid
                + "' and fromuser='" + userid + "') order by time ";
        Cursor cursor = db.rawQuery(sql, null);
        cursor.moveToFirst();
        System.out.println("the find message is " + cursor.getCount());
        if (cursor.getCount() > 0) {
            if (cursor.getCount() > 10) {
                cursor.moveToPosition(cursor.getCount() - 10);
                for (int i = 0; i < 10; i++) {
                    MessageEnity message = new MessageEnity();
                    message.setfroUser(cursor.getString(cursor
                            .getColumnIndex(FROM_USER)));
                    message.setItem(cursor.getString(cursor
                            .getColumnIndex(CHAT_CONTENT)));
                    message.setLayoutID(cursor.getInt(cursor
                            .getColumnIndex(LAYOUT_ID)));
                    message.setTime(cursor.getString(cursor
                            .getColumnIndex(TIME)));
                    message.settoUser(cursor.getString(cursor
                            .getColumnIndex(TO_USER)));
                    messages.add(message);
                    cursor.moveToNext();
                }
            } else {
                cursor.moveToFirst();
                for (int i = 0; i < cursor.getCount(); i++) {
                    MessageEnity message = new MessageEnity();
                    message.setfroUser(cursor.getString(cursor
                            .getColumnIndex(FROM_USER)));
                    message.setItem(cursor.getString(cursor
                            .getColumnIndex(CHAT_CONTENT)));
                    message.setLayoutID(cursor.getInt(cursor
                            .getColumnIndex(LAYOUT_ID)));
                    message.setTime(cursor.getString(cursor
                            .getColumnIndex(TIME)));
                    message.settoUser(cursor.getString(cursor
                            .getColumnIndex(TO_USER)));
                    messages.add(message);
                    cursor.moveToNext();
                }
            }
            return messages;
        } else {
            return null;
        }

    }

    // 列出消息列表
    public List<TalkListInfo> findList(String touser) {
        List<TalkListInfo> infos = new ArrayList<TalkListInfo>();
        SQLiteDatabase db = this.getReadableDatabase();
        System.out.println("the ver sion is" + db.getVersion());
        String sql = "select fromuser, time , content,count(distinct fromuser) from chat_table where touser='"
                + touser + "' group by fromuser order by time desc";
        // Cursor cursor = db.query(TABLE_NAME, new String[] { FROM_USER, TIME,
        // CHAT_CONTENT }, null, null, null, null, TIME);
        Cursor cursor = db.rawQuery(sql, null);
        System.out.println("the ver num is" + cursor.getCount());
        cursor.moveToFirst();
        if (cursor.getCount() > 0) {
            System.out.println("the tag num ");
            for (int i = 0; i < cursor.getCount(); i++) {

                if (cursor.getString(cursor.getColumnIndex(FROM_USER)).equals(
                        openid) != true) {
                    TalkListInfo info = new TalkListInfo();

                    info.setName(cursor.getString(cursor
                            .getColumnIndex(FROM_USER)));

                    info.setDate(cursor.getString(cursor.getColumnIndex(TIME)));
                    info.setItem(cursor.getString(cursor
                            .getColumnIndex(CHAT_CONTENT)));

                    infos.add(info);
                    cursor.moveToNext();
                }
            }

            System.out.println("tag2");
            removeDuplicate(infos);
            return infos;
        } else {
            System.out.println("tag3");
            return infos;
        }

    }

    public static void removeDuplicate(List<TalkListInfo> list) {
        HashSet<TalkListInfo> h = new HashSet<TalkListInfo>(list);
        list.clear();
        list.addAll(h);
        System.out.println(list);
    }

}

 好了到了这里，准备工作已经基本完成了，现在就要编写界面的后台代码了

package com.baidu.push.example;

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

import com.baidu.android.pushservice.PushConstants;
import com.baidu.android.pushservice.PushManager;
import com.demo.Adapter.ListAdapter;
import com.demo.Adapter.TalkListInfo;
import com.tuisong.R;
import com.tuisong.Save_Read;
import com.tuisong.Until;
import com.tuisong.db.DBHelpter;

import android.app.Activity;
import android.app.NotificationManager;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.os.Bundle;
import android.view.Menu;
import android.view.MenuItem;
import android.view.View;
import android.widget.AdapterView.OnItemClickListener;
import android.widget.AdapterView;
import android.widget.ListView;
import android.widget.RelativeLayout;

public class PushDemoActivity extends Activity implements OnItemClickListener {

    private static ListView list;
    private static List<TalkListInfo> talk;
    private static ListAdapter adapter;
    RelativeLayout mainLayout = null;
    public static int initialCnt = 0;
    public Save_Read save = new Save_Read();
    public static Map<String, String> map;
    public static DBHelpter help;
    public static String userid;
    public SharedPreferences sp;
    public static NotificationManager manager;

    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        setContentView(R.layout.main);
        @SuppressWarnings("unused")
        NotificationManager manager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
        @SuppressWarnings("unused")
        MyReceiver receiver = new MyReceiver();
        sp = this.getSharedPreferences("key", 0);
        SharedPreferences.Editor edtior = sp.edit();
        edtior.putString("SSP", "1");
        edtior.commit();

        list = (ListView) findViewById(R.id.list);
        help = new DBHelpter(this);
        map = new HashMap<String, String>();

        userid = sp.getString("Login", null);
        System.out.println("the  login  id is " + userid);

        talk = new ArrayList<TalkListInfo>();

        talk = help.findList(userid);

        if (talk != null) {
            for (TalkListInfo t : talk) {

                map.put("name", t.getName());
                map.put("time", t.getDate());
                map.put("content", t.getItem());
            }
            adapter = new ListAdapter(this, talk);
            list.setAdapter(adapter);
        }

        list.setOnItemClickListener(new OnItemClickListener() {

            @Override
            public void onItemClick(AdapterView<?> arg0, View arg1, int arg2,
                    long arg3) {
                // TODO Auto-generated method stub
                Intent intent = new Intent(PushDemoActivity.this,
                        TalkActivity.class);
                intent.putExtra("name", talk.get(arg2).getName());
                intent.putExtra("userid", userid);
                Until.setString(talk.get(arg2).getName());
                startActivity(intent);

            }
        });

        // 以apikey的方式登录，一般放在主Activity的onCreate中
        PushManager.startWork(getApplicationContext(),
                PushConstants.LOGIN_TYPE_API_KEY,
                Utils.getMetaValue(PushDemoActivity.this, "api_key"));

    }

    @Override
    public void onStart() {
        super.onStart();
        
    }

    @Override
    public void onResume() {
        super.onResume();
        
        SharedPreferences.Editor edtior = sp.edit();
        edtior.putString("SSP", "0");
        edtior.commit();

    }

    @Override
    protected void onNewIntent(Intent intent) {
        // 如果要统计Push引起的用户使用应用情况，请实现本方法，且加上这一个语句
        setIntent(intent);

    }

    @Override
    protected void onPause() {
        // TODO Auto-generated method stub
        super.onPause();
        
        SharedPreferences.Editor edtior = sp.edit();
        edtior.putString("SSP", "0");
        edtior.commit();
    }

    @Override
    public void onStop() {
        super.onStop();
        PushManager.activityStoped(this);
        // SharedPreferences.Editor edtior = sp.edit();
        // edtior.putString("Login", "-1");
        // edtior.commit();
        // }
    }

    @Override
    protected void onDestroy() {
        // TODO Auto-generated method stub
        super.onDestroy();
        // SharedPreferences.Editor edtior = sp.edit();
        // edtior.putString("Login", "-1");
        // edtior.commit();
    }

    @Override
    public void onItemClick(AdapterView<?> arg0, View arg1, int arg2, long arg3) {
        // TODO Auto-generated method stub

    }

    public boolean onCreateOptionsMenu(Menu menu) {
        // 调用父类方法来加入系统菜单
        // 虽然目前android还没有系统菜单，但是为了兼容到以后的版本，最好加上
        super.onCreateOptionsMenu(menu);

        // 添加菜单项（多种方式）
        // 1.直接指定标题
        menu.add(1, 0, 1, "退出");

        // 3.显示指定菜单项的组号、ID、排序号、标题

        // 如果希望显示菜单，请返回true
        return true;
    }

    @Override
    public boolean onOptionsItemSelected(MenuItem item) {
        switch (item.getItemId()) {
        // 响应每个菜单项(通过菜单项的ID)

        case 0:
            change();
            finish();
            // do something here
            break;
        default:
            // 对没有处理的事件，交给父类来处理
            return super.onOptionsItemSelected(item);
        }
        // 返回true表示处理完菜单项的事件，不需要将该事件继续传播下去了
        return true;
    }

    
    //修改当前活动activity的状态
    public void change() {
        SharedPreferences.Editor edtior = sp.edit();
        edtior.putString("Login", "-1");
        edtior.commit();
    }
}

到这里，对话列表的界面搭建已经完成了，下一篇文章里面介绍聊天界面写法