Android基于XMPP Smack Openfire下学习开发IM(六)总结

不管学习什么都应该总结

这里我把关于Xmpp的一些方法整理到一个工具类中了

我就分享给大家

XmppConnection.java

[java] view plaincopyprint?
package com.techrare.utils;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.PacketCollector;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.RosterEntry;
import org.jivesoftware.smack.RosterGroup;
import org.jivesoftware.smack.SmackConfiguration;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.filter.AndFilter;
import org.jivesoftware.smack.filter.PacketFilter;
import org.jivesoftware.smack.filter.PacketIDFilter;
import org.jivesoftware.smack.filter.PacketTypeFilter;
import org.jivesoftware.smack.packet.IQ;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.packet.Packet;
import org.jivesoftware.smack.packet.Presence;
import org.jivesoftware.smack.packet.Registration;
import org.jivesoftware.smack.provider.PrivacyProvider;
import org.jivesoftware.smack.provider.ProviderManager;
import org.jivesoftware.smack.util.StringUtils;
import org.jivesoftware.smackx.Form;
import org.jivesoftware.smackx.FormField;
import org.jivesoftware.smackx.GroupChatInvitation;
import org.jivesoftware.smackx.OfflineMessageManager;
import org.jivesoftware.smackx.PrivateDataManager;
import org.jivesoftware.smackx.ReportedData;
import org.jivesoftware.smackx.ReportedData.Row;
import org.jivesoftware.smackx.ServiceDiscoveryManager;
import org.jivesoftware.smackx.bytestreams.socks5.provider.BytestreamsProvider;
import org.jivesoftware.smackx.filetransfer.FileTransferManager;
import org.jivesoftware.smackx.filetransfer.OutgoingFileTransfer;
import org.jivesoftware.smackx.muc.DiscussionHistory;
import org.jivesoftware.smackx.muc.HostedRoom;
import org.jivesoftware.smackx.muc.MultiUserChat;
import org.jivesoftware.smackx.packet.ChatStateExtension;
import org.jivesoftware.smackx.packet.LastActivity;
import org.jivesoftware.smackx.packet.OfflineMessageInfo;
import org.jivesoftware.smackx.packet.OfflineMessageRequest;
import org.jivesoftware.smackx.packet.SharedGroupsInfo;
import org.jivesoftware.smackx.packet.VCard;
import org.jivesoftware.smackx.provider.AdHocCommandDataProvider;
import org.jivesoftware.smackx.provider.DataFormProvider;
import org.jivesoftware.smackx.provider.DelayInformationProvider;
import org.jivesoftware.smackx.provider.DiscoverInfoProvider;
import org.jivesoftware.smackx.provider.DiscoverItemsProvider;
import org.jivesoftware.smackx.provider.MUCAdminProvider;
import org.jivesoftware.smackx.provider.MUCOwnerProvider;
import org.jivesoftware.smackx.provider.MUCUserProvider;
import org.jivesoftware.smackx.provider.MessageEventProvider;
import org.jivesoftware.smackx.provider.MultipleAddressesProvider;
import org.jivesoftware.smackx.provider.RosterExchangeProvider;
import org.jivesoftware.smackx.provider.StreamInitiationProvider;
import org.jivesoftware.smackx.provider.VCardProvider;
import org.jivesoftware.smackx.provider.XHTMLExtensionProvider;
import org.jivesoftware.smackx.search.UserSearch;
import org.jivesoftware.smackx.search.UserSearchManager;

import android.graphics.drawable.Drawable;
import android.util.Log;

