开发者社区> 迅雷老曾> 正文

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文件传输就可以跑起来了。成功传输文件。。。

如果有什么问题,可以问我。







版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
SOFAMesh中的多协议通用解决方案x-protocol介绍系列(2):快速解码转发
在 SOFAMesh 的开发过程中,针对遇到的实际问题,我们给出了一套名为 x-protocol 的解决方案,本文将会对这个解决方案进行详细的讲解,后面会有更多内容,欢迎持续关注本系列文章。
624 0
「镁客早报」马斯克与SEC再次达成和解协议;Uber公布IPO相关条款
这一次和解后,不仅仅是马斯克的推特,公司的博客、投资者电话会议上声明、社交媒体所发布的相关信息也都被纳入了监管范围。
227 0
关于FileZilla上传文件后服务器端文件与本地文件大小不一致的解决方法
最近在调试网站时发现,通过ftp上传工具FileZilla上传至服务器端的文件与本地文件大小不一致,虽然没有影响网站的最终显示效果,但仍让我困惑不解。后发现是传输类型的原因,解决方法如下: 中文版FileZilla菜单栏->传输->传输类型->二进制(Binary) 造成大小不一致的原因:ASCII模式和二进制(Binary)模式的区别是回车换行的处理,Binary模式不对数据进行任何处理,ASCII模式将回车换行转换为本机的回车字符,比如:UNIX下是\n,Windows下是\r\n,Mac下是\r。
1593 0
缺少dll文件的解决方法
1.什么是dll文件 从专业的角度来说,dll文件,即动态连接库,是一种不可执行的二进制文件,它允许程序共享执行特殊任务所必需的代码和其他资源。打个比方,相当于你去饭店吃饭,只人带上钱或卡就可以了,不用把盘子、碗和筷子都带上,在这里电脑就是饭店,它提供了dll文件(相当于盘子、碗和筷子),其他程序(顾客、消费者)可以直接使用,不必自备。
1487 0
使用OpenApi弹性释放和设置云服务器ECS释放
云服务器ECS的一个重要特性就是按需创建资源。您可以在业务高峰期按需弹性的自定义规则进行资源创建,在完成业务计算的时候释放资源。本篇将提供几个Tips帮助您更加容易和自动化的完成云服务器的释放和弹性设置。
20879 0
Maven项目中无法找到 xml文件或 properties文件等配置文件的解决方法
在初次使用 Maven 项目的时候总是会遇到一些比较奇异的问题 就比如说总是会报错:项目里的 **.xml 或 **.properties 配置文件无法找到 这时你去项目中的 classes 生成文件(target 或 out)中找,确实这些配置文件没有被编译 这是因为 ...
1588 0
我的mqtt协议和emqttd开源项目个人理解(24) - emq v2.3.11源码成熟度如何?
我的mqtt协议和emqttd开源项目个人理解(24) - emq v2.3.11源码成熟度如何?
38 0
+关注
199
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载