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

http://blog.csdn.net/shimiso/article/details/8816540

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

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

（1）登录操作

[java] view plaincopy

  1. PPConnection.DEBUG_ENABLED = true;
  2. AccountManager accountManager;
  3. final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
  4. "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");
  5. // 允许自动连接
  6. connectionConfig.setReconnectionAllowed(true);
  7. connectionConfig.setSendPresence(true);
  8. Connection connection = new XMPPConnection(connectionConfig);
  9. try {
  10. connection.connect();// 开启连接
  11. accountManager = connection.getAccountManager();// 获取账户管理类
  12. } catch (XMPPException e) {
  13. throw new IllegalStateException(e);
  14. }
  15. // 登录
  16. connection.login("admin", "admin","SmackTest");
  17. System.out.println(connection.getUser());
  18. connection.getChatManager().createChat("[email protected]",null).sendMessage("Hello word!");

运行结果：

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

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

[java] view plaincopy

  1. PPConnection.DEBUG_ENABLED = true;
  2. AccountManager accountManager;
  3. final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
  4. "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");
  5. // 允许自动连接
  6. connectionConfig.setReconnectionAllowed(true);
  7. connectionConfig.setSendPresence(true);
  8. Connection connection = new XMPPConnection(connectionConfig);
  9. try {
  10. connection.connect();// 开启连接
  11. accountManager = connection.getAccountManager();// 获取账户管理类
  12. } catch (XMPPException e) {
  13. throw new IllegalStateException(e);
  14. }
  15. // 登录
  16. connection.login("admin", "admin","SmackTest3");
  17. ChatManager chatmanager = connection.getChatManager();
  18. Chat newChat = chatmanager.createChat("[email protected]", new MessageListener() {
  19. public void processMessage(Chat chat, Message message) {
  20. if (message.getBody() != null) {
  21. System.out.println("Received from 【"
  22. + message.getFrom() + "】 message: "
  23. + message.getBody());
  24. }
  25. }
  26. });
  27. Scanner input = new Scanner(System.in);
  28. while (true) {
  29. String message = input.nextLine();
  30. newChat.sendMessage(message);
  31. }

运行结果：

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

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

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

[java] view plaincopy

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

运行结果：

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

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

请看如下代码

[java] view plaincopy

  1. PPConnection.DEBUG_ENABLED = false;
  2. AccountManager accountManager;
  3. final ConnectionConfiguration connectionConfig = new ConnectionConfiguration(
  4. "192.168.1.78", Integer.parseInt("5222"), "csdn.shimiso.com");
  5. // 允许自动连接
  6. connectionConfig.setReconnectionAllowed(true);
  7. connectionConfig.setSendPresence(false);//不要告诉服务器自己的状态
  8. Connection connection = new XMPPConnection(connectionConfig);
  9. try {
  10. connection.connect();// 开启连接
  11. accountManager = connection.getAccountManager();// 获取账户管理类
  12. } catch (XMPPException e) {
  13. throw new IllegalStateException(e);
  14. }
  15. connection.login("shimiso", "123","SmackTest");
  16. OfflineMessageManager offlineManager = new OfflineMessageManager(
  17. connection);
  18. try {
  19. Iterator<org.jivesoftware.smack.packet.Message> it = offlineManager
  20. .getMessages();
  21. System.out.println(offlineManager.supportsFlexibleRetrieval());
  22. System.out.println("离线消息数量: " + offlineManager.getMessageCount());
  23. Map<String, ArrayList<Message>> offlineMsgs = new HashMap<String, ArrayList<Message>>();
  24. while (it.hasNext()) {
  25. org.jivesoftware.smack.packet.Message message = it.next();
  26. System.out
  27. .println("收到离线消息, Received from 【" + message.getFrom()
  28. + "】 message: " + message.getBody());
  29. String fromUser = message.getFrom().split("/")[0];
  30. if (offlineMsgs.containsKey(fromUser)) {
  31. offlineMsgs.get(fromUser).add(message);
  32. } else {
  33. ArrayList<Message> temp = new ArrayList<Message>();
  34. temp.add(message);
  35. offlineMsgs.put(fromUser, temp);
  36. }
  37. }
  38. // 在这里进行处理离线消息集合......
  39. Set<String> keys = offlineMsgs.keySet();
  40. Iterator<String> offIt = keys.iterator();
  41. while (offIt.hasNext()) {
  42. String key = offIt.next();
  43. ArrayList<Message> ms = offlineMsgs.get(key);
  44. for (int i = 0; i < ms.size(); i++) {
  45. System.out.println("-->" + ms.get(i));
  46. }
  47. }
  48. offlineManager.deleteMessages();
  49. } catch (Exception e) {
  50. e.printStackTrace();
  51. }
  52. offlineManager.deleteMessages();//删除所有离线消息
  53. Presence presence = new Presence(Presence.Type.available);
  54. nnection.sendPacket(presence);//上线了
  55. 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 plaincopy

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

