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 = "同步成功!" });
        }
原文地址:https://www.cnblogs.com/kennyliu/p/7154400.html