當前位置：首頁 > 运维知识 > Android >内容正文

Android

Android之基于xmpp openfire smack开发之Android客户端开发[3]

發布時間：2023/12/4 Android 26 豆豆

生活随笔收集整理的這篇文章主要介紹了 Android之基于xmpp openfire smack开发之Android客户端开发[3] 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

http://blog.csdn.net/shimiso/article/details/11225873

在上兩篇文章中，我們依次介紹openfire部署以及smack常用API的使用，這一節中我們著力介紹如何基于asmack開發一個Android的客戶端，本篇的重點在實踐，講解和原理環節，大家可以參考前兩篇的文章

1.源碼結構介紹

activity包下存放一些android頁面交互相關的控制程序，還有一個些公共幫助類

db包為sqlite的工具類封裝，這里做了一些自定義的改造，稍微仿Spring的JdbcTemplate結構，使用起來更加方便一點

manager包留下主要是一些管理組件，包括聯系人管理，消息管理，提醒管理，離線消息管理，用戶管理，xmpp連接管理

model包中都是一些對象模型，傳輸介質

service中存放一些android后臺的核心服務，主要包括聊天服務，聯系人服務，系統消息服務，重連接服務

task包中存放一些耗時的異步操作

util中存放一些常用的工具類

view中一些和android的UI相關的顯示控件

anim中存放一些動畫元素的配置

layout是布局頁面

menu是地步菜單布局頁面

values中存放一些字符，顏色，樣式，參數的配置信息

其中strings.xml中，保存的缺省配置為gtalk的服務器信息，大家如果有谷歌gtalk的賬號可以直接登錄，否則需要更改這里的配置才可以使用其他的xmpp服務器

<integer name="xmpp_port">5222</integer> <string name="xmpp_host">talk.google.com</string> <string name="xmpp_service_name">gmail.com</string> <bool name="is_remember">true</bool> <bool name="is_autologin">false</bool> <bool name="is_novisible">false</bool> AndroidManifest.xml為android功能清單的配置文件，我們這里開放的權限并不多

<uses-permission android:name="android.permission.INTERNET" />  <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />  <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>  <uses-permission android:name="android.permission.MOUNT_UNMOUNT_FILESYSTEMS"/>  <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>

2.核心類介紹

