`

基于openfire+smack的Android、Web、PC开发(一)

 
阅读更多
基于openfire+smack的Android、Web、PC开发(一)

参考:http://my.oschina.net/yuanxulong/blog/348572


前言

Java领域的即时通信的解决方案可以考虑openfire+spark+smack。当然也有其他的选择。

Openfire是基于Jabber协议(XMPP)实现的即时通信服务器端版本,目前建议使用3.8.1版本,这个版本是当前最新的版本,而且网上可以找到下载的源代码。

即时通信客户端可使用spark2.6.3,这个版本是目前最新的release版本,经过测试发现上一版本在视频支持,msn网关支持上可能有问题,所以选择openfire3.8.1+spark2.6.3是最合适的选择。

Smack是即时通信客户端编程库,目前我已测通通过jsp使用smack的API向openfire注册用户发送消息,并且可以通过监听器获得此用户的应答消息。

通过smack向msn用户和QQ用户,gtalk用户发送消息应该也可以实现,关于向gtalk用户发送消息的例子较多。这个留待以后研究。至少目前可以通过程序向spark发消息了。对于局域网内部应用足以解决系统与用户交互的问题,甚至可以做自动应答机器人。

Spark支持聊天,语音,视频,会议,文件收发,截屏,连接msn等功能。

同时在Android移动端和Web端也有相应的编程库支持,在后面的章节会为大家逐步更新介绍,接下来我们首先要对几个重点的技术环节做些必要的讲解。

1.什么是XMPP

XMPP(Extensible Messaging and Presence Protocol),简单的来讲,它就是一个发送接收处理消息的协议,但是这个协议发送的消息,既不是二进制的东东也不是字符串,而是XML。正是因为使用了XML作为消息传递的中介,Extensible 才谈的上。XMPP的前身是Jabber,一个开源形式组织产生的网络即时通信协议。XMPP目前被IETF国际标准组织完成了标准化工作。

2.IM

Instant Messenger,及时通信软件,就是大家使用的QQ、MSN Messenger和Gtalk等等。其中Gtalk 就是基于XMPP 协议的一个实现,其他的则不是。当前IM 几乎作为每个上网者必然使用的工具,在国外的大型企业中有一些企业级的IM应用,但是其商业价值还没完全发挥出来。设想既然XMPP 协议是一个公开的协议,那么每个企业都可以利用它来开发适合本身企业工作,提高自身生产效率的IM;甚至,你还可以在网络游戏中集成这种通信软件,不但让你可以边游戏边聊天,也可以开发出适合游戏本身的IM 应用,比如说一些游戏关键场景提醒功能,团队语音交流等等都可以基于IM来实现。

3.Spark,smack和Openfire

开源界总是有许多有趣的东东,这三个合起来就是一个完整的XMPP IM 实现。包括服务器端——Openfire,客户端——Spark,XMPP 传输协议的实现——Smack(记住,XMPP是一个协议,协议是需要实现的,Smack起到的就是这样的一个作用)。三者都是基于Java 语言的实现。

Spark 提供了客户端一个基本的实现,并提出了一个很好的插件架构,这对于开发者来说不能不说是一个福音。我强烈建议基于插件方式来实现你新增加的功能,而不是去改它的源代码,这样有利于你项目架构,把原始项目的影响降到最低。

Openfire 是基于XMPP 协议的IM 的服务器端的一个实现,虽然当两个用户连接后,可以通过点对点的方式来发送消息,但是用户还是需要连接到服务器来获取一些连接信息和通信信息的,所以服务器端是必须要实现的。Openfire 也提供了一些基本功能,但真的很基本的!庆幸的是,它也提供插件的扩展,像Spark 一样,同样强烈建议使用插件扩展的方式来增加新的功能,而不是修改人家的源代码。

Smack 是一个XMPP 协议的Java 实现,提供一套可扩展的API,不过有些时候,你还是不得不使用自己定制发送的XML 文件内容的方式来实现自己的功能

下图展示了三者之间的关系:

Spark 提供了客户端一个基本的实现,并提出了一个很好的插件架构,这对于开发者来说不能不说是一个福音。我强烈建议基于插件方式来实现你新增加的功能,而不是去改它的源代码,这样有利于你项目架构,把原始项目的影响降到最低。

Openfire 是基于XMPP 协议的IM 的服务器端的一个实现,虽然当两个用户连接后,可以通过点对点的方式来发送消息,但是用户还是需要连接到服务器来获取一些连接信息和通信信息的,所以服务器端是必须要实现的。Openfire 也提供了一些基本功能,但真的很基本的!庆幸的是,它也提供插件的扩展,像Spark 一样。

Smack 是一个XMPP 协议的Java 实现,提供一套可扩展的API,不过有些时候,你还是不得不使用自己定制发送的XML 文件内容的方式来实现自己的功能。

4.安装Openfire3.8.1

使用openfire需要配置机器的域名。如果局域网内没有安装域服务器,则需要手工为机器配置域名,打开C:\WINDOWS\system32\drivers\etc\hosts文件,增加一新行: 127.0.0.1 csdn.shimiso.com (用户根据自己的需要可配置称别的名字,但最好符合带.的域名格式) 其他机器使用域名访问openfire,也需要在C:\WINDOWS\system32\drivers\etc\hosts中指定bzwang.tzsoft.com对应的ip地址,假设安装openfire的主机IP为192.168.1.10,则hosts文件中应增加一新行: 192.168.1.10 csdn.shimiso.com 通过这种方式指定主机域名,建议安装openfire的机器配置静态ip地址以免ip发生改变。

语言选择简体中文,见下图:

后续按照提示安装,点击完成启动openfire,最后出现下面的界面:

点”Launch Admin”,出现下面的页面,页面连接为http://127.0.0.1:9090/setup/index.jsp

语种选择中文(简体),点”Continue”:(下面的页面如果出现英文,请刷新一下页面或者重新点Launch Admin)

这个页面的Domain默认为机器名,请改为一开始设置的域名,例如csdn.shimiso.com,接着点Continue(继续):

这个页面中第一个选项,即标准数据库连接,不要选择嵌入的数据库( Embedded Database,嵌入的数据库是hsqldb数据库,生产环境不要选择此选项),然后点”继续”:

这里我用的是mysql数据库,按官方要求最好是5.0以上,确保有个名字叫openfire的库存在,配好后点继续

这个页面是配置是否使用LDAP,我们现在不配置LDAP,所以选择 Default默认即可,点继续:

这里填写邮箱和确认密码后直接点继续:

等待大约30秒左右,到此安装和配置操作全部完成。打开http://127.0.0.1:9090/login.jsp登录管理页面

进入用户/组新增一个用户。

5.客户端配置和调试

这里我没用使用官方的spark客户端,而是用了 潘迪安 和 如意通 ,配置截图如下:

聊天演示:

从上面的聊天记录我们发现所有的用户id全称都是:用户名@域名/资源名,这个就是我们在XMPP协议中通常说说的JID,即jabber id,它是一个xmpp协议帐号系统的通称,后面我们在使用smack编程库调试接口时会经常用到这个参数。

6.使用Smack编程库进行代码功能调试

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

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

(1)登录操作
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)下面我们继续写个聊天的例子:
 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)除了聊天以外我们经常还能想到就是广播,需要给所有在线的用户发送一个通知,或者给所有在线和离线的用户全发送,我们先演示如何给在线用户发送一个广播:
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这个用户一登陆就取到离线消息呢?请看如下代码
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)下面我们来看看如何来发送文件
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中一定可以看到。

如果我们自己要写文件接收例子的话,参考代码如下:
 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)用户列表
/**

返回所有组信息 <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的组成,含有很多信息的 
/**
获取用户的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)组操作和用户分组操作
/**

添加一个组 */ 
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)用户查询
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)修改自身状态, 包括上线,隐身,对某人隐身,对某人上线
public 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)心情修改
/ **

修改心情
@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)修改用户头像, 有点麻烦,主要是读入图片文件,编码,传输之
 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实现的监听器
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");
      }   

});

至此,有关openfire和smack的安装部署使用基本代码调试讲解完毕,本集源码容我稍作整理后再更新出来,请大家保持关注,同时下面会我们进入课程的重点环节,包括

如何在Openfire服务器上开发一款Android端的聊天软件。。。

如何在openfire上二次开发,如何在在web和android上接入IM模块。。。

如何在Spark基础二次开发基于java swing的PC客户端。。。

结合我之前讲的Android端服务器推送技术原理分析及XMPP简单的使用由浅入深的对apache MINA,XMPP协议,以及socket底层等一些难点进行讨论剖析。。。

Openfire作为一款优秀的XMPP开源服务器,整合及时通讯,视频,语音,会议室等多种服务,如何更好的让它集成到现有的系统中去才是我们研究的最终价值,否则一切都是空谈,本教程结合实战和理论,为大家提供提供一个共同研究和学习的平台,欢迎有识之士加入我们的技术交流群:173711587, 共同探讨Java开发那些事儿
分享到:
评论

相关推荐

    android聊天客户端

    在Android平台上开发一款基于Xmpp协议的聊天客户端是一项技术含量较高的任务。Xmpp(Extensible Messaging and Presence Protocol)是一种开放标准的即时通讯协议,它允许用户进行实时、双向的通信,广泛应用于各种...

    【KUKA 机器人资料】:激光跟踪焊接机器人系统技术方案.pdf

    KUKA机器人相关资料

    基于Matlab的模拟退火算法在旅行商问题(TSP)优化中的应用及其实现

    内容概要:本文详细介绍了利用Matlab实现模拟退火算法来优化旅行商问题(TSP)。首先阐述了TSP的基本概念及其在路径规划、物流配送等领域的重要性和挑战。接着深入讲解了模拟退火算法的工作原理,包括高温状态下随机探索、逐步降温过程中选择较优解或以一定概率接受较差解的过程。随后展示了具体的Matlab代码实现步骤,涵盖城市坐标的定义、路径长度的计算方法、模拟退火主循环的设计等方面。并通过多个实例演示了不同参数配置下的优化效果,强调了参数调优的重要性。最后讨论了该算法的实际应用场景,如物流配送路线优化,并提供了实用技巧和注意事项。 适合人群:对路径规划、物流配送优化感兴趣的科研人员、工程师及高校学生。 使用场景及目标:适用于需要解决复杂路径规划问题的场合,特别是涉及多个节点间最优路径选择的情况。通过本算法可以有效地减少路径长度,提高配送效率,降低成本。 其他说明:文中不仅给出了完整的Matlab代码,还包括了一些优化建议和技术细节,帮助读者更好地理解和应用这一算法。此外,还提到了一些常见的陷阱和解决方案,有助于初学者避开常见错误。

    基于STM32的永磁同步电机Simulink代码生成与57次谐波抑制的霍尔FOC控制

    内容概要:本文详细介绍了如何利用Simulink进行自动代码生成,在STM32平台上实现带57次谐波抑制功能的霍尔场定向控制(FOC)。首先,文章讲解了所需的软件环境准备,包括MATLAB/Simulink及其硬件支持包的安装。接着,阐述了构建永磁同步电机(PMSM)霍尔FOC控制模型的具体步骤,涵盖电机模型、坐标变换模块(如Clark和Park变换)、PI调节器、SVPWM模块以及用于抑制特定谐波的陷波器的设计。随后,描述了硬件目标配置、代码生成过程中的注意事项,以及生成后的C代码结构。此外,还讨论了霍尔传感器的位置估算、谐波补偿器的实现细节、ADC配置技巧、PWM死区时间和换相逻辑的优化。最后,分享了一些实用的工程集成经验,并推荐了几篇有助于深入了解相关技术和优化控制效果的研究论文。 适合人群:从事电机控制系统开发的技术人员,尤其是那些希望掌握基于Simulink的自动代码生成技术,以提高开发效率和控制精度的专业人士。 使用场景及目标:适用于需要精确控制永磁同步电机的应用场合,特别是在面对高次谐波干扰导致的电流波形失真问题时。通过采用文中提供的解决方案,可以显著改善系统的稳定性和性能,降低噪声水平,提升用户体验。 其他说明:文中不仅提供了详细的理论解释和技术指导,还包括了许多实践经验教训,如霍尔传感器处理、谐波抑制策略的选择、代码生成配置等方面的实际案例。这对于初学者来说是非常宝贵的参考资料。

    基于S7-200 PLC和组态王的机械手搬运控制系统设计与调试

    内容概要:本文详细介绍了基于西门子S7-200 PLC和组态王的机械手搬运控制系统的实现方案。首先,文章展示了梯形图程序的关键逻辑,如急停连锁保护、水平移动互锁以及定时器的应用。接着,详细解释了IO分配的具体配置,包括数字输入、数字输出和模拟量接口的功能划分。此外,还讨论了接线图的设计注意事项,强调了电磁阀供电和继电器隔离的重要性。组态王的画面设计部分涵盖了三层画面结构(总览页、参数页、调试页)及其动画脚本的编写。最后,分享了调试过程中遇到的问题及解决方案,如传感器抖动、输出互锁设计等。 适合人群:从事自动化控制领域的工程师和技术人员,尤其是对PLC编程和组态软件有一定基础的读者。 使用场景及目标:适用于自动化生产线中机械手搬运控制系统的开发与调试。目标是帮助读者掌握从硬件接线到软件逻辑的完整实现过程,提高系统的稳定性和可靠性。 其他说明:文中提供了大量实践经验,包括常见的错误和解决方案,有助于读者在实际工作中少走弯路。

    西门子1200PLC污水处理项目:PLC程序、通讯配置与HMI设计详解

    内容概要:本文详细介绍了基于西门子1200PLC的污水处理项目,涵盖了PLC程序结构、通信配置、HMI设计以及CAD原理图等多个方面。PLC程序采用梯形图和SCL语言相结合的方式,实现了复杂的控制逻辑,如水位控制、曝气量模糊控制等。通讯配置采用了Modbus TCP和Profinet双协议,确保了设备间高效稳定的通信。HMI设计则注重用户体验,提供了详细的报警记录和趋势图展示。此外,CAD图纸详尽标注了设备位号,便于后期维护。操作说明书中包含了应急操作流程和定期维护建议,确保系统的长期稳定运行。 适合人群:从事工业自动化领域的工程师和技术人员,尤其是对PLC编程、HMI设计和通信配置感兴趣的从业者。 使用场景及目标:适用于污水处理厂及其他类似工业控制系统的设计、实施和维护。目标是帮助工程师掌握完整的项目开发流程,提高系统的可靠性和效率。 其他说明:文中提供的具体代码片段和设计思路对于理解和解决实际问题非常有价值,建议读者结合实际项目进行深入学习和实践。

    5电平三相MMC的VSG控制与MATLAB-Simulink仿真:调频调压效果验证

    内容概要:本文详细介绍了基于5电平三相模块化多电平变流器(MMC)的虚拟同步发电机(VSG)控制系统的构建与仿真。首先,文章描述了MMC的基本结构和参数设置,包括子模块电容电压均衡策略和载波移相策略。接着,深入探讨了VSG控制算法的设计,特别是有功-频率和无功-电压下垂控制的具体实现方法。文中还展示了通过MATLAB-Simulink进行仿真的具体步骤,包括设置理想的直流电源和可编程三相源来模拟电网扰动。仿真结果显示,VSG控制系统能够在面对频率和电压扰动时迅速恢复稳定,表现出良好的调频调压性能。 适合人群:从事电力电子、电力系统自动化及相关领域的研究人员和技术人员。 使用场景及目标:适用于研究和开发新型电力电子设备,特别是在新能源接入电网时提高系统的稳定性。目标是通过仿真验证VSG控制的有效性,为实际应用提供理论支持和技术指导。 其他说明:文章提供了详细的代码片段和仿真配置,帮助读者更好地理解和重现实验结果。此外,还提到了一些常见的调试技巧和注意事项,如选择合适的仿真步长和参数配对调整。

    工业自动化中基于PLC1200的SCL与梯形图混编立体库及码垛系统的通信与控制

    内容概要:本文详细介绍了在一个复杂的工业自动化项目中,如何利用西门子S7-1200 PLC为核心,结合基恩士视觉相机、ABB机器人以及G120变频器等多种设备,构建了一个高效的立体库码垛系统。文中不仅探讨了不同设备之间的通信协议(如Modbus TCP和Profinet),还展示了SCL和梯形图混合编程的具体应用场景和技术细节。例如,通过SCL进行视觉坐标解析、机器人通信心跳维护等功能的实现,而梯形图则用于处理简单的状态切换和安全回路。此外,作者分享了许多实际调试过程中遇到的问题及其解决方案,强调了良好的注释习惯对于提高代码可维护性的关键作用。 适用人群:从事工业自动化领域的工程师和技术人员,尤其是对PLC编程、机器人控制及多种通信协议感兴趣的从业者。 使用场景及目标:适用于需要整合多种工业设备并确保它们能够稳定协作的工作环境。主要目标是在保证系统高精度的同时降低故障率,从而提升生产效率。 其他说明:文中提到的一些具体技术和方法可以作为类似项目的参考指南,帮助开发者更好地理解和应对复杂的工业控制系统挑战。

    【KUKA 机器人资料】:KUKA机器人_Interbus_输入输出端口配置说明书.pdf

    KUKA机器人相关资料

    java脱敏工具类,敏感数据脱敏

    java脱敏工具类

    基于自抗扰控制的表贴式永磁同步电机双环控制系统设计与实现

    内容概要:本文详细介绍了基于自抗扰控制(ADRC)的表贴式永磁同步电机(SPMSM)双环控制系统的建模与实现方法。该系统采用速度环一阶ADRC控制和电流环PI控制相结合的方式,旨在提高电机在复杂工况下的稳定性和响应速度。文章首先解释了选择ADRC的原因及其优势,接着展示了ADRC和PI控制器的具体实现代码,并讨论了在Matlab/Simulink环境中搭建模型的方法和注意事项。通过对不同工况下的仿真测试,验证了该控制策略的有效性,特别是在负载突变情况下的优越表现。 适合人群:从事电机控制、自动化控制及相关领域的研究人员和技术人员,尤其是对自抗扰控制感兴趣的工程师。 使用场景及目标:适用于需要高精度、高响应速度的工业伺服系统和其他高性能电机应用场景。目标是提升电机在复杂环境下的稳定性和抗扰能力,减少转速波动和恢复时间。 其他说明:文中提供了详细的代码示例和调试技巧,帮助读者更好地理解和实施该控制策略。同时,强调了在实际应用中需要注意的问题,如参数调整、输出限幅等。

    java设计模式之责任链的demo

    java设计模式之责任链的使用demo

    电力电子领域中两相交错并联Buck/Boost变换器的三种控制方式及其仿真分析

    内容概要:本文详细介绍了两相交错并联Buck/Boost变换器的硬件结构和三种控制方式(开环、电压单环、双环)的实现方法及仿真结果。文中首先描述了该变换器的硬件结构特点,即四个MOS管组成的H桥结构,两相电感交错180度工作,从而有效减少电流纹波。接着,针对每种控制方式,具体讲解了其配置步骤、关键参数设置以及仿真过程中需要注意的问题。例如,在开环模式下,通过固定PWM占空比来观察原始波形;电压单环则引入PI控制器进行电压反馈调节;双环控制进一步增加了电流内环,实现了更为精确的电流控制。此外,文章还探讨了单向结构的特点,并提供了仿真技巧和避坑指南。 适合人群:从事电力电子研究的技术人员、高校相关专业师生。 使用场景及目标:适用于希望深入了解两相交错并联Buck/Boost变换器的工作原理和技术细节的研究者,旨在帮助他们掌握不同控制方式的设计思路和仿真方法。 其他说明:文中不仅提供了详细的理论解释,还有丰富的实例代码片段,便于读者理解和实践。同时,作者分享了许多宝贵的实践经验,有助于避免常见的仿真错误。

    第十六届蓝桥杯大赛软件赛省赛第二场 C/C++ 大学 A 组

    第二场c++A组

    数控磨床编程.ppt

    数控磨床编程.ppt

    COMSOL数值模拟:N2和CO2混合气体在THM热流固三场耦合下增强瓦斯抽采的技术研究与应用

    内容概要:本文详细介绍了利用COMSOL软件进行N2和CO2混合气体在热-流-固三场耦合作用下增强煤层气抽采的数值模拟。首先,通过设定煤岩材料参数,如热导率、杨氏模量等,构建了煤岩物理模型。接着,引入达西定律和Maxwell-Stefan扩散方程,建立了混合气体运移方程,考虑了气体膨胀系数和吸附特性。在应力场求解方面,采用自适应步长和阻尼系数调整,确保模型稳定。同时,探讨了温度场与气体运移的耦合机制,特别是在低温条件下CO2注入对煤体裂隙扩展的影响。最后,通过粒子追踪和流线图展示了气体运移路径和抽采效率的变化。 适合人群:从事煤层气开采、数值模拟以及相关领域的科研人员和技术工程师。 使用场景及目标:适用于需要优化煤层气抽采工艺的研究机构和企业,旨在通过数值模拟提高抽采效率并减少环境影响。 其他说明:文中提供了详细的MATLAB和COMSOL代码片段,帮助读者理解和复现模型。此外,强调了模型参数选择和求解器配置的重要性,分享了作者的实际经验和常见问题解决方法。

    计算给定G、相位裕度、交叉频率和安全裕度要求的引线补偿器

    基于Bode的引线补偿器设计 计算给定G、相位裕度、交叉频率和安全裕度要求的引线补偿器。 计算给定电厂G、PM和Wc要求的铅补偿器,并运行ControlSystemDesigner进行验证。

    【KUKA 机器人TCP测量】:mp2_tool_fixed_en.ppt

    KUKA机器人相关文档

    基于单片机的洗衣机设计(51+SEG2+L298+JKx2+LED5+KEY6)#0098

    包括:源程序工程文件、Proteus仿真工程文件、配套技术手册等 1、采用51/52单片机作为主控芯片; 2、采用数码管显示计时秒数,单个操作均为20秒; 3、采用继电器控制进水、排水; 4、采用L298驱动电机; 5、具有强洗、标准洗、弱洗、甩干四种模式; 6、强洗流程:进水、三轮洗涤、排水、甩干、进水、漂洗、排水、甩干; 7、标准洗流程:进水、两轮洗涤、排水、甩干、进水、漂洗、排水、甩干; 8、弱洗流程:进水、一轮洗涤、排水、甩干、进水、漂洗、排水、甩干;

    基于MATLAB 2018b的微电网并网逆变器双环SPWM与下垂控制实现

    内容概要:本文详细介绍了如何利用MATLAB 2018b搭建微电网并网逆变器模型,采用电压电流双环控制配合SPWM调制技术,实现稳定的并网控制。文中涵盖了PI参数整定、下垂系数计算、SPWM载波生成、PLL改进等多个关键技术环节,并分享了调试经验和常见问题解决方案。通过具体的代码示例展示了各模块的具体实现方法,强调了电流环和电压环的设计要点以及下垂控制的应用。 适合人群:具有一定电力电子和控制系统基础知识的研究人员和技术人员,尤其是从事微电网研究和开发的专业人士。 使用场景及目标:适用于希望深入了解微电网并网控制机制及其具体实现方式的学习者和从业者。主要目标是掌握电压电流双环控制与SPWM调制相结合的方法,理解下垂控制的工作原理,并能够独立完成相关系统的建模与调试。 其他说明:文中提供的代码片段可以直接用于MATLAB/Simulink环境进行实验验证,同时附带了许多宝贵的实践经验,如参数选择、波形分析等,有助于提高实际项目的成功率。此外,还特别提到了一些容易被忽视但至关重要的细节,比如载波频率设置、死区时间和谐波抑制等问题。

Global site tag (gtag.js) - Google Analytics