import com.techrare.listener.TaxiConnectionListener;
/**

  • XmppConnection 工具类
  • @author 肖赛SoAi
  • /
    public class XmppConnection {
    private int SERVER_PORT = 5222;
    private String SERVER_HOST = “127.0.0.1”;
    private XMPPConnection connection = null;
    private String SERVER_NAME = “ubuntuserver4java”;
    private static XmppConnection xmppConnection = new XmppConnection();
    private TaxiConnectionListener connectionListener;
    /    *
    • 单例模式
    • @return
      */
      synchronized public static XmppConnection getInstance() {
      return xmppConnection;
      }

    /**

    • 创建连接
      */
      public XMPPConnection getConnection() {
      if (connection == null) {

      openConnection();

      }
      return connection;
      }

    /**

    • 打开连接
      */
      public boolean openConnection() {
      try {

      if (null == connection || !connection.isAuthenticated()) {
    XMPPConnection.DEBUG_ENABLED = true;// 开启DEBUG模式
    // 配置连接
    ConnectionConfiguration config = new ConnectionConfiguration(
            SERVER_HOST, SERVER_PORT, SERVER_NAME);
    config.setReconnectionAllowed(true);
    config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
    config.setSendPresence(true); // 状态设为离线，目的为了取离线消息
    config.setSASLAuthenticationEnabled(false); // 是否启用安全验证
    config.setTruststorePath("/system/etc/security/cacerts.bks");
    config.setTruststorePassword("changeit");
    config.setTruststoreType("bks");
    connection = new XMPPConnection(config);
    connection.connect();// 连接到服务器
    // 配置各种Provider，如果不配置，则会无法解析数据
    configureConnection(ProviderManager.getInstance());
    return true;
}

      } catch (XMPPException xe) {

      xe.printStackTrace();
connection = null;

      }
      return false;
      }

    /**

    • 关闭连接
      */
      public void closeConnection() {
      if(connection!=null){

      //移除連接監聽
//connection.removeConnectionListener(connectionListener);
if(connection.isConnected())
    connection.disconnect();
connection = null;

      }
      Log.i(“XmppConnection”, “關閉連接”);
      }

    /**

    • 登录
    • @param account
    • 登录帐号
    • @param password
    • 登录密码
    • @return
      */
      public boolean login(String account, String password) {
      try { 
      if (getConnection() == null)
    return false;
getConnection().login(account, password);
// 更改在綫狀態
Presence presence = new Presence(Presence.Type.available);
getConnection().sendPacket(presence);
// 添加連接監聽
connectionListener = new TaxiConnectionListener();
getConnection().addConnectionListener(connectionListener);
return true;

      } catch (XMPPException xe) {

      xe.printStackTrace();

      }
      return false;
      }

    /**

    • 注册
    • @param account
    • 注册帐号
    • @param password
    • 注册密码
    • @return 1、注册成功 0、服务器没有返回结果2、这个账号已经存在3、注册失败
      */
      public String regist(String account, String password) {
      if (getConnection() == null) 
      return "0";

      Registration reg = new Registration();
      reg.setType(IQ.Type.SET);
      reg.setTo(getConnection().getServiceName());
      // 注意这里createAccount注册时，参数是UserName，不是jid，是”@“前面的部分。
      reg.setUsername(account);
      reg.setPassword(password);
      // 这边addAttribute不能为空，否则出错。所以做个标志是android手机创建的吧！！！！！
      reg.addAttribute(“android”, “geolo_createUser_android”);
      PacketFilter filter = new AndFilter(new PacketIDFilter(

      reg.getPacketID()), new PacketTypeFilter(IQ.class));

      PacketCollector collector = getConnection().createPacketCollector(

      filter);

      getConnection().sendPacket(reg);
      IQ result = (IQ) collector.nextResult(SmackConfiguration

      .getPacketReplyTimeout());

      // Stop queuing results停止请求results（是否成功的结果）
      collector.cancel();
      if (result == null) {

      Log.e("regist", "No response from server.");
return "0";

      } else if (result.getType() == IQ.Type.RESULT) {

      Log.v("regist", "regist success.");
return "1";

      } else { // if (result.getType() == IQ.Type.ERROR)

      if (result.getError().toString().equalsIgnoreCase("conflict(409)")) {
    Log.e("regist", "IQ.Type.ERROR: "
            + result.getError().toString());
    return "2";
} else {
    Log.e("regist", "IQ.Type.ERROR: "
            + result.getError().toString());
    return "3";
}

      }
      }

    /**

    • 更改用户状态
      */
      public void setPresence(int code) {
      XMPPConnection con = getConnection();
      if (con == null)

      return;

      Presence presence;
      switch (code) {
      case 0:

      presence = new Presence(Presence.Type.available);
con.sendPacket(presence);
Log.v("state", "设置在线");
break;

      case 1:

      presence = new Presence(Presence.Type.available);
presence.setMode(Presence.Mode.chat);
con.sendPacket(presence);
Log.v("state", "设置Q我吧");
break;

      case 2:

      presence = new Presence(Presence.Type.available);
presence.setMode(Presence.Mode.dnd);
con.sendPacket(presence);
Log.v("state", "设置忙碌");
break;

      case 3:

      presence = new Presence(Presence.Type.available);
presence.setMode(Presence.Mode.away);
con.sendPacket(presence);
Log.v("state", "设置离开");
break;

      case 4:

      Roster roster = con.getRoster();
Collection<RosterEntry> entries = roster.getEntries();
for (RosterEntry entry : entries) {
    presence = new Presence(Presence.Type.unavailable);
    presence.setPacketID(Packet.ID_NOT_AVAILABLE);
    presence.setFrom(con.getUser());
    presence.setTo(entry.getUser());
    con.sendPacket(presence);
    Log.v("state", presence.toXML());
}
// 向同一用户的其他客户端发送隐身状态
presence = new Presence(Presence.Type.unavailable);
presence.setPacketID(Packet.ID_NOT_AVAILABLE);
presence.setFrom(con.getUser());
presence.setTo(StringUtils.parseBareAddress(con.getUser()));
con.sendPacket(presence);
Log.v("state", "设置隐身");
break;

      case 5:

      presence = new Presence(Presence.Type.unavailable);
con.sendPacket(presence);
Log.v("state", "设置离线");
break;

      default:

      break;

      }
      }

    /**

    • 获取所有组
    • @return 所有组集合
      */
      public List getGroups() {
      if (getConnection() == null) 
      return null;

      List grouplist = new ArrayList ();
      Collection rosterGroup = getConnection().getRoster()

      .getGroups();

      Iterator i = rosterGroup.iterator();
      while (i.hasNext()) {

      grouplist.add(i.next());

      }
      return grouplist;
      }

    /**

    • 获取某个组里面的所有好友
    • @param roster
    • @param groupName
    • 组名
    • @return
      */
      public List getEntriesByGroup(String groupName) {
      if (getConnection() == null) 
      return null;

      List Entrieslist = new ArrayList ();
      RosterGroup rosterGroup = getConnection().getRoster().getGroup(

      groupName);

      Collection rosterEntry = rosterGroup.getEntries();
      Iterator i = rosterEntry.iterator();
      while (i.hasNext()) {

      Entrieslist.add(i.next());

      }
      return Entrieslist;
      }

    /**

    • 获取所有好友信息
    • @return
      */
      public List getAllEntries() {
      if (getConnection() == null) 
      return null;

      List Entrieslist = new ArrayList ();
      Collection rosterEntry = getConnection().getRoster()

      .getEntries();

      Iterator i = rosterEntry.iterator();
      while (i.hasNext()) {

      Entrieslist.add(i.next());

      }
      return Entrieslist;
      }

    /**

    • 获取用户VCard信息
    • @param connection
    • @param user
    • @return
    • @throws XMPPException
      */
      public VCard getUserVCard(String user) {
      if (getConnection() == null) 
      return null;

      VCard vcard = new VCard();
      try {

      vcard.load(getConnection(), user);

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      return vcard;
      }

    /**

    • 获取用户头像信息
    • @param connection
    • @param user
    • @return
      */
      public Drawable getUserImage(String user) {
      if (getConnection() == null) 
      return null;

      ByteArrayInputStream bais = null;
      try {

      VCard vcard = new VCard();
// 加入这句代码，解决No VCard for
ProviderManager.getInstance().addIQProvider("vCard", "vcard-temp",
        new org.jivesoftware.smackx.provider.VCardProvider());
if (user == "" || user == null || user.trim().length() <= 0) {
    return null;
}
vcard.load(getConnection(), user + "@"
        + getConnection().getServiceName());  

if (vcard == null || vcard.getAvatar() == null)
    return null;
bais = new ByteArrayInputStream(vcard.getAvatar());

      } catch (Exception e) {

      e.printStackTrace();
return null;

      }
      return FormatTools.getInstance().InputStream2Drawable(bais);
      }

    /**

    • 添加一个分组
    • @param groupName
    • @return
      */
      public boolean addGroup(String groupName) {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getRoster().createGroup(groupName);
Log.v("addGroup", groupName + "創建成功");
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 删除分组
    • @param groupName
    • @return
      */
      public boolean removeGroup(String groupName) {
      return true;
      }

    /**

    • 添加好友 无分组
    • @param userName
    • @param name
    • @return
      */
      public boolean addUser(String userName, String name) {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getRoster().createEntry(userName, name, null);
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 添加好友 有分组
    • @param userName
    • @param name
    • @param groupName
    • @return
      */
      public boolean addUser(String userName, String name, String groupName) {
      if (getConnection() == null) 
      return false;

      try {

      Presence subscription = new Presence(Presence.Type.subscribed);
subscription.setTo(userName);
userName += "@" + getConnection().getServiceName();
getConnection().sendPacket(subscription);
getConnection().getRoster().createEntry(userName, name,
        new String[] { groupName });
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 删除好友
    • @param userName
    • @return
      */
      public boolean removeUser(String userName) {
      if (getConnection() == null) 
      return false;

      try {

      RosterEntry entry = null;
if (userName.contains("@"))
    entry = getConnection().getRoster().getEntry(userName);
else
    entry = getConnection().getRoster().getEntry(
            userName + "@" + getConnection().getServiceName());
if (entry == null)
    entry = getConnection().getRoster().getEntry(userName);
getConnection().getRoster().removeEntry(entry);  

return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 查询用户
    • @param userName
    • @return
    • @throws XMPPException
      */
      public List > searchUsers(String userName) {
      if (getConnection() == null) 
      return null;

      HashMap user = null;
      List > results = new ArrayList >();
      try {

      new ServiceDiscoveryManager(getConnection());  

UserSearchManager usm = new UserSearchManager(getConnection());  

Form searchForm = usm.getSearchForm(getConnection()
        .getServiceName());
Form answerForm = searchForm.createAnswerForm();
answerForm.setAnswer("userAccount", true);
answerForm.setAnswer("userPhote", userName);
ReportedData data = usm.getSearchResults(answerForm, "search"
        + getConnection().getServiceName());  

Iterator<Row> it = data.getRows();
Row row = null;
while (it.hasNext()) {
    user = new HashMap<String, String>();
    row = it.next();
    user.put("userAccount", row.getValues("userAccount").next()
            .toString());
    user.put("userPhote", row.getValues("userPhote").next()
            .toString());
    results.add(user);
    // 若存在，则有返回,UserName一定非空，其他两个若是有设，一定非空
}

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      return results;
      }

    /**

    • 修改心情
    • @param connection
    • @param status
      */
      public void changeStateMessage(String status) {
      if (getConnection() == null) 
      return;

      Presence presence = new Presence(Presence.Type.available);
      presence.setStatus(status);
      getConnection().sendPacket(presence);
      }

    /**

    • 修改用户头像
    • @param file
      */
      public boolean changeImage(File file) {
      if (getConnection() == null) 
      return false;

      try {

      VCard vcard = new VCard();
vcard.load(getConnection());  

byte[] bytes;  

bytes = getFileBytes(file);
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());
FormatTools.getInstance().InputStream2Bitmap(bais);  

vcard.save(getConnection());
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 文件转字节
    • @param file
    • @return
    • @throws IOException
      */
      private 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();
}

      }
      }

    /**

    • 删除当前用户
    • @return
      */
      public boolean deleteAccount() {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getAccountManager().deleteAccount();
return true;

      } catch (XMPPException e) {

      return false;

      }
      }

    /**

    • 修改密码
    • @return
      */
      public boolean changePassword(String pwd) {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getAccountManager().changePassword(pwd);
return true;

      } catch (XMPPException e) {

      return false;

      }
      }

    /**

    • 初始化会议室列表
      */
      public List getHostRooms() {
      if (getConnection() == null)

      return null;

      Collection hostrooms = null;
      List roominfos = new ArrayList ();
      try {

      new ServiceDiscoveryManager(getConnection());
hostrooms = MultiUserChat.getHostedRooms(getConnection(),
        getConnection().getServiceName());
for (HostedRoom entry : hostrooms) {
    roominfos.add(entry);
    Log.i("room",
            "名字：" + entry.getName() + " - ID:" + entry.getJid());
}
Log.i("room", "服务会议数量:" + roominfos.size());

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      return roominfos;
      }

    /**

    • 创建房间
    • @param roomName
    • 房间名称

      */
      public MultiUserChat createRoom(String user, String roomName,

      String password) {

      if (getConnection() == null)

      return null;

      MultiUserChat muc = null;
      try {

      // 创建一个MultiUserChat
muc = new MultiUserChat(getConnection(), roomName + "@conference."
        + getConnection().getServiceName());
// 创建聊天室
muc.create(roomName);
// 获得聊天室的配置表单
Form form = muc.getConfigurationForm();
// 根据原始表单创建一个要提交的新表单。
Form submitForm = form.createAnswerForm();
// 向要提交的表单添加默认答复
for (Iterator<FormField> fields = form.getFields(); fields
        .hasNext();) {
    FormField field = (FormField) fields.next();
    if (!FormField.TYPE_HIDDEN.equals(field.getType())
            && field.getVariable() != null) {
        // 设置默认值作为答复
        submitForm.setDefaultAnswer(field.getVariable());
    }
}
// 设置聊天室的新拥有者
List<String> owners = new ArrayList<String>();
owners.add(getConnection().getUser());// 用户JID
submitForm.setAnswer("muc#roomconfig_roomowners", owners);
// 设置聊天室是持久聊天室，即将要被保存下来
submitForm.setAnswer("muc#roomconfig_persistentroom", true);
// 房间仅对成员开放
submitForm.setAnswer("muc#roomconfig_membersonly", false);
// 允许占有者邀请其他人
submitForm.setAnswer("muc#roomconfig_allowinvites", true);
if (!password.equals("")) {
    // 进入是否需要密码
    submitForm.setAnswer("muc#roomconfig_passwordprotectedroom",
            true);
    // 设置进入密码
    submitForm.setAnswer("muc#roomconfig_roomsecret", password);
}
// 能够发现占有者真实 JID 的角色
// submitForm.setAnswer("muc#roomconfig_whois", "anyone");
// 登录房间对话
submitForm.setAnswer("muc#roomconfig_enablelogging", true);
// 仅允许注册的昵称登录
submitForm.setAnswer("x-muc#roomconfig_reservednick", true);
// 允许使用者修改昵称
submitForm.setAnswer("x-muc#roomconfig_canchangenick", false);
// 允许用户注册房间
submitForm.setAnswer("x-muc#roomconfig_registration", false);
// 发送已完成的表单（有默认值）到服务器来配置聊天室
muc.sendConfigurationForm(submitForm);

      } catch (XMPPException e) {

      e.printStackTrace();
return null;

      }
      return muc;
      }

    /**

    • 加入会议室
    • @param user
    • 昵称
    • @param password
    • 会议室密码
    • @param roomsName
    • 会议室名

      */
      public MultiUserChat joinMultiUserChat(String user, String roomsName,

      String password) {

      if (getConnection() == null)

      return null;

      try {

      // 使用XMPPConnection创建一个MultiUserChat窗口
MultiUserChat muc = new MultiUserChat(getConnection(), roomsName
        + "@conference." + getConnection().getServiceName());
// 聊天室服务将会决定要接受的历史记录数量
DiscussionHistory history = new DiscussionHistory();
history.setMaxChars(0);
// history.setSince(new Date());
// 用户加入聊天室
muc.join(user, password, history,
        SmackConfiguration.getPacketReplyTimeout());
Log.i("MultiUserChat", "会议室【"+roomsName+"】加入成功........");
return muc;

      } catch (XMPPException e) {

      e.printStackTrace();
Log.i("MultiUserChat", "会议室【"+roomsName+"】加入失败........");
return null;

      }
      }

    /**

    • 查询会议室成员名字
    • @param muc
      */
      public List findMulitUser(MultiUserChat muc) {
      if (getConnection() == null) 
      return null;

      List listUser = new ArrayList ();
      Iterator it = muc.getOccupants();
      // 遍历出聊天室人员名称
      while (it.hasNext()) {

      // 聊天室成员名字
String name = StringUtils.parseResource(it.next());
listUser.add(name);

      }
      return listUser;
      }

    /**

    • 发送文件
    • @param user
    • @param filePath
      */
      public void sendFile(String user, String filePath) {
      if (getConnection() == null) 
      return;

      // 创建文件传输管理器
      FileTransferManager manager = new FileTransferManager(getConnection());

      // 创建输出的文件传输
      OutgoingFileTransfer transfer = manager

      .createOutgoingFileTransfer(user);

      // 发送文件
      try {

      transfer.sendFile(new File(filePath), "You won‘t believe this!");

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      }

    /**

    • 获取离线消息
    • @return
      */
      public Map ? getHisMessage() {
      if (getConnection() == null) 
      return null;

      Map ? offlineMsgs = null;

      try {

      OfflineMessageManager offlineManager = new OfflineMessageManager(
        getConnection());
Iterator<Message> it = offlineManager.getMessages();  

int count = offlineManager.getMessageCount();
if (count <= 0)
    return null;
offlineMsgs = new HashMap<String, List<HashMap<String, String>>>();  

while (it.hasNext()) {
    Message message = it.next();
    String fromUser = StringUtils.parseName(message.getFrom());
    ;
    HashMap<String, String> histrory = new HashMap<String, String>();
    histrory.put("useraccount",
            StringUtils.parseName(getConnection().getUser()));
    histrory.put("friendaccount", fromUser);
    histrory.put("info", message.getBody());
    histrory.put("type", "left");
    if (offlineMsgs.containsKey(fromUser)) {
        offlineMsgs.get(fromUser).add(histrory);
    } else {
        List<HashMap<String, String>> temp = new ArrayList<HashMap<String, String>>();
        temp.add(histrory);
        offlineMsgs.put(fromUser, temp);
    }
}
offlineManager.deleteMessages();

      } catch (Exception e) {

      e.printStackTrace();

      }
      return offlineMsgs;
      }

    /**

    • 判断OpenFire用户的状态 strUrl :
    • url格式 - http://my.openfire.com:9090/plugins/presence
    • /[email protected]_NAME&type=xml
    • 返回值 : 0 - 用户不存在; 1 - 用户在线; 2 - 用户离线
    • 说明 ：必须要求 OpenFire加载 presence 插件，同时设置任何人都可以访问
      */
      public int IsUserOnLine(String user) {
      String url = “http://“+SERVER_HOST+“:9090/plugins/presence/status?” + 
      "jid="+ user +"@"+ SERVER_NAME +"&type=xml";

      int shOnLineState = 0; // 不存在
      try {

      URL oUrl = new URL(url);
URLConnection oConn = oUrl.openConnection();
if (oConn != null) {
    BufferedReader oIn = new BufferedReader(new InputStreamReader(
            oConn.getInputStream()));
    if (null != oIn) {
        String strFlag = oIn.readLine();
        oIn.close();
        System.out.println("strFlag"+strFlag);
        if (strFlag.indexOf("type=\"unavailable\"") >= 0) {
            shOnLineState = 2;
        }
        if (strFlag.indexOf("type=\"error\"") >= 0) {
            shOnLineState = 0;
        } else if (strFlag.indexOf("priority") >= 0
                || strFlag.indexOf("id=\"") >= 0) {
            shOnLineState = 1;
        }
    }
}

      } catch (Exception e) {

      e.printStackTrace();

      }

      return shOnLineState;
      }

    /**

    • 加入providers的函数 ASmack在/META-INF缺少一个smack.providers 文件
    • @param pm
      */
      public void configureConnection(ProviderManager pm) {

      // Private Data Storage
      pm.addIQProvider(“query”, “jabber:iq:private”,

      new PrivateDataManager.PrivateDataIQProvider());

      // Time
      try {

      pm.addIQProvider("query", "jabber:iq:time",
        Class.forName("org.jivesoftware.smackx.packet.Time"));

      } catch (ClassNotFoundException e) {

      Log.w("TestClient",
        "Can‘t load class for org.jivesoftware.smackx.packet.Time");

      }

      // Roster Exchange
      pm.addExtensionProvider(“x”, “jabber:x:roster”,

      new RosterExchangeProvider());

      // Message Events
      pm.addExtensionProvider(“x”, “jabber:x:event”,

      new MessageEventProvider());

      // Chat State
      pm.addExtensionProvider(“active”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“composing”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“paused”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“inactive”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“gone”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      // XHTML
      pm.addExtensionProvider(“html”, “http://jabber.org/protocol/xhtml-im”,

      new XHTMLExtensionProvider());

      // Group Chat Invitations
      pm.addExtensionProvider(“x”, “jabber:x:conference”,

      new GroupChatInvitation.Provider());

      // Service Discovery # Items
      pm.addIQProvider(“query”, “http://jabber.org/protocol/disco#items”,

      new DiscoverItemsProvider());

      // Service Discovery # Info
      pm.addIQProvider(“query”, “http://jabber.org/protocol/disco#info”,

      new DiscoverInfoProvider());

      // Data Forms
      pm.addExtensionProvider(“x”, “jabber:x:data”, new DataFormProvider());

      // MUC User
      pm.addExtensionProvider(“x”, “http://jabber.org/protocol/muc#user”,

      new MUCUserProvider());

      // MUC Admin
      pm.addIQProvider(“query”, “http://jabber.org/protocol/muc#admin”,

      new MUCAdminProvider());

      // MUC Owner
      pm.addIQProvider(“query”, “http://jabber.org/protocol/muc#owner”,

      new MUCOwnerProvider());

      // Delayed Delivery
      pm.addExtensionProvider(“x”, “jabber:x:delay”,

      new DelayInformationProvider());

      // Version
      try {

      pm.addIQProvider("query", "jabber:iq:version",
        Class.forName("org.jivesoftware.smackx.packet.Version"));

      } catch (ClassNotFoundException e) {

      // Not sure what‘s happening here.

      }

      // VCard
      pm.addIQProvider(“vCard”, “vcard-temp”, new VCardProvider());

      // Offline Message Requests
      pm.addIQProvider(“offline”, “http://jabber.org/protocol/offline”,

      new OfflineMessageRequest.Provider());

      // Offline Message Indicator
      pm.addExtensionProvider(“offline”,

      "http://jabber.org/protocol/offline",
    new OfflineMessageInfo.Provider());

      // Last Activity
      pm.addIQProvider(“query”, “jabber:iq:last”, new LastActivity.Provider());

      // User Search
      pm.addIQProvider(“query”, “jabber:iq:search”, new UserSearch.Provider());

      // SharedGroupsInfo
      pm.addIQProvider(“sharedgroup”,

      "http://www.jivesoftware.org/protocol/sharedgroup",
    new SharedGroupsInfo.Provider());

      // JEP-33: Extended Stanza Addressing
      pm.addExtensionProvider(“addresses”,

      "http://jabber.org/protocol/address",
    new MultipleAddressesProvider());

      // FileTransfer
      pm.addIQProvider(“si”, “http://jabber.org/protocol/si”,

      new StreamInitiationProvider());

      pm.addIQProvider(“query”, “http://jabber.org/protocol/bytestreams”,

      new BytestreamsProvider());

      // Privacy
      pm.addIQProvider(“query”, “jabber:iq:privacy”, new PrivacyProvider());
      pm.addIQProvider(“command”, “http://jabber.org/protocol/commands”,

      new AdHocCommandDataProvider());

      pm.addExtensionProvider(“malformed-action”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.MalformedActionError());

      pm.addExtensionProvider(“bad-locale”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.BadLocaleError());

      pm.addExtensionProvider(“bad-payload”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.BadPayloadError());

      pm.addExtensionProvider(“bad-sessionid”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.BadSessionIDError());

      pm.addExtensionProvider(“session-expired”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.SessionExpiredError());

      }

}

/**
 * 判断OpenFire用户的状态 strUrl :
 * url格式 - http://my.openfire.com:9090/plugins/presence
 * /[email protected]_NAME&type=xml
 * 返回值 : 0 - 用户不存在; 1 - 用户在线; 2 - 用户离线
 * 说明 ：必须要求 OpenFire加载 presence 插件，同时设置任何人都可以访问
 */
public int IsUserOnLine(String user) {
    String url = "http://"+SERVER_HOST+":9090/plugins/presence/status?" +
            "jid="+ user +"@"+ SERVER_NAME +"&type=xml";
    int shOnLineState = 0; // 不存在
    try {
        URL oUrl = new URL(url);
        URLConnection oConn = oUrl.openConnection();
        if (oConn != null) {
            BufferedReader oIn = new BufferedReader(new InputStreamReader(
                    oConn.getInputStream()));
            if (null != oIn) {
                String strFlag = oIn.readLine();
                oIn.close();
                System.out.println("strFlag"+strFlag);
                if (strFlag.indexOf("type=\"unavailable\"") >= 0) {
                    shOnLineState = 2;
                }
                if (strFlag.indexOf("type=\"error\"") >= 0) {
                    shOnLineState = 0;
                } else if (strFlag.indexOf("priority") >= 0
                        || strFlag.indexOf("id=\"") >= 0) {
                    shOnLineState = 1;
                }
            }
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return shOnLineState;
}

package com.techrare.utils;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.PacketCollector;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.RosterEntry;
import org.jivesoftware.smack.RosterGroup;
import org.jivesoftware.smack.SmackConfiguration;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.filter.AndFilter;
import org.jivesoftware.smack.filter.PacketFilter;
import org.jivesoftware.smack.filter.PacketIDFilter;
import org.jivesoftware.smack.filter.PacketTypeFilter;
import org.jivesoftware.smack.packet.IQ;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.packet.Packet;
import org.jivesoftware.smack.packet.Presence;
import org.jivesoftware.smack.packet.Registration;
import org.jivesoftware.smack.provider.PrivacyProvider;
import org.jivesoftware.smack.provider.ProviderManager;
import org.jivesoftware.smack.util.StringUtils;
import org.jivesoftware.smackx.Form;
import org.jivesoftware.smackx.FormField;
import org.jivesoftware.smackx.GroupChatInvitation;
import org.jivesoftware.smackx.OfflineMessageManager;
import org.jivesoftware.smackx.PrivateDataManager;
import org.jivesoftware.smackx.ReportedData;
import org.jivesoftware.smackx.ReportedData.Row;
import org.jivesoftware.smackx.ServiceDiscoveryManager;
import org.jivesoftware.smackx.bytestreams.socks5.provider.BytestreamsProvider;
import org.jivesoftware.smackx.filetransfer.FileTransferManager;
import org.jivesoftware.smackx.filetransfer.OutgoingFileTransfer;
import org.jivesoftware.smackx.muc.DiscussionHistory;
import org.jivesoftware.smackx.muc.HostedRoom;
import org.jivesoftware.smackx.muc.MultiUserChat;
import org.jivesoftware.smackx.packet.ChatStateExtension;
import org.jivesoftware.smackx.packet.LastActivity;
import org.jivesoftware.smackx.packet.OfflineMessageInfo;
import org.jivesoftware.smackx.packet.OfflineMessageRequest;
import org.jivesoftware.smackx.packet.SharedGroupsInfo;
import org.jivesoftware.smackx.packet.VCard;
import org.jivesoftware.smackx.provider.AdHocCommandDataProvider;
import org.jivesoftware.smackx.provider.DataFormProvider;
import org.jivesoftware.smackx.provider.DelayInformationProvider;
import org.jivesoftware.smackx.provider.DiscoverInfoProvider;
import org.jivesoftware.smackx.provider.DiscoverItemsProvider;
import org.jivesoftware.smackx.provider.MUCAdminProvider;
import org.jivesoftware.smackx.provider.MUCOwnerProvider;
import org.jivesoftware.smackx.provider.MUCUserProvider;
import org.jivesoftware.smackx.provider.MessageEventProvider;
import org.jivesoftware.smackx.provider.MultipleAddressesProvider;
import org.jivesoftware.smackx.provider.RosterExchangeProvider;
import org.jivesoftware.smackx.provider.StreamInitiationProvider;
import org.jivesoftware.smackx.provider.VCardProvider;
import org.jivesoftware.smackx.provider.XHTMLExtensionProvider;
import org.jivesoftware.smackx.search.UserSearch;
import org.jivesoftware.smackx.search.UserSearchManager;

import android.graphics.drawable.Drawable;
import android.util.Log;

import com.techrare.listener.TaxiConnectionListener;
/**

  • XmppConnection 工具类
  • @author 肖赛SoAi

    /
    public class XmppConnection {
    private int SERVER_PORT = 5222;
    private String SERVER_HOST = “127.0.0.1”;
    private XMPPConnection connection = null;
    private String SERVER_NAME = “ubuntuserver4java”;
    private static XmppConnection xmppConnection = new XmppConnection();
    private TaxiConnectionListener connectionListener;
    /**
    • 单例模式
    • @return
      */
      synchronized public static XmppConnection getInstance() {
      return xmppConnection;
      }

    /**

    • 创建连接
      */
      public XMPPConnection getConnection() {
      if (connection == null) {

      openConnection();

      }
      return connection;
      }

    /**

    • 打开连接
      */
      public boolean openConnection() {
      try {

      if (null == connection || !connection.isAuthenticated()) {
    XMPPConnection.DEBUG_ENABLED = true;// 开启DEBUG模式
    // 配置连接
    ConnectionConfiguration config = new ConnectionConfiguration(
            SERVER_HOST, SERVER_PORT, SERVER_NAME);
    config.setReconnectionAllowed(true);
    config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
    config.setSendPresence(true); // 状态设为离线，目的为了取离线消息
    config.setSASLAuthenticationEnabled(false); // 是否启用安全验证
    config.setTruststorePath("/system/etc/security/cacerts.bks");
    config.setTruststorePassword("changeit");
    config.setTruststoreType("bks");
    connection = new XMPPConnection(config);
    connection.connect();// 连接到服务器
    // 配置各种Provider，如果不配置，则会无法解析数据
    configureConnection(ProviderManager.getInstance());
    return true;
}

      } catch (XMPPException xe) {

      xe.printStackTrace();
connection = null;

      }
      return false;
      }

    /**

    • 关闭连接
      */
      public void closeConnection() {
      if(connection!=null){

      //移除連接監聽
//connection.removeConnectionListener(connectionListener);
if(connection.isConnected())
    connection.disconnect();
connection = null;

      }
      Log.i(“XmppConnection”, “關閉連接”);
      }

    /**

    • 登录
    • @param account
    • 登录帐号
    • @param password
    • 登录密码
    • @return
      */
      public boolean login(String account, String password) {
      try { 
      if (getConnection() == null)
    return false;
getConnection().login(account, password);
// 更改在綫狀態
Presence presence = new Presence(Presence.Type.available);
getConnection().sendPacket(presence);
// 添加連接監聽
connectionListener = new TaxiConnectionListener();
getConnection().addConnectionListener(connectionListener);
return true;

      } catch (XMPPException xe) {

      xe.printStackTrace();

      }
      return false;
      }

    /**

    • 注册
    • @param account
    • 注册帐号
    • @param password
    • 注册密码
    • @return 1、注册成功 0、服务器没有返回结果2、这个账号已经存在3、注册失败
      */
      public String regist(String account, String password) {
      if (getConnection() == null) 
      return "0";

      Registration reg = new Registration();
      reg.setType(IQ.Type.SET);
      reg.setTo(getConnection().getServiceName());
      // 注意这里createAccount注册时，参数是UserName，不是jid，是”@“前面的部分。
      reg.setUsername(account);
      reg.setPassword(password);
      // 这边addAttribute不能为空，否则出错。所以做个标志是android手机创建的吧！！！！！
      reg.addAttribute(“android”, “geolo_createUser_android”);
      PacketFilter filter = new AndFilter(new PacketIDFilter(

      reg.getPacketID()), new PacketTypeFilter(IQ.class));

      PacketCollector collector = getConnection().createPacketCollector(

      filter);

      getConnection().sendPacket(reg);
      IQ result = (IQ) collector.nextResult(SmackConfiguration

      .getPacketReplyTimeout());

      // Stop queuing results停止请求results（是否成功的结果）
      collector.cancel();
      if (result == null) {

      Log.e("regist", "No response from server.");
return "0";

      } else if (result.getType() == IQ.Type.RESULT) {

      Log.v("regist", "regist success.");
return "1";

      } else { // if (result.getType() == IQ.Type.ERROR)

      if (result.getError().toString().equalsIgnoreCase("conflict(409)")) {
    Log.e("regist", "IQ.Type.ERROR: "
            + result.getError().toString());
    return "2";
} else {
    Log.e("regist", "IQ.Type.ERROR: "
            + result.getError().toString());
    return "3";
}

      }
      }

    /**

    • 更改用户状态
      */
      public void setPresence(int code) {
      XMPPConnection con = getConnection();
      if (con == null)

      return;

      Presence presence;
      switch (code) {
      case 0:

      presence = new Presence(Presence.Type.available);
con.sendPacket(presence);
Log.v("state", "设置在线");
break;

      case 1:

      presence = new Presence(Presence.Type.available);
presence.setMode(Presence.Mode.chat);
con.sendPacket(presence);
Log.v("state", "设置Q我吧");
break;

      case 2:

      presence = new Presence(Presence.Type.available);
presence.setMode(Presence.Mode.dnd);
con.sendPacket(presence);
Log.v("state", "设置忙碌");
break;

      case 3:

      presence = new Presence(Presence.Type.available);
presence.setMode(Presence.Mode.away);
con.sendPacket(presence);
Log.v("state", "设置离开");
break;

      case 4:

      Roster roster = con.getRoster();
Collection<RosterEntry> entries = roster.getEntries();
for (RosterEntry entry : entries) {
    presence = new Presence(Presence.Type.unavailable);
    presence.setPacketID(Packet.ID_NOT_AVAILABLE);
    presence.setFrom(con.getUser());
    presence.setTo(entry.getUser());
    con.sendPacket(presence);
    Log.v("state", presence.toXML());
}
// 向同一用户的其他客户端发送隐身状态
presence = new Presence(Presence.Type.unavailable);
presence.setPacketID(Packet.ID_NOT_AVAILABLE);
presence.setFrom(con.getUser());
presence.setTo(StringUtils.parseBareAddress(con.getUser()));
con.sendPacket(presence);
Log.v("state", "设置隐身");
break;

      case 5:

      presence = new Presence(Presence.Type.unavailable);
con.sendPacket(presence);
Log.v("state", "设置离线");
break;

      default:

      break;

      }
      }

    /**

    • 获取所有组
    • @return 所有组集合
      */
      public List getGroups() {
      if (getConnection() == null) 
      return null;

      List grouplist = new ArrayList ();
      Collection rosterGroup = getConnection().getRoster()

      .getGroups();

      Iterator i = rosterGroup.iterator();
      while (i.hasNext()) {

      grouplist.add(i.next());

      }
      return grouplist;
      }

    /**

    • 获取某个组里面的所有好友
    • @param roster
    • @param groupName
    • 组名
    • @return
      */
      public List getEntriesByGroup(String groupName) {
      if (getConnection() == null) 
      return null;

      List Entrieslist = new ArrayList ();
      RosterGroup rosterGroup = getConnection().getRoster().getGroup(

      groupName);

      Collection rosterEntry = rosterGroup.getEntries();
      Iterator i = rosterEntry.iterator();
      while (i.hasNext()) {

      Entrieslist.add(i.next());

      }
      return Entrieslist;
      }

    /**

    • 获取所有好友信息
    • @return
      */
      public List getAllEntries() {
      if (getConnection() == null) 
      return null;

      List Entrieslist = new ArrayList ();
      Collection rosterEntry = getConnection().getRoster()

      .getEntries();

      Iterator i = rosterEntry.iterator();
      while (i.hasNext()) {

      Entrieslist.add(i.next());

      }
      return Entrieslist;
      }

    /**

    • 获取用户VCard信息
    • @param connection
    • @param user
    • @return
    • @throws XMPPException
      */
      public VCard getUserVCard(String user) {
      if (getConnection() == null) 
      return null;

      VCard vcard = new VCard();
      try {

      vcard.load(getConnection(), user);

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      return vcard;
      }

    /**

    • 获取用户头像信息
    • @param connection
    • @param user
    • @return
      */
      public Drawable getUserImage(String user) {
      if (getConnection() == null) 
      return null;

      ByteArrayInputStream bais = null;
      try {

      VCard vcard = new VCard();
// 加入这句代码，解决No VCard for
ProviderManager.getInstance().addIQProvider("vCard", "vcard-temp",
        new org.jivesoftware.smackx.provider.VCardProvider());
if (user == "" || user == null || user.trim().length() <= 0) {
    return null;
}
vcard.load(getConnection(), user + "@"
        + getConnection().getServiceName());

if (vcard == null || vcard.getAvatar() == null)
    return null;
bais = new ByteArrayInputStream(vcard.getAvatar());

      } catch (Exception e) {

      e.printStackTrace();
return null;

      }
      return FormatTools.getInstance().InputStream2Drawable(bais);
      }

    /**

    • 添加一个分组
    • @param groupName
    • @return
      */
      public boolean addGroup(String groupName) {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getRoster().createGroup(groupName);
Log.v("addGroup", groupName + "創建成功");
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 删除分组
    • @param groupName
    • @return
      */
      public boolean removeGroup(String groupName) {
      return true;
      }

    /**

    • 添加好友 无分组
    • @param userName
    • @param name
    • @return
      */
      public boolean addUser(String userName, String name) {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getRoster().createEntry(userName, name, null);
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 添加好友 有分组
    • @param userName
    • @param name
    • @param groupName
    • @return
      */
      public boolean addUser(String userName, String name, String groupName) {
      if (getConnection() == null) 
      return false;

      try {

      Presence subscription = new Presence(Presence.Type.subscribed);
subscription.setTo(userName);
userName += "@" + getConnection().getServiceName();
getConnection().sendPacket(subscription);
getConnection().getRoster().createEntry(userName, name,
        new String[] { groupName });
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 删除好友
    • @param userName
    • @return
      */
      public boolean removeUser(String userName) {
      if (getConnection() == null) 
      return false;

      try {

      RosterEntry entry = null;
if (userName.contains("@"))
    entry = getConnection().getRoster().getEntry(userName);
else
    entry = getConnection().getRoster().getEntry(
            userName + "@" + getConnection().getServiceName());
if (entry == null)
    entry = getConnection().getRoster().getEntry(userName);
getConnection().getRoster().removeEntry(entry);

return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 查询用户
    • @param userName
    • @return
    • @throws XMPPException
      */
      public List > searchUsers(String userName) {
      if (getConnection() == null) 
      return null;

      HashMap user = null;
      List > results = new ArrayList >();
      try {

      new ServiceDiscoveryManager(getConnection());

UserSearchManager usm = new UserSearchManager(getConnection());

Form searchForm = usm.getSearchForm(getConnection()
        .getServiceName());
Form answerForm = searchForm.createAnswerForm();
answerForm.setAnswer("userAccount", true);
answerForm.setAnswer("userPhote", userName);
ReportedData data = usm.getSearchResults(answerForm, "search"
        + getConnection().getServiceName());

Iterator<Row> it = data.getRows();
Row row = null;
while (it.hasNext()) {
    user = new HashMap<String, String>();
    row = it.next();
    user.put("userAccount", row.getValues("userAccount").next()
            .toString());
    user.put("userPhote", row.getValues("userPhote").next()
            .toString());
    results.add(user);
    // 若存在，则有返回,UserName一定非空，其他两个若是有设，一定非空
}

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      return results;
      }

    /**

    • 修改心情
    • @param connection
    • @param status
      */
      public void changeStateMessage(String status) {
      if (getConnection() == null) 
      return;

      Presence presence = new Presence(Presence.Type.available);
      presence.setStatus(status);
      getConnection().sendPacket(presence);
      }

    /**

    • 修改用户头像
    • @param file
      */
      public boolean changeImage(File file) {
      if (getConnection() == null) 
      return false;

      try {

      VCard vcard = new VCard();
vcard.load(getConnection());

byte[] bytes;

bytes = getFileBytes(file);
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());
FormatTools.getInstance().InputStream2Bitmap(bais);

vcard.save(getConnection());
return true;

      } catch (Exception e) {

      e.printStackTrace();
return false;

      }
      }

    /**

    • 文件转字节
    • @param file
    • @return
    • @throws IOException
      */
      private 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();
}

      }
      }

    /**

    • 删除当前用户
    • @return
      */
      public boolean deleteAccount() {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getAccountManager().deleteAccount();
return true;

      } catch (XMPPException e) {

      return false;

      }
      }

    /**

    • 修改密码
    • @return
      */
      public boolean changePassword(String pwd) {
      if (getConnection() == null) 
      return false;

      try {

      getConnection().getAccountManager().changePassword(pwd);
return true;

      } catch (XMPPException e) {

      return false;

      }
      }

    /**

    • 初始化会议室列表
      */
      public List getHostRooms() {
      if (getConnection() == null)

      return null;

      Collection hostrooms = null;
      List roominfos = new ArrayList ();
      try {

      new ServiceDiscoveryManager(getConnection());
hostrooms = MultiUserChat.getHostedRooms(getConnection(),
        getConnection().getServiceName());
for (HostedRoom entry : hostrooms) {
    roominfos.add(entry);
    Log.i("room",
            "名字：" + entry.getName() + " - ID:" + entry.getJid());
}
Log.i("room", "服务会议数量:" + roominfos.size());

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      return roominfos;
      }

    /**

    • 创建房间
    • @param roomName
    • 房间名称

      */
      public MultiUserChat createRoom(String user, String roomName,

      String password) {

      if (getConnection() == null)

      return null;

      MultiUserChat muc = null;
      try {

      // 创建一个MultiUserChat
muc = new MultiUserChat(getConnection(), roomName + "@conference."
        + getConnection().getServiceName());
// 创建聊天室
muc.create(roomName);
// 获得聊天室的配置表单
Form form = muc.getConfigurationForm();
// 根据原始表单创建一个要提交的新表单。
Form submitForm = form.createAnswerForm();
// 向要提交的表单添加默认答复
for (Iterator<FormField> fields = form.getFields(); fields
        .hasNext();) {
    FormField field = (FormField) fields.next();
    if (!FormField.TYPE_HIDDEN.equals(field.getType())
            && field.getVariable() != null) {
        // 设置默认值作为答复
        submitForm.setDefaultAnswer(field.getVariable());
    }
}
// 设置聊天室的新拥有者
List<String> owners = new ArrayList<String>();
owners.add(getConnection().getUser());// 用户JID
submitForm.setAnswer("muc#roomconfig_roomowners", owners);
// 设置聊天室是持久聊天室，即将要被保存下来
submitForm.setAnswer("muc#roomconfig_persistentroom", true);
// 房间仅对成员开放
submitForm.setAnswer("muc#roomconfig_membersonly", false);
// 允许占有者邀请其他人
submitForm.setAnswer("muc#roomconfig_allowinvites", true);
if (!password.equals("")) {
    // 进入是否需要密码
    submitForm.setAnswer("muc#roomconfig_passwordprotectedroom",
            true);
    // 设置进入密码
    submitForm.setAnswer("muc#roomconfig_roomsecret", password);
}
// 能够发现占有者真实 JID 的角色
// submitForm.setAnswer("muc#roomconfig_whois", "anyone");
// 登录房间对话
submitForm.setAnswer("muc#roomconfig_enablelogging", true);
// 仅允许注册的昵称登录
submitForm.setAnswer("x-muc#roomconfig_reservednick", true);
// 允许使用者修改昵称
submitForm.setAnswer("x-muc#roomconfig_canchangenick", false);
// 允许用户注册房间
submitForm.setAnswer("x-muc#roomconfig_registration", false);
// 发送已完成的表单（有默认值）到服务器来配置聊天室
muc.sendConfigurationForm(submitForm);

      } catch (XMPPException e) {

      e.printStackTrace();
return null;

      }
      return muc;
      }

    /**

    • 加入会议室
    • @param user
    • 昵称
    • @param password
    • 会议室密码
    • @param roomsName
    • 会议室名

      */
      public MultiUserChat joinMultiUserChat(String user, String roomsName,

      String password) {

      if (getConnection() == null)

      return null;

      try {

      // 使用XMPPConnection创建一个MultiUserChat窗口
MultiUserChat muc = new MultiUserChat(getConnection(), roomsName
        + "@conference." + getConnection().getServiceName());
// 聊天室服务将会决定要接受的历史记录数量
DiscussionHistory history = new DiscussionHistory();
history.setMaxChars(0);
// history.setSince(new Date());
// 用户加入聊天室
muc.join(user, password, history,
        SmackConfiguration.getPacketReplyTimeout());
Log.i("MultiUserChat", "会议室【"+roomsName+"】加入成功........");
return muc;

      } catch (XMPPException e) {

      e.printStackTrace();
Log.i("MultiUserChat", "会议室【"+roomsName+"】加入失败........");
return null;

      }
      }

    /**

    • 查询会议室成员名字
    • @param muc
      */
      public List findMulitUser(MultiUserChat muc) {
      if (getConnection() == null) 
      return null;

      List listUser = new ArrayList ();
      Iterator it = muc.getOccupants();
      // 遍历出聊天室人员名称
      while (it.hasNext()) {

      // 聊天室成员名字
String name = StringUtils.parseResource(it.next());
listUser.add(name);

      }
      return listUser;
      }

    /**

    • 发送文件
    • @param user
    • @param filePath
      */
      public void sendFile(String user, String filePath) {
      if (getConnection() == null) 
      return;

      // 创建文件传输管理器
      FileTransferManager manager = new FileTransferManager(getConnection());

      // 创建输出的文件传输
      OutgoingFileTransfer transfer = manager

      .createOutgoingFileTransfer(user);

      // 发送文件
      try {

      transfer.sendFile(new File(filePath), "You won‘t believe this!");

      } catch (XMPPException e) {

      e.printStackTrace();

      }
      }

    /**

    • 获取离线消息
    • @return
      */
      public Map ? getHisMessage() {
      if (getConnection() == null) 
      return null;

      Map ? offlineMsgs = null;

      try {

      OfflineMessageManager offlineManager = new OfflineMessageManager(
        getConnection());
Iterator<Message> it = offlineManager.getMessages();

int count = offlineManager.getMessageCount();
if (count <= 0)
    return null;
offlineMsgs = new HashMap<String, List<HashMap<String, String>>>();

while (it.hasNext()) {
    Message message = it.next();
    String fromUser = StringUtils.parseName(message.getFrom());
    ;
    HashMap<String, String> histrory = new HashMap<String, String>();
    histrory.put("useraccount",
            StringUtils.parseName(getConnection().getUser()));
    histrory.put("friendaccount", fromUser);
    histrory.put("info", message.getBody());
    histrory.put("type", "left");
    if (offlineMsgs.containsKey(fromUser)) {
        offlineMsgs.get(fromUser).add(histrory);
    } else {
        List<HashMap<String, String>> temp = new ArrayList<HashMap<String, String>>();
        temp.add(histrory);
        offlineMsgs.put(fromUser, temp);
    }
}
offlineManager.deleteMessages();

      } catch (Exception e) {

      e.printStackTrace();

      }
      return offlineMsgs;
      }

    /**

    • 判断OpenFire用户的状态 strUrl :
    • url格式 - http://my.openfire.com:9090/plugins/presence
    • /[email protected]_NAME&type=xml
    • 返回值 : 0 - 用户不存在; 1 - 用户在线; 2 - 用户离线
    • 说明 ：必须要求 OpenFire加载 presence 插件，同时设置任何人都可以访问
      */
      public int IsUserOnLine(String user) {
      String url = “http://“+SERVER_HOST+“:9090/plugins/presence/status?” + 
      "jid="+ user +"@"+ SERVER_NAME +"&type=xml";

      int shOnLineState = 0; // 不存在
      try {

      URL oUrl = new URL(url);
URLConnection oConn = oUrl.openConnection();
if (oConn != null) {
    BufferedReader oIn = new BufferedReader(new InputStreamReader(
            oConn.getInputStream()));
    if (null != oIn) {
        String strFlag = oIn.readLine();
        oIn.close();
        System.out.println("strFlag"+strFlag);
        if (strFlag.indexOf("type=\"unavailable\"") >= 0) {
            shOnLineState = 2;
        }
        if (strFlag.indexOf("type=\"error\"") >= 0) {
            shOnLineState = 0;
        } else if (strFlag.indexOf("priority") >= 0
                || strFlag.indexOf("id=\"") >= 0) {
            shOnLineState = 1;
        }
    }
}

      } catch (Exception e) {

      e.printStackTrace();

      }

      return shOnLineState;
      }

    /**

    • 加入providers的函数 ASmack在/META-INF缺少一个smack.providers 文件
    • @param pm
      */
      public void configureConnection(ProviderManager pm) {

      // Private Data Storage
      pm.addIQProvider(“query”, “jabber:iq:private”,

      new PrivateDataManager.PrivateDataIQProvider());

      // Time
      try {

      pm.addIQProvider("query", "jabber:iq:time",
        Class.forName("org.jivesoftware.smackx.packet.Time"));

      } catch (ClassNotFoundException e) {

      Log.w("TestClient",
        "Can‘t load class for org.jivesoftware.smackx.packet.Time");

      }

      // Roster Exchange
      pm.addExtensionProvider(“x”, “jabber:x:roster”,

      new RosterExchangeProvider());

      // Message Events
      pm.addExtensionProvider(“x”, “jabber:x:event”,

      new MessageEventProvider());

      // Chat State
      pm.addExtensionProvider(“active”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“composing”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“paused”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“inactive”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      pm.addExtensionProvider(“gone”,

      "http://jabber.org/protocol/chatstates",
    new ChatStateExtension.Provider());

      // XHTML
      pm.addExtensionProvider(“html”, “http://jabber.org/protocol/xhtml-im”,

      new XHTMLExtensionProvider());

      // Group Chat Invitations
      pm.addExtensionProvider(“x”, “jabber:x:conference”,

      new GroupChatInvitation.Provider());

      // Service Discovery # Items
      pm.addIQProvider(“query”, “http://jabber.org/protocol/disco#items”,

      new DiscoverItemsProvider());

      // Service Discovery # Info
      pm.addIQProvider(“query”, “http://jabber.org/protocol/disco#info”,

      new DiscoverInfoProvider());

      // Data Forms
      pm.addExtensionProvider(“x”, “jabber:x:data”, new DataFormProvider());

      // MUC User
      pm.addExtensionProvider(“x”, “http://jabber.org/protocol/muc#user”,

      new MUCUserProvider());

      // MUC Admin
      pm.addIQProvider(“query”, “http://jabber.org/protocol/muc#admin”,

      new MUCAdminProvider());

      // MUC Owner
      pm.addIQProvider(“query”, “http://jabber.org/protocol/muc#owner”,

      new MUCOwnerProvider());

      // Delayed Delivery
      pm.addExtensionProvider(“x”, “jabber:x:delay”,

      new DelayInformationProvider());

      // Version
      try {

      pm.addIQProvider("query", "jabber:iq:version",
        Class.forName("org.jivesoftware.smackx.packet.Version"));

      } catch (ClassNotFoundException e) {

      // Not sure what‘s happening here.

      }

      // VCard
      pm.addIQProvider(“vCard”, “vcard-temp”, new VCardProvider());

      // Offline Message Requests
      pm.addIQProvider(“offline”, “http://jabber.org/protocol/offline”,

      new OfflineMessageRequest.Provider());

      // Offline Message Indicator
      pm.addExtensionProvider(“offline”,

      "http://jabber.org/protocol/offline",
    new OfflineMessageInfo.Provider());

      // Last Activity
      pm.addIQProvider(“query”, “jabber:iq:last”, new LastActivity.Provider());

      // User Search
      pm.addIQProvider(“query”, “jabber:iq:search”, new UserSearch.Provider());

      // SharedGroupsInfo
      pm.addIQProvider(“sharedgroup”,

      "http://www.jivesoftware.org/protocol/sharedgroup",
    new SharedGroupsInfo.Provider());

      // JEP-33: Extended Stanza Addressing
      pm.addExtensionProvider(“addresses”,

      "http://jabber.org/protocol/address",
    new MultipleAddressesProvider());

      // FileTransfer
      pm.addIQProvider(“si”, “http://jabber.org/protocol/si”,

      new StreamInitiationProvider());

      pm.addIQProvider(“query”, “http://jabber.org/protocol/bytestreams”,

      new BytestreamsProvider());

      // Privacy
      pm.addIQProvider(“query”, “jabber:iq:privacy”, new PrivacyProvider());
      pm.addIQProvider(“command”, “http://jabber.org/protocol/commands”,

      new AdHocCommandDataProvider());

      pm.addExtensionProvider(“malformed-action”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.MalformedActionError());

      pm.addExtensionProvider(“bad-locale”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.BadLocaleError());

      pm.addExtensionProvider(“bad-payload”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.BadPayloadError());

      pm.addExtensionProvider(“bad-sessionid”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.BadSessionIDError());

      pm.addExtensionProvider(“session-expired”,

      "http://jabber.org/protocol/commands",
    new AdHocCommandDataProvider.SessionExpiredError());

      }

}

/**
 * 判断OpenFire用户的状态 strUrl :
 * url格式 - http://my.openfire.com:9090/plugins/presence
 * /[email protected]_NAME&type=xml
 * 返回值 : 0 - 用户不存在; 1 - 用户在线; 2 - 用户离线
 * 说明 ：必须要求 OpenFire加载 presence 插件，同时设置任何人都可以访问
 */
public int IsUserOnLine(String user) {
    String url = "http://"+SERVER_HOST+":9090/plugins/presence/status?" +
            "jid="+ user +"@"+ SERVER_NAME +"&type=xml";
    int shOnLineState = 0; // 不存在
    try {
        URL oUrl = new URL(url);
        URLConnection oConn = oUrl.openConnection();
        if (oConn != null) {
            BufferedReader oIn = new BufferedReader(new InputStreamReader(
                    oConn.getInputStream()));
            if (null != oIn) {
                String strFlag = oIn.readLine();
                oIn.close();
                System.out.println("strFlag"+strFlag);
                if (strFlag.indexOf("type=\"unavailable\"") >= 0) {
                    shOnLineState = 2;
                }
                if (strFlag.indexOf("type=\"error\"") >= 0) {
                    shOnLineState = 0;
                } else if (strFlag.indexOf("priority") >= 0
                        || strFlag.indexOf("id=\"") >= 0) {
                    shOnLineState = 1;
                }
            }
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return shOnLineState;
}

调用该工具类的方法很简单，用了一个单例模式，里面的方法都可以用相同的方法调用

[java] view plaincopyprint?
XmppConnection.getInstance().login(username,password)

XmppConnection.getInstance().login(username,password)

时间： 2024-10-01 04:26:43

Android基于XMPP Smack Openfire下学习开发IM(六)总结的相关文章

Android基于XMPP Smack Openfire下学习开发IM(一)实现用户注册、登录、修改密码和注销等

http://blog.csdn.net/h7870181/article/details/8653865 以前学习过用Scoket 建立聊天,简单的建立聊天是没问题的,但如果要实现多人复杂的聊天,后台服务器代码就比较复杂,对于我这新手来讲就比较难了.后来在网上看到用openfire做服务器,利用强大的Smack API库来实现IM聊天就简单多了. 网上也有很多关于这方面的资料,我就在这里把网上的资料和自己的理解总结一下和大家一起交流学习. 需要用到以下几个工具: Openfire  最新版本(

Android基于XMPP Smack Openfire下学习开发IM(五)连接断开重连

学习过程中大家都碰到过连接被断开的问题给困扰吧,下面教大家如何做到连接断开后,重新连接 首先要创建连接监听器,用来监听连接状态,这里我写了一个类 继承了ConnectionListener,重写了里面5个方法,最重要的两个方法connectionClosed()和connectionClosedOnError() 前者为连接正常断开,后者是连接异常断开,不管是正常还是异常,我们都要监听到 这里写了一个定时器,两秒进行连接一次,注释写的也很清楚,不做太多介绍 要注意的是我把用户名和密码都存到sha

Android 基于XMPP Smack openfire 开发的聊天室

Android基于XMPP Smack openfire 开发的聊天室

Android基于XMPP Smack及Openfire学习笔记（1）

之前开发的项目中实用到IM聊天功能.可是这块功能公司有专门的IM团队来开发,由他们开发好后.直接接入到我们APP中.我參与写IM相关功能非常地少,所以也一直想学习相关知识 . 眼下Android主要用的是XMPP协议及OPenfireserver来实现IM功能,我也从这块入手学习.也感谢全部分享资料让我有机会学习的同行们. 如今正式開始啦. 第一步:搭建Openfireserver: Openfire工具下载地址:http://www.igniterealtime.org/downloads/i

Android基于XMPP的即时通讯2-文件传输

本文是在上一篇博文Android基于XMPP的即时通讯1-基本对话的基础上,添加新的功能,文件传输 1.初始化文件传输管理类 public static FileTransferManager getFileTransferManager() { if (fileManager == null) { ServiceDiscoveryManager sdManager = ServiceDiscoveryManager .getInstanceFor(connection); if (sdMana

Android基于XMPP的即时通讯3-表情发送

这篇博文主要讲表情发送的一些东西. 参考:Android基于XMPP的即时通讯1-基本对话 1.准备好资源文件 采用的是emoji的表情,我打包好了,下载地址:http://files.cnblogs.com/files/pear-lemon/drawable.zip 2.表情布局文件layout_send_emotion.xml <?xml version="1.0" encoding="utf-8"?> <RelativeLayout xmln

Android基于xmpp的即时通讯应用

xmpp是一个通信协议.因为这是个开放的协议,为了节俭开发成本,很多即时应用都采用了这个协议.Android上最常用的组合asmack +openfire.Asmack是smack的android版,是对xmpp协议进行了封装,并提供了丰富的api,简化了操作.Openfire是一个开源的IM服务器,基于Xmpp实现.换句话说使用xmpp开发即时通讯应用的话,服务器端已经开发好了,就是openfire. 现在我做的一个android应用就是采用asmack+openfire.说实在的,xmpp协

6. Swift 基于Xmpp和openfire实现一个简单的登录注册

1. 基本步骤:首先导入Xmpp框架,配置环境 ->由于我们使用的是OC的Xmpp框架,再进行Swift开发时需要进行桥接. 具体方法就是创建一个基于c的.h的头文件,然后将我们需要编译OC的语言的头文件包含这个.h文件中: ->然后导入如下库文件,在头头文件选择路径中 如上图, 设置header Search paths 设置头文件的搜索路径,导入libxml2库文件相对路径,***注意前面是 usr .以前第一次装的时候写成user找了半个多小时 -> 然后创建界面,随便弄两个框框和

Android基于XMPP的即时通讯

闲暇之余,自己写了个简单的即时通讯,基于OpenFire服务器平台. 整个项目包括两个部分,一个是服务器端,一个是android手机端: 一.关于服务器端没什么好说的,下载安装配置即可 推荐下载带jar的程序安装,配置好java_jdk的可以使用压缩包解压安装 OpenFire下载地址:http://www.igniterealtime.org/downloads/index.jsp 顺便下载一个Spark,电脑端通讯,用于和你的安卓手机互发信息. 运行openFire截图 openfire的后