`

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

java即时通信 
阅读更多

本文转载http://blog.csdn.net/shimiso

 

关于Smack编程库，前面我们提到，它是面向Java端的api，主要在PC上使用，利用它我们可以向openfire服务器注册用户，发送消息，并且可以通过监听器获得此用户的应答消息，以及构建聊天室，分组，个人通讯录等等。

下面我们写几个程序小例子测试一下。

（1）登录操作

[java] view plaincopyprint?
  1. PPConnection.DEBUG_ENABLED=true;
  2. AccountManageraccountManager;
  3. finalConnectionConfigurationconnectionConfig=newConnectionConfiguration(
  4. "192.168.1.78",Integer.parseInt("5222"),"csdn.shimiso.com");
  6. //允许自动连接
  7. connectionConfig.setReconnectionAllowed(true);
  8. connectionConfig.setSendPresence(true);
  10. Connectionconnection=newXMPPConnection(connectionConfig);
  11. try{
  12. connection.connect();//开启连接
  13. accountManager=connection.getAccountManager();//获取账户管理类
  14. }catch(XMPPExceptione){
  15. thrownewIllegalStateException(e);
  16. }
  18. //登录
  19. connection.login("admin","admin","SmackTest");
  20. System.out.println(connection.getUser());
  21. connection.getChatManager().createChat("shimiso@csdn.shimiso.com",null).sendMessage("Helloword!"); 
		PPConnection.DEBUG_ENABLED = true;
		AccountManager accountManager;
		final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
				"192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");

		// 允许自动连接
		connectionConfig.setReconnectionAllowed(true);
		connectionConfig.setSendPresence(true);

		Connection connection = new XMPPConnection(connectionConfig);
		try {
			connection.connect();// 开启连接
			accountManager = connection.getAccountManager();// 获取账户管理类
		} catch (XMPPException e) {
			throw new IllegalStateException(e);
		}

		// 登录
		connection.login("admin", "admin","SmackTest");
		System.out.println(connection.getUser()); 
		connection.getChatManager().createChat("shimiso@csdn.shimiso.com",null).sendMessage("Hello word!");

运行结果：

在login中一共有三个参数，登录名，密码，资源名，可能有人不明白资源名到底是什么意思，其实就是客户端的来源，客户端的名称，如果不写它默认就叫smack，如果你用相同的账户不同的资源名和同一个人发三条消息，那将会弹出三个窗口，而不是一个窗口。
同时smack还为我们提供了非常好的调试工具Smack Debug，利用该工具我们可以准确的捕获详细的往返报文信息。

（2）下面我们继续写个聊天的例子：

[java] view plaincopyprint?
  1. PPConnection.DEBUG_ENABLED=true;
  2. AccountManageraccountManager;
  3. finalConnectionConfigurationconnectionConfig=newConnectionConfiguration(
  4. "192.168.1.78",Integer.parseInt("5222"),"csdn.shimiso.com");
  6. //允许自动连接
  7. connectionConfig.setReconnectionAllowed(true);
  8. connectionConfig.setSendPresence(true);
  10. Connectionconnection=newXMPPConnection(connectionConfig);
  11. try{
  12. connection.connect();//开启连接
  13. accountManager=connection.getAccountManager();//获取账户管理类
  14. }catch(XMPPExceptione){
  15. thrownewIllegalStateException(e);
  16. }
  18. //登录
  19. connection.login("admin","admin","SmackTest3");
  20. ChatManagerchatmanager=connection.getChatManager();
  21. ChatnewChat=chatmanager.createChat("shimiso@csdn.shimiso.com",newMessageListener(){
  22. publicvoidprocessMessage(Chatchat,Messagemessage){
  23. if(message.getBody()!=null){
  24. System.out.println("Receivedfrom【"
  25. +message.getFrom()+"】message:"
  26. +message.getBody());
  27. }
  29. }
  30. });
  31. Scannerinput=newScanner(System.in);
  32. while(true){
  33. Stringmessage=input.nextLine();
  34. newChat.sendMessage(message);
  35. }
		PPConnection.DEBUG_ENABLED = true;
		AccountManager accountManager;
		final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
				"192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");

		// 允许自动连接
		connectionConfig.setReconnectionAllowed(true);
		connectionConfig.setSendPresence(true);

		Connection connection = new XMPPConnection(connectionConfig);
		try {
			connection.connect();// 开启连接
			accountManager = connection.getAccountManager();// 获取账户管理类
		} catch (XMPPException e) {
			throw new IllegalStateException(e);
		}

		// 登录
		connection.login("admin", "admin","SmackTest3");  
		ChatManager chatmanager = connection.getChatManager();
		Chat newChat = chatmanager.createChat("shimiso@csdn.shimiso.com", new MessageListener() {
			public void processMessage(Chat chat, Message message) {
				if (message.getBody() != null) {
					System.out.println("Received from 【"
							+ message.getFrom() + "】 message: "
							+ message.getBody());
				}

			}
		});
		Scanner input = new Scanner(System.in);
		while (true) {
			String message = input.nextLine(); 
			newChat.sendMessage(message);
		}

运行结果：

这里我们用Scanner来捕捉用户在控制台的键盘操作，将信息发出，同时创建了一个MessageListener监听，在其中强制实现processMessage方法即可捕获发回的信息，在初次使用上还是较为容易上手的，我们只要细心查看API即可逐步深入下去。

（3）除了聊天以外我们经常还能想到就是广播

需要给所有在线的用户发送一个通知，或者给所有在线和离线的用户全发送，我们先演示如何给在线用户发送一个广播：

[java] view plaincopyprint?
  1. PPConnection.DEBUG_ENABLED=false;
  2. AccountManageraccountManager;
  3. finalConnectionConfigurationconnectionConfig=newConnectionConfiguration(
  4. "192.168.1.78",Integer.parseInt("5222"),"csdn.shimiso.com");
  6. //允许自动连接
  7. connectionConfig.setReconnectionAllowed(true);
  8. connectionConfig.setSendPresence(true);
  10. Connectionconnection=newXMPPConnection(connectionConfig);
  11. try{
  12. connection.connect();//开启连接
  13. accountManager=connection.getAccountManager();//获取账户管理类
  14. }catch(XMPPExceptione){
  15. thrownewIllegalStateException(e);
  16. }
  17. connection.login("admin","admin","SmackTest3");
  18. Messagenewmsg=newMessage();
  19. newmsg.setTo("shimiso@csdn.shimiso.com");
  20. newmsg.setSubject("重要通知");
  21. newmsg.setBody("今天下午2点60分有会！");
  22. newmsg.setType(Message.Type.headline);//normal支持离线
  23. connection.sendPacket(newmsg);
  24. connection.disconnect();
		PPConnection.DEBUG_ENABLED = false;
		AccountManager accountManager;
		final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
				"192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");

		// 允许自动连接
		connectionConfig.setReconnectionAllowed(true);
		connectionConfig.setSendPresence(true);

		Connection connection = new XMPPConnection(connectionConfig);
		try {
			connection.connect();// 开启连接
			accountManager = connection.getAccountManager();// 获取账户管理类
		} catch (XMPPException e) {
			throw new IllegalStateException(e);
		}
		connection.login("admin", "admin","SmackTest3"); 
		Message newmsg = new Message(); 
		newmsg.setTo("shimiso@csdn.shimiso.com");
		newmsg.setSubject("重要通知");
		newmsg.setBody("今天下午2点60分有会！");
		newmsg.setType(Message.Type.headline);// normal支持离线 
		connection.sendPacket(newmsg);
		connection.disconnect();

运行结果：

将参数设置为Message.Type.normal即可支持离线广播，openfire系统会自动判断该用户是否在线，如果在线就直接发送出去，如果不在线则将信息存入ofoffline表，现在我将shimiso用户退出登录，再给它发消息，我们可以进入openfire库的ofoffline表中，非常清楚看到里面躺着一条离线消息记录是发给shimiso这个用户的

（4）那么我们如何让shimiso这个用户一登陆就取到离线消息呢？

请看如下代码

[java] view plaincopyprint?
  1. PPConnection.DEBUG_ENABLED=false;
  2. AccountManageraccountManager;
  3. finalConnectionConfigurationconnectionConfig=newConnectionConfiguration(
  4. "192.168.1.78",Integer.parseInt("5222"),"csdn.shimiso.com");
  6. //允许自动连接
  7. connectionConfig.setReconnectionAllowed(true);
  8. connectionConfig.setSendPresence(false);//不要告诉服务器自己的状态
  9. Connectionconnection=newXMPPConnection(connectionConfig);
  10. try{
  11. connection.connect();//开启连接
  12. accountManager=connection.getAccountManager();//获取账户管理类
  13. }catch(XMPPExceptione){
  14. thrownewIllegalStateException(e);
  15. }
  16. connection.login("shimiso","123","SmackTest");
  17. OfflineMessageManagerofflineManager=newOfflineMessageManager(
  18. connection);
  19. try{
  20. Iterator<org.jivesoftware.smack.packet.Message>it=offlineManager
  21. .getMessages();
  23. System.out.println(offlineManager.supportsFlexibleRetrieval());
  24. System.out.println("离线消息数量:"+offlineManager.getMessageCount());
  26. Map<String,ArrayList<Message>>offlineMsgs=newHashMap<String,ArrayList<Message>>();
  28. while(it.hasNext()){
  29. org.jivesoftware.smack.packet.Messagemessage=it.next();
  30. System.out
  31. .println("收到离线消息,Receivedfrom【"+message.getFrom()
  32. +"】message:"+message.getBody());
  33. StringfromUser=message.getFrom().split("/")[0];
  35. if(offlineMsgs.containsKey(fromUser)){
  36. offlineMsgs.get(fromUser).add(message);
  37. }else{
  38. ArrayList<Message>temp=newArrayList<Message>();
  39. temp.add(message);
  40. offlineMsgs.put(fromUser,temp);
  41. }
  42. }
  44. //在这里进行处理离线消息集合......
  45. Set<String>keys=offlineMsgs.keySet();
  46. Iterator<String>offIt=keys.iterator();
  47. while(offIt.hasNext()){
  48. Stringkey=offIt.next();
  49. ArrayList<Message>ms=offlineMsgs.get(key);
  51. for(inti=0;i<ms.size();i++){
  52. System.out.println("-->"+ms.get(i));
  53. }
  54. }
  56. offlineManager.deleteMessages();
  57. }catch(Exceptione){
  58. e.printStackTrace();
  59. }
  60. offlineManager.deleteMessages();//删除所有离线消息
  61. Presencepresence=newPresence(Presence.Type.available);
  62. nnection.sendPacket(presence);//上线了
  63. nnection.disconnect();//关闭连接 
		PPConnection.DEBUG_ENABLED = false;
		AccountManager accountManager;
		final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
				"192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");

		// 允许自动连接
		connectionConfig.setReconnectionAllowed(true);
		connectionConfig.setSendPresence(false);//不要告诉服务器自己的状态
		Connection connection = new XMPPConnection(connectionConfig);
		try {
			connection.connect();// 开启连接
			accountManager = connection.getAccountManager();// 获取账户管理类
		} catch (XMPPException e) {
			throw new IllegalStateException(e);
		} 
		connection.login("shimiso", "123","SmackTest"); 
		OfflineMessageManager offlineManager = new OfflineMessageManager(
				connection);
		try {
			Iterator<org.jivesoftware.smack.packet.Message> it = offlineManager
					.getMessages();

			System.out.println(offlineManager.supportsFlexibleRetrieval());
			System.out.println("离线消息数量: " + offlineManager.getMessageCount());

			Map<String, ArrayList<Message>> offlineMsgs = new HashMap<String, ArrayList<Message>>();

			while (it.hasNext()) {
				org.jivesoftware.smack.packet.Message message = it.next();
				System.out
						.println("收到离线消息, Received from 【" + message.getFrom()
								+ "】 message: " + message.getBody());
				String fromUser = message.getFrom().split("/")[0];

				if (offlineMsgs.containsKey(fromUser)) {
					offlineMsgs.get(fromUser).add(message);
				} else {
					ArrayList<Message> temp = new ArrayList<Message>();
					temp.add(message);
					offlineMsgs.put(fromUser, temp);
				}
			}

			// 在这里进行处理离线消息集合......
			Set<String> keys = offlineMsgs.keySet();
			Iterator<String> offIt = keys.iterator();
			while (offIt.hasNext()) {
				String key = offIt.next();
				ArrayList<Message> ms = offlineMsgs.get(key);

				for (int i = 0; i < ms.size(); i++) {
					System.out.println("-->" + ms.get(i));
				}
			}

			offlineManager.deleteMessages();
		} catch (Exception e) {
			e.printStackTrace();
		}
		offlineManager.deleteMessages();//删除所有离线消息
		Presence presence = new Presence(Presence.Type.available);
        		nnection.sendPacket(presence);//上线了
        		nnection.disconnect();//关闭连接

运行结果：

这里我们需要特别当心的是先不要告诉openfire服务器你上线了，否则永远也拿不到离线消息，用下面英文大概意思就是在你上线之前去获取离线消息，这么设计是很有道理的。

The OfflineMessageManager helps manage offline messages even before the user has sent an available presence. When a user asks for his offline messages before sending an available presence then the server will not send a flood with all the offline messages when the user becomes online. The server will not send a flood with all the offline messages to the session that made the offline messages request or to any other session used by the user that becomes online.

拿到离线消息处理完毕之后删除离线消息offlineManager.deleteMessages() 接着通知服务器上线了。

（5）下面我们来看看如何来发送文件

 

[java] view plaincopyprint?
  1. PPConnection.DEBUG_ENABLED=false;
  2. AccountManageraccountManager;
  3. finalConnectionConfigurationconnectionConfig=newConnectionConfiguration(
  4. "192.168.1.78",Integer.parseInt("5222"),"csdn.shimiso.com");
  6. //允许自动连接
  7. connectionConfig.setReconnectionAllowed(true);
  8. connectionConfig.setSendPresence(true);
  10. Connectionconnection=newXMPPConnection(connectionConfig);
  11. try{
  12. connection.connect();//开启连接
  13. accountManager=connection.getAccountManager();//获取账户管理类
  14. }catch(XMPPExceptione){
  15. thrownewIllegalStateException(e);
  16. }
  17. connection.login("admin","admin","Rooyee");
  18. Presencepre=connection.getRoster().getPresence("shimiso@csdn.shimiso.com");
  19. System.out.println(pre);
  20. if(pre.getType()!=Presence.Type.unavailable){
  21. //创建文件传输管理器
  22. FileTransferManagermanager=newFileTransferManager(connection);
  23. //创建输出的文件传输
  24. OutgoingFileTransfertransfer=manager
  25. .createOutgoingFileTransfer(pre.getFrom());
  26. //发送文件
  27. transfer.sendFile(newFile("E:\\Chrysanthemum.jpg"),"图片");
  28. while(!transfer.isDone()){
  29. if(transfer.getStatus()==FileTransfer.Status.in_progress){
  30. //可以调用transfer.getProgress();获得传输的进度　
  31. System.out.println(transfer.getStatus());
  32. System.out.println(transfer.getProgress());
  33. System.out.println(transfer.isDone());
  34. }
  35. }
  36. }
		PPConnection.DEBUG_ENABLED = false;
		AccountManager accountManager;
		final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
				"192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");

		// 允许自动连接
		connectionConfig.setReconnectionAllowed(true);
		connectionConfig.setSendPresence(true);

		Connection connection = new XMPPConnection(connectionConfig);
		try {
			connection.connect();// 开启连接
			accountManager = connection.getAccountManager();// 获取账户管理类
		} catch (XMPPException e) {
			throw new IllegalStateException(e);
		}
		  connection.login("admin", "admin","Rooyee"); 
		  Presence pre = connection.getRoster().getPresence("shimiso@csdn.shimiso.com");
			System.out.println(pre);
			if (pre.getType() != Presence.Type.unavailable) {
				// 创建文件传输管理器
				FileTransferManager manager = new FileTransferManager(connection);
				// 创建输出的文件传输
				OutgoingFileTransfer transfer = manager
						.createOutgoingFileTransfer(pre.getFrom());
				// 发送文件
				transfer.sendFile(new File("E:\\Chrysanthemum.jpg"), "图片");
				while (!transfer.isDone()) {
					if (transfer.getStatus() == FileTransfer.Status.in_progress) {
						// 可以调用transfer.getProgress();获得传输的进度　
						System.out.println(transfer.getStatus());
						System.out.println(transfer.getProgress());
						System.out.println(transfer.isDone());
					}
				}
			}

运行结果：

在这里我们需要特别注意的是，跨资源是无法发送文件的，看connection.login("admin", "admin","Rooyee");这个代码就明白了，必须是“域名和资源名”完全相同的两个用户才可以互发文件，否则永远都没反应，如果不清楚自己所用的客户端的资源名，可以借助前面提到的SmackDebug工具查看往返信息完整报文，在to和from中一定可以看到。

如果我们自己要写文件接收例子的话，参考代码如下：

[java] view plaincopyprint?
  1. FileTransferManagertransfer=newFileTransferManager(connection);
  2. transfer.addFileTransferListener(newRecFileTransferListener());
  3. publicclassRecFileTransferListenerimplementsFileTransferListener{
  5. publicStringgetFileType(StringfileFullName){
  6. if(fileFullName.contains(".")){
  7. return"."+fileFullName.split("//.")[1];
  8. }else{
  9. returnfileFullName;
  10. }
  12. }
  14. @Override
  15. publicvoidfileTransferRequest(FileTransferRequestrequest){
  16. System.out.println("接收文件开始.....");
  17. finalIncomingFileTransferinTransfer=request.accept();
  18. finalStringfileName=request.getFileName();
  19. longlength=request.getFileSize();
  20. finalStringfromUser=request.getRequestor().split("/")[0];
  21. System.out.println("文件大小:"+length+""+request.getRequestor());
  22. System.out.println(""+request.getMimeType());
  23. try{
  25. JFileChooserchooser=newJFileChooser();
  26. chooser.setCurrentDirectory(newFile("."));
  28. intresult=chooser.showOpenDialog(null);
  30. if(result==JFileChooser.APPROVE_OPTION){
  31. finalFilefile=chooser.getSelectedFile();
  32. System.out.println(file.getAbsolutePath());
  33. newThread(){
  34. publicvoidrun(){
  35. try{
  37. System.out.println("接受文件:"+fileName);
  38. inTransfer
  39. .recieveFile(newFile(file
  40. .getAbsolutePath()
  41. +getFileType(fileName)));
  43. Messagemessage=newMessage();
  44. message.setFrom(fromUser);
  45. message.setProperty("REC_SIGN","SUCCESS");
  46. message.setBody("["+fromUser+"]发送文件:"
  47. +fileName+"/r/n"+"存储位置:"
  48. +file.getAbsolutePath()
  49. +getFileType(fileName));
  50. if(Client.isChatExist(fromUser)){
  51. Client.getChatRoom(fromUser)
  52. .messageReceiveHandler(message);
  53. }else{
  54. ChatFrameThreadcft=newChatFrameThread(
  55. fromUser,message);
  56. cft.start();
  58. }
  59. }catch(Exceptione2){
  60. e2.printStackTrace();
  61. }
  62. }
  63. }.start();
  64. }else{
  66. System.out.println("拒绝接受文件:"+fileName);
  68. request.reject();
  69. Messagemessage=newMessage();
  70. message.setFrom(fromUser);
  71. message.setBody("拒绝"+fromUser+"发送文件:"+fileName);
  72. message.setProperty("REC_SIGN","REJECT");
  73. if(Client.isChatExist(fromUser)){
  74. Client.getChatRoom(fromUser).messageReceiveHandler(message);
  75. }else{
  76. ChatFrameThreadcft=newChatFrameThread(fromUser,message);
  77. cft.start();
  78. }
  79. }
  81. /*
  82. *InputStreamin=inTransfer.recieveFile();
  83. *
  84. *StringfileName="r"+inTransfer.getFileName();
  85. *
  86. *OutputStreamout=newFileOutputStream(new
  87. *File("d:/receive/"+fileName));byte[]b=newbyte[512];
  88. *while(in.read(b)!=-1){out.write(b);out.flush();}
  89. *
  90. *in.close();out.close();
  91. */
  92. }catch(Exceptione){
  93. e.printStackTrace();
  94. }
  96. System.out.println("接收文件结束.....");
  98. }
  100. }
FileTransferManager transfer = new FileTransferManager(connection);
transfer.addFileTransferListener(new RecFileTransferListener());
public class RecFileTransferListener implements FileTransferListener {

	public String getFileType(String fileFullName) {
		if (fileFullName.contains(".")) {
			return "." + fileFullName.split("//.")[1];
		} else {
			return fileFullName;
		}

	}

	@Override
	public void fileTransferRequest(FileTransferRequest request) {
		System.out.println("接收文件开始.....");
		final IncomingFileTransfer inTransfer = request.accept();
		final String fileName = request.getFileName();
		long length = request.getFileSize();
		final String fromUser = request.getRequestor().split("/")[0];
		System.out.println("文件大小:" + length + "  " + request.getRequestor());
		System.out.println("" + request.getMimeType());
		try {

			JFileChooser chooser = new JFileChooser();
			chooser.setCurrentDirectory(new File("."));

			int result = chooser.showOpenDialog(null);

			if (result == JFileChooser.APPROVE_OPTION) {
				final File file = chooser.getSelectedFile();
				System.out.println(file.getAbsolutePath());
				new Thread() {
					public void run() {
						try {

							System.out.println("接受文件: " + fileName);
							inTransfer
									.recieveFile(new File(file
											.getAbsolutePath()
											+ getFileType(fileName)));

							Message message = new Message();
							message.setFrom(fromUser);
							message.setProperty("REC_SIGN", "SUCCESS");
							message.setBody("[" + fromUser + "]发送文件: "
									+ fileName + "/r/n" + "存储位置: "
									+ file.getAbsolutePath()
									+ getFileType(fileName));
							if (Client.isChatExist(fromUser)) {
								Client.getChatRoom(fromUser)
										.messageReceiveHandler(message);
							} else {
								ChatFrameThread cft = new ChatFrameThread(
										fromUser, message);
								cft.start();

							}
						} catch (Exception e2) {
							e2.printStackTrace();
						}
					}
				}.start();
			} else {

				System.out.println("拒绝接受文件: " + fileName);

				request.reject();
				Message message = new Message();
				message.setFrom(fromUser);
				message.setBody("拒绝" + fromUser + "发送文件: " + fileName);
				message.setProperty("REC_SIGN", "REJECT");
				if (Client.isChatExist(fromUser)) {
					Client.getChatRoom(fromUser).messageReceiveHandler(message);
				} else {
					ChatFrameThread cft = new ChatFrameThread(fromUser, message);
					cft.start();
				}
			}

			/*
			 * InputStream in = inTransfer.recieveFile();
			 * 
			 * String fileName = "r"+inTransfer.getFileName();
			 * 
			 * OutputStream out = new FileOutputStream(new
			 * File("d:/receive/"+fileName)); byte[] b = new byte[512];
			 * while(in.read(b) != -1) { out.write(b); out.flush(); }
			 * 
			 * in.close(); out.close();
			 */
		} catch (Exception e) {
			e.printStackTrace();
		}

		System.out.println("接收文件结束.....");

	}

}

（6）用户列表

[java] view plaincopyprint?
  1. **
  2. *返回所有组信息<RosterGroup>
  3. *
  4. *@returnList(RosterGroup)
  5. */
  6. publicstaticList<RosterGroup>getGroups(Rosterroster){
  7. List<RosterGroup>groupsList=newArrayList<RosterGroup>();
  8. Collection<RosterGroup>rosterGroup=roster.getGroups();
  9. Iterator<RosterGroup>i=rosterGroup.iterator();
  10. while(i.hasNext())
  11. groupsList.add(i.next());
  12. returngroupsList;
  13. }
  15. /**
  16. *返回相应(groupName)组里的所有用户<RosterEntry>
  17. *
  18. *@returnList(RosterEntry)
  19. */
  20. publicstaticList<RosterEntry>getEntriesByGroup(Rosterroster,
  21. StringgroupName){
  22. List<RosterEntry>EntriesList=newArrayList<RosterEntry>();
  23. RosterGrouprosterGroup=roster.getGroup(groupName);
  24. Collection<RosterEntry>rosterEntry=rosterGroup.getEntries();
  25. Iterator<RosterEntry>i=rosterEntry.iterator();
  26. while(i.hasNext())
  27. EntriesList.add(i.next());
  28. returnEntriesList;
  29. }
  31. /**
  32. *返回所有用户信息<RosterEntry>
  33. *
  34. *@returnList(RosterEntry)
  35. */
  36. publicstaticList<RosterEntry>getAllEntries(Rosterroster){
  37. List<RosterEntry>EntriesList=newArrayList<RosterEntry>();
  38. Collection<RosterEntry>rosterEntry=roster.getEntries();
  39. Iterator<RosterEntry>i=rosterEntry.iterator();
  40. while(i.hasNext())
  41. EntriesList.add(i.next());
  42. returnEntriesList;
  43. }
	**
	 * 返回所有组信息 <RosterGroup>
	 * 
	 * @return List(RosterGroup)
	 */
	public static List<RosterGroup> getGroups(Roster roster) {
		List<RosterGroup> groupsList = new ArrayList<RosterGroup>();
		Collection<RosterGroup> rosterGroup = roster.getGroups();
		Iterator<RosterGroup> i = rosterGroup.iterator();
		while (i.hasNext())
			groupsList.add(i.next());
		return groupsList;
	}

	/**
	 * 返回相应(groupName)组里的所有用户<RosterEntry>
	 * 
	 * @return List(RosterEntry)
	 */
	public static List<RosterEntry> getEntriesByGroup(Roster roster,
			String groupName) {
		List<RosterEntry> EntriesList = new ArrayList<RosterEntry>();
		RosterGroup rosterGroup = roster.getGroup(groupName);
		Collection<RosterEntry> rosterEntry = rosterGroup.getEntries();
		Iterator<RosterEntry> i = rosterEntry.iterator();
		while (i.hasNext())
			EntriesList.add(i.next());
		return EntriesList;
	}

	/**
	 * 返回所有用户信息 <RosterEntry>
	 * 
	 * @return List(RosterEntry)
	 */
	public static List<RosterEntry> getAllEntries(Roster roster) {
		List<RosterEntry> EntriesList = new ArrayList<RosterEntry>();
		Collection<RosterEntry> rosterEntry = roster.getEntries();
		Iterator<RosterEntry> i = rosterEntry.iterator();
		while (i.hasNext())
			EntriesList.add(i.next());
		return EntriesList;
	}

（7）用户头像的获取

使用VCard，很强大，具体自己看API吧，可以看看VCard传回来XML的组成，含有很多信息的

[java] view plaincopyprint?
  1. **
  2. *获取用户的vcard信息
  3. *@paramconnection
  4. *@paramuser
  5. *@return
  6. *@throwsXMPPException
  7. */
  8. publicstaticVCardgetUserVCard(XMPPConnectionconnection,Stringuser)throwsXMPPException
  9. {
  10. VCardvcard=newVCard();
  11. vcard.load(connection,user);
  13. returnvcard;
  14. }
  16. /**
  17. *获取用户头像信息
  18. */
  19. publicstaticImageIcongetUserImage(XMPPConnectionconnection,Stringuser){
  20. ImageIconic=null;
  21. try{
  22. System.out.println("获取用户头像信息:"+user);
  23. VCardvcard=newVCard();
  24. vcard.load(connection,user);
  26. if(vcard==null||vcard.getAvatar()==null)
  27. {
  28. returnnull;
  29. }
  30. ByteArrayInputStreambais=newByteArrayInputStream(
  31. vcard.getAvatar());
  32. Imageimage=ImageIO.read(bais);
  35. ic=newImageIcon(image);
  36. System.out.println("图片大小:"+ic.getIconHeight()+""+ic.getIconWidth());
  38. }catch(Exceptione){
  39. e.printStackTrace();
  40. }
  41. returnic;
  42. }
	**
	 * 获取用户的vcard信息
	 * @param connection
	 * @param user
	 * @return
	 * @throws XMPPException
	 */
	public static VCard getUserVCard(XMPPConnection connection, String user) throws XMPPException
	{
		VCard vcard = new VCard();
		vcard.load(connection, user);
		
		return vcard;
	}

	/**
	 * 获取用户头像信息
	 */
	public static ImageIcon getUserImage(XMPPConnection connection, String user) {
		ImageIcon ic = null;
		try {
			System.out.println("获取用户头像信息: "+user);
			VCard vcard = new VCard();
			vcard.load(connection, user);
			
			if(vcard == null || vcard.getAvatar() == null)
			{
				return null;
			}
			ByteArrayInputStream bais = new ByteArrayInputStream(
					vcard.getAvatar());
			Image image = ImageIO.read(bais);
	
			
		    ic = new ImageIcon(image);
			System.out.println("图片大小:"+ic.getIconHeight()+" "+ic.getIconWidth());
		
		} catch (Exception e) {
			e.printStackTrace();
		}
		return ic;
	}

（8）组操作和用户分组操作

[java] view plaincopyprint?
  1. **
  2. *添加一个组
  3. */
  4. publicstaticbooleanaddGroup(Rosterroster,StringgroupName)
  5. {
  6. try{
  7. roster.createGroup(groupName);
  8. returntrue;
  9. }catch(Exceptione){
  10. e.printStackTrace();
  11. returnfalse;
  12. }
  13. }
  15. /**
  16. *删除一个组
  17. */
  18. publicstaticbooleanremoveGroup(Rosterroster,StringgroupName)
  19. {
  20. returnfalse;
  21. }
  23. /**
  24. *添加一个好友无分组
  25. */
  26. publicstaticbooleanaddUser(Rosterroster,StringuserName,Stringname)
  27. {
  28. try{
  29. roster.createEntry(userName,name,null);
  30. returntrue;
  31. }catch(Exceptione){
  32. e.printStackTrace();
  33. returnfalse;
  34. }
  35. }
  36. /**
  37. *添加一个好友到分组
  38. *@paramroster
  39. *@paramuserName
  40. *@paramname
  41. *@return
  42. */
  43. publicstaticbooleanaddUser(Rosterroster,StringuserName,Stringname,StringgroupName)
  44. {
  45. try{
  46. roster.createEntry(userName,name,newString[]{groupName});
  47. returntrue;
  48. }catch(Exceptione){
  49. e.printStackTrace();
  50. returnfalse;
  51. }
  52. }
  54. /**
  55. *删除一个好友
  56. *@paramroster
  57. *@paramuserName
  58. *@return
  59. */
  60. publicstaticbooleanremoveUser(Rosterroster,StringuserName)
  61. {
  62. try{
  64. if(userName.contains("@"))
  65. {
  66. userName=userName.split("@")[0];
  67. }
  68. RosterEntryentry=roster.getEntry(userName);
  69. System.out.println("删除好友:"+userName);
  70. System.out.println("User:"+(roster.getEntry(userName)==null));
  71. roster.removeEntry(entry);
  73. returntrue;
  74. }catch(Exceptione){
  75. e.printStackTrace();
  76. returnfalse;
  77. }
  79. }
	**
	 * 添加一个组
	 */
	public static boolean addGroup(Roster roster,String groupName)
	{
		try {
			roster.createGroup(groupName);
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
	}
	
	/**
	 * 删除一个组
	 */
	public static boolean removeGroup(Roster roster,String groupName)
	{
		return false;
	}
	
	/**
	 * 添加一个好友  无分组
	 */
	public static boolean addUser(Roster roster,String userName,String name)
	{
		try {
			roster.createEntry(userName, name, null);
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
	}
	/**
	 * 添加一个好友到分组
	 * @param roster
	 * @param userName
	 * @param name
	 * @return
	 */
	public static boolean addUser(Roster roster,String userName,String name,String groupName)
	{
		try {
			roster.createEntry(userName, name,new String[]{ groupName});
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
	}
	
	/**
	 * 删除一个好友
	 * @param roster
	 * @param userName
	 * @return
	 */
	public static boolean removeUser(Roster roster,String userName)
	{
		try {
			
			if(userName.contains("@"))
			{
				userName = userName.split("@")[0];
			}
			RosterEntry entry = roster.getEntry(userName);
			System.out.println("删除好友:"+userName);
			System.out.println("User: "+(roster.getEntry(userName) == null));
			roster.removeEntry(entry);
			
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
		
	}

（9）用户查询

[java] view plaincopyprint?
  1. publicstaticList<UserBean>searchUsers(XMPPConnectionconnection,StringserverDomain,StringuserName)throwsXMPPException
  2. {
  3. List<UserBean>results=newArrayList<UserBean>();
  4. System.out.println("查询开始..............."+connection.getHost()+connection.getServiceName());
  6. UserSearchManagerusm=newUserSearchManager(connection);
  9. FormsearchForm=usm.getSearchForm(serverDomain);
  10. FormanswerForm=searchForm.createAnswerForm();
  11. answerForm.setAnswer("Username",true);
  12. answerForm.setAnswer("search",userName);
  13. ReportedDatadata=usm.getSearchResults(answerForm,serverDomain);
  15. Iterator<Row>it=data.getRows();
  16. Rowrow=null;
  17. UserBeanuser=null;
  18. while(it.hasNext())
  19. {
  20. user=newUserBean();
  21. row=it.next();
  22. user.setUserName(row.getValues("Username").next().toString());
  23. user.setName(row.getValues("Name").next().toString());
  24. user.setEmail(row.getValues("Email").next().toString());
  25. System.out.println(row.getValues("Username").next());
  26. System.out.println(row.getValues("Name").next());
  27. System.out.println(row.getValues("Email").next());
  28. results.add(user);
  29. //若存在，则有返回,UserName一定非空，其他两个若是有设，一定非空
  30. }
  32. returnresults;
  33. }
public static List<UserBean> searchUsers(XMPPConnection connection,String serverDomain,String userName) throws XMPPException
	{
		List<UserBean> results = new ArrayList<UserBean>();
		System.out.println("查询开始..............."+connection.getHost()+connection.getServiceName());
		
		UserSearchManager usm = new UserSearchManager(connection);
		
		
        Form searchForm = usm.getSearchForm(serverDomain);
        Form answerForm = searchForm.createAnswerForm();
        answerForm.setAnswer("Username", true);
        answerForm.setAnswer("search", userName);
        ReportedData data = usm.getSearchResults(answerForm, serverDomain);
		 
		 Iterator<Row> it = data.getRows();
		 Row row = null;
		 UserBean user = null;
		 while(it.hasNext())
		 {
			 user = new UserBean();
			 row = it.next();
			 user.setUserName(row.getValues("Username").next().toString());
			 user.setName(row.getValues("Name").next().toString());
			 user.setEmail(row.getValues("Email").next().toString());
			 System.out.println(row.getValues("Username").next());
			 System.out.println(row.getValues("Name").next());
			 System.out.println(row.getValues("Email").next());
			 results.add(user);
			 //若存在，则有返回,UserName一定非空，其他两个若是有设，一定非空
		 }
		 
		 return results;
	}

（10）修改自身状态

包括上线，隐身，对某人隐身，对某人上线

[java] view plaincopyprint?
  1. ublicstaticvoidupdateStateToAvailable(XMPPConnectionconnection)
  2. {
  3. Presencepresence=newPresence(Presence.Type.available);
  4. nnection.sendPacket(presence);
  7. publicstaticvoidupdateStateToUnAvailable(XMPPConnectionconnection)
  8. {
  9. Presencepresence=newPresence(Presence.Type.unavailable);
  10. nnection.sendPacket(presence);
  11. }
  13. publicstaticvoidupdateStateToUnAvailableToSomeone(XMPPConnectionconnection,StringuserName)
  14. {
  15. Presencepresence=newPresence(Presence.Type.unavailable);
  16. presence.setTo(userName);
  17. nnection.sendPacket(presence);
  18. }
  19. publicstaticvoidupdateStateToAvailableToSomeone(XMPPConnectionconnection,StringuserName)
  20. {
  21. Presencepresence=newPresence(Presence.Type.available);
  22. presence.setTo(userName);
  23. nnection.sendPacket(presence);
  25. }
	ublic static void updateStateToAvailable(XMPPConnection connection)
	{
		Presence presence = new Presence(Presence.Type.available);
        		nnection.sendPacket(presence);
     	
	
	public static void updateStateToUnAvailable(XMPPConnection connection)
	{
		Presence presence = new Presence(Presence.Type.unavailable);
        		nnection.sendPacket(presence);
    	}
	
	public static void updateStateToUnAvailableToSomeone(XMPPConnection connection,String userName)
	{
		Presence presence = new Presence(Presence.Type.unavailable);
		presence.setTo(userName);
        		nnection.sendPacket(presence);
	}
	public static void updateStateToAvailableToSomeone(XMPPConnection connection,String userName)
	{
		Presence presence = new Presence(Presence.Type.available);
		presence.setTo(userName);
        		nnection.sendPacket(presence);

	}

（11）心情修改

[java] view plaincopyprint?
  1. **
  2. *修改心情
  3. *@paramconnection
  4. *@paramstatus
  5. */
  6. publicstaticvoidchangeStateMessage(XMPPConnectionconnection,Stringstatus)
  7. {
  8. Presencepresence=newPresence(Presence.Type.available);
  9. presence.setStatus(status);
  10. connection.sendPacket(presence);
  12. }
	**
	 * 修改心情
	 * @param connection
	 * @param status
	 */
	public static void changeStateMessage(XMPPConnection connection,String status)
	{
		Presence presence = new Presence(Presence.Type.available);
		presence.setStatus(status);
		connection.sendPacket(presence);
	
	}

（12）修改用户头像

有点麻烦，主要是读入图片文件，编码，传输之

[java] view plaincopyprint?
  1. publicstaticvoidchangeImage(XMPPConnectionconnection,Filef)throwsXMPPException,IOException{
  3. VCardvcard=newVCard();
  4. vcard.load(connection);
  6. byte[]bytes;
  8. bytes=getFileBytes(f);
  9. StringencodedImage=StringUtils.encodeBase64(bytes);
  10. vcard.setAvatar(bytes,encodedImage);
  11. vcard.setEncodedImage(encodedImage);
  12. vcard.setField("PHOTO","<TYPE>image/jpg</TYPE><BINVAL>"
  13. +encodedImage+"</BINVAL>",true);
  16. ByteArrayInputStreambais=newByteArrayInputStream(
  17. vcard.getAvatar());
  18. Imageimage=ImageIO.read(bais);
  19. ImageIconic=newImageIcon(image);
  23. vcard.save(connection);
  25. }
  27. privatestaticbyte[]getFileBytes(Filefile)throwsIOException{
  28. BufferedInputStreambis=null;
  29. try{
  30. bis=newBufferedInputStream(newFileInputStream(file));
  31. intbytes=(int)file.length();
  32. byte[]buffer=newbyte[bytes];
  33. intreadBytes=bis.read(buffer);
  34. if(readBytes!=buffer.length){
  35. thrownewIOException("Entirefilenotread");
  36. }
  37. returnbuffer;
  38. }finally{
  39. if(bis!=null){
  40. bis.close();
  41. }
  42. }
  43. }
public static void changeImage(XMPPConnection connection,File f) throws XMPPException, IOException{
	
		VCard vcard = new VCard();
		vcard.load(connection);
		
	        byte[] bytes;
	      
	            bytes = getFileBytes(f);
	            String encodedImage = StringUtils.encodeBase64(bytes);
	            vcard.setAvatar(bytes, encodedImage);
	            vcard.setEncodedImage(encodedImage);
	            vcard.setField("PHOTO", "<TYPE>image/jpg</TYPE><BINVAL>"
	                    + encodedImage + "</BINVAL>", true);
	            
	            
	            ByteArrayInputStream bais = new ByteArrayInputStream(
						vcard.getAvatar());
				Image image = ImageIO.read(bais);
				ImageIcon ic = new ImageIcon(image);
				 
	       
	      
	        vcard.save(connection);
	       
	}
	
      private static byte[] getFileBytes(File file) throws IOException {
        		BufferedInputStream bis = null;
        	try {
            bis = new BufferedInputStream(new FileInputStream(file));
            int bytes = (int) file.length();
            byte[] buffer = new byte[bytes];
            int readBytes = bis.read(buffer);
            if (readBytes != buffer.length) {
                throw new IOException("Entire file not read");
            }
            return buffer;
        } finally {
            if (bis != null) {
                bis.close();
            }
        }
}

（13）用户状态的监听

即对方改变头像，状态，心情时，更新自己用户列表，其实这里已经有smack实现的监听器

[java] view plaincopyprint?
  1. nalRosterroster=Client.getRoster();
  3. roster.addRosterListener(
  4. newRosterListener(){
  6. @Override
  7. publicvoidentriesAdded(Collection<String>arg0){
  8. //TODOAuto-generatedmethodstub
  9. System.out.println("--------EE:"+"entriesAdded");
  10. }
  12. @Override
  13. publicvoidentriesDeleted(Collection<String>arg0){
  14. //TODOAuto-generatedmethodstub
  15. System.out.println("--------EE:"+"entriesDeleted");
  16. }
  18. @Override
  19. publicvoidentriesUpdated(Collection<String>arg0){
  20. //TODOAuto-generatedmethodstub
  21. System.out.println("--------EE:"+"entriesUpdated");
  22. }
  24. @Override
  25. publicvoidpresenceChanged(Presencearg0){
  26. //TODOAuto-generatedmethodstub
  27. System.out.println("--------EE:"+"presenceChanged");
  28. }
  30. });
		nal Roster roster = Client.getRoster();
		
		roster.addRosterListener(
			new RosterListener() {

					@Override
					public void entriesAdded(Collection<String> arg0) {
						// TODO Auto-generated method stub
						System.out.println("--------EE:"+"entriesAdded");
					}

					@Override
					public void entriesDeleted(Collection<String> arg0) {
						// TODO Auto-generated method stub
						System.out.println("--------EE:"+"entriesDeleted");
					}

					@Override
					public void entriesUpdated(Collection<String> arg0) {
						// TODO Auto-generated method stub
						System.out.println("--------EE:"+"entriesUpdated");
					}

					@Override
					public void presenceChanged(Presence arg0) {
						// TODO Auto-generated method stub
						System.out.println("--------EE:"+"presenceChanged");
					}   
					
		});
 
 
分享到：
| 基于xmpp openfire smack开发之openfire介 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    基于xmpp_openfire_smack开发之smack类库介绍和使用

    总之，Smack 类库为开发者提供了全面的工具集，用于构建基于 XMPP 协议的实时通信应用，无论是在桌面应用还是移动应用中，都能发挥其强大的功能。通过深入理解和熟练使用 Smack，开发者可以构建高效、稳定且功能丰富...

    高仿android qq客户端 基于xmpp openfire smack

    高仿android qq客户端，基于xmpp openfire smack。难得的即时通信学习源码。 介绍链接： http://blog.csdn.net/shimiso/article/details/11225873

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

    2.离线消息 3.添加，删除好友 4.添加，移动好友分组 5.设置昵称 6.监控好友状态 7.网络断开系统自动重连接 8.收到添加好友请求消息处理 9.收到系统广播消息处理 10.查看历史聊天记录 11.消息弹出提醒，和小气泡 .......

    即时通信源码 高仿android qq客户端 基于xmpp openfire smack.

    基于xmpp openfire smack 的即时通信客户端，高仿qq，难得的学习资源。 资源介绍：http://blog.csdn.net/shimiso/article/details/11225873

    Android使用XMPP协议、OpenFire服务器和Smack类库实现即时通信

    本篇文章将深入探讨如何利用XMPP协议，结合OpenFire服务器以及Smack类库，在Android项目中构建一个即时通讯应用。 首先，我们需要了解OpenFire服务器。OpenFire是一款免费、开源的XMPP服务器，它支持多种操作系统，...

    android studio基于XMPP,Openfire,Smack聊天demo

    这个项目“android studio基于XMPP,Openfire,Smack聊天demo”提供了一个使用Android Studio、XMPP协议、Openfire服务器和Smack库实现的聊天应用示例。以下是关于这些关键技术的详细解释： **XMPP（Extensible ...

    Android 基于xmpp协议，smack包，openfire服务端的高仿QQ的即时通讯实现.zip

    综上所述，这个项目涉及到的技术栈包括XMPP协议、Smack库的使用、Openfire服务器的部署和配置，以及Android应用开发中的UI设计、安全性和性能优化。通过这些技术的结合，可以构建出一个功能完善的即时通讯应用，为...

    openfire+smack开发webim笔记

    总结：通过"openfire+smack"开发WebIM，我们可以理解到XMPP协议在Web即时通讯中的重要性，以及Openfire作为服务器软件的角色。同时，Smack库简化了Java应用与XMPP服务器的交互。WebIM的实现方式多样化，包括Ajax、...

    Android启动Service登陆Openfire实现基于XMPP Smack的消息推送功能

    本项目“Android启动Service登陆Openfire实现基于XMPP Smack的消息推送功能”就是一个很好的示例，展示了如何利用Service和XMPP协议在Android设备上实现实时消息传递。 首先，Openfire是一款开源的XMPP服务器，它...

    Android代码-基于openfire和smack的安卓xmpp客户端

    【Android代码-基于openfire和smack的安卓xmpp客户端】是一个项目，它实现了使用XMPP协议在Android设备上创建一个客户端应用。XMPP（Extensible Messaging and Presence Protocol）是一种实时通信协议，常用于实现...

    OpenFire+smack3.0.4 即时通讯Demo

    首先，OpenFire是一款用Java编写的开源XMPP服务器，它基于XMPP（Extensible Messaging and Presence Protocol）协议，这个协议被广泛用于即时通讯系统，提供实时通讯和在线状态等功能。OpenFire的特点包括高效、可...

    openfire+spark+smack开发流程.pdf

    在本文中，我们将详细介绍OpenFire、Spark和Smack三个组件在XMPP IM开发中的作用，以及如何使用它们来开发一个完整的XMPP IM系统。 首先，让我们了解一下XMPP是什么？Extensible Messaging and Presence Protocol，...

    基于smack连接openfire服务器的例子-JAVA

    Openfire是基于XMPP的服务器，提供了一个强大且可扩展的架构，使得开发者可以轻松创建聊天、协作和其他实时通信应用。 本文将深入探讨如何使用Smack库，一个Java实现的XMPP客户端库，来连接到Openfire服务器并进行...

    Smack API java的类库

    在实际开发中，Openfire是一款流行的开源XMPP服务器，它支持多种客户端连接，包括使用Smack API的Java应用。Openfire提供了用户管理、群组管理、权限控制等一系列服务器端功能，与Smack API相结合，可以构建出强大的...

    openfire+spark+smack

    Openfire、Spark和Smack是三个与XMPP（Extensible Messaging and Presence Protocol）相关的开源项目，它们在构建即时通讯（IM）系统中扮演着重要角色。XMPP是一种基于XML的网络协议，主要用于实时通讯，包括消息...

    openfire+smack即时通讯

    综上所述，建立一个"openfire+smack即时通讯"系统涉及的主要技术点有XMPP协议的使用、Openfire服务器的部署与配置、Smack库的集成开发以及客户端的UI设计和功能实现。开发者需要熟悉Java编程，理解XMPP的工作原理，...

    基于Smack3.0.4+ Openfire3.10.2开发之Android 客户端之三

    在本教程中，我们将深入探讨如何使用Smack 3.0.4库和Openfire 3.10.2服务器来开发一个Android客户端，重点在于实现用户登录、注册功能以及与XMPP服务器的交互。首先，让我们理解这两个关键组件。 **Smack 3.0.4** ...

    XMPP+Openfire4.5.1+Smack4.3.4+MySql

    XMPP+Openfire4.5.1+Smack4.3.4+MySql，支持手机对手机，手机对PC(Spark)的消息收发

    java android openfire smack项目源码

    【标题】"java android openfire smack项目源码"所涉及的知识点主要集中在Java、Android、OpenFire和Smack这四个核心领域。以下是对这些技术的详细介绍： 1. **Java**：Java是一种广泛使用的面向对象的编程语言，...

    Xmpp和OpenFire实例

    先说一下为什么要写这篇博客，是因为本人在周末在研究XMPP和OpenFire，从网上下载了个Demo，但跑不起来，花了很长时间，经改造后，跑起来了，写个篇博文也是希望后边学习XMPP和OpenFire的同学下载后直接运行，少走...

Magicbox
Global site tag (gtag.js) - Google Analytics