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


设置User Service插件
在选项卡“服务器”找到“服务器设置”下有个菜单“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项值如下图:

代码示例
/// <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 = "同步成功!" });
}
版权声明:部分文章、图片等内容为用户发布或互联网整理而来,仅供学习参考。如有侵犯您的版权,请联系我们,将立刻删除。