OpenFire通过User Service管理用户

安装OpenFire服务器略去

1.安装User Service插件：

在管理控制平台找到选项卡“插件”，里边有我们需要安装的一个User Service插件，如果安装过了会显示已经安装的哪些插件，没有安装，需要点击左侧菜单“有效的插件”，在列表里找到此插件进行安装，可能有点慢，稍等即可。如果在有效的插件列表没有发现很多的插件，那么你需要重新安装openfire服务器或者升级最新版本。

2：

在选项卡“服务器”找到“服务器设置”下有个菜单“User Service”，说明安装插件成功，但是还是需要进行设置才能通过端口进行访问，不然无法访问或者报错401未授权等。设置：Enabled - User service requests will be processed. 启用、勾选HTTP basic auth - User service REST authentication with Openfire admin account. 如果选择Secret key auth，那C#写着太麻烦，通过访问接口需要传Secret key的值，否则就是报错401。

还可以在系统属性里添加进行设置接口是否启用，需要设置2项值如下图：

3：然后就可以通过C#代码进行访问接口，获取所有的用户列表：

 /// <summary>
        /// 获取所有openfire用户
        /// </summary>
        /// <returns></returns>
        public ActionResult Index()
        {
　　　　　　　//这个地方的地址和用户名密码我是从配置文件读取的，大家可以直接赋值。
            string url = CachedConfigContext.Current.SettingConfig.OpenFireServer + "plugins/userService/users";
            WebRequest req = WebRequest.Create(url);
            req.Method = "GET";
            string username = CachedConfigContext.Current.SettingConfig.OpenFireUsername;
            string password = CachedConfigContext.Current.SettingConfig.OpenFirePassword;
            string usernamePassword = username + ":" + password;
            CredentialCache mycache = new CredentialCache();
            mycache.Add(new Uri(url), "Basic", new NetworkCredential(username, password));
            req.Credentials = mycache;
            req.Headers.Add("Authorization", "Basic " + Convert.ToBase64String(new ASCIIEncoding().GetBytes(usernamePassword)));
            WebResponse result = null;
            try
            {
                result = req.GetResponse();
                Stream ReceiveStream = result.GetResponseStream();
                //read the stream into a string
                StreamReader sr = new StreamReader(ReceiveStream);
                string resultstring = sr.ReadToEnd();
                if (!string.IsNullOrEmpty(resultstring))
                {
                    XmlDocument doc = new XmlDocument();
                    doc.LoadXml(resultstring);
                    var xmlModel = XmlToObjList<OpenFireUser>(resultstring, "user");
                    this.ViewBag.existUsers = string.Join(",", xmlModel.Select(s => s.username));
                    return View(xmlModel);
                }

            }
            catch (Exception exp)
            {

            }
            finally
            {
                if (result != null)
                {
                    result.Close();
                }
            }
            return View();
        }

  /// <summary>  
        /// xml文件转化为实体类列表  
        /// </summary>  
        /// <typeparam name="T">实体名称</typeparam>  
        /// <param name="xml">您的xml文件</param>  
        /// <param name="headtag">xml头文件</param>  
        /// <returns>实体列表</returns>  
        public List<T> XmlToObjList<T>(string xml, string headtag)
            where T : new()
        {

            List<T> list = new List<T>();
            XmlDocument doc = new XmlDocument();
            PropertyInfo[] propinfos = null;
            doc.LoadXml(xml);
            //XmlNodeList nodelist = doc.SelectNodes(headtag);  
            XmlNodeList nodelist = doc.GetElementsByTagName(headtag);
            foreach (XmlNode node in nodelist)
            {
                T entity = new T();
                //初始化propertyinfo  
                if (propinfos == null)
                {
                    Type objtype = entity.GetType();
                    propinfos = objtype.GetProperties();
                }
                //填充entity类的属性  
                foreach (PropertyInfo propinfo in propinfos)
                {
                    //实体类字段首字母变成小写的  
                    string name = propinfo.Name.Substring(0, 1) + propinfo.Name.Substring(1, propinfo.Name.Length - 1);
                    XmlNode cnode = node.SelectSingleNode(name);
                    if (cnode != null)
                    {
                        string v = cnode.InnerText;
                        if (v != null)
                            propinfo.SetValue(entity, Convert.ChangeType(v, propinfo.PropertyType), null);
                    }
                }
                list.Add(entity);

            }
            return list;

        }

最后会返回一个xml的文件，里边是所有用户的信息。

至于新增、删除的接口就不做案例里，你可以通过管理控制平台查找demo，里边有介绍如何访问接口，查看地址：http://192.168.3.66:9090/plugin-admin.jsp?plugin=userservice&showReadme=true&decorator=none

如下图点击图标就可以查看此插件的demo：

通过User Service添加用户：

        [HttpPost]
        public JsonResult syncUser(string existUsers)
        {
            if (!string.IsNullOrEmpty(existUsers))
            {
                var array = existUsers.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
                var Users = this.FoundationService.GetPersonMain(s => s.UnitID == this.CurrentManager.UnitID);
                foreach (var item in Users)
                {
                    if (array.Contains(item.UserName.ToLower()))
                    {
                        continue;
                    }

                    var userXML = string.Format("<?xml version='1.0' encoding='UTF-8' standalone='yes'?> <user> <username>{0}</username> <password>{1}</password>  <name>{2}</name> <email>{3}</email></user>", item.UserName, item.Password, item.PersonName, item.Email);
                    //通过openFire user service添加用户
                    string url = CachedConfigContext.Current.SettingConfig.OpenFireServer + "plugins/userService/users";
                    WebRequest req = WebRequest.Create(url);
                    req.Method = "POST";
                    string username = CachedConfigContext.Current.SettingConfig.OpenFireUsername;
                    string password = CachedConfigContext.Current.SettingConfig.OpenFirePassword;
                    string usernamePassword = username + ":" + password;
                    CredentialCache mycache = new CredentialCache();
                    mycache.Add(new Uri(url), "Basic", new NetworkCredential(username, password));
                    req.Credentials = mycache;
                    req.Headers.Add("Authorization", "Basic " + Convert.ToBase64String(new ASCIIEncoding().GetBytes(usernamePassword)));
                    req.ContentType = "application/xml";

                    byte[] byteArray = Encoding.UTF8.GetBytes(userXML);
                    req.ContentLength = byteArray.Length;
                    Stream dataStream = req.GetRequestStream();
                    dataStream.Write(byteArray, 0, byteArray.Length);
                    dataStream.Close();

                    WebResponse result = null;
                    try
                    {
                        result = req.GetResponse();
                        Stream ReceiveStream = result.GetResponseStream();
                        //read the stream into a string
                        StreamReader sr = new StreamReader(ReceiveStream);
                        string resultstring = sr.ReadToEnd();
                    }
                    catch (Exception exp)
                    {
                        return Json(new { success = false, msg = "同步失败！" + exp.Message });
                    }
                    finally
                    {
                        if (result != null)
                        {
                            result.Close();
                        }
                    }
                }
            }

            return Json(new { success = true, msg = "同步成功！" });
        }