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

时间：2016-01-13 00:39:01 阅读：288 评论：0 收藏：0 [点我收藏+]

标签：

在上两篇文章中，我们依次介绍openfire部署以及smack常用API的使用，这一节中我们着力介绍如何基于asmack开发一个Android的客户端，本篇的重点在实践，讲解和原理环节，大家可以参考前两篇的文章

基于xmpp openfire smack开发之openfire介绍和部署[1]

基于xmpp openfire smack开发之smack类库介绍和使用[2]

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服务器

[html] view plain copy

<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功能清单的配置文件，我们这里开放的权限并不多

[html] view plain copy

<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类

[java] view plain copy

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类

[java] view plain copy