阿尔萨斯
- 浏览: 4150628 次
-
最新评论
XMPP协议Asmack实现文件传输的真正解决方法
在使用Asmack的过程中，文件传输是阻碍我前行的一个极大的绊脚石。在翻遍了百度和Google的情况下，依然不得其解。而偶然的一个蓦然回首，我却解决了这个问题。所以，立此贴，一来为自己记录；而来希望能够帮到后来者。我希望自己能够做出一个像微信一样的即时通信，可以发送各种富媒体，接下来看我怎么做，实现文件传输。
第一点，版本问题。
Asmack是一个开源库，地址：https://github.com/Flowdalic/asmack，如大家所看到的一样，这个GitHub并不是完整的代码，你需要通过Grail去构建，而且现在的代码是4.0.3了，我反正不知道怎么用，网上查到的都是大家用的那个什么Cloudy版本的，大概是在2010年左右出的，所以和4.0.3有差距。我后来选择了http://asmack.freakempire.de/0.8.1.1/ ，对，就是0.8.1.1,。。我之所以要说明版本是因为，不同版本，变化挺大的，特别是4.XX和0.xx，相差非常大。
第二点，Jar还是源码
国内大多数都套用一个叫asmack-jse-buddycloud-2010.12.11.jar的jar包，然后所有的可查资料，贴子，基本和这个相关。但是，如果你需要深入了解Asmcack，我建议是选择源码。这也是我为什么要选择0.8.1.1的原因，版本低，一般而言相对简单，而且有源码，我们就可以打日志跟踪。
第三点，一步步教你如何使用Asmack传输文件。
1）平台初始化。
这是隔住我问题的所在，导致我怎么也查不到问题所在的地方。
你需要调用AndroidSmack进行平台的初始化。记住这是使用Asmack必须的一步。我们很容易忽略它。至于它做了什么，我现在可以告诉大家它用AppClassLoader加载了一些类，而触发执行这些类的静态代码。详细的过程和技术细节我后续会再开一个篇来讲解。因为那个技术还挺难的。
public class SanLiaoApplication extends Application {
private List<Activity> activityList = new LinkedList<Activity>();
private SmackAndroid smackAndroid;//必须在APP的Application类中初始化平台
public void onCreate()
{
super.onCreate();
//使用log4j开启日志系统
LogConfigurator logConfigurator =new LogConfigurator();
SimpleDateFormat sDateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
java.util.Date date=new java.util.Date();
String dateString=date.getYear()+"_"+(date.getMonth()+1)+"_"+date.getDate()+"_"+date.getHours()+"_"+date.getMinutes()+"_"+date.getSeconds();
String pathString=Environment.getExternalStorageDirectory()+
File.separator+"sanliao"+File.separator+"logs"+File.separator+"sanliao"+dateString+".log";
Log.d("EIM",pathString);
logConfigurator.setFileName(pathString);
logConfigurator.setRootLevel(Level.DEBUG );
logConfigurator.setLevel("org.apache", Level.ERROR);
logConfigurator.setFilePattern("%d %t %-5p [%c{2}]-[%L] [%M] %m%n");
logConfigurator.setMaxFileSize(1024*1024*5);
logConfigurator.setImmediateFlush(true);
logConfigurator.configure();
Logger logger =Logger.getLogger(EimApplication.class);
logger.info("EIM APP is created info");
logger.debug("EIM APP is creatd debug");
logger.error("EIM APP is create error");
smackAndroid=SmackAndroid.init(getApplicationContext());//初始化Asmack平台，必须的，否则会导致后续传输文件中出现iterm not find (404)错误。
XMPPConnection.DEBUG_ENABLED=true;
logger.debug("XMPPConnectionDebug enable");
}
// 添加Activity到容器中
public void addActivity(Activity activity) {
activityList.add(activity);
}
// 遍历所有Activity并finish
public void exit() {
XmppConnectionManager.getInstance().disconnect();
smackAndroid.onDestroy();
for (Activity activity : activityList) {
activity.finish();
}
}
}
上述代码其实主要包含三个部分：1）初始化log4j日志系统；2）初始化Asmack平台;3）将Activity都放到一个list，这个主要是为了管理Activity，在退出等处理上可以用到。
2）初始化FileTransferManager
这一步其实在网上大家都能够查到。但是我有必要提醒的是，至少0.8.1.1版本中，网上的代码通常会让你根本跑步起来。
先看代码。
//if you need transport file . you need call this method after connect and login
public boolean initFileTransport()
{
if(connection==null)
{
return false;
}
else if(fileTransferManager!=null)
{
return true;
}
else
{
//fileTransferManager = new FileTransferManager(connection);//网上的放在这里，这回导致Asmack崩溃
ServiceDiscoveryManager sdManager= ServiceDiscoveryManager.getInstanceFor(connection);
if(sdManager==null)
{
sdManager=new ServiceDiscoveryManager(connection);
}
sdManager.addFeature("http://jabber.org/protocol/disco#info");
sdManager.addFeature("jabber:iq:privacy");
FileTransferNegotiator.setServiceEnabled(connection, true);
fileTransferManager = new FileTransferManager(connection);//在0.8.1.1版本（之后应该也是如此），正确的应该是放在这里。
return true;
}
}
我把初始化都封装到一个函数里面。需要提醒三点：
（1）上面代码里面的顺序和网上的一般不同，希望大家注意；
（2），我把fileTransferManager 当做XMPPConnection的一个成员。我之所以这么改是因为connection是全局的，你可以在你的其他全局（至少生命期和APP基本是同步）的，而不是该XMPPConnect的代码。所以，这是设计问题。
（3）这个函数的调用要在login登入之后调用。
为了给大家一个完整的上下文，我这里还是巨细无比的给出登入的代码。
// 登录
private Integer login() {
String username = loginConfig.getUsername();
String password = loginConfig.getPassword();
Log.d(LOG_TAG, "login now");
try {
XMPPConnection connection = XmppConnectionManager.getInstance().getConnection();
Log.d(LOG_TAG,"login c2");
logger.debug("XMPPConnection create ");
connection.connect();
logger.debug("XMPPConnection connected ");
Log.d(LOG_TAG,"login c3");
logger.debug("username:"+username+",passwd:"+password);
connection.login(username, password); // 登录
logger.debug("XMPPConnection logined ");
//init the file transport can not put it here
XmppConnectionManager.getInstance().initFileTransport();//文件传输管理的初始化
// OfflineMsgManager.getInstance(activitySupport).dealOfflineMsg(connection);//处理离线消息
connection.sendPacket(new Presence(Presence.Type.available));
Log.d(LOG_TAG, "login c5");
if (loginConfig.isNovisible()) {// 隐身登录
Presence presence = new Presence(Presence.Type.unavailable);
Collection<RosterEntry> rosters = connection.getRoster()
.getEntries();
for (RosterEntry rosterEntry : rosters) {
presence.setTo(rosterEntry.getUser());
connection.sendPacket(presence);
}
}
loginConfig.setUsername(username);
if (loginConfig.isRemember()) {// 保存密码
loginConfig.setPassword(password);
} else {
loginConfig.setPassword("");
}
loginConfig.setOnline(true);
return Constant.LOGIN_SECCESS;
} catch (Exception xee) {
Log.d(LOG_TAG,xee.toString() );
if (xee instanceof XMPPException) {
XMPPException xe = (XMPPException) xee;
Log.d(LOG_TAG,xe.toString() );
final XMPPError error = xe.getXMPPError();
int errorCode = 0;
if (error != null) {
errorCode = error.getCode();
}
if (errorCode == 401) {
return Constant.LOGIN_ERROR_ACCOUNT_PASS;
}else if (errorCode == 403) {
return Constant.LOGIN_ERROR_ACCOUNT_PASS;
} else {
return Constant.SERVER_UNAVAILABLE;
}
} else {
return Constant.LOGIN_ERROR;
}
}
}
到这里，初始化工作算是告一段落。现在，接下来就是要实现如何传输了。
3）发送方。
发送图片为例子。
如上图所示，我们希望的是点击“图片”的时候，我们就可以选择图片，选择完图片后，就可以把图片发送出去。相信，这就是我们需要的，毕竟这就是和微信一样的。
首先“图片”控件需要响应点击。
///////transport image button
tupianBtn = (ImageButton)getActivity().findViewById(R.id.imageButton_tupian);
tupianBtn.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View v) {
// TODO Auto-generated method stub
Toast.makeText(getActivity(), "send file", Toast.LENGTH_SHORT).show();
Intent intent=new Intent();
intent.setType("image/*");//选择图片，这个采用系统的意图。
intent.setAction(Intent.ACTION_GET_CONTENT);
startActivityForResult(intent, TUPIAN_RESULT);//选择完之后，会回到本Activity来。
}
});选择完图片后，会回到Activity，所以，我们如下处理。public void onActivityResult(int requestCode, int resultCode,Intent data) {
if(requestCode==TUPIAN_RESULT)
{
Uri uri=data.getData();
String[] proj={MediaStore.Images.Media.DATA};
Cursor cursor=getActivity().managedQuery(uri,proj,null,null,null);
int index=cursor.getColumnIndexOrThrow(MediaStore.Images.Media.DATA);
cursor.moveToFirst();
String img_path=cursor.getString(index);
Log.d("FragMultiFunc","img_path:"+img_path);
String toId=((AChatActivity)getActivity()).getTo();
new SendFileTask().execute(img_path,toId);//图片路径和我要向谁发送。
}
}
对，开一个AsynCTask来发送图片，给任务传输两个参数，图片文件的路径和我要向谁发送。接着，我给大家看这个SendFileTask的所有代码。
public class SendFileTask extends AsyncTask<String, Integer, Integer>{
private final static Logger logger=Logger.getLogger(SendFileTask.class);
private final static String TAG="SendFileTask";
@Override
protected Integer doInBackground(String... params) {
// TODO Auto-generated method stub
if (params.length < 2) {
Log.d(TAG,"parameter invalide");
return Integer.valueOf(-1);
}
String img_path=params[0];
String toId=params[1]+"/Smack";
Log.d(TAG,"img_path:"+img_path);
logger.debug("img_path:"+img_path);
// XmppConnectionManager.getInstance().initFileTransport();
FileTransferManager fileTransferManager=XmppConnectionManager.getInstance().getFileTransferManager();//获取文件传输管理对象（它被我写成XMPPConnect里面了）
if(fileTransferManager==null)
{
Log.d(TAG, "get FileTransferManager failed");
return -1 ;
}
File filetosend= new File(img_path);
if(filetosend.exists()==false)
{
Log.d(TAG,"file:"+img_path+" is not exist");
return -1;
}
Log.d(TAG,"to user:"+toId);
OutgoingFileTransfer oft=fileTransferManager.createOutgoingFileTransfer(toId);//创建一个输出文件传输对象
try {
oft.sendFile(filetosend, "recv img");
/////
while(!oft.isDone())
{
if (oft.getStatus().equals(FileTransfer.Status.error))
{
Log.e(TAG, "send failed");
}
else
{
Log.i(TAG, "status:" + oft.getStatus() + "|progress:" + oft.getProgress());//打印进度
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
} catch (XMPPException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
return 0;
}
}上述代码是在一个AsyncTask来发送我们的文件，同时每隔1秒打印下进度。（后续可以传递给UI来显示）
这就是发送端。
那么接受端呢？
4）接收方
对于接收方，我在看网上的代码的时候，我最为痛苦的是，接收方的代码放在哪里。而不是接收方代码本身如何写。有人把它当做一个服务，毕竟接受是属于“listener”，我试过，至少我没有成功的跑起来。或许是因为我当时没有进行平台初始化，不过这都不管了。我就告诉我能行的方法。我觉得当你选择一个好友进行对话的时候，就可以监听。
所以，我在和好友的对话ChatActivity一开始，我就设置文件监听。在Oncreate中调用如下init函数。
public void init()
{
FragChatTitle fragChatTitle = new FragChatTitle();
getFragmentManager().beginTransaction().replace(R.id.chat_title_layout,fragChatTitle).commit();
FragChatHistory fragChatHistory=new FragChatHistory();
getFragmentManager().beginTransaction().replace(R.id.chat_history_layout,fragChatHistory).commit();
FragChatBottom fragChatBottom=new FragChatBottom();
getFragmentManager().beginTransaction().replace(R.id.chat_bottom_layout,fragChatBottom).commit();
FragMultiFunc fragMultiFunc=new FragMultiFunc();
getFragmentManager().beginTransaction().replace(R.id.chat_multifunc_layout,fragMultiFunc).hide(fragMultiFunc).commit();
///add listener for file transport listener
XMPPConnection connection = XmppConnectionManager.getInstance().getConnection();
FileTransferManager manager = XmppConnectionManager.getInstance().getFileTransferManager();
ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection);
if (sdm == null)
sdm = new ServiceDiscoveryManager(connection);
sdm.addFeature("http://jabber.org/protocol/disco#info");
sdm.addFeature("jabber:iq:privacy");
// Create the file transfer manager
FileTransferNegotiator.setServiceEnabled(connection, true);
manager.addFileTransferListener(new FileTransferListener() {
@Override
public void fileTransferRequest(final FileTransferRequest request) {
Log.d("NewChatActivity","recv file");
// TODO Auto-generated method stub
new Thread(){
@Override
public void run() {
IncomingFileTransfer transfer = request.accept();
Log.d(LOG_TAG,"file_name:"+transfer.getFileName());
File mf = Environment.getExternalStorageDirectory();
String save_path= Environment.getExternalStorageDirectory()+File.separator+"Eim"+File.separator+transfer.getFileName();
File file = new File(save_path);
try{
transfer.recieveFile(file);
while(!transfer.isDone()) {
try{
Thread.sleep(1000L);
}catch (Exception e) {
Log.e("NewChat", e.getMessage());
}
if(transfer.getStatus().equals(Status.error)) {
Log.e("ERROR!!! ", transfer.getError() +"");
}
if(transfer.getException() != null) {
transfer.getException().printStackTrace();
}
}
}catch (Exception e) {
Log.e("NewChatActivit", e.getMessage());
}
};
}.start();
}
});
}
这个函数会被Activity的Oncreate调用。这样，完整的Asmack文件传输就可以跑起来了。成功传输文件。。。
如果有什么问题，可以问我。
分享到：
发表评论
相关推荐
基于Asmack库 xmpp 协议 socket5 文件传输
xmpp android asmack 即时通讯 功能 聊天 包括文件传输
基于OpenFire 配合asmack 这个年久失修的项目有很多Bug 此asmack2已经修改好部分，可正常实现单人，多人，聊天室功能，并且成功解决文件传输不了问题。
android基于xmpp,asmack的消息推送源码
通过绑定你的gmail邮箱 既可以通过xmpp协议即时传输数据
应http://download.csdn.net/detail/longfei36/5927427 的广大码友要求，现上传源码 基于XMPP 的asmack 安卓即时通讯聊天程序源码 可以正常接收文件，聊天，添加好友，注册，表情等。 特此和广大码友分享
基于asmack包对xmpp开发的功能实现，可以供xmpp协议开发参考
Ⅺ咿P协议的即时通信系统，文件传输只是作为系统的最重要 的组成部分，用于传输普通的文件及在系统中用到的数字签名 文件。基于)m但P协议的文件传输也是基于Ⅺv儿流的传输方 式传输数据，为以后不同风格代码和外来...
xmpp客户端协议实现源代码
XMPP基于openfire asmack实现的即时通讯，包括连接，注册，登录消息发送，群聊等
可以正常运行的基于asmack的即时通讯程序 可登录，注册，收发表情，接收文件，添加分组，修改分组，添加好友 如有问题直接联系我邮箱longfei36@vip.qq.com
asmack是安卓上XMPP协议的一个实现。本示例为安卓上使用asmack连接openfire服务器，实现收发文件、收发文字信息的功能。附带了简单的录音与回放的方法，配合asmack可实现类似微信的功能。附带了一个service示例，可...
XMPP协议中文参考指南
不可多的XMPP协议中文帮助文档,大家可要下来保存哦!
XMPP体系架构 XMPP server:其内核是一个XMPP路由器，完成基本组件间的数据包交换和路由。 功能： 1.会话管理器：负责客户端会话认证，在线状态，用户联系表等 ...5.传输器：建立xmpp服务器与非xmpp服务器通信
agsXMPP\XMPP协议--即时通讯工具实现原理
android项目中打印xmpp协议(收发的报文)到日志文件，只需将代码中使用的Log.debug替换为你自己输入到日志文件的代码即可，详情见https://blog.csdn.net/w690333243/article/details/79963639
net平台 基于 XMPP协议的即时消息服务端简单实现
一个很好的基于XMPP协议通信的源码例子，之前在网上下载了很多基于XMpp协议的例子都不好使，经自己改动后能正常通信，VS2010
xmpp协议和xmpp扩展协议,chm格式