运行结果：

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

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

[java] view plaincopy

  1. FileTransferManager transfer = new FileTransferManager(connection);
  2. transfer.addFileTransferListener(new RecFileTransferListener());
  3. public class RecFileTransferListener implements FileTransferListener {
  4. public String getFileType(String fileFullName) {
  5. if (fileFullName.contains(".")) {
  6. return "." + fileFullName.split("//.")[1];
  7. } else {
  8. return fileFullName;
  9. }
  10. }
  11. @Override
  12. public void fileTransferRequest(FileTransferRequest request) {
  13. System.out.println("接收文件开始.....");
  14. final IncomingFileTransfer inTransfer = request.accept();
  15. final String fileName = request.getFileName();
  16. long length = request.getFileSize();
  17. final String fromUser = request.getRequestor().split("/")[0];
  18. System.out.println("文件大小:" + length + "  " + request.getRequestor());
  19. System.out.println("" + request.getMimeType());
  20. try {
  21. JFileChooser chooser = new JFileChooser();
  22. chooser.setCurrentDirectory(new File("."));
  23. int result = chooser.showOpenDialog(null);
  24. if (result == JFileChooser.APPROVE_OPTION) {
  25. final File file = chooser.getSelectedFile();
  26. System.out.println(file.getAbsolutePath());
  27. new Thread() {
  28. public void run() {
  29. try {
  30. System.out.println("接受文件: " + fileName);
  31. inTransfer
  32. .recieveFile(new File(file
  33. .getAbsolutePath()
  34. + getFileType(fileName)));
  35. Message message = new Message();
  36. message.setFrom(fromUser);
  37. message.setProperty("REC_SIGN", "SUCCESS");
  38. message.setBody("[" + fromUser + "]发送文件: "
  39. + fileName + "/r/n" + "存储位置: "
  40. + file.getAbsolutePath()
  41. + getFileType(fileName));
  42. if (Client.isChatExist(fromUser)) {
  43. Client.getChatRoom(fromUser)
  44. .messageReceiveHandler(message);
  45. } else {
  46. ChatFrameThread cft = new ChatFrameThread(
  47. fromUser, message);
  48. cft.start();
  49. }
  50. } catch (Exception e2) {
  51. e2.printStackTrace();
  52. }
  53. }
  54. }.start();
  55. } else {
  56. System.out.println("拒绝接受文件: " + fileName);
  57. request.reject();
  58. Message message = new Message();
  59. message.setFrom(fromUser);
  60. message.setBody("拒绝" + fromUser + "发送文件: " + fileName);
  61. message.setProperty("REC_SIGN", "REJECT");
  62. if (Client.isChatExist(fromUser)) {
  63. Client.getChatRoom(fromUser).messageReceiveHandler(message);
  64. } else {
  65. ChatFrameThread cft = new ChatFrameThread(fromUser, message);
  66. cft.start();
  67. }
  68. }
  69. /*
  70. * InputStream in = inTransfer.recieveFile();
  71. *
  72. * String fileName = "r"+inTransfer.getFileName();
  73. *
  74. * OutputStream out = new FileOutputStream(new
  75. * File("d:/receive/"+fileName)); byte[] b = new byte[512];
  76. * while(in.read(b) != -1) { out.write(b); out.flush(); }
  77. *
  78. * in.close(); out.close();
  79. */
  80. } catch (Exception e) {
  81. e.printStackTrace();
  82. }
  83. System.out.println("接收文件结束.....");
  84. }
  85. }