1.ActivitySupport類 package csdn.shimiso.eim.activity; import android.app.Activity; import android.app.AlertDialog; import android.app.Notification; import android.app.NotificationManager; import android.app.PendingIntent; import android.app.ProgressDialog; import android.content.Context; import android.content.DialogInterface; import android.content.Intent; import android.content.SharedPreferences; import android.location.LocationManager; import android.net.ConnectivityManager; import android.net.NetworkInfo; import android.os.Bundle; import android.os.Environment; import android.provider.Settings; import android.view.inputmethod.InputMethodManager; import android.widget.Toast; import csdn.shimiso.eim.R; import csdn.shimiso.eim.comm.Constant; import csdn.shimiso.eim.model.LoginConfig; import csdn.shimiso.eim.service.IMChatService; import csdn.shimiso.eim.service.IMContactService; import csdn.shimiso.eim.service.IMSystemMsgService; import csdn.shimiso.eim.service.ReConnectService; /** * Actity 工具支持類 * * @author shimiso * */ public class ActivitySupport extends Activity implements IActivitySupport { protected Context context = null; protected SharedPreferences preferences; protected EimApplication eimApplication; protected ProgressDialog pg = null; protected NotificationManager notificationManager; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); context = this; preferences = getSharedPreferences(Constant.LOGIN_SET, 0); notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); pg = new ProgressDialog(context); eimApplication = (EimApplication) getApplication(); eimApplication.addActivity(this); } @Override protected void onStart() { super.onStart(); } @Override protected void onResume() { super.onResume(); } @Override protected void onPause() { super.onPause(); } @Override protected void onStop() { super.onStop(); } @Override public void onDestroy() { super.onDestroy(); } @Override public ProgressDialog getProgressDialog() { return pg; } @Override public void startService() { // 好友聯系人服務 Intent server = new Intent(context, IMContactService.class); context.startService(server); // 聊天服務 Intent chatServer = new Intent(context, IMChatService.class); context.startService(chatServer); // 自動恢復連接服務 Intent reConnectService = new Intent(context, ReConnectService.class); context.startService(reConnectService); // 系統消息連接服務 Intent imSystemMsgService = new Intent(context, IMSystemMsgService.class); context.startService(imSystemMsgService); } /** * * 銷毀服務. * * @author shimiso * @update 2012-5-16 下午12:16:08 */ @Override public void stopService() { // 好友聯系人服務 Intent server = new Intent(context, IMContactService.class); context.stopService(server); // 聊天服務 Intent chatServer = new Intent(context, IMChatService.class); context.stopService(chatServer); // 自動恢復連接服務 Intent reConnectService = new Intent(context, ReConnectService.class); context.stopService(reConnectService); // 系統消息連接服務 Intent imSystemMsgService = new Intent(context, IMSystemMsgService.class); context.stopService(imSystemMsgService); } @Override public void isExit() { new AlertDialog.Builder(context).setTitle("確定退出嗎?") .setNeutralButton("確定", new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { stopService(); eimApplication.exit(); } }) .setNegativeButton("取消", new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { dialog.cancel(); } }).show(); } @Override public boolean hasInternetConnected() { ConnectivityManager manager = (ConnectivityManager) context .getSystemService(context.CONNECTIVITY_SERVICE); if (manager != null) { NetworkInfo network = manager.getActiveNetworkInfo(); if (network != null && network.isConnectedOrConnecting()) { return true; } } return false; } @Override public boolean validateInternet() { ConnectivityManager manager = (ConnectivityManager) context .getSystemService(context.CONNECTIVITY_SERVICE); if (manager == null) { openWirelessSet(); return false; } else { NetworkInfo[] info = manager.getAllNetworkInfo(); if (info != null) { for (int i = 0; i < info.length; i++) { if (info[i].getState() == NetworkInfo.State.CONNECTED) { return true; } } } } openWirelessSet(); return false; } @Override public boolean hasLocationGPS() { LocationManager manager = (LocationManager) context .getSystemService(context.LOCATION_SERVICE); if (manager .isProviderEnabled(android.location.LocationManager.GPS_PROVIDER)) { return true; } else { return false; } } @Override public boolean hasLocationNetWork() { LocationManager manager = (LocationManager) context .getSystemService(context.LOCATION_SERVICE); if (manager .isProviderEnabled(android.location.LocationManager.NETWORK_PROVIDER)) { return true; } else { return false; } } @Override public void checkMemoryCard() { if (!Environment.MEDIA_MOUNTED.equals(Environment .getExternalStorageState())) { new AlertDialog.Builder(context) .setTitle(R.string.prompt) .setMessage("請檢查內存卡") .setPositiveButton(R.string.menu_settings, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { dialog.cancel(); Intent intent = new Intent( Settings.ACTION_SETTINGS); context.startActivity(intent); } }) .setNegativeButton("退出", new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { dialog.cancel(); eimApplication.exit(); } }).create().show(); } } public void openWirelessSet() { AlertDialog.Builder dialogBuilder = new AlertDialog.Builder(context); dialogBuilder .setTitle(R.string.prompt) .setMessage(context.getString(R.string.check_connection)) .setPositiveButton(R.string.menu_settings, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { dialog.cancel(); Intent intent = new Intent( Settings.ACTION_WIRELESS_SETTINGS); context.startActivity(intent); } }) .setNegativeButton(R.string.close, new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int whichButton) { dialog.cancel(); } }); dialogBuilder.show(); } /** * * 顯示toast * * @param text * @param longint * @author shimiso * @update 2012-6-28 下午3:46:18 */ public void showToast(String text, int longint) { Toast.makeText(context, text, longint).show(); } @Override public void showToast(String text) { Toast.makeText(context, text, Toast.LENGTH_SHORT).show(); } /** * * 關閉鍵盤事件 * * @author shimiso * @update 2012-7-4 下午2:34:34 */ public void closeInput() { InputMethodManager inputMethodManager = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE); if (inputMethodManager != null && this.getCurrentFocus() != null) { inputMethodManager.hideSoftInputFromWindow(this.getCurrentFocus() .getWindowToken(), InputMethodManager.HIDE_NOT_ALWAYS); } } /** * * 發出Notification的method. * * @param iconId * 圖標 * @param contentTitle * 標題 * @param contentText * 你內容 * @param activity * @author shimiso * @update 2012-5-14 下午12:01:55 */ public void setNotiType(int iconId, String contentTitle, String contentText, Class activity, String from) { /* * 創建新的Intent，作為點擊Notification留言條時，會運行的Activity */ Intent notifyIntent = new Intent(this, activity); notifyIntent.putExtra("to", from); // notifyIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK); /* 創建PendingIntent作為設置遞延運行的Activity */ PendingIntent appIntent = PendingIntent.getActivity(this, 0, notifyIntent, 0); /* 創建Notication，并設置相關參數 */ Notification myNoti = new Notification(); // 點擊自動消失 myNoti.flags = Notification.FLAG_AUTO_CANCEL; /* 設置statusbar顯示的icon */ myNoti.icon = iconId; /* 設置statusbar顯示的文字信息 */ myNoti.tickerText = contentTitle; /* 設置notification發生時同時發出默認聲音 */ myNoti.defaults = Notification.DEFAULT_SOUND; /* 設置Notification留言條的參數 */ myNoti.setLatestEventInfo(this, contentTitle, contentText, appIntent); /* 送出Notification */ notificationManager.notify(0, myNoti); } @Override public Context getContext() { return context; } @Override public SharedPreferences getLoginUserSharedPre() { return preferences; } @Override public void saveLoginConfig(LoginConfig loginConfig) { preferences.edit() .putString(Constant.XMPP_HOST, loginConfig.getXmppHost()) .commit(); preferences.edit() .putInt(Constant.XMPP_PORT, loginConfig.getXmppPort()).commit(); preferences .edit() .putString(Constant.XMPP_SEIVICE_NAME, loginConfig.getXmppServiceName()).commit(); preferences.edit() .putString(Constant.USERNAME, loginConfig.getUsername()) .commit(); preferences.edit() .putString(Constant.PASSWORD, loginConfig.getPassword()) .commit(); preferences.edit() .putBoolean(Constant.IS_AUTOLOGIN, loginConfig.isAutoLogin()) .commit(); preferences.edit() .putBoolean(Constant.IS_NOVISIBLE, loginConfig.isNovisible()) .commit(); preferences.edit() .putBoolean(Constant.IS_REMEMBER, loginConfig.isRemember()) .commit(); preferences.edit() .putBoolean(Constant.IS_ONLINE, loginConfig.isOnline()) .commit(); preferences.edit() .putBoolean(Constant.IS_FIRSTSTART, loginConfig.isFirstStart()) .commit(); } @Override public LoginConfig getLoginConfig() { LoginConfig loginConfig = new LoginConfig(); String a = preferences.getString(Constant.XMPP_HOST, null); String b = getResources().getString(R.string.xmpp_host); loginConfig.setXmppHost(preferences.getString(Constant.XMPP_HOST, getResources().getString(R.string.xmpp_host))); loginConfig.setXmppPort(preferences.getInt(Constant.XMPP_PORT, getResources().getInteger(R.integer.xmpp_port))); loginConfig.setUsername(preferences.getString(Constant.USERNAME, null)); loginConfig.setPassword(preferences.getString(Constant.PASSWORD, null)); loginConfig.setXmppServiceName(preferences.getString( Constant.XMPP_SEIVICE_NAME, getResources().getString(R.string.xmpp_service_name))); loginConfig.setAutoLogin(preferences.getBoolean(Constant.IS_AUTOLOGIN, getResources().getBoolean(R.bool.is_autologin))); loginConfig.setNovisible(preferences.getBoolean(Constant.IS_NOVISIBLE, getResources().getBoolean(R.bool.is_novisible))); loginConfig.setRemember(preferences.getBoolean(Constant.IS_REMEMBER, getResources().getBoolean(R.bool.is_remember))); loginConfig.setFirstStart(preferences.getBoolean( Constant.IS_FIRSTSTART, true)); return loginConfig; } @Override public boolean getUserOnlineState() { // preferences = getSharedPreferences(Constant.LOGIN_SET,0); return preferences.getBoolean(Constant.IS_ONLINE, true); } @Override public void setUserOnlineState(boolean isOnline) { // preferences = getSharedPreferences(Constant.LOGIN_SET,0); preferences.edit().putBoolean(Constant.IS_ONLINE, isOnline).commit(); } @Override public EimApplication getEimApplication() { return eimApplication; } } 大家寫android程序會發現，不同的activity之間經常需要調用一些公共的資源，這里的資源不僅包括android自身的，還有我們自己的管理服務類，甚至相互之間傳遞一些參數，這里我仿照struts2的設計，提煉出一個ActivitySupport類，同時抽取一個接口，讓所有的Activity都集成這個類，因為有了接口，我們便可以采用回調模式，非常方便的傳遞數據和使用公共的資源，這種好處相信大家使用之后都能有深刻的體會，通過接口回調傳遞參數和相互調用的方式無疑是最優雅的，spring和hibernate源碼中曾經大量使用這種結構。
2.SQLiteTemplate類 package csdn.shimiso.eim.db; import java.util.ArrayList; import java.util.List; import android.content.ContentValues; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; /** * SQLite數據庫模板工具類 * * 該類提供了數據庫操作常用的增刪改查,以及各種復雜條件匹配,分頁,排序等操作 * * @see SQLiteDatabase */ public class SQLiteTemplate { /** * Default Primary key */ protected String mPrimaryKey = "_id"; /** * DBManager */ private DBManager dBManager; /** * 是否為一個事務 */ private boolean isTransaction = false; /** * 數據庫連接 */ private SQLiteDatabase dataBase = null; private SQLiteTemplate() { } private SQLiteTemplate(DBManager dBManager, boolean isTransaction) { this.dBManager = dBManager; this.isTransaction = isTransaction; } /** * isTransaction 是否屬于一個事務注:一旦isTransaction設為true * 所有的SQLiteTemplate方法都不會自動關閉資源,需在事務成功后手動關閉 * * @return */ public static SQLiteTemplate getInstance(DBManager dBManager, boolean isTransaction) { return new SQLiteTemplate(dBManager, isTransaction); } /** * 執行一條sql語句 * * @param name * @param tel */ public void execSQL(String sql) { try { dataBase = dBManager.openDatabase(); dataBase.execSQL(sql); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } } /** * 執行一條sql語句 * * @param name * @param tel */ public void execSQL(String sql, Object[] bindArgs) { try { dataBase = dBManager.openDatabase(); dataBase.execSQL(sql, bindArgs); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } } /** * 向數據庫表中插入一條數據 * * @param table * 表名 * @param content * 字段值 */ public long insert(String table, ContentValues content) { try { dataBase = dBManager.openDatabase(); // insert方法第一參數：數據庫表名，第二個參數如果CONTENT為空時則向表中插入一個NULL,第三個參數為插入的內容 return dataBase.insert(table, null, content); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return 0; } /** * 批量刪除指定主鍵數據 * * @param ids */ public void deleteByIds(String table, Object... primaryKeys) { try { if (primaryKeys.length > 0) { StringBuilder sb = new StringBuilder(); for (@SuppressWarnings("unused") Object id : primaryKeys) { sb.append("?").append(","); } sb.deleteCharAt(sb.length() - 1); dataBase = dBManager.openDatabase(); dataBase.execSQL("delete from " + table + " where " + mPrimaryKey + " in(" + sb + ")", (Object[]) primaryKeys); } } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } } /** * 根據某一個字段和值刪除一行數據, 如 name="jack" * * @param table * @param field * @param value * @return 返回值大于0表示刪除成功 */ public int deleteByField(String table, String field, String value) { try { dataBase = dBManager.openDatabase(); return dataBase.delete(table, field + "=?", new String[] { value }); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return 0; } /** * 根據條件刪除數據 * * @param table * 表名 * @param whereClause * 查詢語句參數采用? * @param whereArgs * 參數值 * @return 返回值大于0表示刪除成功 */ public int deleteByCondition(String table, String whereClause, String[] whereArgs) { try { dataBase = dBManager.openDatabase(); return dataBase.delete(table, whereClause, whereArgs); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return 0; } /** * 根據主鍵刪除一行數據 * * @param table * @param id * @return 返回值大于0表示刪除成功 */ public int deleteById(String table, String id) { try { dataBase = dBManager.openDatabase(); return deleteByField(table, mPrimaryKey, id); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return 0; } /** * 根據主鍵更新一行數據 * * @param table * @param id * @param values * @return 返回值大于0表示更新成功 */ public int updateById(String table, String id, ContentValues values) { try { dataBase = dBManager.openDatabase(); return dataBase.update(table, values, mPrimaryKey + "=?", new String[] { id }); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return 0; } /** * 更新數據 * * @param table * @param values * @param whereClause * @param whereArgs * @return 返回值大于0表示更新成功 */ public int update(String table, ContentValues values, String whereClause, String[] whereArgs) { try { dataBase = dBManager.openDatabase(); return dataBase.update(table, values, whereClause, whereArgs); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return 0; } /** * 根據主鍵查看某條數據是否存在 * * @param table * @param id * @return */ public Boolean isExistsById(String table, String id) { try { dataBase = dBManager.openDatabase(); return isExistsByField(table, mPrimaryKey, id); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return null; } /** * 根據某字段/值查看某條數據是否存在 * * @param status * @return */ public Boolean isExistsByField(String table, String field, String value) { StringBuilder sql = new StringBuilder(); sql.append("SELECT COUNT(*) FROM ").append(table).append(" WHERE ") .append(field).append(" =?"); try { dataBase = dBManager.openDatabase(); return isExistsBySQL(sql.toString(), new String[] { value }); } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(null); } } return null; } /** * 使用SQL語句查看某條數據是否存在 * * @param sql * @param selectionArgs * @return */ public Boolean isExistsBySQL(String sql, String[] selectionArgs) { Cursor cursor = null; try { dataBase = dBManager.openDatabase(); cursor = dataBase.rawQuery(sql, selectionArgs); if (cursor.moveToFirst()) { return (cursor.getInt(0) > 0); } else { return false; } } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(cursor); } } return null; } /** * 查詢一條數據 * * @param rowMapper * @param sql * @param args * @return */ public <T> T queryForObject(RowMapper<T> rowMapper, String sql, String[] args) { Cursor cursor = null; T object = null; try { dataBase = dBManager.openDatabase(); cursor = dataBase.rawQuery(sql, args); if (cursor.moveToFirst()) { object = rowMapper.mapRow(cursor, cursor.getCount()); } } finally { if (!isTransaction) { closeDatabase(cursor); } } return object; } /** * 查詢 * * @param rowMapper * @param sql * @param startResult * 開始索引注:第一條記錄索引為0 * @param maxResult * 步長 * @return */ public <T> List<T> queryForList(RowMapper<T> rowMapper, String sql, String[] selectionArgs) { Cursor cursor = null; List<T> list = null; try { dataBase = dBManager.openDatabase(); cursor = dataBase.rawQuery(sql, selectionArgs); list = new ArrayList<T>(); while (cursor.moveToNext()) { list.add(rowMapper.mapRow(cursor, cursor.getPosition())); } } finally { if (!isTransaction) { closeDatabase(cursor); } } return list; } /** * 分頁查詢 * * @param rowMapper * @param sql * @param startResult * 開始索引注:第一條記錄索引為0 * @param maxResult * 步長 * @return */ public <T> List<T> queryForList(RowMapper<T> rowMapper, String sql, int startResult, int maxResult) { Cursor cursor = null; List<T> list = null; try { dataBase = dBManager.openDatabase(); cursor = dataBase.rawQuery(sql + " limit ?,?", new String[] { String.valueOf(startResult), String.valueOf(maxResult) }); list = new ArrayList<T>(); while (cursor.moveToNext()) { list.add(rowMapper.mapRow(cursor, cursor.getPosition())); } } finally { if (!isTransaction) { closeDatabase(cursor); } } return list; } /** * 獲取記錄數 * * @return */ public Integer getCount(String sql, String[] args) { Cursor cursor = null; try { dataBase = dBManager.openDatabase(); cursor = dataBase.rawQuery("select count(*) from (" + sql + ")", args); if (cursor.moveToNext()) { return cursor.getInt(0); } } catch (Exception e) { e.printStackTrace(); } finally { if (!isTransaction) { closeDatabase(cursor); } } return 0; } /** * 分頁查詢 * * @param rowMapper * @param table * 檢索的表 * @param columns * 由需要返回列的列名所組成的字符串數組，傳入null會返回所有的列。 * @param selection * 查詢條件子句，相當于select語句where關鍵字后面的部分，在條件子句允許使用占位符"?" * @param selectionArgs * 對應于selection語句中占位符的值，值在數組中的位置與占位符在語句中的位置必須一致，否則就會有異常 * @param groupBy * 對結果集進行分組的group by語句（不包括GROUP BY關鍵字）。傳入null將不對結果集進行分組 * @param having * 對查詢后的結果集進行過濾,傳入null則不過濾 * @param orderBy * 對結果集進行排序的order by語句（不包括ORDER BY關鍵字）。傳入null將對結果集使用默認的排序 * @param limit * 指定偏移量和獲取的記錄數，相當于select語句limit關鍵字后面的部分,如果為null則返回所有行 * @return */ public <T> List<T> queryForList(RowMapper<T> rowMapper, String table, String[] columns, String selection, String[] selectionArgs, String groupBy, String having, String orderBy, String limit) { List<T> list = null; Cursor cursor = null; try { dataBase = dBManager.openDatabase(); cursor = dataBase.query(table, columns, selection, selectionArgs, groupBy, having, orderBy, limit); list = new ArrayList<T>(); while (cursor.moveToNext()) { list.add(rowMapper.mapRow(cursor, cursor.getPosition())); } } finally { if (!isTransaction) { closeDatabase(cursor); } } return list; } /** * Get Primary Key * * @return */ public String getPrimaryKey() { return mPrimaryKey; } /** * Set Primary Key * * @param primaryKey */ public void setPrimaryKey(String primaryKey) { this.mPrimaryKey = primaryKey; } /** * * @author shimiso * * @param <T> */ public interface RowMapper<T> { /** * * @param cursor * 游標 * @param index * 下標索引 * @return */ public T mapRow(Cursor cursor, int index); } /** * 關閉數據庫 */ public void closeDatabase(Cursor cursor) { if (null != dataBase) { dataBase.close(); } if (null != cursor) { cursor.close(); } } } 我們希望在android操作數據庫是優雅的一種方式，這里不必關注事務，也不用擔心分頁，更不用為了封裝傳遞對象煩惱，總之一切就像面向對象那樣，簡單，模板類的出現正是解決這個問題，雖然它看上去可能不是那么完美有待提高，這里我封裝了很多sqlite常用的工具，大家可以借鑒使用。
3.XmppConnectionManager管理類 package csdn.shimiso.eim.manager; import org.jivesoftware.smack.Connection; import org.jivesoftware.smack.ConnectionConfiguration; import org.jivesoftware.smack.Roster; import org.jivesoftware.smack.XMPPConnection; import org.jivesoftware.smack.provider.ProviderManager; import org.jivesoftware.smackx.GroupChatInvitation; import org.jivesoftware.smackx.PrivateDataManager; import org.jivesoftware.smackx.packet.ChatStateExtension; import org.jivesoftware.smackx.packet.LastActivity; import org.jivesoftware.smackx.packet.OfflineMessageInfo; import org.jivesoftware.smackx.packet.OfflineMessageRequest; import org.jivesoftware.smackx.packet.SharedGroupsInfo; import org.jivesoftware.smackx.provider.DataFormProvider; import org.jivesoftware.smackx.provider.DelayInformationProvider; import org.jivesoftware.smackx.provider.DiscoverInfoProvider; import org.jivesoftware.smackx.provider.DiscoverItemsProvider; import org.jivesoftware.smackx.provider.MUCAdminProvider; import org.jivesoftware.smackx.provider.MUCOwnerProvider; import org.jivesoftware.smackx.provider.MUCUserProvider; import org.jivesoftware.smackx.provider.MessageEventProvider; import org.jivesoftware.smackx.provider.MultipleAddressesProvider; import org.jivesoftware.smackx.provider.RosterExchangeProvider; import org.jivesoftware.smackx.provider.StreamInitiationProvider; import org.jivesoftware.smackx.provider.VCardProvider; import org.jivesoftware.smackx.provider.XHTMLExtensionProvider; import org.jivesoftware.smackx.search.UserSearch; import csdn.shimiso.eim.model.LoginConfig; /** * * XMPP服務器連接工具類. * * @author shimiso */ public class XmppConnectionManager { private XMPPConnection connection; private static ConnectionConfiguration connectionConfig; private static XmppConnectionManager xmppConnectionManager; private XmppConnectionManager() { } public static XmppConnectionManager getInstance() { if (xmppConnectionManager == null) { xmppConnectionManager = new XmppConnectionManager(); } return xmppConnectionManager; } // init public XMPPConnection init(LoginConfig loginConfig) { Connection.DEBUG_ENABLED = false; ProviderManager pm = ProviderManager.getInstance(); configure(pm); connectionConfig = new ConnectionConfiguration( loginConfig.getXmppHost(), loginConfig.getXmppPort(), loginConfig.getXmppServiceName()); connectionConfig.setSASLAuthenticationEnabled(false);// 不使用SASL驗證，設置為false connectionConfig .setSecurityMode(ConnectionConfiguration.SecurityMode.enabled); // 允許自動連接 connectionConfig.setReconnectionAllowed(false); // 允許登陸成功后更新在線狀態 connectionConfig.setSendPresence(true); // 收到好友邀請后manual表示需要經過同意,accept_all表示不經同意自動為好友 Roster.setDefaultSubscriptionMode(Roster.SubscriptionMode.manual); connection = new XMPPConnection(connectionConfig); return connection; } /** * * 返回一個有效的xmpp連接,如果無效則返回空. * * @return * @author shimiso * @update 2012-7-4 下午6:54:31 */ public XMPPConnection getConnection() { if (connection == null) { throw new RuntimeException("請先初始化XMPPConnection連接"); } return connection; } /** * * 銷毀xmpp連接. * * @author shimiso * @update 2012-7-4 下午6:55:03 */ public void disconnect() { if (connection != null) { connection.disconnect(); } } public void configure(ProviderManager pm) { // Private Data Storage pm.addIQProvider("query", "jabber:iq:private", new PrivateDataManager.PrivateDataIQProvider()); // Time try { pm.addIQProvider("query", "jabber:iq:time", Class.forName("org.jivesoftware.smackx.packet.Time")); } catch (ClassNotFoundException e) { } // XHTML pm.addExtensionProvider("html", "http://jabber.org/protocol/xhtml-im", new XHTMLExtensionProvider()); // Roster Exchange pm.addExtensionProvider("x", "jabber:x:roster", new RosterExchangeProvider()); // Message Events pm.addExtensionProvider("x", "jabber:x:event", new MessageEventProvider()); // Chat State pm.addExtensionProvider("active", "http://jabber.org/protocol/chatstates", new ChatStateExtension.Provider()); pm.addExtensionProvider("composing", "http://jabber.org/protocol/chatstates", new ChatStateExtension.Provider()); pm.addExtensionProvider("paused", "http://jabber.org/protocol/chatstates", new ChatStateExtension.Provider()); pm.addExtensionProvider("inactive", "http://jabber.org/protocol/chatstates", new ChatStateExtension.Provider()); pm.addExtensionProvider("gone", "http://jabber.org/protocol/chatstates", new ChatStateExtension.Provider()); // FileTransfer pm.addIQProvider("si", "http://jabber.org/protocol/si", new StreamInitiationProvider()); // Group Chat Invitations pm.addExtensionProvider("x", "jabber:x:conference", new GroupChatInvitation.Provider()); // Service Discovery # Items pm.addIQProvider("query", "http://jabber.org/protocol/disco#items", new DiscoverItemsProvider()); // Service Discovery # Info pm.addIQProvider("query", "http://jabber.org/protocol/disco#info", new DiscoverInfoProvider()); // Data Forms pm.addExtensionProvider("x", "jabber:x:data", new DataFormProvider()); // MUC User pm.addExtensionProvider("x", "http://jabber.org/protocol/muc#user", new MUCUserProvider()); // MUC Admin pm.addIQProvider("query", "http://jabber.org/protocol/muc#admin", new MUCAdminProvider()); // MUC Owner pm.addIQProvider("query", "http://jabber.org/protocol/muc#owner", new MUCOwnerProvider()); // Delayed Delivery pm.addExtensionProvider("x", "jabber:x:delay", new DelayInformationProvider()); // Version try { pm.addIQProvider("query", "jabber:iq:version", Class.forName("org.jivesoftware.smackx.packet.Version")); } catch (ClassNotFoundException e) { } // VCard pm.addIQProvider("vCard", "vcard-temp", new VCardProvider()); // Offline Message Requests pm.addIQProvider("offline", "http://jabber.org/protocol/offline", new OfflineMessageRequest.Provider()); // Offline Message Indicator pm.addExtensionProvider("offline", "http://jabber.org/protocol/offline", new OfflineMessageInfo.Provider()); // Last Activity pm.addIQProvider("query", "jabber:iq:last", new LastActivity.Provider()); // User Search pm.addIQProvider("query", "jabber:iq:search", new UserSearch.Provider()); // SharedGroupsInfo pm.addIQProvider("sharedgroup", "http://www.jivesoftware.org/protocol/sharedgroup", new SharedGroupsInfo.Provider()); // JEP-33: Extended Stanza Addressing pm.addExtensionProvider("addresses", "http://jabber.org/protocol/address", new MultipleAddressesProvider()); } }
這個類是xmpp連接的管理類，如果大家使用smack的api對這個應該不會陌生，asmack對xmpp連接的管理，與smack的差別不大，但是部分細微區別也有，我們在使用中如果遇到問題，還要多加注意，我們這里將其設計成單例，畢竟重復創建連接是個非常消耗的過程。

3.演示效果

很像QQ吧，沒錯，這是2012年版本qq的安卓界面，只是界面元素一樣，實現方式大不相同，下面簡單列一下這個客戶端實現的功能： 1.聊天 2.離線消息 3.添加，刪除好友 4.添加，移動好友分組 5.設置昵稱 6.監控好友狀態 7.網絡斷開系統自動重連接 8.收到添加好友請求消息處理 9.收到系統廣播消息處理 10.查看歷史聊天記錄 11.消息彈出提醒，和小氣泡 .... 因為時間關系不是很完美，主要用于學習研究，歡迎大家給我提bug和改進意見。

4.源碼下載

http://download.csdn.net/detail/shimiso/6224163

分數比較大，不是為了坑大家，是怕有伸手黨出現，拿了源碼出去招搖撞騙，請尊重作者原創！

參閱文獻
Openfirehttp://www.igniterealtime.org/
push-notificationhttp://www.push-notification.org/
Claros chathttp://www.claros.org/
androidpnsourceforgehttp://sourceforge.net/projects/androidpn/
android消息推送解決方案http://www.cnblogs.com/hanyonglu/archive/2012/03/04/2378971.html
xmpp協議實現原理介紹?http://www.cnblogs.com/hanyonglu/archive/2012/03/04/2378956.html

總結

以上是生活随笔為你收集整理的Android之基于xmpp openfire smack开发之Android客户端开发[3]的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： Android之基于xmpp openf
下一篇： Android之基于xmpp openf