本文是在上一篇博文Android基于XMPP的即时通讯1-基本对话的基础上,添加新的功能,文件传输
1、初始化文件传输管理类
public static FileTransferManager getFileTransferManager() { if (fileManager == null) { 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); fileManager = new FileTransferManager(connection); } return fileManager; }
2、监听接收文件(文件路径创建好,不然会报错),直接接收文件,没有写确认
private void addFileListerer() { FileTransferManager manager = XmppConnection.getFileTransferManager(); manager.addFileTransferListener(new FileTransferListener() { @Override public void fileTransferRequest(final FileTransferRequest request) { new Thread() { @Override public void run() { IncomingFileTransfer transfer = request.accept(); String fileName = transfer.getFileName(); // 在handler里取出来显示消息 String[] args = new String[] { toUserName, fileName }; android.os.Message msg = handler.obtainMessage(); msg.what = 1; msg.obj = args; msg.sendToTarget(); String save_path = Environment .getExternalStorageDirectory() + File.separator + "XmppTest" + File.separator + fileName; File file = new File(save_path); try { transfer.recieveFile(file); while (!transfer.isDone()) { if (transfer.getStatus().equals(FileTransfer.Status.error)) { System.out.println("ERROR!!! " + transfer.getError()); } else { } try { Thread.sleep(1000L); } catch (Exception e) { } } } catch (XMPPException e) { e.printStackTrace(); } }; }.start(); } }); }
3、发送文件,这里发送图片测试
客户端文件发送:toId后边要加一个字符串"/Smack",发送给其他的平台要加相应的字符串;
这里手机客户端发送给Spark客户端,发送文件时toId+"/Spark"
private void getImage(){ Intent intent = new Intent(); intent.setType("image/*"); intent.setAction(Intent.ACTION_GET_CONTENT); startActivityForResult(intent, TUPIAN_RESULT); }
protected void onActivityResult(int requestCode, int resultCode, Intent data) { super.onActivityResult(requestCode, resultCode, data); Uri uri = data.getData(); String[] proj = { MediaStore.Images.Media.DATA }; Cursor cursor = activity.managedQuery(uri, proj, null, null, null); int index = cursor.getColumnIndexOrThrow(MediaStore.Images.Media.DATA); cursor.moveToFirst(); String img_path = cursor.getString(index); new SendFileTask().execute(img_path, toUserID); };
class SendFileTask extends AsyncTask<String, Integer, Integer> { protected Integer doInBackground(String... params) { if (params.length < 2) { return Integer.valueOf(-1); } String img_path = params[0]; String toId = params[1] + "/Spark"; FileTransferManager fileTransferManager = XmppConnection.getFileTransferManager(); File filetosend = new File(img_path); if (filetosend.exists() == false) { return -1; } // 在handler里取出来显示消息 String[] args = new String[] { toUserName, img_path }; android.os.Message msg = handler.obtainMessage(); msg.what = 1; msg.obj = args; msg.sendToTarget(); OutgoingFileTransfer transfer = fileTransferManager .createOutgoingFileTransfer(toId);// 创建一个输出文件传输对象 try { transfer.sendFile(filetosend, "recv img"); while (!transfer.isDone()) { if (transfer.getStatus().equals(FileTransfer.Status.error)) { System.out.println("ERROR!!! " + transfer.getError()); } else { } try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } catch (XMPPException e1) { e1.printStackTrace(); } return 0; } }
源码送上:http://files.cnblogs.com/files/pear-lemon/XmppTest.zip
时间: 2024-10-24 23:12:34