（6）用户列表

[java] view plaincopy

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

（7）用户头像的获取

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

[java] view plaincopy

  1. **
  2. * 获取用户的vcard信息
  3. * @param connection
  4. * @param user
  5. * @return
  6. * @throws XMPPException
  7. */
  8. public static VCard getUserVCard(XMPPConnection connection, String user) throws XMPPException
  9. {
  10. VCard vcard = new VCard();
  11. vcard.load(connection, user);
  12. return vcard;
  13. }
  14. /**
  15. * 获取用户头像信息
  16. */
  17. public static ImageIcon getUserImage(XMPPConnection connection, String user) {
  18. ImageIcon ic = null;
  19. try {
  20. System.out.println("获取用户头像信息: "+user);
  21. VCard vcard = new VCard();
  22. vcard.load(connection, user);
  23. if(vcard == null || vcard.getAvatar() == null)
  24. {
  25. return null;
  26. }
  27. ByteArrayInputStream bais = new ByteArrayInputStream(
  28. vcard.getAvatar());
  29. Image image = ImageIO.read(bais);
  30. ic = new ImageIcon(image);
  31. System.out.println("图片大小:"+ic.getIconHeight()+" "+ic.getIconWidth());
  32. } catch (Exception e) {
  33. e.printStackTrace();
  34. }
  35. return ic;
  36. }

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

[java] view plaincopy

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

（9）用户查询

[java] view plaincopy

  1. public static List<UserBean> searchUsers(XMPPConnection connection,String serverDomain,String userName) throws XMPPException
  2. {
  3. List<UserBean> results = new ArrayList<UserBean>();
  4. System.out.println("查询开始..............."+connection.getHost()+connection.getServiceName());
  5. UserSearchManager usm = new UserSearchManager(connection);
  6. Form searchForm = usm.getSearchForm(serverDomain);
  7. Form answerForm = searchForm.createAnswerForm();
  8. answerForm.setAnswer("Username", true);
  9. answerForm.setAnswer("search", userName);
  10. ReportedData data = usm.getSearchResults(answerForm, serverDomain);
  11. Iterator<Row> it = data.getRows();
  12. Row row = null;
  13. UserBean user = null;
  14. while(it.hasNext())
  15. {
  16. user = new UserBean();
  17. row = it.next();
  18. user.setUserName(row.getValues("Username").next().toString());
  19. user.setName(row.getValues("Name").next().toString());
  20. user.setEmail(row.getValues("Email").next().toString());
  21. System.out.println(row.getValues("Username").next());
  22. System.out.println(row.getValues("Name").next());
  23. System.out.println(row.getValues("Email").next());
  24. results.add(user);
  25. //若存在，则有返回,UserName一定非空，其他两个若是有设，一定非空
  26. }
  27. return results;
  28. }

（10）修改自身状态

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

