[关闭]
@Tyhj 2016-11-28T14:20:17.000000Z 字数 12386 阅读 1461

Asmark+openFire开发Android聊天

实验班作业

利用asmark提供的方法来进行用户注册，查找，发送

消息和接收消息，我整理成了一个静态类具体方法如下：

  1. package publicinfo;
  3. import android.content.Context;
  4. import android.content.Intent;
  5. import android.content.SharedPreferences;
  6. import android.graphics.Bitmap;
  7. import android.graphics.drawable.BitmapDrawable;
  8. import android.graphics.drawable.Drawable;
  9. import android.util.Log;
  11. import com.avos.avoscloud.AVException;
  12. import com.avos.avoscloud.AVObject;
  13. import com.avos.avoscloud.AVQuery;
  14. import com.avos.avoscloud.DeleteCallback;
  15. import com.avos.avoscloud.FindCallback;
  16. import com.avos.avoscloud.GetCallback;
  17. import com.tyhj.myfist_2016_6_29.MyTime;
  19. import org.jivesoftware.smack.AccountManager;
  20. import org.jivesoftware.smack.ConnectionConfiguration;
  21. import org.jivesoftware.smack.Roster;
  22. import org.jivesoftware.smack.RosterEntry;
  23. import org.jivesoftware.smack.XMPPConnection;
  24. import org.jivesoftware.smack.XMPPException;
  25. import org.jivesoftware.smack.packet.Presence;
  26. import org.jivesoftware.smack.provider.ProviderManager;
  27. import org.jivesoftware.smack.util.StringUtils;
  28. import org.jivesoftware.smackx.Form;
  29. import org.jivesoftware.smackx.ReportedData;
  30. import org.jivesoftware.smackx.ServiceDiscoveryManager;
  31. import org.jivesoftware.smackx.packet.VCard;
  32. import org.jivesoftware.smackx.search.UserSearchManager;
  34. import java.io.BufferedReader;
  35. import java.io.ByteArrayInputStream;
  36. import java.io.ByteArrayOutputStream;
  37. import java.io.File;
  38. import java.io.InputStreamReader;
  39. import java.net.URL;
  40. import java.net.URLConnection;
  41. import java.util.ArrayList;
  42. import java.util.Collection;
  43. import java.util.HashMap;
  44. import java.util.Iterator;
  45. import java.util.List;
  47. import api.File2Bytes;
  48. import api.FormatTools;
  49. import service.ChatService;
  51. /**
  52.  * Created by Tyhj on 2016/10/16.
  53.  */
  55. public class UserInfo {
  56.     private static int SERVER_PORT = 5222;
  57.     private static String SERVER_HOST = "120.27.49.173";
  58.     private static String SERVER_NAME = "120.27.49.173";
  61.     public static boolean canDo() {
  62.         if (xmppConnection != null && xmppConnection.isConnected())
  63.             return true;
  64.         else
  65.             return false;
  66.     }
  68.     static {
  69.         try {
  70.             Class.forName("org.jivesoftware.smack.ReconnectionManager");
  71.         } catch (Exception e) {
  72.             e.printStackTrace();
  73.         }
  74.     }
  76.     //名字
  77.     static String name;
  78.     //id
  79.     static String id;
  80.     //连接
  81.     static XMPPConnection xmppConnection;
  82.     // 加入组的名字
  83.     static String groupName;
  85.     //
  86.     private static void setXmppConnection() {
  87.         try {
  88.             Class.forName("org.jivesoftware.smack.ReconnectionManager");
  89.         } catch (Exception e) {
  90.             e.printStackTrace();
  91.         }
  92.         XMPPConnection conn;
  93.         ConnectionConfiguration config = new ConnectionConfiguration(
  94.                 SERVER_HOST, SERVER_PORT, SERVER_NAME);
  95.         config.setReconnectionAllowed(true);
  96.         config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
  97.         config.setSASLAuthenticationEnabled(false);
  98.         conn = new XMPPConnection(config);
  99.         try {
  100.             conn.connect();
  101.             xmppConnection = conn;
  102.         } catch (XMPPException e) {
  103.             e.printStackTrace();
  104.         }
  105.     }
  107.     public static void setXmppConnection(XMPPConnection xmppConnection) {
  108.         UserInfo.xmppConnection = xmppConnection;
  109.     }
  111.     //登陆
  112.     public static synchronized boolean Login(String name, String pas, Context context) {
  113.         try {
  114.             if (!MyFunction.isIntenet(context, null))
  115.                 return false;
  116.             setXmppConnection();
  117.             if (xmppConnection == null || !xmppConnection.isConnected())
  118.                 return false;
  119.             xmppConnection.login(name, pas);
  120.             Presence presence = new Presence(Presence.Type.available);
  121.             xmppConnection.sendPacket(presence);
  122.             SharedPreferences shared = context.getSharedPreferences("login", Context.MODE_PRIVATE);
  123.             SharedPreferences.Editor editor = shared.edit();
  124.             editor.putString("name", name);
  125.             editor.putString("pas", pas);
  126.             editor.commit();
  127.             UserInfo.id = name;
  128.             UserInfo.groupName = name + MyFunction.getTime();
  129.             return true;
  131.         } catch (XMPPException e) {
  132.             e.printStackTrace();
  133.         }
  134.         return false;
  135.     }
  137.     //重新连接
  138.     public static synchronized boolean reLogin(Context context) {
  139.         try {
  140.             if (!MyFunction.isIntenet(context, null))
  141.                 return false;
  143.             if (MyFunction.isServiceRun(context, "service.ChatService")) {
  144.                 xmppConnection = ChatService.getConnection();
  145.                 return true;
  146.             }
  148.             SharedPreferences shared = context.getSharedPreferences("login", Context.MODE_PRIVATE);
  149.             UserInfo.id = shared.getString("name", null);
  150.             UserInfo.groupName = id + MyFunction.getTime();
  153.             if (!canDo())
  154.                 setXmppConnection();
  155.             if (!canDo())
  156.                 return false;
  158.             xmppConnection.login(id, shared.getString("pas", null));
  159.             Presence presence = new Presence(Presence.Type.available);
  160.             xmppConnection.sendPacket(presence);
  161.             return true;
  162.         } catch (Exception e) {
  163.             e.printStackTrace();
  164.         }
  165.         return false;
  166.     }
  168.     //注册
  169.     public static boolean Register(String account, String password, Context context) {
  170.         if (!MyFunction.isIntenet(context, null))
  171.             return false;
  172.         setXmppConnection();
  173.         if (xmppConnection == null)
  174.             return false;
  175.         AccountManager manager = new AccountManager(xmppConnection);
  176.         try {
  177.             manager.createAccount(account, password);
  178.         } catch (XMPPException e) {
  179.             return false;
  180.         }
  181.         return true;
  182.     }
  184.     //退出登录
  185.     public static void logout(Context context) {
  187.         SharedPreferences shared = context.getSharedPreferences("login", Context.MODE_PRIVATE);
  188.         shared.edit().clear().commit();
  190.         shared = context.getSharedPreferences("chat_date", Context.MODE_PRIVATE);
  191.         shared.edit().clear().commit();
  194.         if (UserInfo.canDo())
  195.             xmppConnection.disconnect();
  196.         final AVQuery<AVObject> query = new AVQuery<>("Image");
  197.         query.whereEqualTo("user", UserInfo.getId());
  198.         query.findInBackground(new FindCallback<AVObject>() {
  199.             @Override
  200.             public void done(List<AVObject> list, AVException e) {
  201.                 if (e == null && list.size() > 0) {
  202.                     for (int i = 0; i < list.size(); i++) {
  203.                         list.get(i).deleteInBackground();
  204.                     }
  205.                 }
  206.             }
  207.         });
  208.         final AVQuery<AVObject> query1 = new AVQuery<>("Record");
  209.         query1.whereEqualTo("user", UserInfo.getId());
  210.         query1.findInBackground(new FindCallback<AVObject>() {
  211.             @Override
  212.             public void done(List<AVObject> list, AVException e) {
  213.                 if (e == null && list.size() > 0) {
  214.                     for (int i = 0; i < list.size(); i++) {
  215.                         list.get(i).deleteInBackground();
  216.                     }
  217.                 }
  218.             }
  219.         });
  220.         Intent intent = new Intent(context, ChatService.class);
  221.         context.stopService(intent);
  222.     }
  224.     //强制下线
  225.     public static void logoutFore(Context context) {
  226.         SharedPreferences shared = context.getSharedPreferences("login", Context.MODE_PRIVATE);
  227.         SharedPreferences.Editor editor = shared.edit();
  228.         editor.clear();
  229.         editor.commit();
  230.         if (xmppConnection.isConnected())
  231.             xmppConnection.disconnect();
  232.         Intent intent = new Intent(context, ChatService.class);
  233.         context.stopService(intent);
  234.     }
  236.     //修改密码
  237.     public static boolean changePassword(Context context, String pwd, String prepas, boolean b) {
  238.         SharedPreferences shared = context.getSharedPreferences("login", Context.MODE_PRIVATE);
  239.         String pas = shared.getString("pas", null);
  240.         if (!canDo())
  241.             return false;
  242.         if (b && pas != null) {
  243.             try {
  244.                 xmppConnection.getAccountManager().changePassword(pwd);
  245.                 return true;
  246.             } catch (XMPPException e) {
  247.                 return false;
  248.             }
  249.         } else if (pas != null) {
  250.             if (pas.equals(prepas)) {
  251.                 try {
  252.                     xmppConnection.getAccountManager().changePassword(pwd);
  253.                     return true;
  254.                 } catch (XMPPException e) {
  255.                     return false;
  256.                 }
  257.             } else
  258.                 return false;
  259.         }
  260.         return false;
  261.     }
  263.     //查询用户
  264.     public static List<HashMap<String, String>> searchUsers(String userName) {
  265.         if (!canDo())
  266.             return null;
  267.         HashMap<String, String> user = null;
  268.         List<HashMap<String, String>> results = new ArrayList<HashMap<String, String>>();
  269.         try {
  270.             new ServiceDiscoveryManager(xmppConnection);
  271.             UserSearchManager usm = new UserSearchManager(xmppConnection);
  272.             Form searchForm = usm.getSearchForm(xmppConnection.getServiceName());
  273.             Form answerForm = searchForm.createAnswerForm();
  274.             answerForm.setAnswer("userAccount", true);
  275.             answerForm.setAnswer("userPhote", userName);
  276.             ReportedData data = usm.getSearchResults(answerForm, xmppConnection.getServiceName());
  278.             Iterator<ReportedData.Row> it = data.getRows();
  279.             ReportedData.Row row = null;
  280.             while (it.hasNext()) {
  281.                 user = new HashMap<String, String>();
  282.                 row = it.next();
  283.                 user.put("userAccount", row.getValues("userAccount").next()
  284.                         .toString());
  285.                 Log.e("获取的东西", row.getValues("userAccount").next().toString());
  286.                 user.put("userPhote", row.getValues("userPhote").next().toString());
  287.                 Log.e("获取的东西", row.getValues("userPhote").next().toString());
  288.                 results.add(user);
  289.                 // 若存在，则有返回,UserName一定非空，其他两个若是有设，一定非空
  290.             }
  291.             Log.e("my=没有", "哈哈哈哈哈哈哈");
  292.         } catch (XMPPException e) {
  293.             e.printStackTrace();
  294.         }
  295.         return results;
  296.     }
  298.     //获取用户信息
  299.     public VCard getUserVCard(String user) {
  300.         if (!canDo())
  301.             return null;
  302.         VCard vcard = new VCard();
  303.         try {
  304.             vcard.load(xmppConnection, user);
  305.         } catch (XMPPException e) {
  306.             e.printStackTrace();
  307.         }
  308.         Log.e("获取的东西", vcard.getNickName());
  309.         return vcard;
  310.     }
  312.     //添加好友
  313.     public static void addUser(String userName) {
  314.         if (!canDo())
  315.             return;
  316.         Presence subscription = new Presence(Presence.Type.subscribe);
  317.         subscription.setTo(userName + "@" + xmppConnection.getServiceName());
  318.         xmppConnection.sendPacket(subscription);
  319.     }
  321.     //同意添加好友并添加对方为好友
  322.     public static void agreeAdd(String from) {
  323.         if (!canDo())
  324.             return;
  325.         Presence reSubscription = new Presence(Presence.Type.subscribe);
  326.         reSubscription.setTo(from);
  327.         xmppConnection.sendPacket(reSubscription);
  328.     }
  330.     //获取好友状态
  331.     public int IsUserOnLine(String user) {
  332.         String url = "http://" + SERVER_HOST + ":9090/plugins/presence/status?" +
  333.                 "jid=" + user + "@" + SERVER_NAME + "&type=xml";
  334. //        System.out.println(url);
  335.         int shOnLineState = 0; // 不存在
  336.         try {
  337.             URL oUrl = new URL(url);
  338.             URLConnection oConn = oUrl.openConnection();
  339.             if (oConn != null) {
  340.                 BufferedReader oIn = new BufferedReader(new InputStreamReader(
  341.                         oConn.getInputStream()));
  342.                 if (null != oIn) {
  343.                     String strFlag = oIn.readLine();
  344.                     oIn.close();
  345.                     System.out.println("strFlag" + strFlag);
  346.                     if (strFlag.indexOf("type=\"unavailable\"") >= 0) {
  347.                         shOnLineState = 2;
  348.                     }
  349.                     if (strFlag.indexOf("type=\"error\"") >= 0) {
  350.                         shOnLineState = 0;
  351.                     } else if (strFlag.indexOf("priority") >= 0
  352.                             || strFlag.indexOf("id=\"") >= 0) {
  353.                         shOnLineState = 1;
  354.                     }
  355.                 }
  356.             }
  357.         } catch (Exception e) {
  358.             e.printStackTrace();
  359.         }
  360.         return shOnLineState;
  361.     }
  363.     //设置昵称
  364.     public static void setNickName(String nickName) {
  365.         VCard vCard1 = new VCard();
  366.         vCard1.setNickName(nickName);
  367.         try {
  368.             vCard1.save(xmppConnection);
  369.         } catch (XMPPException e) {
  370.             e.printStackTrace();
  371.         }
  372.     }
  374.     //获取昵称
  375.     public static String getNickName(String name) {
  376.         if (!canDo())
  377.             return null;
  378.         VCard vCard = new VCard();
  379.         try {
  380.             vCard.load(xmppConnection, name + SERVER_HOST);
  381.         } catch (XMPPException e) {
  382.             e.printStackTrace();
  383.             return null;
  384.         }
  385.         return vCard.getNickName();
  386.     }
  388.     //获取用户头像
  389.     public static byte[] getUserImage(String user) {
  390.         if (!canDo()) {
  391.             return null;
  392.         }
  393.         ByteArrayInputStream bais = null;
  394.         try {
  395.             VCard vcard = new VCard();
  396.             // 加入这句代码，解决No VCard for
  397.             ProviderManager.getInstance().addIQProvider("vCard", "vcard-temp",
  398.                     new org.jivesoftware.smackx.provider.VCardProvider());
  399.             vcard.load(xmppConnection, user + "@" + xmppConnection.getServiceName());
  400.             if (vcard == null || vcard.getAvatar() == null)
  401.                 return null;
  402.             bais = new ByteArrayInputStream(vcard.getAvatar());
  404.         } catch (Exception e) {
  405.             e.printStackTrace();
  406.         }
  407.         if (bais == null)
  408.             return null;
  409.         Drawable drawable = FormatTools.getInstance().InputStream2Drawable(bais);
  410.         return getPicture(drawable);
  411.     }
  413.     //修改用户头像
  414.     public static boolean changeImage(File file) {
  415.         if (!canDo())
  416.             return false;
  417.         try {
  418.             VCard vcard = new VCard();
  419.             vcard.load(xmppConnection);
  420.             byte[] bytes;
  421.             bytes = File2Bytes.getFileBytes(file);
  422.             String encodedImage = StringUtils.encodeBase64(bytes);
  423.             vcard.setAvatar(bytes);
  424.             vcard.setEncodedImage(encodedImage);
  425.             vcard.setField("PHOTO", "<TYPE>image/jpg</TYPE><BINVAL>"
  426.                     + encodedImage + "</BINVAL>", true);
  427.             ByteArrayInputStream bais = new ByteArrayInputStream(
  428.                     vcard.getAvatar());
  429.             vcard.save(xmppConnection);
  430.             return true;
  431.         } catch (Exception e) {
  432.             e.printStackTrace();
  433.             return false;
  434.         }
  435.     }
  437.     //修改用户头像
  438.     public static boolean changeImage(byte[] bytes) {
  439.         if (!canDo())
  440.             return false;
  441.         try {
  442.             VCard vcard = new VCard();
  443.             vcard.load(xmppConnection);
  444.             String encodedImage = StringUtils.encodeBase64(bytes);
  445.             vcard.setAvatar(bytes);
  446.             vcard.setEncodedImage(encodedImage);
  447.             vcard.setField("PHOTO", "<TYPE>image/jpg</TYPE><BINVAL>"
  448.                     + encodedImage + "</BINVAL>", true);
  449.             ByteArrayInputStream bais = new ByteArrayInputStream(
  450.                     vcard.getAvatar());
  451.             vcard.save(xmppConnection);
  452.             return true;
  453.         } catch (Exception e) {
  454.             e.printStackTrace();
  455.             return false;
  456.         }
  457.     }
  459.     //删除好友
  460.     public static boolean removeUser(String userName) {
  461.         try {
  463.             RosterEntry entry;
  464.             if (userName.contains("@"))
  465.                 entry = xmppConnection.getRoster().getEntry(userName);
  466.             else
  467.                 entry = xmppConnection.getRoster().getEntry(
  468.                         userName + "@" + xmppConnection.getServiceName());
  469.             if (entry == null)
  470.                 entry = xmppConnection.getRoster().getEntry(userName);
  471.             xmppConnection.getRoster().removeEntry(entry);
  472.             return true;
  473.         } catch (Exception e) {
  474.             e.printStackTrace();
  475.             return false;
  476.         }
  477.     }
  479.     //获取好友列表
  480.     public static List<RosterEntry> getAllEntries() {
  481.         if (!canDo())
  482.             return null;
  483.         Roster roster = xmppConnection.getRoster();
  484.         List<RosterEntry> Entrieslist = new ArrayList<RosterEntry>();
  485.         Collection<RosterEntry> rosterEntry = roster.getEntries();
  486.         Iterator<RosterEntry> i = rosterEntry.iterator();
  487.         while (i.hasNext()) {
  488.             Entrieslist.add(i.next());
  489.         }
  490.         return Entrieslist;
  491.     }
  494.     private static List<Group> groups;
  496.     public static List<Group> getMyGroups() {
  497.         return groups;
  498.     }
  500.     public static void setMyGroups(List<Group> groups) {
  501.         UserInfo.groups = groups;
  502.     }
  504.     public static void addGroup(Group group) {
  505.         if (!groups.contains(group)) groups.add(group);
  506.     }
  508.     public static void deleteGroup(Group group) {
  509.         if (groups.contains(group))
  510.             groups.remove(group);
  511.     }
  513.     public static String getName() {
  514.         return name;
  515.     }
  517.     public static String getId() {
  518.         return id;
  519.     }
  521.     public static XMPPConnection getXmppConnection() {
  522.         return xmppConnection;
  523.     }
  525.     public static String getGroupName() {
  526.         return groupName;
  527.     }
  529.     //将drawable转换成可以用来存储的byte[]类型
  530.     public static byte[] getPicture(Drawable drawable) {
  531.         if (drawable == null) {
  532.             return null;
  533.         }
  534.         BitmapDrawable bd = (BitmapDrawable) drawable;
  535.         Bitmap bitmap = bd.getBitmap();
  536.         ByteArrayOutputStream os = new ByteArrayOutputStream();
  537.         bitmap.compress(Bitmap.CompressFormat.PNG, 100, os);
  538.         return os.toByteArray();
  539.     }
  541. }
添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注