[java] view plaincopy

  1. ublic static void updateStateToAvailable(XMPPConnection connection)
  2. {
  3. Presence presence = new Presence(Presence.Type.available);
  4. nnection.sendPacket(presence);
  5. public static void updateStateToUnAvailable(XMPPConnection connection)
  6. {
  7. Presence presence = new Presence(Presence.Type.unavailable);
  8. nnection.sendPacket(presence);
  9. }
  10. public static void updateStateToUnAvailableToSomeone(XMPPConnection connection,String userName)
  11. {
  12. Presence presence = new Presence(Presence.Type.unavailable);
  13. presence.setTo(userName);
  14. nnection.sendPacket(presence);
  15. }
  16. public static void updateStateToAvailableToSomeone(XMPPConnection connection,String userName)
  17. {
  18. Presence presence = new Presence(Presence.Type.available);
  19. presence.setTo(userName);
  20. nnection.sendPacket(presence);
  21. }

（11）心情修改

[java] view plaincopy

  1. **
  2. * 修改心情
  3. * @param connection
  4. * @param status
  5. */
  6. public static void changeStateMessage(XMPPConnection connection,String status)
  7. {
  8. Presence presence = new Presence(Presence.Type.available);
  9. presence.setStatus(status);
  10. connection.sendPacket(presence);
  11. }

（12）修改用户头像

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

[java] view plaincopy

  1. public static void changeImage(XMPPConnection connection,File f) throws XMPPException, IOException{
  2. VCard vcard = new VCard();
  3. vcard.load(connection);
  4. byte[] bytes;
  5. bytes = getFileBytes(f);
  6. String encodedImage = StringUtils.encodeBase64(bytes);
  7. vcard.setAvatar(bytes, encodedImage);
  8. vcard.setEncodedImage(encodedImage);
  9. vcard.setField("PHOTO", "<TYPE>image/jpg</TYPE><BINVAL>"
  10. + encodedImage + "</BINVAL>", true);
  11. ByteArrayInputStream bais = new ByteArrayInputStream(
  12. vcard.getAvatar());
  13. Image image = ImageIO.read(bais);
  14. ImageIcon ic = new ImageIcon(image);
  15. vcard.save(connection);
  16. }
  17. private static byte[] getFileBytes(File file) throws IOException {
  18. BufferedInputStream bis = null;
  19. try {
  20. bis = new BufferedInputStream(new FileInputStream(file));
  21. int bytes = (int) file.length();
  22. byte[] buffer = new byte[bytes];
  23. int readBytes = bis.read(buffer);
  24. if (readBytes != buffer.length) {
  25. throw new IOException("Entire file not read");
  26. }
  27. return buffer;
  28. } finally {
  29. if (bis != null) {
  30. bis.close();
  31. }
  32. }
  33. }

（13）用户状态的监听

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

[java] view plaincopy

  1. nal Roster roster = Client.getRoster();
  2. roster.addRosterListener(
  3. new RosterListener() {
  4. @Override
  5. public void entriesAdded(Collection<String> arg0) {
  6. // TODO Auto-generated method stub
  7. System.out.println("--------EE:"+"entriesAdded");
  8. }
  9. @Override
  10. public void entriesDeleted(Collection<String> arg0) {
  11. // TODO Auto-generated method stub
  12. System.out.println("--------EE:"+"entriesDeleted");
  13. }
  14. @Override
  15. public void entriesUpdated(Collection<String> arg0) {
  16. // TODO Auto-generated method stub
  17. System.out.println("--------EE:"+"entriesUpdated");
  18. }
  19. @Override
  20. public void presenceChanged(Presence arg0) {
  21. // TODO Auto-generated method stub
  22. System.out.println("--------EE:"+"presenceChanged");
  23. }
  24. });

SmackTest例子下载

时间： 2024-10-13 00:47:39

基于xmpp openfire smack开发之smack类库介绍和使用[2]的相关文章

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

在上两篇文章中,我们依次介绍openfire部署以及smack常用API的使用,这一节中我们着力介绍如何基于asmack开发一个Android的客户端,本篇的重点在实践,讲解和原理环节,大家可以参考前两篇的文章 基于xmpp openfire smack开发之openfire介绍和部署[1] 基于xmpp openfire smack开发之smack类库介绍和使用[2] 1.源码结构介绍 activity包下存放一些android页面交互相关的控制程序,还有一个些公共帮助类 db包为sqlite

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

前言 http://blog.csdn.net/shimiso/article/details/8816558 Java领域的即时通信的解决方案可以考虑openfire+spark+smack.当然也有其他的选择. Openfire是基于Jabber协议(XMPP)实现的即时通信服务器端版本,目前建议使用3.8.1版本,这个版本是当前最新的版本,而且网上可以找到下载的源代码. 即时通信客户端可使用spark2.6.3,这个版本是目前最新的release版本,经过测试发现上一版本在视频支持,msn

Pilin —— 一个基于Xmpp openfire smack的即时聊天工具

https://github.com/whfcomm/Pilin

openfire插件开发之IQHander

IQHander插件 注意事项 我们如果要做自己的IQ包处理,可以自定义类如TestTemplateMethodHandler:class TestTemplateMethodHandler extends IQHandler. 以下需要注意: IQ handlers相应包中特定的元素名或命名空间,在public IQHandlerInfo getInfo()方法中写上自己想要注册的元素名及命名空间.如: private IQHandlerInfo info;private String HIS

测试开发之Django——No1.介绍以及引申

前言 > 测试行业发展飞速,自动化测试兴起,由此对测试人员的要求与日俱增.随时而来的,就是职能的增加. > 首先需要学习的,就是自动化测试.而由自动化测试引申而来的,就是另外几个新增的岗位:自动化测试工程师.测试开发工程师.测试架构工程师.作为测试人员,学习的内容也越来越多 > 除了大家需要学会编程能力外,还需要具备的一点,就是对测试平台的开发或维护,这里有些同学就要不明白了.既然有自动化测试工程师,为什么很多公司都不会去开展自动化测试. > 原因很简单,维护成本太大. >

C#学习与上位机开发之2窗口介绍

一.引子 窗口就是打开程序我们所面对的一个面板,里面可以添加各种控件,如下图所示,我们可以在属性栏设置其标题名称.图标.大小等.               图1    窗口图                                                          图2     设置面板                               图3   设置 双击标题框,会生成Load函数,也可以到事件里面去找 Load函数是窗口生成后需要执行的事件函数. 可以在里

嵌入式开发之davinci--- mcfw框架介绍

整体上mcfw框架如下图 从中可见其层次是清楚的,link实在基本的驱动之上的,而mcfw是在link之上的api,是通过link来实现相应的功能.可见link是框架中承上启下的层次,通过link来实现具体的功能,所以对link进行深入的学习和了解,对于理解mcfw以及扩展其功能是至关重要的. link的主要功能包括视频的输入输出,视频的编解码,以及dsp算法等. ezsdk与dvrrdk 要看你的应用了,如果是DVR.NVR,建议使用DVR RDK,里面去掉了OpenMax,改用专门针对多通道

游戏开发之UDK引擎介绍和模型导入

2014-09-18 10:01:3 UnrealDevelopmentKit(虚幻引擎开发工具包),简称UDK,是一套强大并免费的游戏引擎开发套件,可以用来制作高端的3D游戏或者场景展示.不过,如果你要制作商业游戏,并且获得不错的收益,UDK官方会乐于找你分享所得. *UDK直接支持针对苹果Iphone平台的游戏开发. 有关UDK的强大功能和一些基本操作,都能在网上找到不少资料,这里我仅简介UDK的基本构造,以及UDK和Maya的一些交互操作. [UDK的构成] 虽然UDK官方提供了中文界面,

linux驱动开发之framebuffer驱动介绍

framebuffer是linux里面的显示设备.在驱动底下如何操作lcd实现图形的显示. 1.什么是framebuffer? (1)首先想一下在裸机中我们是怎么操作LCD的. Soc内部有lcd的控制器,Soc外面有lcd的驱动器,lcd的驱动器连接着lcd的屏幕,Soc的内部还有CPU,外部还有DDR内存.这些设备都参与到了lcd的显示中. 在裸机中我们是怎么搞的呢,lcd的驱动器和lcd的控制器之间通过排线进行链接,连接的接口就是lcd所特有的一个接口.lcd控制器里面是很多和lcd相关的